Package | Description |
---|---|
storm.kafka | |
storm.kafka.trident | |
storm.trident | |
storm.trident.spout | |
storm.trident.testing | |
storm.trident.topology |
Class and Description |
---|
ISpoutPartition |
Class and Description |
---|
IOpaquePartitionedTridentSpout
This defines a transactional spout which does *not* necessarily
replay the same batch every time it emits a batch for a transaction id.
|
IOpaquePartitionedTridentSpout.Coordinator |
IOpaquePartitionedTridentSpout.Emitter |
IPartitionedTridentSpout
This interface defines a transactional spout that reads its tuples from a partitioned set of
brokers.
|
IPartitionedTridentSpout.Coordinator |
IPartitionedTridentSpout.Emitter |
Class and Description |
---|
IBatchSpout |
IOpaquePartitionedTridentSpout
This defines a transactional spout which does *not* necessarily
replay the same batch every time it emits a batch for a transaction id.
|
IPartitionedTridentSpout
This interface defines a transactional spout that reads its tuples from a partitioned set of
brokers.
|
ITridentSpout |
Class and Description |
---|
IBatchID |
IBatchSpout |
ICommitterTridentSpout |
ICommitterTridentSpout.Emitter |
IOpaquePartitionedTridentSpout
This defines a transactional spout which does *not* necessarily
replay the same batch every time it emits a batch for a transaction id.
|
IOpaquePartitionedTridentSpout.Coordinator |
IOpaquePartitionedTridentSpout.Emitter |
IPartitionedTridentSpout
This interface defines a transactional spout that reads its tuples from a partitioned set of
brokers.
|
IPartitionedTridentSpout.Coordinator |
IPartitionedTridentSpout.Emitter |
ISpoutPartition |
ITridentSpout |
ITridentSpout.BatchCoordinator |
ITridentSpout.Emitter |
RichSpoutBatchId |
Class and Description |
---|
IBatchSpout |
ICommitterTridentSpout |
ICommitterTridentSpout.Emitter |
ITridentSpout |
ITridentSpout.BatchCoordinator |
ITridentSpout.Emitter |
Class and Description |
---|
IBatchID |
IBatchSpout |
ITridentSpout |
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.