public class EventHubSpout extends BaseRichSpout
Constructor and Description |
---|
EventHubSpout(EventHubSpoutConfig spoutConfig) |
EventHubSpout(EventHubSpoutConfig spoutConfig,
IStateStore store,
IPartitionManagerFactory pmFactory,
IEventHubReceiverFactory recvFactory) |
EventHubSpout(String username,
String password,
String namespace,
String entityPath,
int partitionCount) |
Modifier and Type | Method and Description |
---|---|
void |
ack(Object msgId) |
void |
close() |
void |
deactivate() |
void |
declareOutputFields(OutputFieldsDeclarer declarer) |
void |
fail(Object msgId) |
void |
nextTuple() |
void |
open(Map config,
TopologyContext context,
SpoutOutputCollector collector) |
void |
preparePartitions(Map config,
int totalTasks,
int taskIndex,
SpoutOutputCollector collector)
This is a extracted method that is easy to test
|
activate
getComponentConfiguration
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getComponentConfiguration
public EventHubSpout(String username, String password, String namespace, String entityPath, int partitionCount)
public EventHubSpout(EventHubSpoutConfig spoutConfig)
public EventHubSpout(EventHubSpoutConfig spoutConfig, IStateStore store, IPartitionManagerFactory pmFactory, IEventHubReceiverFactory recvFactory)
public void preparePartitions(Map config, int totalTasks, int taskIndex, SpoutOutputCollector collector) throws Exception
config
- totalTasks
- taskIndex
- collector
- Exception
public void open(Map config, TopologyContext context, SpoutOutputCollector collector)
public void nextTuple()
public void ack(Object msgId)
ack
in interface ISpout
ack
in class BaseRichSpout
public void fail(Object msgId)
fail
in interface ISpout
fail
in class BaseRichSpout
public void deactivate()
deactivate
in interface ISpout
deactivate
in class BaseRichSpout
public void close()
close
in interface ISpout
close
in class BaseRichSpout
public void declareOutputFields(OutputFieldsDeclarer declarer)
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.