public class OpaqueTridentKafkaSpout extends Object implements IOpaquePartitionedTridentSpout<GlobalPartitionInformation,Partition,Map>
IOpaquePartitionedTridentSpout.Coordinator<Partitions>, IOpaquePartitionedTridentSpout.Emitter<Partitions,Partition extends ISpoutPartition,M>
Constructor and Description |
---|
OpaqueTridentKafkaSpout(TridentKafkaConfig config) |
Modifier and Type | Method and Description |
---|---|
Map<String,Object> |
getComponentConfiguration() |
IOpaquePartitionedTridentSpout.Coordinator |
getCoordinator(Map conf,
TopologyContext tc) |
IOpaquePartitionedTridentSpout.Emitter<GlobalPartitionInformation,Partition,Map> |
getEmitter(Map conf,
TopologyContext context) |
Fields |
getOutputFields() |
public OpaqueTridentKafkaSpout(TridentKafkaConfig config)
public IOpaquePartitionedTridentSpout.Emitter<GlobalPartitionInformation,Partition,Map> getEmitter(Map conf, TopologyContext context)
getEmitter
in interface IOpaquePartitionedTridentSpout<GlobalPartitionInformation,Partition,Map>
public IOpaquePartitionedTridentSpout.Coordinator getCoordinator(Map conf, TopologyContext tc)
getCoordinator
in interface IOpaquePartitionedTridentSpout<GlobalPartitionInformation,Partition,Map>
public Fields getOutputFields()
getOutputFields
in interface IOpaquePartitionedTridentSpout<GlobalPartitionInformation,Partition,Map>
public Map<String,Object> getComponentConfiguration()
getComponentConfiguration
in interface IOpaquePartitionedTridentSpout<GlobalPartitionInformation,Partition,Map>
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.