1.1.1.9 リリース19.1.0.0.2 - 2020年2月

この項では、OSA 19.1.0.0.2バンドル・パッチ・リリースに追加された新機能を示します。

1.1.1.9.1 Oracle Goldengateとの統合

Oracle Goldengate機能との統合により、Goldengateマイクロサービス・インスタンスに接続し、抽出プロセスから変更データ・ストリーム(GG変更データ)を生成できます。GG変更データを構成すると、新しいKafkaトピックが作成され、それを使用してストリームを作成できます。

1.1.1.9.2 Coherenceターゲット

OSAでは、Coherenceサーバーにデータを出力するためにCoherenceターゲットがサポートされるようになりました。出力OSAイベント(タプル)は、キャッシュ名およびユーザーが提供するCoherenceサーバーの詳細を使用して外部Coherenceクラスタにプッシュされます。

1.1.1.9.3 DBターゲット/参照およびメタデータのウォレット・サポート

Oracle Stream Analyticsユーザー・インタフェースを使用すると、ユーザーはATP/ADWデータベース接続を作成およびテストできます。

ユーザーは、このデータベース接続を使用してデータベース参照またはデータベース・ターゲットを作成できます。

1.1.1.9.4 参照用のMySQL DBのサポート

この機能により、ユーザーはOSAでMySQLデータベース表を参照として作成できます。MySQLデータベースへのJDBCベースの接続がサポートされます。

1.1.1.9.5 OCIストリーミング・サービスおよびSecure Kafkaとの統合

Oracle Stream Analyticsでは、OSSのKafka互換機能を使用したOCIストリーミング・サービスからの収集がサポートされるようになりました。

1.1.1.9.6 Oracleアドバンスト・キュー・ソース

OSAは、Oracleアドバンスト・キューからメッセージを読み取ることができます。このオプションは、一般的なJMSコネクタとして使用できます。ユーザーは、アドバンスト・キュー接続を作成し、それを使用してJMSタイプ・ストリームを作成できます。

1.1.1.9.7 安全なRESTターゲットのサポート

OSAは、SSLが有効化され、Basic認証を必要とするRESTターゲット・タイプをサポートするようになりました。

エンド・ポイントで認証が必要な場合にSSLが有効になることに加えて、カスタム・ヘッダー・フィールドとして渡すことができます。現在、OSAはBasic認証のみサポートしています。カスタム・ヘッダーの例 - Authorization Basic admin:admin

1.1.1.9.8 Kerberos認証

Hadoopでは、YarnベースのSparkクラスタで実行されているOSA用のKerberos認証がサポートされるようになりました。Kerberos認証を使用する場合、ユーザーは、KerberosサーバーからKerberosチケットを取得することで認証されます。

1.1.1.9.9 SSLおよび認証が有効なRESTエンドポイント

SSLが有効でBasic認証が必要な"REST"タイプのターゲットの作成: RESTエンドポイントでSSLのみが有効な場合、次のいずれかの方法で接続できます:

  • トラストストア・ファイルをアップロードし、トラストストア・パスワードを入力します。トラストストア・パスワードはオプションです。
  • トラストストア・ファイルとパスワードがない場合、トラスト・パスワードをクリックしてRESTエンドポイントに接続できます

    ノート:

    トラスト・パスワード・オプションを使用すると、信頼されていない証明書を使用して接続するため、セキュアでない接続になります。

エンド・ポイントで認証が必要な場合にSSLが有効になることに加えて、カスタム・ヘッダー・フィールドとして渡すことができます。現在、OSAはBasic認証のみサポートしています。カスタム・ヘッダーは、たとえば"Authorization Basic admin:admin"のようになります。

1.1.1.9.10 新しいデータ・パターン

OSAは4つの新しいデータ・パターンをサポートしています:

  • 現在および以前のパターン - 現在および以前のイベントを自動的に関連付けます
  • 遅延パターン - パイプラインのダウンストリーム・ノードへのイベント配信を指定した秒数だけ遅延させます
  • 行ウィンドウのスナップショット - 新規イベントの到着時に、ウィンドウの内容全体をダウンストリーム・ノードにダンプします。ウィンドウ容量は、イベントの最大数を指定することによって制限されます。
  • 時間ウィンドウのスナップショット - 新規イベントの到着時に、ウィンドウの内容全体をダウンストリーム・ノードにダンプします。ウィンドウ内のイベントは、指定された時間範囲後に失効します。

1.1.1.9.11 OSAでのバックプレッシャ

バックプレッシャは、Sparkがストリーミング・アプリケーションの安定性を確保する方法で、ストリーミング・アプリケーションが処理可能なかぎり高速にデータを受信することを意味します。

バックプレッシャ機能が有効になっている場合、現在のバッチ処理に基づいて、ダウンストリーム・コンポーネントからSpark内のアップストリーム・コンポーネントにシグナルが渡され、遅延統計がスケジューリングされます。

HAが有効かどうかに関係なく、現在はすべての公開済アプリケーションでバックプレッシャが既定で有効になっています。また、この設定は、Yarnとスタンドアロン・クラスタ・マネージャの両方で有効になります。

1.1.1.9.12 INフィルタでのDB列の参照のサポート

INフィルタを使用して、データベース表内の列を参照できます。実行時にデータベース列の値を変更すると、パイプラインを再公開することなく、パイプラインがDB列から最新の値を取得します。