v1.3-SNAPSHOT
ホーム
概念
プログラミング モデル
分散ランタイム
クイックススタート
例
概要
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の監視
チェックポイントと大規模状態のデバッグとチューニング
デバッグ ウィンドウ & イベントタイム
クラスローディングのデバッグ
内部
コンポーネントのスタック
データストリーミングのための耐障害性
ジョブとスケジューリング
ファイルシステム
プロジェクトのページ
Go
ドキュメントバージョンの選択
v1.2
v1.1
v1.0
ページ 'Event Time' は移動しました
Event Time
は移動しました。1秒以内に
//flink/flink-docs-release-1.3/dev/event_time.html
に移動します
TOP