重要このサンプルプログラムは、バージョン2.2.0(またはそれ以上)のコネクタを使用していることを前提としています。Snowflake内部ステージを使用して一時データを保存するため、一時データの保存にS3の場所は必要ありません。の)を含める必要があります。(このトピック)をご参照ください。次のScalaプログラムは、Spark用Snowflakeコネクタの完全な使用例を提供します。(このトピック内)で説明されているように、次の文字列を適切な値に置き換えます。Snowflakeユーザーのログイン認証情報。:Snowflakeセッションのデフォルト。サンプルのScalaプログラムは、基本認証(つまり、ユーザー名とパスワード)を使用します。使用(このトピック内)をご参照ください。.save()CopyPythonでのコネクタの使用¶Pythonでコネクタを使用することは、Scalaの使用法に非常に似ています。スクリプトを使用することをお勧めします。環境変数に含めることを忘れないでください。セッションでのプッシュダウンの有効化/無効化¶コネクタのバージョン2.1.0(以降)はクエリプッシュダウンをサポートします。これは、SnowflakeがSparkデータソースである場合にクエリ処理をSnowflakeにプッシュすることにより、パフォーマンスを大幅に改善できます。デフォルトでは、プッシュダウンは有効になっています。オブジェクトを渡します。sfOptions)。重要このサンプルスクリプトは、バージョン2.2.0(またはそれ以上)のコネクタを使用していることを前提としています。Snowflake内部ステージを使用して一時データを保存するため、このデータの保存にS3の場所は必要ありません。の)を含める必要があります。(このトピック)をご参照ください。クエリおよびその他の操作を実行できます。クエリを実行するPythonスクリプトの例です。このスクリプトは、基本的なコネクタの使用法を示しています。このドキュメントのScalaの例のほとんどは、Pythonで使用するための最小限の労力/変更で適応できます。サンプルPythonスクリプトは、基本認証(つまり、ユーザー名とパスワード)を使用します。使用(このトピック内)をご参照ください。使用に注意してください。これにより、コードが簡素化され、エラーが発生する可能性が低くなります。(このトピック)をご参照ください。データ型マッピング¶Sparkコネクタは、多くの一般的なデータ型間の変換をサポートしています。タイプをサポートしていません。