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