Package ch.tocco.nice2.outputcenter.impl.persisttask

Class CreateOutputJobItemPersistTask

java.lang.Object

ch.tocco.nice2.persist.core.api.exec.AbstractPartitionedPersistTask<OutputJobItemBuilder,Void,Entity>

ch.tocco.nice2.outputcenter.impl.persisttask.CreateOutputJobItemPersistTask

All Implemented Interfaces:

PersistTask<Iterable<OutputJobItemBuilder>,Iterable<Void>>

public class CreateOutputJobItemPersistTask
extends AbstractPartitionedPersistTask<OutputJobItemBuilder,Void,Entity>

Constructor Summary

Constructors

Constructor	Description
CreateOutputJobItemPersistTask(PrimaryKey outputJobKey, EntityDefaultValueService entityDefaultValueService, DocumentDao documentDao, Collection<AddressAsStringProvider> addressAsStringProviders)

Method Summary

Modifier and Type	Method	Description
protected Function<Context,Entity>	createTaskData()	Create a function that creates an instance of Z.
protected Entity	getEntity(CommandContext commandContext, EntityId entityId)
Iterable<Void>	run(Optional<Iterable<OutputJobItemBuilder>> outputJobItemBuilders, CommandContext commandContext)
protected void	setRelation(CommandContext commandContext, Entity entity, String relationName, @Nullable EntityId entityDescriptor)

Methods inherited from class ch.tocco.nice2.persist.core.api.exec.AbstractPartitionedPersistTask

getTaskData, partition, partition, partition

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface ch.tocco.nice2.persist.core.api.exec.PersistTask

andThenDo, compose, compose2, composeWhen, discardResult, expand, expand, getDescription, ifElse, logTime, orWhen, orWhenNot, passWhen, passWhenNot, skipErrors, unwrap

Constructor Details

CreateOutputJobItemPersistTask

public CreateOutputJobItemPersistTask(PrimaryKey outputJobKey,
 EntityDefaultValueService entityDefaultValueService,
 DocumentDao documentDao,
 Collection<AddressAsStringProvider> addressAsStringProviders)

Method Details

createTaskData

protected Function<Context,Entity> createTaskData()

Description copied from class: AbstractPartitionedPersistTask

Create a function that creates an instance of Z. This function is called once for each context and should be used to load entities (or other Context related objects) which are used in every iteration.

Specified by:

createTaskData in class AbstractPartitionedPersistTask<OutputJobItemBuilder,Void,Entity>

run

public Iterable<Void> run(Optional<Iterable<OutputJobItemBuilder>> outputJobItemBuilders,
 CommandContext commandContext)
                   throws Exception

Throws:

Exception

setRelation

protected void setRelation(CommandContext commandContext,
 Entity entity,
 String relationName,
 @Nullable
 @Nullable EntityId entityDescriptor)
                    throws InterruptedException

Throws:

InterruptedException

getEntity

protected Entity getEntity(CommandContext commandContext,
 EntityId entityId)