Package org.apache.storm.hdfs.trident

Class HdfsStateFactory

java.lang.Object

org.apache.storm.hdfs.trident.HdfsStateFactory

All Implemented Interfaces:

Serializable, StateFactory

public class HdfsStateFactory
extends Object
implements StateFactory

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
HdfsStateFactory()

Method Summary

Modifier and Type	Method	Description
State	makeState(Map<String,Object> conf, IMetricsContext metrics, int partitionIndex, int numPartitions)
HdfsStateFactory	withOptions(HdfsState.Options options)

Methods inherited from class java.lang.Object

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

Constructor Detail

HdfsStateFactory

public HdfsStateFactory()

Method Detail

withOptions

public HdfsStateFactory withOptions(HdfsState.Options options)

makeState

public State makeState(Map<String,Object> conf,
                       IMetricsContext metrics,
                       int partitionIndex,
                       int numPartitions)

Specified by:

makeState in interface StateFactory