public class OpaqueTridentEventHubSpout extends Object implements IOpaquePartitionedTridentSpout<Partitions,Partition,Map>
Opaque Trident EventHubs Spout.
IOpaquePartitionedTridentSpout.Coordinator<PartitionsT>, IOpaquePartitionedTridentSpout.Emitter<PartitionsT,PartitionT extends ISpoutPartition,M>
Constructor and Description |
---|
OpaqueTridentEventHubSpout(EventHubSpoutConfig config) |
Modifier and Type | Method and Description |
---|---|
Map<String,Object> |
getComponentConfiguration() |
IOpaquePartitionedTridentSpout.Coordinator<Partitions> |
getCoordinator(Map<String,Object> conf,
TopologyContext context) |
IOpaquePartitionedTridentSpout.Emitter<Partitions,Partition,Map> |
getEmitter(Map<String,Object> conf,
TopologyContext context) |
Fields |
getOutputFields() |
public OpaqueTridentEventHubSpout(EventHubSpoutConfig config)
public Map<String,Object> getComponentConfiguration()
getComponentConfiguration
in interface IOpaquePartitionedTridentSpout<Partitions,Partition,Map>
public IOpaquePartitionedTridentSpout.Coordinator<Partitions> getCoordinator(Map<String,Object> conf, TopologyContext context)
getCoordinator
in interface IOpaquePartitionedTridentSpout<Partitions,Partition,Map>
public IOpaquePartitionedTridentSpout.Emitter<Partitions,Partition,Map> getEmitter(Map<String,Object> conf, TopologyContext context)
getEmitter
in interface IOpaquePartitionedTridentSpout<Partitions,Partition,Map>
public Fields getOutputFields()
getOutputFields
in interface IOpaquePartitionedTridentSpout<Partitions,Partition,Map>
Copyright © 2022 The Apache Software Foundation. All rights reserved.