storm.kafka.trident
Class TridentKafkaState

java.lang.Object
  extended by storm.kafka.trident.TridentKafkaState
All Implemented Interfaces:
State

public class TridentKafkaState
extends Object
implements State


Field Summary
static String KAFKA_BROKER_PROPERTIES
           
 
Constructor Summary
TridentKafkaState()
           
 
Method Summary
 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)


Copyright © 2014 The Apache Software Foundation. All Rights Reserved.