• ホーム

---

• 概念
  • プログラミング モデル
  • 分散ランタイム
• クイックススタート
• 例
  • 概要
  • Wikipediaの編集の監視
  • バッチの例

  ---

• プロジェクトのセットアップ
  • Javaでのサンプルプロジェクト
  • Scalaでのサンプルプロジェクト
  • Flinkとのリンク
  • IDE セットアップ
  • Scala REPL
  • オプションのモジュールとのリンク
  • Windows上でのFlinkの実行
  • ソースからのFlinkのビルド
• アプリケーションの配備
  • 基本的なAPIの概念
    • 概要
    • Scala API 拡張
    • Java 8
  • ストリーミング (DataStream API)
    • 概要
    • ウィンドウ
    • イベントタイム
      • 概要
      • タイムスタンプ/watermarkの生成
      • 事前定義された、タイムスタンプのエクストラクタ/ウォーターマークのエミッタ
    • コネクタ
      • 概要
      • 耐障害性の保証
      • Kafka
      • Cassandra
      • Kinesis
      • Elasticsearch
      • Rolling File Sink
      • RabbitMQ
      • NiFi
      • Twitter
    • Process Function
    • 状態との連動
    • チェックポイント
    • 非同期 I/O
    • クエリ可能な状態
  • バッチ (DataSet API)
    • 概要
    • 変換
    • イテレーション
    • 要素のジッピング
    • 耐障害性
    • Python API
    • コネクタ
    • Hadoop 互換性
    • ローカルでの実行
    • クラスタでの実行
  • データ型 & シリアライズ化
    • 概要
    • カスタム シリアライザ
  • 実行の管理
    • 実行設定
    • プログラムのパッケージ化
    • 並行実行
    • 実行プラン
    • ストラテジの再実行
  • ライブラリ
    • テーブルとSQL
    • イベント処理 (CEP)
    • Storm 互換
    • グラフ: Gelly
      • 概要
      • Graph API
      • 逐次グラフ処理
      • ライブラリのメソッド
      • グラフ アルゴリズム
      • グラフ ジェネレータ
      • 二分グラフ
    • 機械学習
      • 概要
      • クイックススタート
      • 複合線形回帰
      • クロス検証
      • 距離
      • k-近傍join
      • MinMax スケーラー
      • どうやって貢献するか
      • パイプライン
      • 多項式特徴
      • ALS
      • 統計的外れ値検出
      • 標準スケーラー
      • CoCoAを使ったSVM
  • 最善の実践
  • API 移行ガイド
• 配備と操作
  • 設定
  • CLI
  • クラスタ & 配備
    • スタンドアローン クラスタ
    • YARN
    • Mesos
    • Docker
    • AWS
    • Google Compute Engine
  • 高可用性 (HA)
  • チェックポイント
  • セーブポイント
  • SSL セットアップ
  • Kerberos
  • バックエンドの状態
  • アプリケーションとFlinkバージョンのアップグレード
  • プロダクションの準備ができたチェックポイント
• デバッグ & 監視
  • マトリックス
  • ログ
  • チェックポイントの監視
  • バックプレッシャーの監視
  • REST APIの監視
  • チェックポイントと大規模状態のデバッグとチューニング
  • デバッグ ウィンドウ & イベントタイム
  • クラスローディングのデバッグ

  ---

• 内部
  • コンポーネントのスタック
  • データストリーミングのための耐障害性
  • ジョブとスケジューリング
  • ファイルシステム
• プロジェクトのページ