public class KafkaETLKey extends java.lang.Object implements org.apache.hadoop.io.WritableComparable<KafkaETLKey>
Modifier and Type | Field and Description |
---|---|
protected long |
_checksum |
protected int |
_inputIndex |
protected long |
_offset |
Constructor and Description |
---|
KafkaETLKey()
dummy empty constructor
|
KafkaETLKey(int index,
long offset) |
KafkaETLKey(int index,
long offset,
long checksum) |
Modifier and Type | Method and Description |
---|---|
int |
compareTo(KafkaETLKey o) |
long |
getChecksum() |
int |
getIndex() |
long |
getOffset() |
void |
readFields(java.io.DataInput in) |
void |
set(int index,
long offset,
long checksum) |
java.lang.String |
toString() |
void |
write(java.io.DataOutput out) |
protected int _inputIndex
protected long _offset
protected long _checksum
public KafkaETLKey()
public KafkaETLKey(int index, long offset)
public KafkaETLKey(int index, long offset, long checksum)
public void set(int index, long offset, long checksum)
public int getIndex()
public long getOffset()
public long getChecksum()
public void readFields(java.io.DataInput in) throws java.io.IOException
readFields
in interface org.apache.hadoop.io.Writable
java.io.IOException
public void write(java.io.DataOutput out) throws java.io.IOException
write
in interface org.apache.hadoop.io.Writable
java.io.IOException
public int compareTo(KafkaETLKey o)
compareTo
in interface java.lang.Comparable<KafkaETLKey>
public java.lang.String toString()
toString
in class java.lang.Object