You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by dh...@apache.org on 2016/04/27 03:08:52 UTC
[20/21] incubator-beam git commit: Fix a few underlying checkstyle
issues in java8 examples
Fix a few underlying checkstyle issues in java8 examples
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9e19efdf
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/9e19efdf
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/9e19efdf
Branch: refs/heads/master
Commit: 9e19efdf37541ee082bed1ebfd6dd0b154de5f0a
Parents: c08f973
Author: Davor Bonaci <da...@google.com>
Authored: Mon Apr 25 15:02:27 2016 -0700
Committer: Davor Bonaci <da...@google.com>
Committed: Tue Apr 26 17:59:39 2016 -0700
----------------------------------------------------------------------
.../apache/beam/examples/complete/game/GameStats.java | 12 ++++++++----
.../beam/examples/complete/game/HourlyTeamScore.java | 6 ++++--
.../apache/beam/examples/complete/game/LeaderBoard.java | 6 ++++--
3 files changed, 16 insertions(+), 8 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/9e19efdf/examples/java8/src/main/java/org/apache/beam/examples/complete/game/GameStats.java
----------------------------------------------------------------------
diff --git a/examples/java8/src/main/java/org/apache/beam/examples/complete/game/GameStats.java b/examples/java8/src/main/java/org/apache/beam/examples/complete/game/GameStats.java
index d93c2ae..2d14264 100644
--- a/examples/java8/src/main/java/org/apache/beam/examples/complete/game/GameStats.java
+++ b/examples/java8/src/main/java/org/apache/beam/examples/complete/game/GameStats.java
@@ -207,8 +207,10 @@ public class GameStats extends LeaderBoard {
c -> c.element().getValue()));
tableConfigure.put("window_start",
new WriteWindowedToBigQuery.FieldInfo<KV<String, Integer>>("STRING",
- c -> { IntervalWindow w = (IntervalWindow) c.window();
- return fmt.print(w.start()); }));
+ c -> {
+ IntervalWindow w = (IntervalWindow) c.window();
+ return fmt.print(w.start());
+ }));
tableConfigure.put("processing_time",
new WriteWindowedToBigQuery.FieldInfo<KV<String, Integer>>(
"STRING", c -> fmt.print(Instant.now())));
@@ -226,8 +228,10 @@ public class GameStats extends LeaderBoard {
new HashMap<String, WriteWindowedToBigQuery.FieldInfo<Double>>();
tableConfigure.put("window_start",
new WriteWindowedToBigQuery.FieldInfo<Double>("STRING",
- c -> { IntervalWindow w = (IntervalWindow) c.window();
- return fmt.print(w.start()); }));
+ c -> {
+ IntervalWindow w = (IntervalWindow) c.window();
+ return fmt.print(w.start());
+ }));
tableConfigure.put("mean_duration",
new WriteWindowedToBigQuery.FieldInfo<Double>("FLOAT", c -> c.element()));
return tableConfigure;
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/9e19efdf/examples/java8/src/main/java/org/apache/beam/examples/complete/game/HourlyTeamScore.java
----------------------------------------------------------------------
diff --git a/examples/java8/src/main/java/org/apache/beam/examples/complete/game/HourlyTeamScore.java b/examples/java8/src/main/java/org/apache/beam/examples/complete/game/HourlyTeamScore.java
index 5ce7d95..b516a32 100644
--- a/examples/java8/src/main/java/org/apache/beam/examples/complete/game/HourlyTeamScore.java
+++ b/examples/java8/src/main/java/org/apache/beam/examples/complete/game/HourlyTeamScore.java
@@ -132,8 +132,10 @@ public class HourlyTeamScore extends UserScore {
c -> c.element().getValue()));
tableConfig.put("window_start",
new WriteWindowedToBigQuery.FieldInfo<KV<String, Integer>>("STRING",
- c -> { IntervalWindow w = (IntervalWindow) c.window();
- return fmt.print(w.start()); }));
+ c -> {
+ IntervalWindow w = (IntervalWindow) c.window();
+ return fmt.print(w.start());
+ }));
return tableConfig;
}
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/9e19efdf/examples/java8/src/main/java/org/apache/beam/examples/complete/game/LeaderBoard.java
----------------------------------------------------------------------
diff --git a/examples/java8/src/main/java/org/apache/beam/examples/complete/game/LeaderBoard.java b/examples/java8/src/main/java/org/apache/beam/examples/complete/game/LeaderBoard.java
index 594d2b8..97958b0 100644
--- a/examples/java8/src/main/java/org/apache/beam/examples/complete/game/LeaderBoard.java
+++ b/examples/java8/src/main/java/org/apache/beam/examples/complete/game/LeaderBoard.java
@@ -143,8 +143,10 @@ public class LeaderBoard extends HourlyTeamScore {
c -> c.element().getValue()));
tableConfigure.put("window_start",
new WriteWindowedToBigQuery.FieldInfo<KV<String, Integer>>("STRING",
- c -> { IntervalWindow w = (IntervalWindow) c.window();
- return fmt.print(w.start()); }));
+ c -> {
+ IntervalWindow w = (IntervalWindow) c.window();
+ return fmt.print(w.start());
+ }));
tableConfigure.put("processing_time",
new WriteWindowedToBigQuery.FieldInfo<KV<String, Integer>>(
"STRING", c -> fmt.print(Instant.now())));