org.apache.flink.table.runtime.arrow.sources

Class RowArrowSourceFunction

java.lang.Object

org.apache.flink.api.common.functions.AbstractRichFunction

org.apache.flink.streaming.api.functions.source.RichParallelSourceFunction<OUT>

org.apache.flink.table.runtime.arrow.sources.AbstractArrowSourceFunction<Row>

org.apache.flink.table.runtime.arrow.sources.RowArrowSourceFunction

All Implemented Interfaces:

Serializable, Function, RichFunction, ResultTypeQueryable<Row>, CheckpointedFunction, ParallelSourceFunction<Row>, SourceFunction<Row>

@Internal
public class RowArrowSourceFunction
extends AbstractArrowSourceFunction<Row>

An Arrow SourceFunction which takes Row as the type of the produced records.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.streaming.api.functions.source.SourceFunction

SourceFunction.SourceContext<T>

Method Summary

Modifier and Type	Method and Description
TypeInformation<Row>	getProducedType() Gets the data type (as a TypeInformation) produced by this function or input format.

Methods inherited from class org.apache.flink.table.runtime.arrow.sources.AbstractArrowSourceFunction

cancel, close, initializeState, open, run, snapshotState

Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction

getIterationRuntimeContext, getRuntimeContext, setRuntimeContext

Methods inherited from class java.lang.Object

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

Method Detail

getProducedType

public TypeInformation<Row> getProducedType()

Description copied from interface: ResultTypeQueryable

Gets the data type (as a TypeInformation) produced by this function or input format.

Returns:

The data type produced by this function or input format.