Package org.apache.storm.kafka.trident

Class TridentKafkaState<K,V>

java.lang.Object

org.apache.storm.kafka.trident.TridentKafkaState<K,V>

All Implemented Interfaces:

State

public class TridentKafkaState<K,V>
extends Object
implements State

Constructor Summary

Constructors

Constructor	Description
TridentKafkaState()

Method Summary

Modifier and Type	Method	Description
void	beginCommit(Long txid)
void	commit(Long txid)
void	prepare(Properties options)	Prepare this State.
void	updateState(List<TridentTuple> tuples, TridentCollector collector)	Write the given tuples to Kafka.
TridentKafkaState<K,V>	withKafkaTopicSelector(KafkaTopicSelector selector)
TridentKafkaState<K,V>	withTridentTupleToKafkaMapper(TridentTupleToKafkaMapper<K,V> mapper)

Methods inherited from class java.lang.Object

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

Constructor Details

TridentKafkaState

public TridentKafkaState()

Method Details

withTridentTupleToKafkaMapper

public TridentKafkaState<K,V> withTridentTupleToKafkaMapper(TridentTupleToKafkaMapper<K,V> mapper)

withKafkaTopicSelector

public TridentKafkaState<K,V> 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(Properties options)

Prepare this State.

Parameters:

options - The KafkaProducer config.

updateState

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

Write the given tuples to Kafka.

Parameters:

tuples - The tuples to write.

collector - The Trident collector.