使用することを指定します。パラメーターを設定する必要があります。アクセストークンに設定する必要があります。設定する必要があります。デフォルトはありません。必要なコンテキストオプション¶セッションのデータベースとスキーマコンテキストを設定するには、次のオプションが必要です:sfDatabase接続後にセッションに使用するデータベース。sfSchema接続後にセッションに使用するスキーマ。その他のコンテキストオプション¶このセクションにリストされているオプションは必須ではありません。myorganization-myaccount)。指定されているため、このオプションは不要になりました。ここでは、下位互換性のためにのみ文書化されています。sfWarehouse接続後にセッションに使用するデフォルトの仮想ウェアハウス。sfRole接続後にセッションに使用するデフォルトのセキュリティロール。プロキシオプション¶このセクションにリストされているオプションは必須ではありません。use_proxyコネクタが、プロキシを使用するかどうかを指定します。コネクタがプロキシを使用する必要があることを指定します。コネクタがプロキシを使用する必要がないことを指定します。場合に必須)使用するプロキシサーバーのホスト名を指定します。場合に必須)使用するプロキシサーバーのポート番号を指定します。proxy_protocolプロキシサーバーへの接続に使用するプロトコルを指定します。次の値のいずれかを指定できます。Snowflakeでのみサポートされています。このオプションは、Sparkコネクタのバージョン2.11.1で追加されました。proxy_userプロキシサーバーへの認証用のユーザー名を指定します。プロキシサーバーが認証を必要とする場合はこの設定を行います。Snowflakeでのみサポートされています。パスワードを指定します。プロキシサーバーが認証を必要とする場合はこの設定を行います。Snowflakeでのみサポートされています。non_proxy_hostsプロキシサーバーをバイパスして、コネクタが直接接続する必要があるホストのリストを指定します。エスケープしたパイプ記号(%7C)で区切ります。アスタリスク(*)をワイルドカードとして使用することもできます。Snowflakeでのみサポートされています。追加オプション¶このセクションにリストされているオプションは必須ではありません。sfTimezoneSparkでの作業時にSnowflakeが使用するタイムゾーン。パラメーターはSnowflakeのタイムゾーンのみを設定することに注意してください。Spark環境は変更されません。サポートされている値は次のとおりです。:Sparkのタイムゾーンを使用します(デフォルト)。:Snowflakeの現在のタイムゾーンを使用します。:接続しているSnowflakeユーザーのデフォルトのタイムゾーンを使用します。America/New_York)を使用します。(このトピック内)をご参照ください。(デフォルト)に設定すると、SnowflakeとSparkの間で渡されるデータが圧縮されます。s3MaxFileSizeSnowflakeからSparkにデータを移動するときに使用されるファイルのサイズ。コマンドのセミコロン区切りリスト。操作で参照されるテーブル名に置き換えられます。コマンドのセミコロン区切りリスト。含まれる場合、これは操作で参照されるテーブル名に置き換えられます。コマンドはターゲット列の長さを超えるテキスト文字列を自動的に切り捨てます。設定した場合、ロードされた文字列がターゲット列の長さを超えると、コマンドはエラーを生成します。truncate_tableこのパラメーターは、そのテーブルを上書きするときに、SnowflakeがSnowflakeターゲットテーブルのスキーマを保持するかどうかを制御します。デフォルトでは、Snowflakeのターゲットテーブルが上書きされると、そのターゲットテーブルのスキーマも上書きされます。新しいスキーマは、ソーステーブル(Sparkデータフレーム)のスキーマに基づいています。ソースのスキーマが理想的でない場合があります。値を格納できるようにしたい場合があります。その場合は、Snowflakeテーブルのスキーマを上書きしないでください。Snowflakeテーブルは単に切り捨ててから、現在のスキーマで再利用する必要があります。場合、ターゲットテーブルの元のスキーマが保持されます。場合、テーブルの古いスキーマは無視され、ソースのスキーマに基づいて新しいスキーマが生成されます。このパラメーターはオプションです。(つまり、デフォルトでは元のテーブルスキーマが上書きされます)。(このトピック)をご参照ください。コマンドを中止するかどうかを制御します。エラーが発生しても続行することを意味します。エラーが発生した場合に中止することを意味します。このパラメーターはオプションです。このオプションをオンにすることはお勧めしません。Snowflakeにエラーが報告された場合、データが失われる可能性があります。行が拒否されたまたは欠落している場合、入力ソースでそれらの行に明らかに欠陥がない場合は、Snowflakeに報告してください。usestagingtableこのパラメーターは、データのロードでステージングテーブルを使用するかどうかを制御します。ステージングテーブルは、コネクタによって作成される通常のテーブル(一時的な名前を持つ)です。データのロード操作が成功すると、元のターゲットテーブルが削除され、ステージングテーブルの名前が元のターゲットテーブルの名前に変更されます。データのロード操作が失敗した場合、ステージングテーブルは削除され、ターゲットテーブルには操作の直前に保持していたデータが残ります。したがって、ステージングテーブルを使用すると、操作が失敗した場合に元のターゲットテーブルデータを保持できます。安全のため、Snowflakeはほとんどの状況でステージングテーブルを使用することを強くお勧めします。実行するユーザーに、テーブルを作成するための十分な権限が必要です。ユーザーがテーブルを作成する権限を持っていない場合、直接ロード(つまり、ステージングテーブルを使用しない読み込み)は便利です。場合、ステージングテーブルが使用されます。場合、データはターゲットテーブルに直接ロードされます。このパラメーターはオプションです。(つまり、ステージングテーブルを使用します)。autopushdownこのパラメーターは、自動クエリプッシュダウンを有効にするかどうかを制御します。プッシュダウンが有効になっている場合、クエリがSparkで実行されるときに、クエリの一部をSnowflakeサーバーに「プッシュダウン」できる場合、プッシュダウンされます。これにより、一部のクエリのパフォーマンスが向上します。このパラメーターはオプションです。