org.apache.flink.connectors.hive

Class HiveSource

java.lang.Object

org.apache.flink.connector.file.src.AbstractFileSource<org.apache.flink.table.data.RowData,HiveSourceSplit>

org.apache.flink.connectors.hive.HiveSource

All Implemented Interfaces:

Serializable, org.apache.flink.api.connector.source.Source<org.apache.flink.table.data.RowData,HiveSourceSplit,org.apache.flink.connector.file.src.PendingSplitsCheckpoint<HiveSourceSplit>>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<org.apache.flink.table.data.RowData>

public class HiveSource
extends org.apache.flink.connector.file.src.AbstractFileSource<org.apache.flink.table.data.RowData,HiveSourceSplit>
implements org.apache.flink.api.java.typeutils.ResultTypeQueryable<org.apache.flink.table.data.RowData>

A unified data source that reads a hive table.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	HiveSource.HiveSourceBuilder Builder to build HiveSource instances.

Nested classes/interfaces inherited from class org.apache.flink.connector.file.src.AbstractFileSource

org.apache.flink.connector.file.src.AbstractFileSource.AbstractFileSourceBuilder<T,SplitT extends org.apache.flink.connector.file.src.FileSourceSplit,SELF extends org.apache.flink.connector.file.src.AbstractFileSource.AbstractFileSourceBuilder<T,SplitT,SELF>>

Method Summary

Modifier and Type	Method and Description
org.apache.flink.api.connector.source.SplitEnumerator<HiveSourceSplit,org.apache.flink.connector.file.src.PendingSplitsCheckpoint<HiveSourceSplit>>	createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<HiveSourceSplit> enumContext)
org.apache.flink.core.io.SimpleVersionedSerializer<org.apache.flink.connector.file.src.PendingSplitsCheckpoint<HiveSourceSplit>>	getEnumeratorCheckpointSerializer()
org.apache.flink.core.io.SimpleVersionedSerializer<HiveSourceSplit>	getSplitSerializer()
org.apache.flink.api.connector.source.SplitEnumerator<HiveSourceSplit,org.apache.flink.connector.file.src.PendingSplitsCheckpoint<HiveSourceSplit>>	restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<HiveSourceSplit> enumContext, org.apache.flink.connector.file.src.PendingSplitsCheckpoint<HiveSourceSplit> checkpoint)

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

createReader, getAssignerFactory, getBoundedness, getContinuousEnumerationSettings, getProducedType

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.api.java.typeutils.ResultTypeQueryable

getProducedType

Method Detail

getSplitSerializer

public org.apache.flink.core.io.SimpleVersionedSerializer<HiveSourceSplit> getSplitSerializer()

Specified by:

getSplitSerializer in interface org.apache.flink.api.connector.source.Source<org.apache.flink.table.data.RowData,HiveSourceSplit,org.apache.flink.connector.file.src.PendingSplitsCheckpoint<HiveSourceSplit>>

Specified by:

getSplitSerializer in class org.apache.flink.connector.file.src.AbstractFileSource<org.apache.flink.table.data.RowData,HiveSourceSplit>

getEnumeratorCheckpointSerializer

public org.apache.flink.core.io.SimpleVersionedSerializer<org.apache.flink.connector.file.src.PendingSplitsCheckpoint<HiveSourceSplit>> getEnumeratorCheckpointSerializer()

Specified by:

getEnumeratorCheckpointSerializer in interface org.apache.flink.api.connector.source.Source<org.apache.flink.table.data.RowData,HiveSourceSplit,org.apache.flink.connector.file.src.PendingSplitsCheckpoint<HiveSourceSplit>>

Overrides:

getEnumeratorCheckpointSerializer in class org.apache.flink.connector.file.src.AbstractFileSource<org.apache.flink.table.data.RowData,HiveSourceSplit>

createEnumerator

public org.apache.flink.api.connector.source.SplitEnumerator<HiveSourceSplit,org.apache.flink.connector.file.src.PendingSplitsCheckpoint<HiveSourceSplit>> createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<HiveSourceSplit> enumContext)

Specified by:

createEnumerator in interface org.apache.flink.api.connector.source.Source<org.apache.flink.table.data.RowData,HiveSourceSplit,org.apache.flink.connector.file.src.PendingSplitsCheckpoint<HiveSourceSplit>>

Overrides:

createEnumerator in class org.apache.flink.connector.file.src.AbstractFileSource<org.apache.flink.table.data.RowData,HiveSourceSplit>

restoreEnumerator

public org.apache.flink.api.connector.source.SplitEnumerator<HiveSourceSplit,org.apache.flink.connector.file.src.PendingSplitsCheckpoint<HiveSourceSplit>> restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<HiveSourceSplit> enumContext,
                                                                                                                                                                             org.apache.flink.connector.file.src.PendingSplitsCheckpoint<HiveSourceSplit> checkpoint)

Specified by:

restoreEnumerator in interface org.apache.flink.api.connector.source.Source<org.apache.flink.table.data.RowData,HiveSourceSplit,org.apache.flink.connector.file.src.PendingSplitsCheckpoint<HiveSourceSplit>>

Overrides:

restoreEnumerator in class org.apache.flink.connector.file.src.AbstractFileSource<org.apache.flink.table.data.RowData,HiveSourceSplit>