| Interface | Description |
|---|---|
| Partitioner | |
| PartitionerDecorator.GeneralExecuteIface |
Helper interface to generalize functionality executed in the thread
since it is absolutely the same for partitionBatch and flushOutgoingBatches
protected is for testing purposes
|
| PartitionOutgoingBatch |
| Class | Description |
|---|---|
| PartitionerDecorator |
Decorator class to hide multiple Partitioner existence from the caller since
this class involves multithreaded processing of incoming batches as well as
flushing it needs special handling of OperatorStats - stats since stats are
not suitable for use in multithreaded environment The algorithm to figure out
processing versus wait time is based on following formula: totalWaitTime =
totalAllPartitionersProcessingTime - max(sum(processingTime) by partitioner)
|
| PartitionerTemplate | |
| PartitionSenderCreator | |
| PartitionSenderRootExec |
| Enum | Description |
|---|---|
| PartitionSenderRootExec.Metric |
Copyright © 1970 The Apache Software Foundation. All rights reserved.