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 2017/04/24 16:45:24 UTC
[1/2] beam git commit: Remove unnecessary semicolons
Repository: beam
Updated Branches:
refs/heads/master d6dddee23 -> f8d616816
Remove unnecessary semicolons
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/8f407c5d
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/8f407c5d
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/8f407c5d
Branch: refs/heads/master
Commit: 8f407c5db772e11c0f8456329178ccc555939ff0
Parents: d6dddee
Author: wtanaka.com <wt...@yahoo.com>
Authored: Sat Apr 22 08:18:58 2017 -1000
Committer: Dan Halperin <dh...@google.com>
Committed: Mon Apr 24 09:45:15 2017 -0700
----------------------------------------------------------------------
.../org/apache/beam/sdk/transforms/reflect/DoFnSignatures.java | 2 +-
.../src/main/java/org/apache/beam/sdk/util/WindowingStrategy.java | 2 +-
.../core/src/test/java/org/apache/beam/sdk/io/AvroSourceTest.java | 2 +-
.../apache/beam/sdk/io/elasticsearch/ElasticSearchIOTestUtils.java | 2 +-
4 files changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/8f407c5d/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnSignatures.java
----------------------------------------------------------------------
diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnSignatures.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnSignatures.java
index 80dbe10..7beeeb8 100644
--- a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnSignatures.java
+++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnSignatures.java
@@ -69,7 +69,7 @@ import org.apache.beam.sdk.values.TypeParameter;
*/
public class DoFnSignatures {
- private DoFnSignatures() {};
+ private DoFnSignatures() {}
private static final Map<Class<?>, DoFnSignature> signatureCache = new LinkedHashMap<>();
http://git-wip-us.apache.org/repos/asf/beam/blob/8f407c5d/sdks/java/core/src/main/java/org/apache/beam/sdk/util/WindowingStrategy.java
----------------------------------------------------------------------
diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/util/WindowingStrategy.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/util/WindowingStrategy.java
index c14523c..268718a 100644
--- a/sdks/java/core/src/main/java/org/apache/beam/sdk/util/WindowingStrategy.java
+++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/util/WindowingStrategy.java
@@ -51,7 +51,7 @@ public class WindowingStrategy<T, W extends BoundedWindow> implements Serializab
*/
public enum AccumulationMode {
DISCARDING_FIRED_PANES,
- ACCUMULATING_FIRED_PANES;
+ ACCUMULATING_FIRED_PANES
}
private static final Duration DEFAULT_ALLOWED_LATENESS = Duration.ZERO;
http://git-wip-us.apache.org/repos/asf/beam/blob/8f407c5d/sdks/java/core/src/test/java/org/apache/beam/sdk/io/AvroSourceTest.java
----------------------------------------------------------------------
diff --git a/sdks/java/core/src/test/java/org/apache/beam/sdk/io/AvroSourceTest.java b/sdks/java/core/src/test/java/org/apache/beam/sdk/io/AvroSourceTest.java
index 64b0027..c822e8c 100644
--- a/sdks/java/core/src/test/java/org/apache/beam/sdk/io/AvroSourceTest.java
+++ b/sdks/java/core/src/test/java/org/apache/beam/sdk/io/AvroSourceTest.java
@@ -82,7 +82,7 @@ public class AvroSourceTest {
private enum SyncBehavior {
SYNC_REGULAR, // Sync at regular, user defined intervals
SYNC_RANDOM, // Sync at random intervals
- SYNC_DEFAULT; // Sync at default intervals (i.e., no manual syncing).
+ SYNC_DEFAULT // Sync at default intervals (i.e., no manual syncing).
}
private static final int DEFAULT_RECORD_COUNT = 1000;
http://git-wip-us.apache.org/repos/asf/beam/blob/8f407c5d/sdks/java/io/elasticsearch/src/test/java/org/apache/beam/sdk/io/elasticsearch/ElasticSearchIOTestUtils.java
----------------------------------------------------------------------
diff --git a/sdks/java/io/elasticsearch/src/test/java/org/apache/beam/sdk/io/elasticsearch/ElasticSearchIOTestUtils.java b/sdks/java/io/elasticsearch/src/test/java/org/apache/beam/sdk/io/elasticsearch/ElasticSearchIOTestUtils.java
index 9a121f8..b0d161f 100644
--- a/sdks/java/io/elasticsearch/src/test/java/org/apache/beam/sdk/io/elasticsearch/ElasticSearchIOTestUtils.java
+++ b/sdks/java/io/elasticsearch/src/test/java/org/apache/beam/sdk/io/elasticsearch/ElasticSearchIOTestUtils.java
@@ -37,7 +37,7 @@ class ElasticSearchIOTestUtils {
/** Enumeration that specifies whether to insert malformed documents. */
enum InjectionMode {
INJECT_SOME_INVALID_DOCS,
- DO_NOT_INJECT_INVALID_DOCS;
+ DO_NOT_INJECT_INVALID_DOCS
}
/** Deletes the given index synchronously. */
[2/2] beam git commit: This closes #2650
Posted by dh...@apache.org.
This closes #2650
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f8d61681
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f8d61681
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f8d61681
Branch: refs/heads/master
Commit: f8d6168167b133d2c5279d92963294ad2733e9bb
Parents: d6dddee 8f407c5
Author: Dan Halperin <dh...@google.com>
Authored: Mon Apr 24 09:45:17 2017 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Mon Apr 24 09:45:17 2017 -0700
----------------------------------------------------------------------
.../org/apache/beam/sdk/transforms/reflect/DoFnSignatures.java | 2 +-
.../src/main/java/org/apache/beam/sdk/util/WindowingStrategy.java | 2 +-
.../core/src/test/java/org/apache/beam/sdk/io/AvroSourceTest.java | 2 +-
.../apache/beam/sdk/io/elasticsearch/ElasticSearchIOTestUtils.java | 2 +-
4 files changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------