From 5a97dcd245dcf62a8001a9b9c5d351557c9b64fa Mon Sep 17 00:00:00 2001 From: zentol Date: Tue, 20 Jun 2017 15:42:13 +0200 Subject: [PATCH] [FLINK-6956] Make table example POJO classes public --- .../org/apache/flink/table/examples/java/WordCountSQL.java | 5 ++++- .../org/apache/flink/table/examples/java/WordCountTable.java | 5 ++++- 2 files changed, 8 insertions(+), 2 deletions(-) diff --git a/flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/WordCountSQL.java b/flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/WordCountSQL.java index c4a36f07e770b..c5c22fd2903ef 100644 --- a/flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/WordCountSQL.java +++ b/flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/WordCountSQL.java @@ -65,7 +65,10 @@ public static void main(String[] args) throws Exception { // USER DATA TYPES // ************************************************************************* - private static class WC { + /** + * Simple POJO containing a word and it's respective count. + */ + public static class WC { public String word; public long frequency; diff --git a/flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/WordCountTable.java b/flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/WordCountTable.java index 8606cd82788f2..3401a68b25b5f 100644 --- a/flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/WordCountTable.java +++ b/flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/WordCountTable.java @@ -62,7 +62,10 @@ public static void main(String[] args) throws Exception { // USER DATA TYPES // ************************************************************************* - private static class WC { + /** + * Simple POJO containing a word and it's respective count. + */ + public static class WC { public String word; public long frequency;