You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gobblin.apache.org by ab...@apache.org on 2017/07/31 17:32:33 UTC
[2/2] incubator-gobblin git commit: Merge pull request #2032 from
abti/move_packages_to_apache
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 <ab...@gmail.com>
Authored: Mon Jul 31 10:32:22 2017 -0700
Committer: Abhishek Tiwari <ab...@gmail.com>
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(-)
----------------------------------------------------------------------