Interface | Description |
---|---|
IOpaquePartitionedTransactionalSpout<T> |
This defines a transactional spout which does *not* necessarily
replay the same batch every time it emits a batch for a transaction id.
|
IOpaquePartitionedTransactionalSpout.Coordinator | |
IOpaquePartitionedTransactionalSpout.Emitter<X> | |
IPartitionedTransactionalSpout<T> |
This interface defines a transactional spout that reads its tuples from a partitioned set of
brokers.
|
IPartitionedTransactionalSpout.Coordinator | |
IPartitionedTransactionalSpout.Emitter<X> |
Class | Description |
---|---|
OpaquePartitionedTransactionalSpoutExecutor | |
PartitionedTransactionalSpoutExecutor |
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.