Package org.apache.storm.hdfs.trident

Class HdfsState

java.lang.Object

org.apache.storm.hdfs.trident.HdfsState

All Implemented Interfaces:

State

public class HdfsState
extends Object
implements State

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	HdfsState.HdfsFileOptions
static class	HdfsState.Options
static class	HdfsState.SequenceFileOptions

Field Summary

Fields

Modifier and Type	Field	Description
static org.slf4j.Logger	LOG

Method Summary

Modifier and Type	Method	Description
void	beginCommit(Long txId)
void	commit(Long txId)
void	updateState(List<TridentTuple> tuples, TridentCollector tridentCollector)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final org.slf4j.Logger LOG

Method Detail

beginCommit

public void beginCommit(Long txId)

Specified by:

beginCommit in interface State

commit

public void commit(Long txId)

Specified by:

commit in interface State

updateState

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