public static class SequenceFileReader.Offset extends Object
Modifier and Type | Field and Description |
---|---|
long |
currentRecord |
long |
lastSyncPoint |
long |
recordsSinceLastSync |
Constructor and Description |
---|
Offset(long lastSyncPoint,
long recordsSinceLastSync,
long currentRecord) |
Offset(long lastSyncPoint,
long recordsSinceLastSync,
long currentRecord,
long currRecordEndOffset,
long prevRecordEndOffset) |
Offset(String offset) |
Modifier and Type | Method and Description |
---|---|
SequenceFileReader.Offset |
clone() |
int |
compareTo(org.apache.storm.hdfs.spout.FileOffset o) |
boolean |
equals(Object o) |
int |
hashCode() |
boolean |
isNextOffset(org.apache.storm.hdfs.spout.FileOffset rhs)
tests if rhs == currOffset+1.
|
String |
toString() |
public long lastSyncPoint
public long recordsSinceLastSync
public long currentRecord
public Offset(long lastSyncPoint, long recordsSinceLastSync, long currentRecord)
public Offset(long lastSyncPoint, long recordsSinceLastSync, long currentRecord, long currRecordEndOffset, long prevRecordEndOffset)
public Offset(String offset)
public boolean isNextOffset(org.apache.storm.hdfs.spout.FileOffset rhs)
public int compareTo(org.apache.storm.hdfs.spout.FileOffset o)
public SequenceFileReader.Offset clone()
Copyright © 2022 The Apache Software Foundation. All rights reserved.