リアルタイムコンピューティングの開発コンソールで Paimon テーブルを効率的かつ柔軟に管理するには、small ファイルのマージやデータのソートなどのタスクに必要なツールキットを構成する必要があります。このトピックでは、Paimon テーブルデータをより簡単に管理できるように、この構成プロセスについて説明します。
制限
Paimon テーブルは、リアルタイムコンピューティングエンジン Ververica Runtime (VVR) 8.0.5 以降でのみサポートされます。
手順
リンクをクリックして、Paimon データ管理環境に必要な JAR パッケージをダウンロードします。
paimon-flink-action:
paimon-ali-vvr: VVR バージョンに対応するパッケージをダウンロードします:
VVR 11.2 以降 (JDK 11) の場合: paimon-ali-vvr-11-vvp-1-ali-16.0-1.jar
VVR 11.2 以降 (JDK 8) の場合: paimon-ali-vvr-11-vvp-jdk8-1-ali-16.0-1.jar
VVR 11.1 の場合: paimon-ali-vvr-11.1-1-ali-16.0-1.jar
VVR 8.0.11 の場合: paimon-ali-vvr-8.0-vvp-1-ali-16.0-1.jar
リアルタイムコンピューティングの開発コンソールで、[ファイル管理] ページに移動し、[リソースのアップロード] をクリックして、ステップ 1 でダウンロードした 2 つの JAR パッケージをアップロードします。
ページで、 をクリックし、設定項目を入力します。
次の表に設定項目を示します。
設定項目
説明
例
デプロイモード
ストリームモードまたはバッチモード。特定の機能に基づいていずれかを選択します。
バッチモード
デプロイメント名
JAR ジョブの名前を入力します。
test
エンジンバージョン
リアルタイムコンピューティングエンジン VVR 8.0.5 以降のバージョンを選択します。
vvr-8.0.5-flink-1.17
JAR URI
paimon-flink-action JAR パッケージをアップロードします。
ステップ 2 でアップロードした paimon-flink-action パッケージを選択します。
エントリポイントクラス
プログラムのエントリポイントクラス。
空白のままにします。
エントリポイントのメイン引数
main メソッドで呼び出される入力パラメーター。
特定の機能に基づいてパラメーターを入力します。詳細については、関連する機能のドキュメントをご参照ください。たとえば、データソートを実装するには、「消費ジョブの最適化」をご参照ください。
追加の依存ファイル
アタッチする依存ファイルのパスまたはファイル名を指定します。
ステップ 2 でアップロードした paimon-ali-vvr パッケージを選択します。
[デプロイ] をクリックします。
ページで、[開始] をクリックします。起動ステップの詳細については、「ジョブの開始」をご参照ください。
関連ドキュメント
ジョブの開始後に Flink ジョブの実行パラメーターを構成するには、「ジョブデプロイ情報の構成」をご参照ください。
一部のジョブ実行パラメーターは動的更新をサポートしており、ジョブの開始と停止によるビジネスのダウンタイムを削減できます。詳細については、「動的なスケーリングとパラメーターの更新」をご参照ください。
さまざまなシナリオにおける Paimon プライマリキーテーブルと Append Scalable テーブルの一般的な最適化については、「Paimon パフォーマンスの最適化」をご参照ください。