適用於阿帕奇 Flink 管理服務的 Java 範例

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

注意

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

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

代碼示例：GettingStarted

此範例顯示使用和的簡單應用TableAPI程式SQL。它示範如何DataStreamAPI與TableAPI或SQL在相同的 Java 應用程式中整合。它還示範如何使用DataGen連接器從 Flink 應用程式本身產生隨機測試資料，而不需要外部資料產生器。

完整的例子：GettingStartedTable

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

範例程式碼：

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

代碼示例：KinesisConnectors

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

代碼示例：KinesisFirehoseSink

此範例將示範中的四種視窗聚合類型。DataStream API