This closes #1994
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b79dd642 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b79dd642 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b79dd642 Branch: refs/heads/master Commit: b79dd6428f328e0615deef5ab9880a69903b79ca Parents: ef256df d01620c Author: Davor Bonaci <[email protected]> Authored: Thu Mar 9 15:21:02 2017 -0800 Committer: Davor Bonaci <[email protected]> Committed: Thu Mar 9 15:21:02 2017 -0800 ---------------------------------------------------------------------- sdks/java/io/hadoop-input-format/README.md | 167 ++++ sdks/java/io/hadoop-input-format/pom.xml | 136 +++ .../hadoop/inputformat/HadoopInputFormatIO.java | 941 +++++++++++++++++++ .../sdk/io/hadoop/inputformat/package-info.java | 23 + .../ConfigurableEmployeeInputFormat.java | 131 +++ .../sdk/io/hadoop/inputformat/Employee.java | 85 ++ .../hadoop/inputformat/EmployeeInputFormat.java | 172 ++++ .../inputformat/HadoopInputFormatIOTest.java | 844 +++++++++++++++++ .../ReuseObjectsEmployeeInputFormat.java | 176 ++++ .../hadoop/inputformat/TestEmployeeDataSet.java | 76 ++ 10 files changed, 2751 insertions(+) ----------------------------------------------------------------------
