Package org.apache.storm.hdfs.spout
Class ProgressTracker
java.lang.Object
org.apache.storm.hdfs.spout.ProgressTracker
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionvoiddumpState(PrintStream stream) org.apache.storm.hdfs.spout.FileOffsetvoidrecordAckedOffset(org.apache.storm.hdfs.spout.FileOffset newOffset) intsize()
- 
Constructor Details- 
ProgressTrackerpublic ProgressTracker()
 
- 
- 
Method Details- 
recordAckedOffsetpublic void recordAckedOffset(org.apache.storm.hdfs.spout.FileOffset newOffset) 
- 
getCommitPositionpublic org.apache.storm.hdfs.spout.FileOffset getCommitPosition()
- 
dumpState
- 
sizepublic int size()
 
-