@TypeInfo(value=TimestampedHiveInputSplit.SplitTypeInfoFactory.class) public class TimestampedHiveInputSplit extends HiveTableInputSplit implements TimestampedInputSplit
HiveTableInputSplit
with TimestampedInputSplit
. Kryo serializer can not deal
with hadoop split, need specific type information factory.
Note: this class has a natural ordering that is inconsistent with equals.
Modifier and Type | Class and Description |
---|---|
static class |
TimestampedHiveInputSplit.SplitTypeInfoFactory
|
hiveTablePartition
Constructor and Description |
---|
TimestampedHiveInputSplit(long modificationTime,
HiveTableInputSplit split) |
Modifier and Type | Method and Description |
---|---|
int |
compareTo(TimestampedInputSplit o)
Note Again: this class has a natural ordering that is inconsistent with equals.
|
boolean |
equals(Object o) |
long |
getModificationTime() |
Serializable |
getSplitState() |
int |
hashCode() |
void |
setSplitState(Serializable state)
Sets the state of the split.
|
String |
toString() |
getHiveTablePartition
getHadoopInputSplit, getHostnames, getJobConf
getSplitNumber
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
resetSplitState
getSplitNumber
public TimestampedHiveInputSplit(long modificationTime, HiveTableInputSplit split)
public void setSplitState(Serializable state)
TimestampedInputSplit
* This is applicable to FileInputFormats
that implement the CheckpointableInputFormat
interface.
setSplitState
in interface TimestampedInputSplit
public Serializable getSplitState()
getSplitState
in interface TimestampedInputSplit
public long getModificationTime()
getModificationTime
in interface TimestampedInputSplit
public int compareTo(TimestampedInputSplit o)
compareTo
in interface Comparable<TimestampedInputSplit>
public boolean equals(Object o)
equals
in class HiveTableInputSplit
public int hashCode()
hashCode
in class HiveTableInputSplit
public String toString()
toString
in class HiveTableInputSplit
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.