org.apache.flink.connectors.hive.read

Class HiveSourceSplit

java.lang.Object

org.apache.flink.connector.file.src.FileSourceSplit

org.apache.flink.connectors.hive.read.HiveSourceSplit

All Implemented Interfaces:

Serializable, org.apache.flink.api.connector.source.SourceSplit

public class HiveSourceSplit
extends org.apache.flink.connector.file.src.FileSourceSplit

A wrapper class that wraps info needed for a file input split. Right now, it contains info about the partition of the split.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected HiveTablePartition	hiveTablePartition

Constructor Summary

Constructors

Constructor and Description
HiveSourceSplit(org.apache.hadoop.mapred.FileSplit fileSplit, HiveTablePartition hiveTablePartition, org.apache.flink.connector.file.src.util.CheckpointedPosition readerPosition)
HiveSourceSplit(String id, org.apache.flink.core.fs.Path filePath, long offset, long length, String[] hostnames, org.apache.flink.connector.file.src.util.CheckpointedPosition readerPosition, HiveTablePartition hiveTablePartition)

Method Summary

Modifier and Type	Method and Description
HiveTablePartition	getHiveTablePartition()
org.apache.hadoop.mapred.FileSplit	toMapRedSplit()
String	toString()
org.apache.flink.connector.file.src.FileSourceSplit	updateWithCheckpointedPosition(org.apache.flink.connector.file.src.util.CheckpointedPosition position)

Methods inherited from class org.apache.flink.connector.file.src.FileSourceSplit

getReaderPosition, hostnames, length, offset, path, splitId

Methods inherited from class java.lang.Object

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

Field Detail

hiveTablePartition

protected final HiveTablePartition hiveTablePartition

Constructor Detail

HiveSourceSplit

public HiveSourceSplit(org.apache.hadoop.mapred.FileSplit fileSplit,
                       HiveTablePartition hiveTablePartition,
                       @Nullable
                       org.apache.flink.connector.file.src.util.CheckpointedPosition readerPosition)
                throws IOException

Throws:

IOException

HiveSourceSplit

public HiveSourceSplit(String id,
                       org.apache.flink.core.fs.Path filePath,
                       long offset,
                       long length,
                       String[] hostnames,
                       @Nullable
                       org.apache.flink.connector.file.src.util.CheckpointedPosition readerPosition,
                       HiveTablePartition hiveTablePartition)

Method Detail

getHiveTablePartition

public HiveTablePartition getHiveTablePartition()

toMapRedSplit

public org.apache.hadoop.mapred.FileSplit toMapRedSplit()

updateWithCheckpointedPosition

public org.apache.flink.connector.file.src.FileSourceSplit updateWithCheckpointedPosition(@Nullable
                                                                                          org.apache.flink.connector.file.src.util.CheckpointedPosition position)

Overrides:

updateWithCheckpointedPosition in class org.apache.flink.connector.file.src.FileSourceSplit

toString

public String toString()

Overrides:

toString in class org.apache.flink.connector.file.src.FileSourceSplit