org.apache.flink.table.utils.python

Class PythonTableUtils

java.lang.Object

org.apache.flink.table.utils.python.PythonTableUtils

@Internal
public final class PythonTableUtils
extends Object

Python utilities.

Method Summary

Modifier and Type	Method and Description
static Table	createTableFromElement(TableEnvironment tEnv, String filePath, DataType schema, boolean batched) Create a table from PythonDynamicTableSource that read data from input file with specific DataType.
static InputFormat<RowData,?>	getInputFormat(List<Object[]> data, DataType dataType) Wrap the unpickled python data with an InputFormat.

Methods inherited from class java.lang.Object

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

Method Detail

createTableFromElement

public static Table createTableFromElement(TableEnvironment tEnv,
                                           String filePath,
                                           DataType schema,
                                           boolean batched)

Create a table from PythonDynamicTableSource that read data from input file with specific DataType.

Parameters:

tEnv - The TableEnvironment to create table.

filePath - the file path of the input data.

schema - The python data type.

batched - Whether to read data in a batch

Returns:

Table with InputFormat.

getInputFormat

public static InputFormat<RowData,?> getInputFormat(List<Object[]> data,
                                                    DataType dataType)

Wrap the unpickled python data with an InputFormat. It will be passed to PythonDynamicTableSource later.

Parameters:

data - The unpickled python data.

dataType - The python data type.

Returns:

An InputFormat containing the python data.