@Internal public class ArrowSourceFunction extends AbstractArrowSourceFunction<RowData>
SourceFunction
which takes RowData
as the type of the produced records.SourceFunction.SourceContext<T>
Modifier and Type | Method and Description |
---|---|
TypeInformation<RowData> |
getProducedType()
Gets the data type (as a
TypeInformation ) produced by this function or input format. |
cancel, close, initializeState, open, run, snapshotState
getIterationRuntimeContext, getRuntimeContext, setRuntimeContext
public TypeInformation<RowData> getProducedType()
ResultTypeQueryable
TypeInformation
) produced by this function or input format.Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.