storm.trident.spout
Interface IOpaquePartitionedTridentSpout<T>

All Superinterfaces:

java.io.Serializable

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

This defines a transactional spout which does *not* necessarily replay the same batch every time it emits a batch for a transaction id.

Nested Class Summary

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

Method Summary

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

Method Detail

getEmitter

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

getCoordinator

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

getComponentConfiguration

java.util.Map getComponentConfiguration()

getOutputFields

Fields getOutputFields()