Java 範例

下面的實例演示如何創建用 Java 編寫的應用程序。

注意

大多數範例都設計為在本機、您的開發機器和您選擇的 IDE 上執行，以及在 Apache Flink 的 Amazon 受管服務上執行。它們會示範您可以用來傳遞應用程式參數的機制，以及如何正確設定相依性，以便在兩個環境中執行應用程式，而不需要變更。

開始使用 DataStream API

此範例顯示一個簡單的應用程式，使用 API 從 Kinesis 資料串流讀取並寫入另一個 Kinesis 資料串流。DataStream此範例示範如何使用正確的相依性設定檔案、建立 Uber-JAR，然後剖析組態參數，以便您可以在本機、IDE 中以及在 Apache Flink 的 Amazon 受管服務上執行應用程式。

代碼示例：GettingStarted

開始使用資料表 API 和 SQL

此範例顯示使用 Table API 和 SQL 的簡單應用程式。它演示瞭如何將 API 與 DataStream Table API 或 SQL 集成在同一個 Java 應用程序中。它還示範如何使用DataGen連接器從 Flink 應用程式本身產生隨機測試資料，而不需要外部資料產生器。

完整的例子：GettingStartedTable

使用 S3 DataStream 接收器

此範例示範如何使用 DataStream API FileSink 將 JSON 檔案寫入 S3 儲存貯體。

範例程式碼：

使用 Kinesis 來源、標準或 EFO 消費者，以及接收器 (DataStream API)

本範例示範如何設定 Kinesis 資料串流的來源消耗 (使用標準取用者或 EFO)，以及如何設定 Kinesis 資料串流的接收器。

代碼示例：KinesisConnectors

使用 Amazon 數據 Firehose 收器（DataStream API）

此範例顯示如何將資料傳送至 Amazon 資料 Firehose (以前稱為 Kinesis Data Firehose)。

代碼示例：KinesisFirehoseSink

使用滑動和翻滾窗口（DataStream API）

這兩個範例說明如何在處理時間視窗中實作彙總 (滑動或翻滾)，以及如何在 API 上執行彙總。DataStream

代碼示例：

• WindowingSliding

• WindowingTumbling

使用自訂指標

這兩個獨立的範例，RecordCount並WordCount示範如何在 DataStream API 中實作自訂指標，並將其傳送至 CloudWatch 指標。

代碼示例：CustomMetrics