org.apache.heron.kafka.spout

Class KafkaSpout<K,V>

java.lang.Object

org.apache.heron.api.topology.BaseComponent

org.apache.heron.api.spout.BaseRichSpout

org.apache.heron.kafka.spout.KafkaSpout<K,V>

All Implemented Interfaces:

Serializable, org.apache.heron.api.spout.IRichSpout, org.apache.heron.api.spout.ISpout, org.apache.heron.api.topology.IComponent

public class KafkaSpout<K,V>
extends org.apache.heron.api.spout.BaseRichSpout

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.heron.api.spout.SpoutOutputCollector	collector
static long	TIMER_DELAY_MS

Constructor Summary

Constructors

Constructor and Description
KafkaSpout(KafkaSpoutConfig<K,V> kafkaSpoutConfig)

Method Summary

Modifier and Type	Method and Description
void	ack(Object messageId)
void	activate()
void	close()
void	deactivate()
void	declareOutputFields(org.apache.heron.api.topology.OutputFieldsDeclarer declarer)
void	fail(Object messageId)
Map<String,Object>	getComponentConfiguration()
void	nextTuple()
void	open(Map<String,Object> conf, org.apache.heron.api.topology.TopologyContext context, org.apache.heron.api.spout.SpoutOutputCollector collector)
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

TIMER_DELAY_MS

public static final long TIMER_DELAY_MS

See Also:

Constant Field Values

collector

protected org.apache.heron.api.spout.SpoutOutputCollector collector

Constructor Detail

KafkaSpout

public KafkaSpout(KafkaSpoutConfig<K,V> kafkaSpoutConfig)

Method Detail

open

public void open(Map<String,Object> conf,
                 org.apache.heron.api.topology.TopologyContext context,
                 org.apache.heron.api.spout.SpoutOutputCollector collector)

nextTuple

public void nextTuple()

ack

public void ack(Object messageId)

Specified by:

ack in interface org.apache.heron.api.spout.ISpout

Overrides:

ack in class org.apache.heron.api.spout.BaseRichSpout

fail

public void fail(Object messageId)

Specified by:

fail in interface org.apache.heron.api.spout.ISpout

Overrides:

fail in class org.apache.heron.api.spout.BaseRichSpout

activate

public void activate()

Specified by:

activate in interface org.apache.heron.api.spout.ISpout

Overrides:

activate in class org.apache.heron.api.spout.BaseRichSpout

deactivate

public void deactivate()

Specified by:

deactivate in interface org.apache.heron.api.spout.ISpout

Overrides:

deactivate in class org.apache.heron.api.spout.BaseRichSpout

close

public void close()

Specified by:

close in interface org.apache.heron.api.spout.ISpout

Overrides:

close in class org.apache.heron.api.spout.BaseRichSpout

declareOutputFields

public void declareOutputFields(org.apache.heron.api.topology.OutputFieldsDeclarer declarer)

toString

public String toString()

Overrides:

toString in class Object

getComponentConfiguration

public Map<String,Object> getComponentConfiguration()

Specified by:

getComponentConfiguration in interface org.apache.heron.api.topology.IComponent

Overrides:

getComponentConfiguration in class org.apache.heron.api.topology.BaseComponent