[FLINK-6956] Make table example POJO classes public

This closes apache#4148.
Pance · Jun 24, 2017 · 1f6be83 · 1f6be83
1 parent 9f77073
commit 1f6be83
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git a/...flink-examples-table/src/main/java/org/apache/flink/table/examples/java/WordCountSQL.java b/...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 its respective count.
+ */
+ public static class WC {
  public String word;
  public long frequency;
 

diff --git a/...ink-examples-table/src/main/java/org/apache/flink/table/examples/java/WordCountTable.java b/...ink-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 its respective count.
+ */
+ public static class WC {
  public String word;
  public long frequency;