You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2017/08/07 23:53:59 UTC
[34/50] [abbrv] beam git commit: Remove unused codes
Remove unused codes
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b21fa04f
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b21fa04f
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b21fa04f
Branch: refs/heads/master
Commit: b21fa04f28f5e7be87b41d5478c4c6decd87e433
Parents: 11caa97
Author: manuzhang <ow...@gmail.com>
Authored: Fri Jun 23 10:12:19 2017 +0800
Committer: manuzhang <ow...@gmail.com>
Committed: Fri Jun 23 10:12:19 2017 +0800
----------------------------------------------------------------------
.../apache/beam/runners/gearpump/translators/io/GearpumpSource.java | 1 -
1 file changed, 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/b21fa04f/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/io/GearpumpSource.java
----------------------------------------------------------------------
diff --git a/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/io/GearpumpSource.java b/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/io/GearpumpSource.java
index 558eb0d..daa8c81 100644
--- a/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/io/GearpumpSource.java
+++ b/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/io/GearpumpSource.java
@@ -46,7 +46,6 @@ public abstract class GearpumpSource<T> implements DataSource {
private Source.Reader<T> reader;
private boolean available = false;
- private long count = 0L;
GearpumpSource(PipelineOptions options) {
try {