flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ches...@apache.org
Subject [18/21] flink git commit: [FLINK-6956] Make table example POJO classes public
Date Sun, 25 Jun 2017 06:45:01 GMT
[FLINK-6956] Make table example POJO classes public

This closes #4148.


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1f6be837
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1f6be837
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/1f6be837

Branch: refs/heads/master
Commit: 1f6be8372706c1531844857291bc166bf091176b
Parents: 9f77073
Author: zentol <chesnay@apache.org>
Authored: Tue Jun 20 15:42:13 2017 +0200
Committer: zentol <chesnay@apache.org>
Committed: Sat Jun 24 22:09:05 2017 +0200

----------------------------------------------------------------------
 .../java/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(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/1f6be837/flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/WordCountSQL.java
----------------------------------------------------------------------
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 c4a36f0..65efc17 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 class WordCountSQL {
 	//     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;
 

http://git-wip-us.apache.org/repos/asf/flink/blob/1f6be837/flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/WordCountTable.java
----------------------------------------------------------------------
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 8606cd8..5fb1beb 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 class WordCountTable {
 	//     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;
 


Mime
View raw message