org.apache.flink.connectors.hive.read

类 TimestampedHiveInputSplit

java.lang.Object

org.apache.flink.core.io.LocatableInputSplit

org.apache.flink.api.java.hadoop.mapred.wrapper.HadoopInputSplit

org.apache.flink.connectors.hive.read.HiveTableInputSplit

org.apache.flink.connectors.hive.read.TimestampedHiveInputSplit

所有已实现的接口:

Serializable, Comparable<org.apache.flink.streaming.api.functions.source.TimestampedInputSplit>, org.apache.flink.core.io.InputSplit, org.apache.flink.streaming.api.functions.source.TimestampedInputSplit

@TypeInfo(value=TimestampedHiveInputSplit.SplitTypeInfoFactory.class)
public class TimestampedHiveInputSplit
extends HiveTableInputSplit
implements org.apache.flink.streaming.api.functions.source.TimestampedInputSplit

A 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.

另请参阅:

序列化表格

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	TimestampedHiveInputSplit.SplitTypeInfoFactory TypeInfoFactory for TimestampedHiveInputSplit.

字段概要

从类继承的字段 org.apache.flink.connectors.hive.read.HiveTableInputSplit

hiveTablePartition

构造器概要

构造器

构造器和说明
TimestampedHiveInputSplit(long modificationTime, HiveTableInputSplit split)

方法概要

限定符和类型	方法和说明
int	compareTo(org.apache.flink.streaming.api.functions.source.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)
String	toString()

从类继承的方法 org.apache.flink.connectors.hive.read.HiveTableInputSplit

getHiveTablePartition

从类继承的方法 org.apache.flink.api.java.hadoop.mapred.wrapper.HadoopInputSplit

getHadoopInputSplit, getHostnames, getJobConf

从类继承的方法 org.apache.flink.core.io.LocatableInputSplit

getSplitNumber

从类继承的方法 java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

从接口继承的方法 org.apache.flink.streaming.api.functions.source.TimestampedInputSplit

resetSplitState

从接口继承的方法 org.apache.flink.core.io.InputSplit

getSplitNumber

构造器详细资料

TimestampedHiveInputSplit

public TimestampedHiveInputSplit(long modificationTime,
                                 HiveTableInputSplit split)

方法详细资料

setSplitState

public void setSplitState(Serializable state)

指定者:

setSplitState 在接口中 org.apache.flink.streaming.api.functions.source.TimestampedInputSplit

getSplitState

public Serializable getSplitState()

指定者:

getSplitState 在接口中 org.apache.flink.streaming.api.functions.source.TimestampedInputSplit

getModificationTime

public long getModificationTime()

指定者:

getModificationTime 在接口中 org.apache.flink.streaming.api.functions.source.TimestampedInputSplit

compareTo

public int compareTo(org.apache.flink.streaming.api.functions.source.TimestampedInputSplit o)

Note Again: this class has a natural ordering that is inconsistent with equals.

指定者:

compareTo 在接口中 Comparable<org.apache.flink.streaming.api.functions.source.TimestampedInputSplit>

equals

public boolean equals(Object o)

覆盖:

equals 在类中 HiveTableInputSplit

hashCode

public int hashCode()

覆盖:

hashCode 在类中 HiveTableInputSplit

toString

public String toString()

覆盖:

toString 在类中 HiveTableInputSplit