メインコンテンツへジャンプ
APACHE SPARK 宣言型パイプライン

エージェントとデータチームのためのオープンパイプラインフレームワーク

組み込みのデータ品質管理、検証、ガバナンスにより、AI エージェントによる大規模な利用に対応したパイプラインを安全に構築できます。
lakedflow declarative pipelines
TOP TEAMS SUCCEED WITH INTELLIGENT DATA PIPELINES
メリット

AI エージェントによる大規模な利用に対応したパイプラインを安心して構築・実行

オープンスタンダード、自動化された品質チェック、エンタープライズグレードのガバナンスにより、データチームとAIエージェントを強化します。

オープンスタンダード

データパイプラインの普遍的なオープンスタンダード。 Apache Spark™ でバッチとストリーミング、そして SQL と Python を統合し、データチームや AI エージェントが堅牢な本番用コードを生成するためのポータブルな基盤を提供します。

エージェント向けに構築

コーディングエージェントのためのネイティブフレームワーク。 エージェントは、データをどのような状態にしたいかを宣言します。 Apache Spark™ 宣言型パイプライン(SDP)は、パイプラインを実行する前に、依存関係グラフを自動的に解決し、コンパイラのドライランを実行し、品質ルールを適用します。

ガバナンスが適用された実行

安全で自律的なパイプライン実行。 Unity Catalogは厳格なカタログ境界とセキュリティを適用し、SDPは状態管理、エラー回復、増分処理をバックグラウンドで処理します。

機能

エージェントと人間のパイプライン開発を標準化するように構築されています

エージェントに対応した作成機能、データ処理パターンへの自動対応、すべてのチームで共通のフレームワークにより、パイプライン開発を標準化します。

Genie Code または任意のコーディングエージェントを通じて自然言語を使用し、宣言的にパイプラインを作成・検証し、改善を繰り返せます。

Agent-Ready Pipelines

その他の機能

統合ガバナンスとストレージ

Unity Catalog とオープンテーブル形式という、レイクハウスの基盤となる標準に基づいて構築されています。

サーバーレスコンピューティング

データ取り込みの価格性能比を最大 5 倍に改善し、複雑な変換のコストを 98% 削減します。

明示的なパイプラインフロー

手動のバックフィルロジックを必要とせず、標準機能で Auto CDC、複数ソースからのデータ追加、ストリーミング更新などの複雑なデータパターンの処理を簡素化します。

タスクのオーケストレーション

一連の個別の Apache Spark タスクを手動で定義する代わりに、変換を定義するだけで、Spark宣言型パイプラインによって、それらが正しい順序で実行されます。

エラー処理と障害復旧

データパイプラインの実行中に発生するエラーからシームレスに復旧します。

CI/CDとバージョン管理

開発、テスト、本番環境でパイプラインを分離する構成を容易に指定できます。

パイプラインのモニタリングと可観測性

データリネージ、更新履歴、データ品質レポートなど、組み込みのモニタリングおよび可観測性機能。

柔軟な更新スケジュール設定

パイプラインの要件に応じて、レイテンシまたはコストを簡単に最適化できます。

ユースケース

データパイプラインを合理化

declarative etl

ソース、変換、出力先をシンプルに

宣言型プログラミングにより、わずか数行で処理の意図を記述するだけで、Databricks Platform 上の ETL の機能を活用できます。

料金

使用量に応じた価格設定で、支出を抑制

使用した製品の分のみが、秒単位で課金されます。
関連製品

さらに詳しく

Databricks Data + AI Platform で他の統合されたインテリジェントなサービスもご覧ください。

Genie Code

データ作業のための自律型AIパートナー。

Lakeflow Connect

あらゆるソースからの効率的なデータ取り込みコネクタとDatabricks Data + AI Platformとのネイティブ統合により、統合ガバナンスの下で、分析やAIへのアクセスが容易になります。

Lakeflow Jobs

ETL、分析、機械学習パイプラインのマルチタスクワークフローを簡単に定義、管理、監視できます。 サポートされている幅広いタスクタイプ、高度な可観測性機能、そして高い信頼性により、データチームはあらゆるパイプラインの自動化とオーケストレーションを強化し、生産性を向上させることができます。

Lakehouse Storage

レイクハウス内のあらゆるフォーマットや種類のデータを統合し、すべての分析およびAIワークロードに活用します。

Unity Catalog

Databricks Data + AI Platform に組み込まれた、データ・AI のための業界唯一の統合されたオープンなガバナンスソリューションにより、あらゆるデータ資産をシームレスに管理できます。

Document Intelligence

組み込みのガバナンスの下で、エージェント AI 向けにエンタープライズドキュメントの解析、情報抽出、分類を大規模に行います。

Databricks Data + AI Platform

Databricks Data + AI Platform が、お客様のデータと AI のワークロードをどのように支えるかをご覧ください。

次のステップへ

Spark 宣言型パイプラインに関するよくある質問

Spark 宣言型パイプライン(SDP)は、Apache Sparkにおけるバッチおよびストリーミングデータエンジニアリングを簡素化するオープンフレームワークです。 データチームとコーディングエージェントが手続き型コードを記述する代わりに、ターゲットとなるデータ状態を宣言できるようにすることで、SDP は依存関係を自動的に解決し、データ品質のエクスペクテーションを適用し、増分状態管理を行います。

データ+AI 企業になる準備はできていますか?

変革への第一歩を踏み出そう