This documentation is for an unreleased version of Apache Flink. We recommend you use the latest stable version.

データの型 #

このページでは、PyFlink Table APIでサポートされるデータ型を説明します。

データ型 #

data typeはtableエコシステム内の値の論理型を表します。これはPythonのユーザ定義関数の入力および/または出力型を宣言するために使えます。Python Table APIのユーザは、Python Table APIの中や、ユーザ定義関数を定義する時に、pyflink.table.types.DataTypeのインスタンスを操作できます。

DataTypeインスタンスは、論理型を宣言します。これは送信または保存のための具体的な物理表現を意味しません。全ての事前定義されたデータ型はpyflink.table.typesで利用可能で、pyflink.table.types.DataTypesで定義されたユーティリティメソッドを使ってインスタンス化できます。

全ての事前定義されたデータ型のリストは、以下にあります。

データ型とPythonの型のマッピング #

データ型は、Pythonユーザ定義関数の入力および/または出力型を宣言するために使えます。入力はデータ型に対応するPythonオブジェクトに変換され、ユーザ定義関数の結果の型も定義されたデータ型に一致する必要があります。

ベクトル化されたPython UDFの場合、入力型と出力型はpandas.Seriesです。pandas.Seriesの要素の型は、指定されたデータ型に対応します。