Merge pull request #2032 from abti/move_packages_to_apache
Project: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/commit/f96379e1 Tree: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/tree/f96379e1 Diff: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/diff/f96379e1 Branch: refs/heads/master Commit: f96379e11219589bf87659228c48a5054f751032 Parents: 5457af8 886c6e4 Author: Abhishek Tiwari <[email protected]> Authored: Mon Jul 31 10:32:22 2017 -0700 Committer: Abhishek Tiwari <[email protected]> Committed: Mon Jul 31 10:32:22 2017 -0700 ---------------------------------------------------------------------- .../configuration/ImmutableWorkUnitState.java | 26 ++++++++ .../java/gobblin/configuration/SourceState.java | 52 ++++++++++++++++ .../main/java/gobblin/configuration/State.java | 36 +++++++++++ .../gobblin/configuration/WorkUnitState.java | 40 +++++++++++++ .../extractor/CheckpointableWatermark.java | 25 ++++++++ .../gobblin/source/extractor/Watermark.java | 23 +++++++ .../source/extractor/WatermarkInterval.java | 26 ++++++++ .../java/gobblin/source/workunit/Extract.java | 51 ++++++++++++++++ .../source/workunit/ImmutableExtract.java | 41 +++++++++++++ .../source/workunit/ImmutableWorkUnit.java | 26 ++++++++ .../gobblin/source/workunit/MultiWorkUnit.java | 27 +++++++++ .../java/gobblin/source/workunit/WorkUnit.java | 49 +++++++++++++++ .../main/java/gobblin/state/ConstructState.java | 36 +++++++++++ .../conversion/hive/source/HiveWorkUnit.java | 32 ++++++++++ .../main/java/gobblin/hive/HiveRegProps.java | 32 ++++++++++ .../gobblin/metastore/FsStateStoreTest.java | 40 ++++++------- .../runtime/CheckpointableWatermarkState.java | 33 ++++++++++ .../src/main/java/gobblin/runtime/JobState.java | 63 ++++++++++++++++++++ .../main/java/gobblin/runtime/TaskState.java | 5 ++ .../util/JobStateToJsonConverterTest.java | 34 +++++------ 20 files changed, 660 insertions(+), 37 deletions(-) ----------------------------------------------------------------------
