public class OpaqueTridentEventHubEmitter extends Object implements IOpaquePartitionedTridentSpout.Emitter<Partitions,Partition,Map>
Constructor and Description |
---|
OpaqueTridentEventHubEmitter(EventHubSpoutConfig spoutConfig) |
OpaqueTridentEventHubEmitter(EventHubSpoutConfig spoutConfig,
int batchSize,
ITridentPartitionManagerFactory pmFactory,
IEventHubReceiverFactory recvFactory) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
Map |
emitPartitionBatch(TransactionAttempt attempt,
TridentCollector collector,
Partition partition,
Map meta)
Emit a batch of tuples for a partition/transaction.
|
List<Partition> |
getOrderedPartitions(Partitions partitions) |
void |
refreshPartitions(List<Partition> partitionList)
This method is called when this task is responsible for a new set of partitions.
|
public OpaqueTridentEventHubEmitter(EventHubSpoutConfig spoutConfig)
public OpaqueTridentEventHubEmitter(EventHubSpoutConfig spoutConfig, int batchSize, ITridentPartitionManagerFactory pmFactory, IEventHubReceiverFactory recvFactory)
public void close()
close
in interface IOpaquePartitionedTridentSpout.Emitter<Partitions,Partition,Map>
public Map emitPartitionBatch(TransactionAttempt attempt, TridentCollector collector, Partition partition, Map meta)
IOpaquePartitionedTridentSpout.Emitter
emitPartitionBatch
in interface IOpaquePartitionedTridentSpout.Emitter<Partitions,Partition,Map>
public List<Partition> getOrderedPartitions(Partitions partitions)
getOrderedPartitions
in interface IOpaquePartitionedTridentSpout.Emitter<Partitions,Partition,Map>
public void refreshPartitions(List<Partition> partitionList)
IOpaquePartitionedTridentSpout.Emitter
refreshPartitions
in interface IOpaquePartitionedTridentSpout.Emitter<Partitions,Partition,Map>
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.