org.apache.storm.hdfs.trident
Class HdfsState

java.lang.Object
  extended by org.apache.storm.hdfs.trident.HdfsState
All Implemented Interfaces:
State

public class HdfsState
extends Object
implements State


Nested Class Summary
static class HdfsState.HdfsFileOptions
           
static class HdfsState.Options
           
static class HdfsState.SequenceFileOptions
           
 
Field Summary
static org.slf4j.Logger LOG
           
 
Method Summary
 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)


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