storm.trident.spout
Interface IOpaquePartitionedTridentSpout.Emitter<X>

Enclosing interface:
IOpaquePartitionedTridentSpout<T>

public static interface IOpaquePartitionedTridentSpout.Emitter<X>


Method Summary
 void close()
           
 X emitPartitionBatch(TransactionAttempt tx, TridentCollector collector, int partition, X lastPartitionMeta)
          Emit a batch of tuples for a partition/transaction.
 long numPartitions()
           
 

Method Detail

emitPartitionBatch

X emitPartitionBatch(TransactionAttempt tx,
                     TridentCollector collector,
                     int partition,
                     X lastPartitionMeta)
Emit a batch of tuples for a partition/transaction. Return the metadata describing this batch that will be used as lastPartitionMeta for defining the parameters of the next batch.


numPartitions

long numPartitions()

close

void close()