Package org.apache.storm.hdfs.spout

Class ProgressTracker

java.lang.Object

org.apache.storm.hdfs.spout.ProgressTracker

public class ProgressTracker
extends Object

Constructor Summary

Constructors

Constructor	Description
ProgressTracker()

Method Summary

Modifier and Type	Method	Description
void	dumpState(PrintStream stream)
org.apache.storm.hdfs.spout.FileOffset	getCommitPosition()
void	recordAckedOffset(org.apache.storm.hdfs.spout.FileOffset newOffset)
int	size()

Methods inherited from class java.lang.Object

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

Constructor Details

ProgressTracker

public ProgressTracker()

Method Details

recordAckedOffset

public void recordAckedOffset(org.apache.storm.hdfs.spout.FileOffset newOffset)

getCommitPosition

public org.apache.storm.hdfs.spout.FileOffset getCommitPosition()

dumpState

public void dumpState(PrintStream stream)

size

public int size()