storm.trident.spout
Interface IPartitionedTridentSpout<T>

All Superinterfaces:

java.io.Serializable

public interface IPartitionedTridentSpout<T>
extends java.io.Serializable

This interface defines a transactional spout that reads its tuples from a partitioned set of brokers. It automates the storing of metadata for each partition to ensure that the same batch is always emitted for the same transaction id. The partition metadata is stored in Zookeeper.

Nested Class Summary

static interface	IPartitionedTridentSpout.Coordinator
static interface	IPartitionedTridentSpout.Emitter<X>

Method Summary

java.util.Map	getComponentConfiguration()
IPartitionedTridentSpout.Coordinator	getCoordinator(java.util.Map conf, TopologyContext context)
IPartitionedTridentSpout.Emitter<T>	getEmitter(java.util.Map conf, TopologyContext context)
Fields	getOutputFields()

Method Detail

getCoordinator

IPartitionedTridentSpout.Coordinator getCoordinator(java.util.Map conf,
                                                    TopologyContext context)

getEmitter

IPartitionedTridentSpout.Emitter<T> getEmitter(java.util.Map conf,
                                               TopologyContext context)

getComponentConfiguration

java.util.Map getComponentConfiguration()

getOutputFields

Fields getOutputFields()