How to Use Real Time Computing Flink Version Correctly

1. リアルタイムコンピューティング Flink 版とは

リアルタイムコンピューティング Flink 版 (Alibaba Cloud Realtime Compute for Apache Flink, Powered by Ververica) は、Alibaba Cloud が Apache Flink をベースに構築したエンタープライズグレードの高性能リアルタイムビッグデータ処理システムです。Apache Flink の創業チームによって公式に開発され、グローバル統一の商用ブランド「Powered by Ververica」を持ち、オープンソース Flink API と完全に互換性があり、豊富なエンタープライズ向けの付加価値機能を提供します。

Realtime Compute for Apache Flink は、Apache Flink のコア機能を基盤として、エンタープライズユーザーが重視するクラスターの安定性、パフォーマンス最適化、セキュリティコントロール、システムモニタリング、およびジョブ管理をさらに強化しています。

同時に、PB レベルのデータセットでサブ秒レベルの処理遅延をサポートし、ユーザーに標準的なリアルタイムデータ処理プロセスと業界ソリューションを提供します。Datastream API によるジョブ開発をサポートしつつ、完全な SQL セマンティクスを提供することで、BI シナリオでの開発を容易にします。豊富なアップストリームおよびダウンストリームコネクターにより、ユーザーが既に利用しているビッグデータコンポーネントとのシームレスな接続を確保し、インテリジェントなジョブチューニングと診断機能によってユーザーの開発と運用をさらに簡素化します。

Alibaba Cloud の「リアルタイムコンピューティングチーム」は現在、世界最大の Flink チームであり、最多のコミッター数と最高の専門性を有し、リアルタイムコンピューティングユーザーにエンタープライズグレードの管理およびコンサルティングサービスを提供しています。2019 年 6 月、データセンターアライアンスが実施したビッグデータプロダクト能力評価の結果が正式に発表されました。Alibaba Cloud の Realtime Compute for Apache Flink は、新たに策定された分散ストリーム処理プラットフォームの基礎能力評価に合格し、国内のストリームコンピューティングプロダクト能力として評価に合格した最初の製品群となり、データセンターアライアンスによって国内ビッグデータフローコンピューティング基礎プラットフォームの第一梯队に位置付けられました。2019 年には、国際的に著名なコンサルティングおよびリサーチ企業である Forrester の評価において、Realtime Compute for Apache Flink は中国で唯一 Forrester クアドラントに参入したリアルタイムストリームコンピューティングプロダクトとなりました。

2. リアルタイムコンピューティング Flink 版と Apache Flink の比較

3. リアルタイムコンピューティング Flink 版の製品アーキテクチャ

4. リアルタイムコンピューティング Flink 版を使う理由

プロダクトの優位性：

・優れたパフォーマンス：シングルコア CPU で 1 秒あたり数十万レコードを処理でき、ポート間のデータ処理遅延はサブ秒レベルで、数万の同時接続に対応する超大型リアルタイムタスク計算をサポートします。

・強力な機能：ワンストップの SQL 開発・メンテナンスプラットフォーム、インテリジェントな診断と自動設定・最適化、および Alibaba Cloud の主流データプロダクトとのシームレスな接続を提供します。

・高品質・低価格：シングルコア CPU のコンピューティング料金は 1 時間あたりわずか 0.25 人民元で、ロードに応じてエラスティックスケーリングと従量課金が可能です。TCO は IDC 自建と比べて大幅に低くなります。

・安定性と信頼性：99.9% の SLA 安定性保証、全リンク指標のモニタリングとアラートを備え、Alibaba のダブルイレブンの長年にわたる検証を経ています。

・オープンソースとの互換性：Apache Flink と 100% 互換性があり、オープンソース Flink からクラウドへのスムーズな移行をサポートし、主流のオープンソースビッグデータエコシステムとシームレスに接続します。

・ブランド認証：Flink の創業チームによる公式開発、中国情報通信研究院による権威ある認証、および中国で唯一 Forrester クアドラントに参入したリアルタイムストリームコンピューティングプロダクトです。

5. リアルタイムコンピューティング Flink 版の適用シナリオ

Realtime Compute for Apache Flink - プロダクトソリューション

1. インターネット通販業界ソリューション

国内インターネット通販業界の急速な発展に伴い、従来の「大規模」「広範囲なネット展開」による運営手法は、もはやビジネスのニーズを満たせなくなっています。リアルタイムコンピューティングを通じてユーザーの特徴を迅速に掘り起こし、ニーズと嗜好を分析することで、企業のデジタル化、精緻化、パーソナライズ化された運営への転換を支援します。

リアルタイムユーザープロファイル：さまざまなタイプの顧客に対してリアルタイムかつ効率的なパーソナライズされたレコメンデーションを行い、注文のコンバージョン率を向上させます。

リアルタイムアソシエーションレコメンデーション：顧客の購入情報に基づくリアルタイムアソシエーション分析を構築し、再購入の確率を高めます。

2. オンライン教育業界ソリューション

今後、K12 オンライン教育市場は引き続き拡大し、ビッグデータと教育の組み合わせはさらに密接になります。Alibaba Cloud の Realtime Compute for Apache Flink を使用することで、更新レポート、授業再開、ライブ授業のビデオ品質モニタリングなどの主要なオンライン教育シナリオにおけるリアルタイムかつ正確なコンピューティングの問題を効果的に解決できます。同時に、プロダクトの自動エラスティックスケーリング機能を活用してトラフィックのピークに効果的に対応し、複雑に変化するシナリオのニーズをより良く満たすことができます。

効率的なデータ処理：ログ、データベース、ビジネスクラスターデータなど、さまざまなソースからのデータのリアルタイム分析・処理のニーズに対応します。

マルチロール権限設定：教育業界の異なるロールに対して、それぞれに必要なリアルタイムレポート閲覧権限を設定し、業務効率を向上させます。

ビジネスシナリオのサポート：オンライン教育のビジネスロジックに基づき、リアルタイム BI シナリオにおいて完全な SQL サポートでビジネスを支援します。

3. ゲーム業界ソリューション

新興エンターテインメント業界として、ゲームはその集金力と楽しさから、多くの企業や人材を投資に引き付けています。アプリストアやソーシャルネットワークの台頭により、ゲーム市場は未曾有の拡大を見せ、ビッグデータと人工知能がゲーム運営、特にゲームの寿命延長に与える好影響はますます顕著になっています。

フォーラムデータ追跡：プレイヤーフォーラムのコミュニケーションと管理に基づき、現在のプレイヤーの核心的な関心事やゲームバグの検知を行い、ゲームの公平性を確保します。

運用データコントロール：リアルタイムコンピューティング技術を通じてゲーム運用活動のリアルタイム分析を行い、最も効果的なユーザーコンバージョンチャネルを特定し、運用プロモーションの効果を向上させます。

行動データ分析：プレイヤーのリアルタイム行動データ分析に基づき、プレイヤーのユーザープロファイルを構築し、異なるゲーム福利厚生モードをカスタマイズして、プレイヤーのリテンションとコンバージョン率を向上させます。

4. 金融業界ソリューション

近年、インターネット金融業界の急速な発展に伴い、従来の金融機関 (取引所、証券会社、銀行など) のさまざまなビジネスは、インターネットとますます密接に融合しています。銀行業務の需要チェーン、リスク管理、与信評価、不正リスク、データ品質などのニーズに対して、包括的なソリューションを提供します。金融機関を例にとると、Realtime Compute for Apache Flink を通じてリアルタイムデータウェアハウスと不正防止システムを構築することで、金融機関のリアルタイムリスク管理システムの迅速な構築を支援します。

不正検知：ユーザーアカウントとトランザクション行動をリアルタイムでモニタリングおよび区別し、トランザクション情報を迅速に識別してユーザーの損失を削減します。

リスク管理のニーズ：Realtime Compute for Apache Flink を通じて従来のリスク管理システムを最適化し、インテリジェントなリスク管理に変革して、全体的な識別効率を向上させ、複数のシナリオに適用します。

与信評価：虚偽情報や情報偽造などの悪意ある不正行為を迅速に識別し、高リスクグループを特定して、インテリジェントな手法で審査プロセスを短縮します。