This closes #2118
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a81c4578 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a81c4578 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a81c4578 Branch: refs/heads/master Commit: a81c45781491185569f8ff75f5256d6de84a7150 Parents: b49ec3f 44624c3 Author: Sela <[email protected]> Authored: Wed Mar 1 22:47:40 2017 +0200 Committer: Sela <[email protected]> Committed: Wed Mar 1 22:47:40 2017 +0200 ---------------------------------------------------------------------- runners/spark/pom.xml | 6 + .../runners/spark/coders/NullWritableCoder.java | 76 ------------ .../runners/spark/coders/WritableCoder.java | 122 ------------------- .../runners/spark/coders/WritableCoderTest.java | 45 ------- .../io/hadoop/HadoopFileFormatPipelineTest.java | 2 +- sdks/java/io/hadoop-common/pom.xml | 10 ++ .../beam/sdk/io/hadoop/WritableCoder.java | 116 ++++++++++++++++++ .../beam/sdk/io/hadoop/WritableCoderTest.java | 45 +++++++ sdks/java/io/hdfs/pom.xml | 5 - .../apache/beam/sdk/io/hdfs/HDFSFileSource.java | 1 + .../apache/beam/sdk/io/hdfs/WritableCoder.java | 116 ------------------ .../beam/sdk/io/hdfs/WritableCoderTest.java | 45 ------- 12 files changed, 179 insertions(+), 410 deletions(-) ----------------------------------------------------------------------
