データロード
ロードの概要
1項目
Amazon S3 からのバッチデータロード
INSERT と FILES()、または Broker Load を使用して、Amazon S3 から PhoenixAI Cloud にデータをバッチロードする方法について説明します。
Azure クラウドストレージからのバッチデータロード
INSERT と FILES()、または Broker Load を使用して、Azure Blob Storage または Azure Data Lake Storage Gen2 から PhoenixAI Cloud にデータをバッチロードする方法について説明します。
ローカルファイルシステムからデータをロードする
curl コマンドで Stream Load を実行し、ローカルファイルシステムから CSV および JSON 形式のデータを StarRocks にロードする方法。
Confluent Cloud からのデータロード
2項目
Amazon MSK からデータをロードする
Routine Load ジョブを使用して、Amazon MSK のトピックから PhoenixAI Cloud に CSV または JSON のメッセージを継続的にロードする方法について説明します。
INSERT を使用したデータのロード
INSERT ステートメント(INSERT VALUES、INSERT INTO SELECT、INSERT OVERWRITE)を使用して StarRocks にデータをロードする方法。
Stream Load トランザクションインターフェースを使用したデータのロード
Flink または Kafka からのデータロード用に Stream Load トランザクションインターフェース(2 フェーズコミット)で複数テーブルトランザクションを実装する方法。
MySQL からのリアルタイム同期
Flink CDC を使用して MySQL の変更データをリアルタイムでキャプチャし、StarRocks Flink コネクタで StarRocks テーブルに同期する方法。
PostgreSQL からのリアルタイム同期
Flink CDC パイプラインを使用して PostgreSQL の変更をキャプチャし、StarRocks の主キーテーブルにリアルタイムで同期する方法。
Apache Flink® からデータを継続的にロードする
StarRocks Flink コネクタは DataStream API・Table API & SQL・Python API に対応し、Flink から StarRocks への継続的なデータロードを実現します。
ロードによるデータ変更
Stream Load、Broker Load、Routine Load を使用して Primary Key テーブルで INSERT、UPDATE、DELETE、部分更新、条件付き更新を実行する方法。
Strict mode
StarRocks データロード時の Strict mode:設定方法、制御内容、列型変換失敗時の行拒否タイミング。