入力と出力

入力のデータ型と変換

Code Workbook では、トランスフォームが受け取る各入力のデータ型を指定できます。入力のデータ型は、トランスフォーム名の下にあるドロップダウンメニューを選択して設定できます。

指定した入力のデータ型が実際に受け取る入力のデータ型と一致しない場合、Code Workbook が必要な変換を行います。

たとえば、transform_A の出力が pandas データフレームで、その派生トランスフォームである transform_B の入力を手動で Spark データフレームに設定した場合、Code Workbook は pandas データフレームを指定された Spark データフレームに変換します。transform_C の出力が pandas データフレームで、その派生トランスフォームである transform_D が入力として R data.frame を指定した場合、Code Workbook はまず pandas データフレームを Spark データフレームに戻してから、R data.frame に変換します。

次のフローチャートは、Code Workbook が入力のデータ型間の変換をどのように処理するかを示しています。

入力と出力の制限

出力タイプ

Code Workbook のトランスフォームは、任意の数の入力を持つことができ、それぞれに異なる入力のデータ型を設定できます。ただし、トランスフォームの出力は1個に限られます。現在、複数の出力はサポートされていません。

Code Workbook のトランスフォームで使用できる出力タイプは、言語に応じて次の種類に限られます。

トランスフォームが上記以外のデータ型を返した場合、Code Workbook はサポートされていないデータ型のエラーを返します。

Python の入力のデータ型

デフォルトでは、Python トランスフォームは入力を Spark データフレームとして受け取ります。トランスフォーム名の下にあるドロップダウンメニューを選択して入力のデータ型を設定すると、Code Workbook が上流の出力を指定した入力のデータ型に変換します。

Python トランスフォームでは、次の入力のデータ型がサポートされています。

R の入力のデータ型

デフォルトでは、R トランスフォームは入力を R data.frame として受け取ります。トランスフォーム名の下にあるドロップダウンメニューを選択して入力のデータ型を設定すると、Code Workbook が上流の出力を指定した入力のデータ型に変換します。

R トランスフォームでは、次の入力のデータ型がサポートされています。

SQL の入力と出力のデータ型

SQL トランスフォームでサポートされている入力と出力のデータ型は、Spark データフレームのみです。データフレームは SQL 内でテーブルとして読み取ることができます。