| Package | Description |
|---|---|
| storm.trident | |
| storm.trident.spout | |
| storm.trident.testing | |
| storm.trident.topology |
| 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 © 2015. All rights reserved.