内部ソース
Oracle AI Data Platform Workbenchは、組込みの取込みコネクタを使用して、内部Oracleソースからの取込みをサポートします。これらのコネクタにより、ユーザーはSparkベースのノートブックを使用してデータをシームレスに抽出し、ワークフローおよびデータ・パイプラインに統合できます。
取込みコネクタは、接続設定の複雑さを抽象化し、Oracleネイティブ・サービスからのバッチとほぼリアルタイムの取込みの両方に対して最適化されたアクセス・パターンを提供します。
AI Data Platform Workbenchは、ノートブックでSparkを使用して複数の内部ソースからのデータの取込みをサポートするために、Oracle AI Data Platform WorkbenchサンプルGitリポジトリにサンプル・コード・テンプレートを提供します。
表14-1内部ソース
| ソース: | アクセス・タイプ | 統合方法 | 説明 | 外部カタログのサポート | 利用できるサンプル コード |
|---|---|---|---|---|---|
| フュージョン | 抽出のみ | 事前構成されたSparkテンプレート | BICCを介してFusion SaaSアプリケーションからAIデータ・プラットフォーム・ワークベンチの表またはボリュームにデータを抽出します。 | × | ○ |
| RESTエンドポイント | 読取り専用 | Sparkノートブックを介したJDBC | JSONなどの半構造化データを取り込むためのAPIから読み取ります。 | × | ○ |
| MySQL HeatWave | 読取り専用 | Sparkノートブックを介したJDBC | JDBCを使用して、AI Data Platform WorkbenchとMySQL HeatWaveの間でデータを移動します。 | × | ○ |
| Oracle Autonomous AI Lakehouse | 読み取り/書き込み+ゼロコピー | JDBCまたは外部カタログ | Oracle Autonomous AI Lakehouseから取り込むか、または外部カタログとして登録して、重複することなくデータを直接クエリします。 | ○ | ○ |
| Oracle Autonomous AI Transaction Processing | 読み取り/書き込み+ゼロコピー | JDBCまたは外部カタログ | 重複せずにデータを直接問い合せるための外部カタログからの取込みまたは外部カタログとしての登録。 | ○ | ○ |
| Oracle Database | 読取り/書込み | JDBCまたは外部カタログ | オンプレミスまたはOCIデータベースからのデータ取込みをサポートします。 | ○ | ○ |
| Exadata | 読取り/書込み | JDBCまたは外部カタログ | JDBCを使用して高パフォーマンスの読取りおよび書込みを行うためにExadataシステムにアクセスします。 | × | ○ |
表14-2 Spark SQLから、Oracle Autonomous AI Database、Exadataデータ型へのマッピング
| Spark SQLタイプ | Oracle AI Database、Oracle Autonomous AI Database、Exadataデータ型 |
|---|---|
| バイトタイプ | NUMBER(38,10) |
| ショートタイプ | NUMBER(38,10) |
| IntegerType (INT) | NUMBER(38,10) |
| ロングタイプ | NUMBER(38,10) |
| フロート・タイプ | FLOAT(126) |
| ダブルタイプ | NUMBER(38,10) |
| DecimalType(p,s) | NUMBER(p,s) |
| 文字列型 | VARCHAR2(4000文字) |
| バイナリ・タイプ | BLOB |
| ブール・タイプ | VARCHAR2(4000文字) |
| 日付タイプ | DATE |
| TimestampType | タイムスタンプ(6) |
| 配列タイプ | VARCHAR2(4000文字) |
| マップ・タイプ | サポート対象外 |
| 構造タイプ | VARCHAR2(4000文字) |
| カレンダ間隔タイプ | 文字列/VARCHAR2に変換された場合にサポートされます。 |