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/gearpump-runner Commit: b21fa04f28f5e7be87b41d5478c4c6decd87e433 Parents: 11caa97 Author: manuzhang <[email protected]> Authored: Fri Jun 23 10:12:19 2017 +0800 Committer: manuzhang <[email protected]> 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 {
