Package | Description |
---|---|
org.apache.storm.testing | |
org.apache.storm.topology.base | |
org.apache.storm.transactional | |
org.apache.storm.transactional.partitioned |
Class and Description |
---|
IOpaquePartitionedTransactionalSpout
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 |
IPartitionedTransactionalSpout
This interface defines a transactional spout that reads its tuples from a partitioned set of brokers.
|
IPartitionedTransactionalSpout.Coordinator |
IPartitionedTransactionalSpout.Emitter |
Class and Description |
---|
IOpaquePartitionedTransactionalSpout
This defines a transactional spout which does not necessarily replay the same batch every time it emits a batch for a transaction id.
|
IPartitionedTransactionalSpout
This interface defines a transactional spout that reads its tuples from a partitioned set of brokers.
|
Class and Description |
---|
IOpaquePartitionedTransactionalSpout
This defines a transactional spout which does not necessarily replay the same batch every time it emits a batch for a transaction id.
|
IPartitionedTransactionalSpout
This interface defines a transactional spout that reads its tuples from a partitioned set of brokers.
|
Class and Description |
---|
IOpaquePartitionedTransactionalSpout
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 |
IPartitionedTransactionalSpout
This interface defines a transactional spout that reads its tuples from a partitioned set of brokers.
|
IPartitionedTransactionalSpout.Coordinator |
IPartitionedTransactionalSpout.Emitter |
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.