Package | Description |
---|---|
storm.kafka | |
storm.trident.spout |
Modifier and Type | Class and Description |
---|---|
class |
Partition |
Modifier and Type | Interface and Description |
---|---|
interface |
IOpaquePartitionedTridentSpout<Partitions,Partition extends ISpoutPartition,M>
This defines a transactional spout which does *not* necessarily
replay the same batch every time it emits a batch for a transaction id.
|
static interface |
IOpaquePartitionedTridentSpout.Emitter<Partitions,Partition extends ISpoutPartition,M> |
interface |
IPartitionedTridentSpout<Partitions,Partition extends ISpoutPartition,T>
This interface defines a transactional spout that reads its tuples from a partitioned set of
brokers.
|
static interface |
IPartitionedTridentSpout.Emitter<Partitions,Partition extends ISpoutPartition,X> |
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.