Package | Description |
---|---|
backtype.storm.testing | |
backtype.storm.topology.base | |
backtype.storm.transactional | |
backtype.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 © 2016 The Apache Software Foundation. All Rights Reserved.