storm.kafka.trident
Class TridentKafkaStateFactory

java.lang.Object
  extended by storm.kafka.trident.TridentKafkaStateFactory
All Implemented Interfaces:
Serializable, StateFactory

public class TridentKafkaStateFactory
extends Object
implements StateFactory

See Also:
Serialized Form

Constructor Summary
TridentKafkaStateFactory()
           
 
Method Summary
 State makeState(Map conf, IMetricsContext metrics, int partitionIndex, int numPartitions)
           
 TridentKafkaStateFactory withKafkaTopicSelector(KafkaTopicSelector selector)
           
 TridentKafkaStateFactory withTridentTupleToKafkaMapper(TridentTupleToKafkaMapper mapper)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

TridentKafkaStateFactory

public TridentKafkaStateFactory()
Method Detail

withTridentTupleToKafkaMapper

public TridentKafkaStateFactory withTridentTupleToKafkaMapper(TridentTupleToKafkaMapper mapper)

withKafkaTopicSelector

public TridentKafkaStateFactory withKafkaTopicSelector(KafkaTopicSelector selector)

makeState

public State makeState(Map conf,
                       IMetricsContext metrics,
                       int partitionIndex,
                       int numPartitions)
Specified by:
makeState in interface StateFactory


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