アパッチスパークコードツール

インポートライブラリはインポートステートメントを作成します。

インポートパッケージ

データの読み取りは、readAlteryxData 関数を作成して、入力データを Apache SparkSQL データフレームとして返します。

val dataFrame = readAlteryxData(1)

書き込みデータは、Apache SparkSQL データフレームを出力する writeAlteryxData 関数を作成します。

writeAlteryxData(dataFrame、1)

log メッセージは、メッセージとしてログに文字列を書き込む logAlteryxMessage 関数を作成します。

logAlteryxMessage(「メッセージ例」)

ログ警告は、警告としてログに文字列を書き込む logAlteryxWarning 関数を作成します。

logAlteryxWarning(「警告の例」)

log error は、エラーとしてログに文字列を書き込む logAlteryxError 関数を作成します。

logAlteryxError(「エラー例」)

インポートライブラリはインポートステートメントを作成します。

モジュールインポートライブラリから

データの読み取りは、readAlteryxData 関数を作成して、入力データを Apache SparkSQL データフレームとして返します。

dataFrame = readAlteryxData(1)

書き込みデータは、Apache SparkSQL データフレームを出力する writeAlteryxData 関数を作成します。

writeAlteryxData(dataFrame、1)

log メッセージは、メッセージとしてログに文字列を書き込む logAlteryxMessage 関数を作成します。

logAlteryxMessage(「メッセージ例」)

ログ警告は、警告としてログに文字列を書き込む logAlteryxWarning 関数を作成します。

logAlteryxWarning(「警告の例」)

log error は、エラーとしてログに文字列を書き込む logAlteryxError 関数を作成します。

logAlteryxError(「エラー例」)

インポートライブラリはインポートステートメントを作成します。

ライブラリ(jsonlite)

データの読み取りは、readAlteryxData 関数を作成して、入力データを Apache SparkSQL データフレームとして返します。

データフレーム<- readAlteryxData(1)></- readAlteryxData(1)>

書き込みデータは、Apache SparkSQL データフレームを出力する writeAlteryxData 関数を作成します。

writeAlteryxData(dataFrame、1)

log メッセージは、メッセージとしてログに文字列を書き込む logAlteryxMessage 関数を作成します。

logAlteryxMessage(「メッセージ例」)

ログ警告は、警告としてログに文字列を書き込む logAlteryxWarning 関数を作成します。

logAlteryxWarning(「警告の例」)

log error は、エラーとしてログに文字列を書き込む logAlteryxError 関数を作成します。

logAlteryxError(「エラー例」)