storm.kafka.trident

Class TridentKafkaState

java.lang.Object

storm.kafka.trident.TridentKafkaState

All Implemented Interfaces:

State

public class TridentKafkaState
extends Object
implements State

Field Summary

Fields

Modifier and Type	Field and Description
static String	KAFKA_BROKER_PROPERTIES

Constructor Summary

Constructors

Constructor and Description
TridentKafkaState()

Method Summary

Modifier and Type	Method and Description
void	beginCommit(Long txid)
void	commit(Long txid)
void	prepare(Map stormConf)
void	updateState(List<TridentTuple> tuples, TridentCollector collector)
TridentKafkaState	withKafkaTopicSelector(KafkaTopicSelector selector)
TridentKafkaState	withTridentTupleToKafkaMapper(TridentTupleToKafkaMapper mapper)

Methods inherited from class java.lang.Object

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

Field Detail

KAFKA_BROKER_PROPERTIES

public static final String KAFKA_BROKER_PROPERTIES

See Also:

Constant Field Values

Constructor Detail

TridentKafkaState

public TridentKafkaState()

Method Detail

withTridentTupleToKafkaMapper

public TridentKafkaState withTridentTupleToKafkaMapper(TridentTupleToKafkaMapper mapper)

withKafkaTopicSelector

public TridentKafkaState withKafkaTopicSelector(KafkaTopicSelector selector)

beginCommit

public void beginCommit(Long txid)

Specified by:

beginCommit in interface State

commit

public void commit(Long txid)

Specified by:

commit in interface State

prepare

public void prepare(Map stormConf)

updateState

public void updateState(List<TridentTuple> tuples,
                        TridentCollector collector)