Uses of Class
io.confluent.parallelconsumer.state.WorkContainer

Packages that use WorkContainer

Package	Description
io.confluent.parallelconsumer
io.confluent.parallelconsumer.internal
io.confluent.parallelconsumer.state

Uses of WorkContainer in io.confluent.parallelconsumer

Fields in io.confluent.parallelconsumer declared as WorkContainer

Modifier and Type	Field	Description
protected final WorkContainer<K,V>	RecordContext.workContainer

Methods in io.confluent.parallelconsumer that return WorkContainer

Modifier and Type	Method	Description
protected WorkContainer<K,V>	RecordContext.getWorkContainer()
WorkContainer<K,V>	RecordContextInternal.getWorkContainer()

Methods in io.confluent.parallelconsumer that return types with arguments of type WorkContainer

Modifier and Type	Method	Description
List<WorkContainer<K,V>>	PollContextInternal.getWorkContainers()
Stream<WorkContainer<K,V>>	PollContextInternal.streamWorkContainers()

Methods in io.confluent.parallelconsumer with parameters of type WorkContainer

Modifier and Type	Method	Description
RecordContext.RecordContextBuilder<K,V>	RecordContext.RecordContextBuilder.workContainer(WorkContainer<K,V> workContainer)

Constructors in io.confluent.parallelconsumer with parameters of type WorkContainer

Modifier	Constructor	Description
	RecordContext(WorkContainer<K,V> wc)
	RecordContext(WorkContainer<K,V> workContainer, org.apache.kafka.clients.consumer.ConsumerRecord<K,V> consumerRecord)
	RecordContextInternal(WorkContainer<K,V> wc)

Constructor parameters in io.confluent.parallelconsumer with type arguments of type WorkContainer

Modifier	Constructor	Description
	PollContextInternal(List<WorkContainer<K,V>> workContainers)

Uses of WorkContainer in io.confluent.parallelconsumer.internal

Methods in io.confluent.parallelconsumer.internal with parameters of type WorkContainer

Modifier and Type	Method	Description
protected void	AbstractParallelEoSStreamProcessor.addToMailbox(WorkContainer<K,V> wc)
protected void	AbstractParallelEoSStreamProcessor.addToMailBoxOnUserFunctionSuccess(WorkContainer<K,V> wc, List<?> resultsFromUserFunction)
protected void	ExternalEngine.addToMailBoxOnUserFunctionSuccess(WorkContainer<K,V> wc, List<?> resultsFromUserFunction)	With Vertx and Reactor, a function hasn't succeeded until the inner vertx function has also succeeded no op
protected void	AbstractParallelEoSStreamProcessor.onUserFunctionSuccess(WorkContainer<K,V> wc, List<?> resultsFromUserFunction)
protected void	ExternalEngine.onUserFunctionSuccess(WorkContainer<K,V> wc, List<?> resultsFromUserFunction)	With Vertx and Reactor, a function hasn't succeeded until the inner vertx function has also succeeded logging

Method parameters in io.confluent.parallelconsumer.internal with type arguments of type WorkContainer

Modifier and Type	Method	Description
protected <R> List<ParallelConsumer.Tuple<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>,R>>	AbstractParallelEoSStreamProcessor.runUserFunction(Function<PollContextInternal<K,V>,List<R>> usersFunction, Consumer<R> callback, List<WorkContainer<K,V>> workContainerBatch)	Run the supplied function.
protected <R> void	AbstractParallelEoSStreamProcessor.submitWorkToPool(Function<PollContextInternal<K,V>,List<R>> usersFunction, Consumer<R> callback, List<WorkContainer<K,V>> workToProcess)	Submit a piece of work to the processing pool.

Uses of WorkContainer in io.confluent.parallelconsumer.state

Methods in io.confluent.parallelconsumer.state that return WorkContainer

Modifier and Type	Method	Description
WorkContainer<K,V>	ProcessingShard.remove(long offset)

Methods in io.confluent.parallelconsumer.state that return types with arguments of type WorkContainer

Modifier and Type	Method	Description
NavigableMap<Long,WorkContainer<K,V>>	ProcessingShard.getEntries()	Map of offset to WorkUnits.
List<Consumer<WorkContainer<K,V>>>	WorkManager.getSuccessfulWorkListeners()	Useful for testing
List<WorkContainer<K,V>>	ShardManager.getWorkIfAvailable(int requestedMaxWorkToRetrieve)
List<WorkContainer<K,V>>	WorkManager.getWorkIfAvailable()	Get work with no limit on quantity, useful for testing.
List<WorkContainer<K,V>>	WorkManager.getWorkIfAvailable(int requestedMaxWorkToRetrieve)	Depth first work retrieval.

Methods in io.confluent.parallelconsumer.state with parameters of type WorkContainer

Modifier and Type	Method	Description
void	PartitionState.addWorkContainer(WorkContainer<K,V> wc)
void	PartitionStateManager.addWorkContainer(WorkContainer<K,V> wc)
void	ProcessingShard.addWorkContainer(WorkContainer<K,V> wc)
void	RemovedPartitionState.addWorkContainer(WorkContainer<K,V> wc)
void	ShardManager.addWorkContainer(WorkContainer<K,V> wc)
boolean	WorkManager.checkIfWorkIsStale(WorkContainer<K,V> workContainer)	Have our partitions been revoked?
int	WorkContainer.compareTo(WorkContainer o)
boolean	PartitionStateManager.couldBeTakenAsWork(WorkContainer<?,?> workContainer)
void	WorkManager.handleFutureResult(WorkContainer<K,V> wc)
boolean	PartitionStateManager.isAllowedMoreRecords(WorkContainer<?,?> wc)
static ShardKey	ShardKey.of(WorkContainer<?,?> wc, ParallelConsumerOptions.ProcessingOrder ordering)
void	PartitionState.onFailure(WorkContainer<K,V> work)
void	PartitionStateManager.onFailure(WorkContainer<K,V> wc)
void	ShardManager.onFailure(WorkContainer<?,?> wc)	Idempotent - work may have not been removed, either way it's put back
void	WorkManager.onFailureResult(WorkContainer<K,V> wc)
void	PartitionState.onSuccess(WorkContainer<K,V> work)
void	PartitionStateManager.onSuccess(WorkContainer<K,V> wc)
void	ProcessingShard.onSuccess(WorkContainer<?,?> wc)
void	RemovedPartitionState.onSuccess(WorkContainer<K,V> work)
void	ShardManager.onSuccess(WorkContainer<?,?> wc)
void	WorkManager.onSuccessResult(WorkContainer<K,V> wc)

Method parameters in io.confluent.parallelconsumer.state with type arguments of type WorkContainer

Modifier and Type	Method	Description
boolean	WorkManager.checkIfWorkIsStale(List<WorkContainer<K,V>> workContainers)	Have our partitions been revoked? Can a batch contain messages of different epochs?