@Internal public class PythonInputFormatTableSource extends InputFormatTableSource<Row>
InputFormatTableSource
created by python 'from_element' method.Constructor and Description |
---|
PythonInputFormatTableSource(InputFormat<Row,? extends InputSplit> inputFormat,
RowTypeInfo rowTypeInfo) |
Modifier and Type | Method and Description |
---|---|
InputFormat<Row,?> |
getInputFormat()
Returns an
InputFormat for reading the data of the table. |
TypeInformation<Row> |
getReturnType() |
TableSchema |
getTableSchema()
Returns the schema of the produced table.
|
getDataStream, isBounded
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
explainSource, getProducedDataType
public PythonInputFormatTableSource(InputFormat<Row,? extends InputSplit> inputFormat, RowTypeInfo rowTypeInfo)
public InputFormat<Row,?> getInputFormat()
InputFormatTableSource
InputFormat
for reading the data of the table.getInputFormat
in class InputFormatTableSource<Row>
public TableSchema getTableSchema()
TableSource
TableSchema
of the produced table.public TypeInformation<Row> getReturnType()
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.