Native SDK for Connectors Java - リリースノート¶

一般的な変更¶

• SnowSQL ツールを新しいSnowflake CLI ツールに置き換えました

• Java依存関係を更新しました

動作の変更¶

• com.snowflake.connectors.common.object:

  • toString が返す値を、クラス内の getValue と同じになるように変更しました。

    • Identifier

    • ObjectName

    • Reference

    • SchemaName

• com.snowflake.connectors.application.scheduler.SchedulerCreator:

  • クラス名を SchedulerManager に変更しました。

• com.snowflake.connectors.taskreactor.commands.queue.CommandsQueueRepository:

  • クラス名を CommandsQueue に変更しました。

• com.snowflake.connectors.application.integration.SchedulerTaskReactorOnIngestionScheduled:

  • クラス名を TaskReactorOnIngestionScheduledCallback に変更しました。

  • このクラスは ResourceIngestionDefinition とその汎用パラメーターを使うようになりました。

• com.snowflake.connectors.taskreactor.config.ConfigRepository:

  • 構成値はバリアントではなく、常に文字列として扱われるようになりました。

新機能¶

• 構成ウィザードの状態をリセットできる新しい PUBLIC.RESET_CONFIGURATION() プロシージャ。さらに、プロシージャフロー中にカスタム操作を実行できるコールバックが追加されました。 構成のリセット もご参照ください。

• コネクタの状態をリセットできる新しい PUBLIC.RECOVER_CONNECTOR_STATE(STRING) プロシージャ。 コネクタの状態を回復 もご参照ください。

• タスクリアクターのインスタンスを削除できる新しい TASK_REACTOR.REMOVE_INSTANCE(STRING) プロシージャを追加しました。 インスタンスの削除 もご参照ください。

• com.snowflake.connectors.application.configuration.connector.ConnectorConfigurationKey:

  • 新しい CORTEX_WAREHOUSE キーを追加しました。

  • 新しい CORTEX_USER_ROLE キーを追加しました。

• com.snowflake.connectors.util.time:

  • LocalDate と ZoneId の JSON シリアライズ用の新しいクラスを追加しました。

• com.snowflake.connectors.common.task.TaskRepository:

  • タスク作成時に、先行タスクが指定されている場合、 AFTER パラメーターをサポートするようになりました。

  • USER_TASK_TIMEOUT_MS パラメーターのサポートを追加しました。

• com.snowflake.connectors.common.task.TaskProperties:

  • 先行タスクのサポートを追加しました。

  • USER_TASK_TIMEOUT_MS プロパティのサポートを追加しました。

• com.snowflake.connectors.util.sql.SqlTools:

• callProcedureRaw(Session, String, String...) メソッドを追加しました。

• callProcedureRaw(Session, String, String, String...) メソッドを追加しました。

• 新しい com.snowflake.connectors.taskreactor.worker.ingestion.SimpleIngestionWorker クラスを追加しました。インジェスチョンワークロードで使用するシンプルなワーカー実装です。

• 新しい com.snowflake.connectors.taskreactor.worker.ingestion.SimpleIngestion クラスを追加しました。 IngestionWorker で使用するための、シンプルなインジェスチョン表現です。

• 新しい com.snowflake.connectors.taskreactor.worker.ingestion.SimpleIngestionWorkItem クラスが追加されました。インジェスチョン作業のためのシンプルなワークアイテムの実装です。

バグ修正¶

• com.snowflake.connectors.common.task.TaskRepository:

  • create(TaskDefinition, boolean, boolean) のタスク作成成功条件チェックを修正しました。

• com.snowflake.connectors.util.variant.VarianMapper:

  • バリアントのタイムスタンプの処理を修正しました。

• コネクタ構成プロセスのハンドラーのデフォルト入力バリデータを修正しました。

• ほとんどの SELECT クエリから DataFrame#first を削除し、タスクでいくつかのプロシージャを使用する際の問題を修正しました。

• STATE スキーマに対する USAGE のアプリロール ADMIN への付与を削除しました。

• タスクリアクター設定テーブルに欠落していた UPDATED_AT 列を追加しました。

動作の変更¶

• 新しい識別子のアプローチ。

  重要

  この新しいアプローチにより、コネクタ内での識別子の使用方法が変更される可能性があります。新しい変更を十分にテストしてください。

  • SDK は、すべての識別子がユーザーによって提供されたとおりに送信されることを期待できるようになりました。 SDK は、それをさらに正しく処理するために、引用符で囲まれた識別子かどうかをそれ自体で判断します。

  • 識別子の自動引用符付けは、Snowflakeクエリが返す値を使用する場合にのみ行われます。

  • 新しいアプローチを UI で使用するには、コネクタが PUBLIC.APP_PROPERTIES ビューの新しいプロパティを、キーが UI_ADD_QUOTES_TO_EXISTING_QUOTED_IDENTIFIERS で値が TRUE で返す必要があります。

  • com.snowflake.connectors.common.object.Identifier クラスを以下のように変更しました。

    • fromWithAutoQuoting() と getName() メソッドを削除しました。

    • 空の識別子の概念である、 empty()、 isNullOrEmpty()、 validateNullOrEmpty()、 isEmpty() メソッドを削除しました。

    • 新しい from() メソッドが追加され、識別子インスタンスの作成時に自動引用符付けを有効化できるようになりました。指定された文字列が引用符付けされておらず、すべてが大文字の識別子の場合は自動引用符付けが実行されません。

    • validate() メソッドを isValid() に変更しました。

    • toSqlString() メソッドを getValue() に変更しました。

    • getUnquotedValue()、 getQuotedValue()、 getVariantValue()、および isUnquoted() メソッドを追加しました。

• com.snowflake.connectors.common.object.ObjectName クラスを以下のように変更しました。

  • データベースとスキーマのプロパティを Optional にしました。

  • getDatabase() と getSchema() の戻り型を Optional に変更しました。

  • validate() メソッドを isValid() に変更しました。

  • validateDoubleDot() メソッドを isDoubleDot() に変更しました。

  • getEscapedName() メソッドを getValue() に変更しました。

  • getVariantValue() と getSchemaName() メソッドを追加しました。

• com.snowflake.connectors.common.object.Reference クラスを以下のように変更しました。

  • 空の参照の概念である、 empty() と isEmpty() メソッドを削除しました。

  • validate() メソッドを isValid() に変更しました。

  • referenceName() メソッドを getName() に変更しました。

  • value() メソッドを getValue() に変更しました。

  • スキーマを表現するための新しいクラス com.snowflake.connectors.common.object.SchemaName を追加しました。 com.snowflake.connectors.common.object.ObjectName クラスと同じように動作します。

  • com.snowflake.connectors.common.object.InvalidSchemaNameException クラスを追加しました。

新機能¶

• リソース管理のプロシージャは以下のとおりです。

  • PUBLIC.CREATE_RESOURCE() プロシージャに新しいコールバックを導入して、プロシージャフロー中にカスタム操作を実行できるようにしました。 リソースを作成する もご参照ください。

  • 無効化されたリソースを有効にすることができる新しい PUBLIC.ENABLE_RESOURCE() プロシージャ。さらに、プロシージャフロー中にカスタム操作を実行できるコールバックが追加されました。 リソースを有効にする もご参照ください。

  • 有効化されたリソースを無効にすることができる新しい PUBLIC.DISABLE_RESOURCE() プロシージャ。さらに、プロシージャフロー中にカスタム操作を実行できるコールバックが追加されました。 リソースを無効にする もご参照ください。

  • 新しい PUBLIC.UPDATE_RESOURCE() プロシージャを追加して、特定のリソースのインジェスチョン構成を更新できるようにしました。さらに、プロシージャフロー中にカスタム操作を実行できるコールバックが追加されました。 リソースを更新する もご参照ください。

• com.snowflake.connectors.util.sql.SqlTools:

  • varcharArgument() メソッドに代わる予定の asVarchar() メソッドを追加しました。

  • variantArgument() メソッドに代わる予定の asVariant() メソッドを追加しました。

  • varcharArgument() と variantArgument() メソッドを廃止し、将来的に削除されるように設定しました。

• その他の追加:

  • com.snowflake.connectors.application.ingestion.process.IngestionProcessStatuses クラスの定数として、インジェスチョンプロセスのステータスを定義しました。

  • com.snowflake.connectors.common.response.ConnectorResponse クラスに isNotOk() メソッドを追加しました。

  • com.snowflake.connectors.util.snowflake.DefaultTransactionManager クラスを追加して、 withTransaction() メソッドを使用し、トランザクション内でSQLステートメントを実行できるようにしました。

  • タスクリアクターのログを改善しました。

バグ修正¶

• CREATE_INSTANCE_OBJECTS() プロシージャ中に予期せぬエラーが発生すると、タスクリアクターのインスタンススキーマが削除される不具合を修正しました。