You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by uc...@apache.org on 2016/04/25 11:07:21 UTC
flink git commit: [FLINK-3560] [examples] Remove unchecked output of
usage statement in examples
Repository: flink
Updated Branches:
refs/heads/master f2f5bd5be -> 44c2d2f0a
[FLINK-3560] [examples] Remove unchecked output of usage statement in examples
This closes #1752.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/44c2d2f0
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/44c2d2f0
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/44c2d2f0
Branch: refs/heads/master
Commit: 44c2d2f0a51f3d2c3b0ff85f02a5d2a248d4ee2e
Parents: f2f5bd5
Author: Till Rohrmann <tr...@apache.org>
Authored: Tue Mar 1 17:21:57 2016 +0100
Committer: Ufuk Celebi <uc...@apache.org>
Committed: Mon Apr 25 11:07:00 2016 +0200
----------------------------------------------------------------------
.../apache/flink/examples/java/clustering/KMeans.java | 1 -
.../org/apache/flink/examples/java/distcp/DistCp.java | 4 ++--
.../flink/examples/java/graph/ConnectedComponents.java | 11 +----------
.../apache/flink/examples/java/graph/EnumTriangles.java | 3 +--
.../org/apache/flink/examples/java/graph/PageRank.java | 11 +++++------
.../examples/java/graph/TransitiveClosureNaive.java | 10 +---------
.../apache/flink/examples/java/ml/LinearRegression.java | 1 -
.../java/relational/EmptyFieldsCountAccumulator.java | 1 -
.../flink/examples/java/relational/TPCHQuery10.java | 1 -
.../flink/examples/java/relational/TPCHQuery3.java | 2 +-
.../flink/examples/java/relational/WebLogAnalysis.java | 3 +--
.../apache/flink/examples/java/wordcount/WordCount.java | 3 +--
.../apache/flink/examples/scala/clustering/KMeans.scala | 2 --
.../flink/examples/scala/graph/ConnectedComponents.scala | 3 ---
.../flink/examples/scala/graph/EnumTriangles.scala | 2 --
.../flink/examples/scala/graph/PageRankBasic.scala | 3 ---
.../examples/scala/graph/TransitiveClosureNaive.scala | 4 +---
.../flink/examples/scala/ml/LinearRegression.scala | 2 --
.../flink/examples/scala/relational/TPCHQuery10.scala | 1 -
.../flink/examples/scala/relational/TPCHQuery3.scala | 1 -
.../flink/examples/scala/relational/WebLogAnalysis.scala | 1 -
.../flink/examples/scala/wordcount/WordCount.scala | 2 --
.../streaming/examples/iteration/IterateExample.java | 1 -
.../flink/streaming/examples/kafka/WriteIntoKafka.java | 1 +
.../examples/ml/IncrementalLearningSkeleton.java | 1 -
.../streaming/examples/windowing/SessionWindowing.java | 1 -
.../streaming/examples/windowing/TopSpeedWindowing.java | 1 -
.../streaming/examples/windowing/WindowWordCount.java | 2 --
.../flink/streaming/examples/wordcount/PojoExample.java | 1 -
.../flink/streaming/examples/wordcount/WordCount.java | 1 -
.../scala/examples/windowing/TopSpeedWindowing.scala | 2 --
.../src/main/java/SocketTextStreamWordCount.java | 1 -
.../src/main/scala/SocketTextStreamWordCount.scala | 1 -
33 files changed, 15 insertions(+), 70 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/44c2d2f0/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/clustering/KMeans.java
----------------------------------------------------------------------
diff --git a/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/clustering/KMeans.java b/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/clustering/KMeans.java
index b2e9462..8e51df8 100644
--- a/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/clustering/KMeans.java
+++ b/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/clustering/KMeans.java
@@ -82,7 +82,6 @@ public class KMeans {
// Checking input parameters
final ParameterTool params = ParameterTool.fromArgs(args);
- System.out.println("Usage: KMeans --points <path> --centroids <path> --output <path> --iterations <n>");
// set up execution environment
ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
http://git-wip-us.apache.org/repos/asf/flink/blob/44c2d2f0/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/distcp/DistCp.java
----------------------------------------------------------------------
diff --git a/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/distcp/DistCp.java b/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/distcp/DistCp.java
index 1d07c2d..82f1c52 100644
--- a/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/distcp/DistCp.java
+++ b/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/distcp/DistCp.java
@@ -102,7 +102,8 @@ public class DistCp {
FlatMapOperator<FileCopyTask, Object> res = inputTasks.flatMap(new RichFlatMapFunction<FileCopyTask, Object>() {
-
+
+ private static final long serialVersionUID = 1109254230243989929L;
private LongCounter fileCounter;
private LongCounter bytesCounter;
@@ -185,5 +186,4 @@ public class DistCp {
}
}
}
-
}
http://git-wip-us.apache.org/repos/asf/flink/blob/44c2d2f0/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/graph/ConnectedComponents.java
----------------------------------------------------------------------
diff --git a/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/graph/ConnectedComponents.java b/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/graph/ConnectedComponents.java
index a86cdfd..3bd6522 100644
--- a/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/graph/ConnectedComponents.java
+++ b/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/graph/ConnectedComponents.java
@@ -19,7 +19,6 @@
package org.apache.flink.examples.java.graph;
-import org.apache.flink.api.common.ProgramDescription;
import org.apache.flink.api.common.functions.FlatJoinFunction;
import org.apache.flink.api.common.functions.FlatMapFunction;
import org.apache.flink.api.common.functions.JoinFunction;
@@ -74,7 +73,7 @@ import org.apache.flink.api.java.ExecutionEnvironment;
* </ul>
*/
@SuppressWarnings("serial")
-public class ConnectedComponents implements ProgramDescription {
+public class ConnectedComponents {
// *************************************************************************
// PROGRAM
@@ -84,7 +83,6 @@ public class ConnectedComponents implements ProgramDescription {
// Checking input parameters
final ParameterTool params = ParameterTool.fromArgs(args);
- System.out.println("Usage: ConnectedComponents --vertices <path> --edges <path> --output <path> --iterations <n>");
// set up execution environment
ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
@@ -185,13 +183,6 @@ public class ConnectedComponents implements ProgramDescription {
}
}
-
-
- @Override
- public String getDescription() {
- return "Parameters: --vertices <path> --edges <path> --output <path> --iterations <n>";
- }
-
// *************************************************************************
// UTIL METHODS
// *************************************************************************
http://git-wip-us.apache.org/repos/asf/flink/blob/44c2d2f0/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/graph/EnumTriangles.java
----------------------------------------------------------------------
diff --git a/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/graph/EnumTriangles.java b/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/graph/EnumTriangles.java
index 33570fc..5fbb321 100644
--- a/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/graph/EnumTriangles.java
+++ b/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/graph/EnumTriangles.java
@@ -82,7 +82,6 @@ public class EnumTriangles {
// Checking input parameters
final ParameterTool params = ParameterTool.fromArgs(args);
- System.out.println("Usage: EnumTriangleBasic --edges <path> --output <path>");
// set up execution environment
final ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
@@ -124,7 +123,7 @@ public class EnumTriangles {
triangles.print();
}
}
-
+
// *************************************************************************
// USER FUNCTIONS
// *************************************************************************
http://git-wip-us.apache.org/repos/asf/flink/blob/44c2d2f0/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/graph/PageRank.java
----------------------------------------------------------------------
diff --git a/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/graph/PageRank.java b/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/graph/PageRank.java
index c613a7e..33305af 100644
--- a/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/graph/PageRank.java
+++ b/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/graph/PageRank.java
@@ -83,7 +83,6 @@ public class PageRank {
public static void main(String[] args) throws Exception {
ParameterTool params = ParameterTool.fromArgs(args);
- System.out.println("Usage: PageRankBasic --pages <path> --links <path> --output <path> --numPages <n> --iterations <n>");
final int numPages = params.getInt("numPages", PageRankData.getNumberOfPages());
final int maxIterations = params.getInt("iterations", 10);
@@ -135,7 +134,7 @@ public class PageRank {
}
-
+
// *************************************************************************
// USER FUNCTIONS
// *************************************************************************
@@ -147,7 +146,7 @@ public class PageRank {
Tuple2<Long, Double> outPageWithRank;
public RankAssigner(double rank) {
- this.outPageWithRank = new Tuple2<Long, Double>(-1l, rank);
+ this.outPageWithRank = new Tuple2<Long, Double>(-1L, rank);
}
@Override
@@ -189,9 +188,9 @@ public class PageRank {
Long[] neighbors = value.f1.f1;
double rank = value.f0.f1;
double rankToDistribute = rank / ((double) neighbors.length);
-
- for (int i = 0; i < neighbors.length; i++) {
- out.collect(new Tuple2<Long, Double>(neighbors[i], rankToDistribute));
+
+ for (Long neighbor: neighbors) {
+ out.collect(new Tuple2<Long, Double>(neighbor, rankToDistribute));
}
}
}
http://git-wip-us.apache.org/repos/asf/flink/blob/44c2d2f0/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/graph/TransitiveClosureNaive.java
----------------------------------------------------------------------
diff --git a/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/graph/TransitiveClosureNaive.java b/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/graph/TransitiveClosureNaive.java
index b4cf036..50e86ec 100644
--- a/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/graph/TransitiveClosureNaive.java
+++ b/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/graph/TransitiveClosureNaive.java
@@ -18,7 +18,6 @@
package org.apache.flink.examples.java.graph;
-import org.apache.flink.api.common.ProgramDescription;
import org.apache.flink.api.common.functions.CoGroupFunction;
import org.apache.flink.api.common.functions.GroupReduceFunction;
import org.apache.flink.api.common.functions.JoinFunction;
@@ -34,13 +33,12 @@ import java.util.HashSet;
import java.util.Set;
@SuppressWarnings("serial")
-public class TransitiveClosureNaive implements ProgramDescription {
+public class TransitiveClosureNaive {
public static void main (String... args) throws Exception {
// Checking input parameters
final ParameterTool params = ParameterTool.fromArgs(args);
- System.out.println("Usage: TransitiveClosure --edges <path> --output <path> --iterations <n>");
// set up execution environment
ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
@@ -117,10 +115,4 @@ public class TransitiveClosureNaive implements ProgramDescription {
transitiveClosure.print();
}
}
-
- @Override
- public String getDescription() {
- return "Parameters: --edges <path> --output <path> --iterations <n>";
- }
-
}
http://git-wip-us.apache.org/repos/asf/flink/blob/44c2d2f0/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/ml/LinearRegression.java
----------------------------------------------------------------------
diff --git a/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/ml/LinearRegression.java b/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/ml/LinearRegression.java
index d225215..90ad67a 100644
--- a/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/ml/LinearRegression.java
+++ b/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/ml/LinearRegression.java
@@ -73,7 +73,6 @@ public class LinearRegression {
public static void main(String[] args) throws Exception {
final ParameterTool params = ParameterTool.fromArgs(args);
- System.out.println("Usage: LinearRegression --input <path> --output <path> --iterations <n>");
// set up execution environment
final ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
http://git-wip-us.apache.org/repos/asf/flink/blob/44c2d2f0/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/relational/EmptyFieldsCountAccumulator.java
----------------------------------------------------------------------
diff --git a/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/relational/EmptyFieldsCountAccumulator.java b/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/relational/EmptyFieldsCountAccumulator.java
index b6eba8f..87b5bff 100644
--- a/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/relational/EmptyFieldsCountAccumulator.java
+++ b/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/relational/EmptyFieldsCountAccumulator.java
@@ -65,7 +65,6 @@ public class EmptyFieldsCountAccumulator {
final ParameterTool params = ParameterTool.fromArgs(args);
final ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
- System.out.println("Usage: EmptyFieldsCountAccumulator --input <path> --output <path>");
// make parameters available in the web interface
env.getConfig().setGlobalJobParameters(params);
http://git-wip-us.apache.org/repos/asf/flink/blob/44c2d2f0/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/relational/TPCHQuery10.java
----------------------------------------------------------------------
diff --git a/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/relational/TPCHQuery10.java b/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/relational/TPCHQuery10.java
index 816be1e..14fbc34 100644
--- a/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/relational/TPCHQuery10.java
+++ b/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/relational/TPCHQuery10.java
@@ -216,5 +216,4 @@ public class TPCHQuery10 {
.includeFields("1100")
.types(Integer.class, String.class);
}
-
}
http://git-wip-us.apache.org/repos/asf/flink/blob/44c2d2f0/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/relational/TPCHQuery3.java
----------------------------------------------------------------------
diff --git a/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/relational/TPCHQuery3.java b/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/relational/TPCHQuery3.java
index e0bd536..c849764 100644
--- a/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/relational/TPCHQuery3.java
+++ b/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/relational/TPCHQuery3.java
@@ -181,7 +181,7 @@ public class TPCHQuery3 {
}
}
-
+
// *************************************************************************
// DATA TYPES
// *************************************************************************
http://git-wip-us.apache.org/repos/asf/flink/blob/44c2d2f0/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/relational/WebLogAnalysis.java
----------------------------------------------------------------------
diff --git a/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/relational/WebLogAnalysis.java b/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/relational/WebLogAnalysis.java
index 677ca1c..5c8fac5 100644
--- a/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/relational/WebLogAnalysis.java
+++ b/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/relational/WebLogAnalysis.java
@@ -102,7 +102,6 @@ public class WebLogAnalysis {
final ParameterTool params = ParameterTool.fromArgs(args);
final ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
- System.out.println("Usage: WebLogAnalysis --documents <path> --ranks <path> --visits <path> --output <path>");
env.getConfig().setGlobalJobParameters(params);
@@ -147,7 +146,7 @@ public class WebLogAnalysis {
result.print();
}
}
-
+
// *************************************************************************
// USER FUNCTIONS
// *************************************************************************
http://git-wip-us.apache.org/repos/asf/flink/blob/44c2d2f0/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/wordcount/WordCount.java
----------------------------------------------------------------------
diff --git a/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/wordcount/WordCount.java b/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/wordcount/WordCount.java
index b914d77..8538a20 100644
--- a/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/wordcount/WordCount.java
+++ b/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/wordcount/WordCount.java
@@ -62,7 +62,6 @@ public class WordCount {
// make parameters available in the web interface
env.getConfig().setGlobalJobParameters(params);
- System.out.println("Usage: WordCount --input <path> --output <path>");
// get input data
DataSet<String> text;
@@ -94,7 +93,7 @@ public class WordCount {
}
}
-
+
// *************************************************************************
// USER FUNCTIONS
// *************************************************************************
http://git-wip-us.apache.org/repos/asf/flink/blob/44c2d2f0/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/clustering/KMeans.scala
----------------------------------------------------------------------
diff --git a/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/clustering/KMeans.scala b/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/clustering/KMeans.scala
index 78ce45b..e5a16a5 100644
--- a/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/clustering/KMeans.scala
+++ b/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/clustering/KMeans.scala
@@ -76,7 +76,6 @@ object KMeans {
// checking input parameters
val params: ParameterTool = ParameterTool.fromArgs(args)
- println("Usage: KMeans --points <path> --centroids <path> --output <path> --iterations <n>")
// set up execution environment
val env: ExecutionEnvironment = ExecutionEnvironment.getExecutionEnvironment
@@ -225,7 +224,6 @@ object KMeans {
}
}
-
}
http://git-wip-us.apache.org/repos/asf/flink/blob/44c2d2f0/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/graph/ConnectedComponents.scala
----------------------------------------------------------------------
diff --git a/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/graph/ConnectedComponents.scala b/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/graph/ConnectedComponents.scala
index 2538aa6..c718612 100644
--- a/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/graph/ConnectedComponents.scala
+++ b/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/graph/ConnectedComponents.scala
@@ -66,8 +66,6 @@ object ConnectedComponents {
def main(args: Array[String]) {
val params: ParameterTool = ParameterTool.fromArgs(args)
- println("Usage: ConnectedComponents " +
- "--vertices <path> --edges <path> --output <path> --iterations <n>")
// set up execution environment
val env = ExecutionEnvironment.getExecutionEnvironment
@@ -151,5 +149,4 @@ object ConnectedComponents {
env.fromCollection(edgeData)
}
}
-
}
http://git-wip-us.apache.org/repos/asf/flink/blob/44c2d2f0/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/graph/EnumTriangles.scala
----------------------------------------------------------------------
diff --git a/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/graph/EnumTriangles.scala b/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/graph/EnumTriangles.scala
index 88037c5..0a59699 100644
--- a/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/graph/EnumTriangles.scala
+++ b/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/graph/EnumTriangles.scala
@@ -71,7 +71,6 @@ object EnumTriangles {
def main(args: Array[String]) {
val params: ParameterTool = ParameterTool.fromArgs(args)
- println("Usage: EnumTriangleBasic --edges <path> --output <path>")
// set up execution environment
val env = ExecutionEnvironment.getExecutionEnvironment
@@ -156,5 +155,4 @@ object EnumTriangles {
}
}
}
-
}
http://git-wip-us.apache.org/repos/asf/flink/blob/44c2d2f0/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/graph/PageRankBasic.scala
----------------------------------------------------------------------
diff --git a/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/graph/PageRankBasic.scala b/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/graph/PageRankBasic.scala
index 84ebff5..1f842d5 100644
--- a/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/graph/PageRankBasic.scala
+++ b/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/graph/PageRankBasic.scala
@@ -75,8 +75,6 @@ object PageRankBasic {
def main(args: Array[String]) {
val params: ParameterTool = ParameterTool.fromArgs(args)
- println("Usage: PageRankBasic " +
- "--pages <path> --links <path> --output <path> --numPages <n> --iterations <n>")
// set up execution environment
val env = ExecutionEnvironment.getExecutionEnvironment
@@ -183,5 +181,4 @@ object PageRankBasic {
env.fromCollection(edges)
}
}
-
}
http://git-wip-us.apache.org/repos/asf/flink/blob/44c2d2f0/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/graph/TransitiveClosureNaive.scala
----------------------------------------------------------------------
diff --git a/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/graph/TransitiveClosureNaive.scala b/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/graph/TransitiveClosureNaive.scala
index d989969..1f3a32b 100644
--- a/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/graph/TransitiveClosureNaive.scala
+++ b/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/graph/TransitiveClosureNaive.scala
@@ -23,12 +23,11 @@ import org.apache.flink.api.scala._
import org.apache.flink.examples.java.graph.util.ConnectedComponentsData
import org.apache.flink.util.Collector
-object TransitiveClosureNaive {
+object TransitiveClosureNaive {
def main (args: Array[String]): Unit = {
val params: ParameterTool = ParameterTool.fromArgs(args)
- println("Usage: TransitiveClosure --edges <path> --output <path> --iterations <n>")
// set up execution environment
val env = ExecutionEnvironment.getExecutionEnvironment
@@ -86,5 +85,4 @@ object TransitiveClosureNaive {
}
}
-
}
http://git-wip-us.apache.org/repos/asf/flink/blob/44c2d2f0/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/ml/LinearRegression.scala
----------------------------------------------------------------------
diff --git a/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/ml/LinearRegression.scala b/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/ml/LinearRegression.scala
index eec84b9..4663db6 100644
--- a/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/ml/LinearRegression.scala
+++ b/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/ml/LinearRegression.scala
@@ -64,7 +64,6 @@ object LinearRegression {
def main(args: Array[String]) {
val params: ParameterTool = ParameterTool.fromArgs(args)
- println("Usage: LinearRegression --input <path> --output <path> --iterations <n>")
// set up execution environment
val env = ExecutionEnvironment.getExecutionEnvironment
@@ -157,5 +156,4 @@ object LinearRegression {
(Params(theta0, theta1), 1)
}
}
-
}
http://git-wip-us.apache.org/repos/asf/flink/blob/44c2d2f0/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/relational/TPCHQuery10.scala
----------------------------------------------------------------------
diff --git a/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/relational/TPCHQuery10.scala b/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/relational/TPCHQuery10.scala
index 4962f2c..f0d21f2 100644
--- a/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/relational/TPCHQuery10.scala
+++ b/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/relational/TPCHQuery10.scala
@@ -175,5 +175,4 @@ object TPCHQuery10 {
fieldDelimiter = "|",
includedFields = Array(0, 1) )
}
-
}
http://git-wip-us.apache.org/repos/asf/flink/blob/44c2d2f0/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/relational/TPCHQuery3.scala
----------------------------------------------------------------------
diff --git a/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/relational/TPCHQuery3.scala b/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/relational/TPCHQuery3.scala
index d157a75..d6d1846 100644
--- a/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/relational/TPCHQuery3.scala
+++ b/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/relational/TPCHQuery3.scala
@@ -169,5 +169,4 @@ object TPCHQuery3 {
fieldDelimiter = "|",
includedFields = Array(0, 1, 4, 7) )
}
-
}
http://git-wip-us.apache.org/repos/asf/flink/blob/44c2d2f0/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/relational/WebLogAnalysis.scala
----------------------------------------------------------------------
diff --git a/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/relational/WebLogAnalysis.scala b/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/relational/WebLogAnalysis.scala
index 09e2d52..7ed39c9 100644
--- a/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/relational/WebLogAnalysis.scala
+++ b/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/relational/WebLogAnalysis.scala
@@ -93,7 +93,6 @@ object WebLogAnalysis {
def main(args: Array[String]) {
val params: ParameterTool = ParameterTool.fromArgs(args)
- println("Usage: --documents <path> --ranks <path> --visits <path> --output <path>")
// set up execution environment
val env = ExecutionEnvironment.getExecutionEnvironment
http://git-wip-us.apache.org/repos/asf/flink/blob/44c2d2f0/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/wordcount/WordCount.scala
----------------------------------------------------------------------
diff --git a/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/wordcount/WordCount.scala b/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/wordcount/WordCount.scala
index 7ce9d51..0f3d6c8 100644
--- a/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/wordcount/WordCount.scala
+++ b/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/wordcount/WordCount.scala
@@ -48,7 +48,6 @@ object WordCount {
def main(args: Array[String]) {
val params: ParameterTool = ParameterTool.fromArgs(args)
- System.out.println("Usage: WordCount --input <path> --output <path>")
// set up execution environment
val env = ExecutionEnvironment.getExecutionEnvironment
@@ -78,7 +77,6 @@ object WordCount {
}
}
-
}
http://git-wip-us.apache.org/repos/asf/flink/blob/44c2d2f0/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/iteration/IterateExample.java
----------------------------------------------------------------------
diff --git a/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/iteration/IterateExample.java b/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/iteration/IterateExample.java
index 67718cf..5859ad4 100644
--- a/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/iteration/IterateExample.java
+++ b/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/iteration/IterateExample.java
@@ -58,7 +58,6 @@ public class IterateExample {
// Checking input parameters
final ParameterTool params = ParameterTool.fromArgs(args);
- System.out.println(" Usage: IterateExample --input <path> --output <path>");
// set up input for the stream of integer pairs
http://git-wip-us.apache.org/repos/asf/flink/blob/44c2d2f0/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/kafka/WriteIntoKafka.java
----------------------------------------------------------------------
diff --git a/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/kafka/WriteIntoKafka.java b/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/kafka/WriteIntoKafka.java
index 63b37c4..37c86a3 100644
--- a/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/kafka/WriteIntoKafka.java
+++ b/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/kafka/WriteIntoKafka.java
@@ -49,6 +49,7 @@ public class WriteIntoKafka {
// very simple data generator
DataStream<String> messageStream = env.addSource(new SourceFunction<String>() {
+ private static final long serialVersionUID = 6369260445318862378L;
public boolean running = true;
@Override
http://git-wip-us.apache.org/repos/asf/flink/blob/44c2d2f0/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/ml/IncrementalLearningSkeleton.java
----------------------------------------------------------------------
diff --git a/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/ml/IncrementalLearningSkeleton.java b/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/ml/IncrementalLearningSkeleton.java
index 4108485..f10c55e 100644
--- a/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/ml/IncrementalLearningSkeleton.java
+++ b/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/ml/IncrementalLearningSkeleton.java
@@ -61,7 +61,6 @@ public class IncrementalLearningSkeleton {
// Checking input parameters
final ParameterTool params = ParameterTool.fromArgs(args);
- System.out.println("Usage: IncrementalLearningSkeleton --output <path>");
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);
http://git-wip-us.apache.org/repos/asf/flink/blob/44c2d2f0/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing/SessionWindowing.java
----------------------------------------------------------------------
diff --git a/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing/SessionWindowing.java b/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing/SessionWindowing.java
index 27804fe..61616fe 100644
--- a/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing/SessionWindowing.java
+++ b/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing/SessionWindowing.java
@@ -37,7 +37,6 @@ public class SessionWindowing {
final ParameterTool params = ParameterTool.fromArgs(args);
final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
- System.out.println("Usage: SessionWindowing --output <path>");
env.getConfig().setGlobalJobParameters(params);
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);
http://git-wip-us.apache.org/repos/asf/flink/blob/44c2d2f0/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing/TopSpeedWindowing.java
----------------------------------------------------------------------
diff --git a/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing/TopSpeedWindowing.java b/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing/TopSpeedWindowing.java
index 8f0eb47..df24008 100644
--- a/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing/TopSpeedWindowing.java
+++ b/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing/TopSpeedWindowing.java
@@ -53,7 +53,6 @@ public class TopSpeedWindowing {
public static void main(String[] args) throws Exception {
final ParameterTool params = ParameterTool.fromArgs(args);
- System.err.println("Usage: TopSpeedWindowingExample --input <path> --output <path>");
final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);
http://git-wip-us.apache.org/repos/asf/flink/blob/44c2d2f0/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing/WindowWordCount.java
----------------------------------------------------------------------
diff --git a/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing/WindowWordCount.java b/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing/WindowWordCount.java
index d6f7450..38fcd76 100644
--- a/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing/WindowWordCount.java
+++ b/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing/WindowWordCount.java
@@ -53,7 +53,6 @@ public class WindowWordCount {
public static void main(String[] args) throws Exception {
final ParameterTool params = ParameterTool.fromArgs(args);
- System.out.println(" Usage: WindowWordCount --input <path> --output <path> --window <n> --slide <n>");
// set up the execution environment
final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
@@ -96,5 +95,4 @@ public class WindowWordCount {
// execute program
env.execute("WindowWordCount");
}
-
}
http://git-wip-us.apache.org/repos/asf/flink/blob/44c2d2f0/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/wordcount/PojoExample.java
----------------------------------------------------------------------
diff --git a/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/wordcount/PojoExample.java b/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/wordcount/PojoExample.java
index d023246..8c16172 100644
--- a/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/wordcount/PojoExample.java
+++ b/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/wordcount/PojoExample.java
@@ -52,7 +52,6 @@ public class PojoExample {
// Checking input parameters
final ParameterTool params = ParameterTool.fromArgs(args);
- System.out.println("Usage: PojoExample --input <path> --output <path>");
// set up the execution environment
final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
http://git-wip-us.apache.org/repos/asf/flink/blob/44c2d2f0/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/wordcount/WordCount.java
----------------------------------------------------------------------
diff --git a/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/wordcount/WordCount.java b/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/wordcount/WordCount.java
index a143fa5..4290878 100644
--- a/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/wordcount/WordCount.java
+++ b/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/wordcount/WordCount.java
@@ -56,7 +56,6 @@ public class WordCount {
// Checking input parameters
final ParameterTool params = ParameterTool.fromArgs(args);
- System.out.println("Usage: WordCount --input <path> --output <path>");
// set up the execution environment
final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
http://git-wip-us.apache.org/repos/asf/flink/blob/44c2d2f0/flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/windowing/TopSpeedWindowing.scala
----------------------------------------------------------------------
diff --git a/flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/windowing/TopSpeedWindowing.scala b/flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/windowing/TopSpeedWindowing.scala
index 3a75a49..80881cc 100644
--- a/flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/windowing/TopSpeedWindowing.scala
+++ b/flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/windowing/TopSpeedWindowing.scala
@@ -58,7 +58,6 @@ object TopSpeedWindowing {
def main(args: Array[String]) {
val params = ParameterTool.fromArgs(args)
- println("Usage: TopSpeedWindowing --input <path> --output <path>")
val env = StreamExecutionEnvironment.getExecutionEnvironment
env.getConfig.setGlobalJobParameters(params)
@@ -124,5 +123,4 @@ object TopSpeedWindowing {
val record = line.substring(1, line.length - 1).split(",")
(record(0).toInt, record(1).toInt, record(2).toDouble, record(3).toLong)
}
-
}
http://git-wip-us.apache.org/repos/asf/flink/blob/44c2d2f0/flink-quickstart/flink-quickstart-java/src/main/resources/archetype-resources/src/main/java/SocketTextStreamWordCount.java
----------------------------------------------------------------------
diff --git a/flink-quickstart/flink-quickstart-java/src/main/resources/archetype-resources/src/main/java/SocketTextStreamWordCount.java b/flink-quickstart/flink-quickstart-java/src/main/resources/archetype-resources/src/main/java/SocketTextStreamWordCount.java
index 10d8044..6a3383c 100644
--- a/flink-quickstart/flink-quickstart-java/src/main/resources/archetype-resources/src/main/java/SocketTextStreamWordCount.java
+++ b/flink-quickstart/flink-quickstart-java/src/main/resources/archetype-resources/src/main/java/SocketTextStreamWordCount.java
@@ -84,7 +84,6 @@ public class SocketTextStreamWordCount {
// execute program
env.execute("WordCount from SocketTextStream Example");
}
-
//
// User Functions
//
http://git-wip-us.apache.org/repos/asf/flink/blob/44c2d2f0/flink-quickstart/flink-quickstart-scala/src/main/resources/archetype-resources/src/main/scala/SocketTextStreamWordCount.scala
----------------------------------------------------------------------
diff --git a/flink-quickstart/flink-quickstart-scala/src/main/resources/archetype-resources/src/main/scala/SocketTextStreamWordCount.scala b/flink-quickstart/flink-quickstart-scala/src/main/resources/archetype-resources/src/main/scala/SocketTextStreamWordCount.scala
index 9bc85ea..d08974d 100644
--- a/flink-quickstart/flink-quickstart-scala/src/main/resources/archetype-resources/src/main/scala/SocketTextStreamWordCount.scala
+++ b/flink-quickstart/flink-quickstart-scala/src/main/resources/archetype-resources/src/main/scala/SocketTextStreamWordCount.scala
@@ -66,5 +66,4 @@ object SocketTextStreamWordCount {
env.execute("Scala SocketTextStreamWordCount Example")
}
-
}