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 07:52:30 UTC
[12/77] [abbrv] incubator-gobblin git commit: Updated package names,
imports and shell scripts
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebMasterSourceDaily.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebMasterSourceDaily.java b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebMasterSourceDaily.java
index b994445..b29856b 100644
--- a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebMasterSourceDaily.java
+++ b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebMasterSourceDaily.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.ingestion.google.webmaster;
+package org.apache.gobblin.ingestion.google.webmaster;
import java.io.IOException;
import java.util.Collections;
@@ -30,19 +30,19 @@ import com.google.gson.JsonArray;
import lombok.extern.slf4j.Slf4j;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.extractor.extract.google.GoogleCommon;
-import gobblin.source.extractor.extract.google.GoogleCommonKeys;
-import gobblin.source.extractor.partition.Partition;
-import gobblin.source.extractor.watermark.DateWatermark;
-import gobblin.source.extractor.watermark.TimestampWatermark;
-
-import static gobblin.configuration.ConfigurationKeys.SOURCE_CONN_PRIVATE_KEY;
-import static gobblin.configuration.ConfigurationKeys.SOURCE_CONN_USERNAME;
-import static gobblin.configuration.ConfigurationKeys.SOURCE_CONN_USE_PROXY_PORT;
-import static gobblin.configuration.ConfigurationKeys.SOURCE_CONN_USE_PROXY_URL;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.source.extractor.extract.google.GoogleCommon;
+import org.apache.gobblin.source.extractor.extract.google.GoogleCommonKeys;
+import org.apache.gobblin.source.extractor.partition.Partition;
+import org.apache.gobblin.source.extractor.watermark.DateWatermark;
+import org.apache.gobblin.source.extractor.watermark.TimestampWatermark;
+
+import static org.apache.gobblin.configuration.ConfigurationKeys.SOURCE_CONN_PRIVATE_KEY;
+import static org.apache.gobblin.configuration.ConfigurationKeys.SOURCE_CONN_USERNAME;
+import static org.apache.gobblin.configuration.ConfigurationKeys.SOURCE_CONN_USE_PROXY_PORT;
+import static org.apache.gobblin.configuration.ConfigurationKeys.SOURCE_CONN_USE_PROXY_URL;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterClient.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterClient.java b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterClient.java
index 1f275e2..ef6d2af 100644
--- a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterClient.java
+++ b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterClient.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.ingestion.google.webmaster;
+package org.apache.gobblin.ingestion.google.webmaster;
import java.io.IOException;
import java.util.List;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterClientImpl.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterClientImpl.java b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterClientImpl.java
index d0b0214..3c8c8b2 100644
--- a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterClientImpl.java
+++ b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterClientImpl.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.ingestion.google.webmaster;
+package org.apache.gobblin.ingestion.google.webmaster;
import java.io.IOException;
import java.util.ArrayList;
@@ -32,7 +32,7 @@ import com.google.api.services.webmasters.model.ApiDimensionFilterGroup;
import com.google.api.services.webmasters.model.SearchAnalyticsQueryRequest;
import com.google.api.services.webmasters.model.SearchAnalyticsQueryResponse;
-import gobblin.source.extractor.extract.google.GoogleCommon;
+import org.apache.gobblin.source.extractor.extract.google.GoogleCommon;
public class GoogleWebmasterClientImpl extends GoogleWebmasterClient {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterDataFetcher.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterDataFetcher.java b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterDataFetcher.java
index b7b6b42..0a0b7e9 100644
--- a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterDataFetcher.java
+++ b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterDataFetcher.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.ingestion.google.webmaster;
+package org.apache.gobblin.ingestion.google.webmaster;
import java.io.IOException;
import java.util.ArrayList;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterDataFetcherImpl.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterDataFetcherImpl.java b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterDataFetcherImpl.java
index ec6163b..d5a00c3 100644
--- a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterDataFetcherImpl.java
+++ b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterDataFetcherImpl.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.ingestion.google.webmaster;
+package org.apache.gobblin.ingestion.google.webmaster;
import java.io.IOException;
import java.util.ArrayDeque;
@@ -45,13 +45,13 @@ import com.google.common.base.Optional;
import lombok.extern.slf4j.Slf4j;
-import gobblin.configuration.State;
-import gobblin.util.ExecutorsUtils;
-import gobblin.util.limiter.RateBasedLimiter;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.util.ExecutorsUtils;
+import org.apache.gobblin.util.limiter.RateBasedLimiter;
-import static gobblin.ingestion.google.webmaster.GoogleWebmasterFilter.Dimension;
-import static gobblin.ingestion.google.webmaster.GoogleWebmasterFilter.FilterOperator;
-import static gobblin.ingestion.google.webmaster.GoogleWebmasterFilter.countryFilterToString;
+import static org.apache.gobblin.ingestion.google.webmaster.GoogleWebmasterFilter.Dimension;
+import static org.apache.gobblin.ingestion.google.webmaster.GoogleWebmasterFilter.FilterOperator;
+import static org.apache.gobblin.ingestion.google.webmaster.GoogleWebmasterFilter.countryFilterToString;
@Slf4j
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterDayPartitioner.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterDayPartitioner.java b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterDayPartitioner.java
index 67dc8e2..62e8bf0 100644
--- a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterDayPartitioner.java
+++ b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterDayPartitioner.java
@@ -15,10 +15,10 @@
* limitations under the License.
*/
-package gobblin.ingestion.google.webmaster;
+package org.apache.gobblin.ingestion.google.webmaster;
-import gobblin.configuration.State;
-import gobblin.ingestion.google.DayPartitioner;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.ingestion.google.DayPartitioner;
public class GoogleWebmasterDayPartitioner extends DayPartitioner {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterExtractor.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterExtractor.java b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterExtractor.java
index 3b74e79..557c337 100644
--- a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterExtractor.java
+++ b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterExtractor.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.ingestion.google.webmaster;
+package org.apache.gobblin.ingestion.google.webmaster;
import java.io.IOException;
import java.util.ArrayList;
@@ -34,12 +34,12 @@ import com.google.gson.JsonArray;
import avro.shaded.com.google.common.collect.Iterables;
import lombok.extern.slf4j.Slf4j;
-import gobblin.annotation.Alpha;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.extractor.DataRecordException;
-import gobblin.source.extractor.Extractor;
-import gobblin.source.extractor.extract.LongWatermark;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.source.extractor.DataRecordException;
+import org.apache.gobblin.source.extractor.Extractor;
+import org.apache.gobblin.source.extractor.extract.LongWatermark;
@Slf4j
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterExtractorIterator.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterExtractorIterator.java b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterExtractorIterator.java
index 6928214..c5a1c60 100644
--- a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterExtractorIterator.java
+++ b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterExtractorIterator.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.ingestion.google.webmaster;
+package org.apache.gobblin.ingestion.google.webmaster;
import java.io.IOException;
import java.util.ArrayDeque;
@@ -44,11 +44,11 @@ import com.google.common.base.Optional;
import avro.shaded.com.google.common.base.Joiner;
import lombok.extern.slf4j.Slf4j;
-import gobblin.configuration.WorkUnitState;
-import gobblin.ingestion.google.AsyncIteratorWithDataSink;
-import gobblin.ingestion.google.GoggleIngestionConfigurationKeys;
-import gobblin.util.ExecutorsUtils;
-import gobblin.util.limiter.RateBasedLimiter;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.ingestion.google.AsyncIteratorWithDataSink;
+import org.apache.gobblin.ingestion.google.GoggleIngestionConfigurationKeys;
+import org.apache.gobblin.util.ExecutorsUtils;
+import org.apache.gobblin.util.limiter.RateBasedLimiter;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterFilter.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterFilter.java b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterFilter.java
index d8c6b9e..95ebdcf 100644
--- a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterFilter.java
+++ b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterFilter.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.ingestion.google.webmaster;
+package org.apache.gobblin.ingestion.google.webmaster;
import java.util.ArrayList;
import java.util.Collection;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/ProducerJob.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/ProducerJob.java b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/ProducerJob.java
index f51d8f3..7c9e1dd 100644
--- a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/ProducerJob.java
+++ b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/ProducerJob.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.ingestion.google.webmaster;
+package org.apache.gobblin.ingestion.google.webmaster;
import java.util.ArrayList;
import java.util.Arrays;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/SimpleProducerJob.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/SimpleProducerJob.java b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/SimpleProducerJob.java
index 1fd9998..d5a9ba3 100644
--- a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/SimpleProducerJob.java
+++ b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/SimpleProducerJob.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.ingestion.google.webmaster;
+package org.apache.gobblin.ingestion.google.webmaster;
import java.util.ArrayList;
import java.util.List;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/TrieBasedProducerJob.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/TrieBasedProducerJob.java b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/TrieBasedProducerJob.java
index df63fed..1605eb8 100644
--- a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/TrieBasedProducerJob.java
+++ b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/TrieBasedProducerJob.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.ingestion.google.webmaster;
+package org.apache.gobblin.ingestion.google.webmaster;
import java.util.ArrayList;
import java.util.List;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/UrlGrouper.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/UrlGrouper.java b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/UrlGrouper.java
index 752c965..87adb38 100644
--- a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/UrlGrouper.java
+++ b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/UrlGrouper.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.ingestion.google.webmaster;
+package org.apache.gobblin.ingestion.google.webmaster;
import java.util.Iterator;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/UrlTrie.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/UrlTrie.java b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/UrlTrie.java
index 313c0b7..15075ae 100644
--- a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/UrlTrie.java
+++ b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/UrlTrie.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.ingestion.google.webmaster;
+package org.apache.gobblin.ingestion.google.webmaster;
import java.util.Collection;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/UrlTrieNode.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/UrlTrieNode.java b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/UrlTrieNode.java
index ee47b60..45eb931 100644
--- a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/UrlTrieNode.java
+++ b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/UrlTrieNode.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.ingestion.google.webmaster;
+package org.apache.gobblin.ingestion.google.webmaster;
import java.util.TreeMap;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/UrlTriePostOrderIterator.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/UrlTriePostOrderIterator.java b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/UrlTriePostOrderIterator.java
index 6a9098d..8c48374 100644
--- a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/UrlTriePostOrderIterator.java
+++ b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/UrlTriePostOrderIterator.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.ingestion.google.webmaster;
+package org.apache.gobblin.ingestion.google.webmaster;
import java.util.ArrayDeque;
import java.util.Deque;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/UrlTriePrefixGrouper.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/UrlTriePrefixGrouper.java b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/UrlTriePrefixGrouper.java
index 064fc40..92484aa 100644
--- a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/UrlTriePrefixGrouper.java
+++ b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/UrlTriePrefixGrouper.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.ingestion.google.webmaster;
+package org.apache.gobblin.ingestion.google.webmaster;
import java.util.ArrayList;
import java.util.Iterator;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleAnalyticsUnsampledExtractor.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleAnalyticsUnsampledExtractor.java b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleAnalyticsUnsampledExtractor.java
index 97c859e..f65f74c 100644
--- a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleAnalyticsUnsampledExtractor.java
+++ b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleAnalyticsUnsampledExtractor.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.source.extractor.extract.google;
+package org.apache.gobblin.source.extractor.extract.google;
import java.io.Closeable;
import java.io.IOException;
@@ -47,22 +47,22 @@ import com.google.common.io.Closer;
import com.typesafe.config.Config;
import com.typesafe.config.ConfigFactory;
-import static gobblin.retry.RetryerFactory.*;
-import static gobblin.configuration.ConfigurationKeys.*;
-import static gobblin.source.extractor.extract.google.GoogleCommonKeys.*;
-import static gobblin.source.extractor.extract.google.GoogleAnalyticsUnsampledSource.*;
-import gobblin.config.ConfigBuilder;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.instrumented.Instrumented;
-import gobblin.metrics.GobblinMetrics;
-import gobblin.retry.RetryerFactory;
-import gobblin.source.extractor.DataRecordException;
-import gobblin.source.extractor.Extractor;
-import gobblin.source.extractor.extract.LongWatermark;
-import gobblin.source.extractor.filebased.CsvFileDownloader;
-import gobblin.source.workunit.WorkUnit;
-import gobblin.writer.exception.NonTransientException;
+import static org.apache.gobblin.retry.RetryerFactory.*;
+import static org.apache.gobblin.configuration.ConfigurationKeys.*;
+import static org.apache.gobblin.source.extractor.extract.google.GoogleCommonKeys.*;
+import static org.apache.gobblin.source.extractor.extract.google.GoogleAnalyticsUnsampledSource.*;
+import org.apache.gobblin.config.ConfigBuilder;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.instrumented.Instrumented;
+import org.apache.gobblin.metrics.GobblinMetrics;
+import org.apache.gobblin.retry.RetryerFactory;
+import org.apache.gobblin.source.extractor.DataRecordException;
+import org.apache.gobblin.source.extractor.Extractor;
+import org.apache.gobblin.source.extractor.extract.LongWatermark;
+import org.apache.gobblin.source.extractor.filebased.CsvFileDownloader;
+import org.apache.gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.writer.exception.NonTransientException;
/**
* Extracts Google Analytics(GA) unsampled report data.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleAnalyticsUnsampledSource.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleAnalyticsUnsampledSource.java b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleAnalyticsUnsampledSource.java
index e5471b3..f0b6e20 100644
--- a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleAnalyticsUnsampledSource.java
+++ b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleAnalyticsUnsampledSource.java
@@ -14,16 +14,16 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.source.extractor.extract.google;
+package org.apache.gobblin.source.extractor.extract.google;
import java.io.IOException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.extractor.Extractor;
-import gobblin.source.extractor.extract.QueryBasedSource;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.source.extractor.Extractor;
+import org.apache.gobblin.source.extractor.extract.QueryBasedSource;
/**
* Source for Google analytics unsampled report.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleCommon.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleCommon.java b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleCommon.java
index 42143b8..9df3d45 100644
--- a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleCommon.java
+++ b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleCommon.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.source.extractor.extract.google;
+package org.apache.gobblin.source.extractor.extract.google;
import java.io.File;
import java.io.IOException;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleCommonKeys.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleCommonKeys.java b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleCommonKeys.java
index 7ea8d7d..88ce1e3 100644
--- a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleCommonKeys.java
+++ b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleCommonKeys.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.source.extractor.extract.google;
+package org.apache.gobblin.source.extractor.extract.google;
public interface GoogleCommonKeys {
public static final String GOOGLE_SOURCE_PREFIX = "source.google.";
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveExtractor.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveExtractor.java b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveExtractor.java
index 7a8bcc1..faedb75 100644
--- a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveExtractor.java
+++ b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveExtractor.java
@@ -14,14 +14,14 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.source.extractor.extract.google;
+package org.apache.gobblin.source.extractor.extract.google;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.extractor.filebased.FileBasedExtractor;
-import gobblin.source.extractor.filebased.FileBasedHelper;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.source.extractor.filebased.FileBasedExtractor;
+import org.apache.gobblin.source.extractor.filebased.FileBasedHelper;
/**
* Extractor for files in Google drive.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveFileSystem.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveFileSystem.java b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveFileSystem.java
index fc58b6c..a570a09 100644
--- a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveFileSystem.java
+++ b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveFileSystem.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.source.extractor.extract.google;
+package org.apache.gobblin.source.extractor.extract.google;
import java.io.BufferedInputStream;
import java.io.FileNotFoundException;
@@ -46,11 +46,11 @@ import com.google.common.base.Optional;
import com.google.common.base.Preconditions;
import com.google.common.io.Closer;
-import static gobblin.configuration.ConfigurationKeys.*;
-import static gobblin.source.extractor.extract.google.GoogleCommonKeys.*;
-import gobblin.configuration.State;
-import gobblin.util.HadoopUtils;
-import gobblin.util.io.SeekableFSInputStream;
+import static org.apache.gobblin.configuration.ConfigurationKeys.*;
+import static org.apache.gobblin.source.extractor.extract.google.GoogleCommonKeys.*;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.util.HadoopUtils;
+import org.apache.gobblin.util.io.SeekableFSInputStream;
/**
* A {@link FileSystem} implementation that provides the {@link FileSystem} interface for an Google Drive server.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveFsHelper.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveFsHelper.java b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveFsHelper.java
index df08bdc..d12a19a 100644
--- a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveFsHelper.java
+++ b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveFsHelper.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.source.extractor.extract.google;
+package org.apache.gobblin.source.extractor.extract.google;
import java.io.FileNotFoundException;
import java.io.IOException;
@@ -35,9 +35,9 @@ import com.google.common.base.Optional;
import com.google.common.base.Preconditions;
import com.google.common.io.Closer;
-import gobblin.configuration.State;
-import gobblin.source.extractor.filebased.FileBasedHelperException;
-import gobblin.source.extractor.filebased.TimestampAwareFileBasedHelper;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.source.extractor.filebased.FileBasedHelperException;
+import org.apache.gobblin.source.extractor.filebased.TimestampAwareFileBasedHelper;
/**
* File system helper for Google drive.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveSource.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveSource.java b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveSource.java
index a3aea8d..b34a485 100644
--- a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveSource.java
+++ b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveSource.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.source.extractor.extract.google;
+package org.apache.gobblin.source.extractor.extract.google;
import java.io.IOException;
import java.util.ArrayList;
@@ -28,14 +28,14 @@ import com.google.api.client.repackaged.com.google.common.base.Preconditions;
import com.google.api.services.drive.Drive;
import com.google.common.io.Closer;
-import static gobblin.configuration.ConfigurationKeys.*;
-import static gobblin.source.extractor.extract.google.GoogleCommonKeys.*;
-import gobblin.configuration.SourceState;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.extractor.Extractor;
-import gobblin.source.extractor.filebased.FileBasedHelperException;
-import gobblin.source.extractor.filebased.FileBasedSource;
+import static org.apache.gobblin.configuration.ConfigurationKeys.*;
+import static org.apache.gobblin.source.extractor.extract.google.GoogleCommonKeys.*;
+import org.apache.gobblin.configuration.SourceState;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.source.extractor.Extractor;
+import org.apache.gobblin.source.extractor.filebased.FileBasedHelperException;
+import org.apache.gobblin.source.extractor.filebased.FileBasedSource;
/**
* Source for Google drive using GoogleDriveFsHelper.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterDataFetcherImplTest.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterDataFetcherImplTest.java b/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterDataFetcherImplTest.java
index 12e41f6..b9149d1 100644
--- a/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterDataFetcherImplTest.java
+++ b/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterDataFetcherImplTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.ingestion.google.webmaster;
+package org.apache.gobblin.ingestion.google.webmaster;
import java.util.ArrayList;
import java.util.Arrays;
@@ -27,7 +27,7 @@ import org.mockito.Mockito;
import org.testng.Assert;
import org.testng.annotations.Test;
-import gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.configuration.WorkUnitState;
import static org.mockito.Matchers.any;
import static org.mockito.Matchers.eq;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterExtractorIteratorTest.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterExtractorIteratorTest.java b/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterExtractorIteratorTest.java
index d316f93..834a91a 100644
--- a/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterExtractorIteratorTest.java
+++ b/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterExtractorIteratorTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.ingestion.google.webmaster;
+package org.apache.gobblin.ingestion.google.webmaster;
import java.io.IOException;
import java.util.ArrayDeque;
@@ -33,7 +33,7 @@ import org.testng.annotations.Test;
import com.google.api.services.webmasters.model.ApiDimensionFilter;
-import gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.configuration.WorkUnitState;
import static org.mockito.Matchers.argThat;
import static org.mockito.Matchers.eq;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterExtractorTest.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterExtractorTest.java b/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterExtractorTest.java
index aed3e8f..97cdad4 100644
--- a/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterExtractorTest.java
+++ b/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterExtractorTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.ingestion.google.webmaster;
+package org.apache.gobblin.ingestion.google.webmaster;
import java.io.IOException;
import java.util.Arrays;
@@ -27,13 +27,13 @@ import org.mockito.Mockito;
import org.testng.Assert;
import org.testng.annotations.Test;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.extractor.DataRecordException;
-import gobblin.source.extractor.WatermarkInterval;
-import gobblin.source.extractor.extract.LongWatermark;
-import gobblin.source.workunit.Extract;
-import gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.source.extractor.DataRecordException;
+import org.apache.gobblin.source.extractor.WatermarkInterval;
+import org.apache.gobblin.source.extractor.extract.LongWatermark;
+import org.apache.gobblin.source.workunit.Extract;
+import org.apache.gobblin.source.workunit.WorkUnit;
@Test(groups = {"gobblin.source.extractor.extract.google.webmaster"})
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/ProducerJobTest.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/ProducerJobTest.java b/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/ProducerJobTest.java
index 7289a1c..423fb43 100644
--- a/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/ProducerJobTest.java
+++ b/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/ProducerJobTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.ingestion.google.webmaster;
+package org.apache.gobblin.ingestion.google.webmaster;
import java.util.ArrayList;
import java.util.List;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/SimpleProducerJobTest.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/SimpleProducerJobTest.java b/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/SimpleProducerJobTest.java
index a5dee6f..e211c05 100644
--- a/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/SimpleProducerJobTest.java
+++ b/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/SimpleProducerJobTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.ingestion.google.webmaster;
+package org.apache.gobblin.ingestion.google.webmaster;
import java.util.List;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/TrieBasedProducerJobTest.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/TrieBasedProducerJobTest.java b/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/TrieBasedProducerJobTest.java
index d9a0429..1152469 100644
--- a/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/TrieBasedProducerJobTest.java
+++ b/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/TrieBasedProducerJobTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.ingestion.google.webmaster;
+package org.apache.gobblin.ingestion.google.webmaster;
import java.util.List;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/UrlTriePostOrderIteratorTest.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/UrlTriePostOrderIteratorTest.java b/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/UrlTriePostOrderIteratorTest.java
index 9ef3a24..80bf970 100644
--- a/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/UrlTriePostOrderIteratorTest.java
+++ b/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/UrlTriePostOrderIteratorTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.ingestion.google.webmaster;
+package org.apache.gobblin.ingestion.google.webmaster;
import java.util.ArrayList;
import java.util.Arrays;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/UrlTriePrefixGrouperTest.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/UrlTriePrefixGrouperTest.java b/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/UrlTriePrefixGrouperTest.java
index b5a9a16..a418967 100644
--- a/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/UrlTriePrefixGrouperTest.java
+++ b/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/UrlTriePrefixGrouperTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.ingestion.google.webmaster;
+package org.apache.gobblin.ingestion.google.webmaster;
import java.util.ArrayList;
import java.util.Arrays;
@@ -25,7 +25,7 @@ import org.apache.commons.lang3.tuple.Triple;
import org.testng.Assert;
import org.testng.annotations.Test;
-import gobblin.ingestion.google.webmaster.GoogleWebmasterFilter.FilterOperator;
+import org.apache.gobblin.ingestion.google.webmaster.GoogleWebmasterFilter.FilterOperator;
@Test(groups = {"gobblin.source.extractor.extract.google.webmaster"})
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/UrlTrieTest.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/UrlTrieTest.java b/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/UrlTrieTest.java
index 6c342b4..085768c 100644
--- a/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/UrlTrieTest.java
+++ b/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/ingestion/google/webmaster/UrlTrieTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.ingestion.google.webmaster;
+package org.apache.gobblin.ingestion.google.webmaster;
import java.util.ArrayList;
import java.util.Arrays;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/source/extractor/extract/google/GoogleAnalyticsUnsampledExtractorTest.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/source/extractor/extract/google/GoogleAnalyticsUnsampledExtractorTest.java b/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/source/extractor/extract/google/GoogleAnalyticsUnsampledExtractorTest.java
index 777805b..6e6dca0 100644
--- a/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/source/extractor/extract/google/GoogleAnalyticsUnsampledExtractorTest.java
+++ b/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/source/extractor/extract/google/GoogleAnalyticsUnsampledExtractorTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.source.extractor.extract.google;
+package org.apache.gobblin.source.extractor.extract.google;
import java.io.IOException;
import java.util.concurrent.TimeUnit;
@@ -34,11 +34,11 @@ import com.google.api.services.analytics.Analytics.Management.UnsampledReports.G
import com.google.api.services.analytics.model.UnsampledReport;
import com.google.api.services.analytics.model.UnsampledReport.DriveDownloadDetails;
-import static gobblin.retry.RetryerFactory.*;
-import static gobblin.source.extractor.extract.google.GoogleAnalyticsUnsampledExtractor.*;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.extractor.Extractor;
-import gobblin.writer.exception.NonTransientException;
+import static org.apache.gobblin.retry.RetryerFactory.*;
+import static org.apache.gobblin.source.extractor.extract.google.GoogleAnalyticsUnsampledExtractor.*;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.source.extractor.Extractor;
+import org.apache.gobblin.writer.exception.NonTransientException;
@Test(groups = { "gobblin.source.extractor.google" })
public class GoogleAnalyticsUnsampledExtractorTest {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveFileSystemTest.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveFileSystemTest.java b/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveFileSystemTest.java
index 49134fe..b7a7e6c 100644
--- a/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveFileSystemTest.java
+++ b/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveFileSystemTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.source.extractor.extract.google;
+package org.apache.gobblin.source.extractor.extract.google;
import java.io.IOException;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveFsHelperTest.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveFsHelperTest.java b/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveFsHelperTest.java
index d6e4667..68959e2 100644
--- a/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveFsHelperTest.java
+++ b/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveFsHelperTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.source.extractor.extract.google;
+package org.apache.gobblin.source.extractor.extract.google;
import static org.mockito.Mockito.*;
@@ -38,9 +38,9 @@ import com.google.common.collect.ImmutableList;
import com.google.common.collect.Lists;
import com.google.common.io.Closer;
-import static gobblin.source.extractor.extract.google.GoogleDriveFileSystem.*;
-import gobblin.configuration.State;
-import gobblin.source.extractor.filebased.FileBasedHelperException;
+import static org.apache.gobblin.source.extractor.extract.google.GoogleDriveFileSystem.*;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.source.extractor.filebased.FileBasedHelperException;
@Test(groups = { "gobblin.source.extractor.google" })
public class GoogleDriveFsHelperTest {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/source/extractor/filebased/GoogleDriveSourceTest.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/source/extractor/filebased/GoogleDriveSourceTest.java b/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/source/extractor/filebased/GoogleDriveSourceTest.java
index 90add1d..3997bc9 100644
--- a/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/source/extractor/filebased/GoogleDriveSourceTest.java
+++ b/gobblin-modules/google-ingestion/src/test/java/org/apache/gobblin/source/extractor/filebased/GoogleDriveSourceTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.source.extractor.filebased;
+package org.apache.gobblin.source.extractor.filebased;
import static org.mockito.Mockito.*;
@@ -28,12 +28,12 @@ import org.testng.annotations.Test;
import com.google.common.collect.ImmutableList;
import com.google.common.collect.Lists;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.extractor.Extractor;
-import gobblin.source.extractor.extract.google.GoogleDriveExtractor;
-import gobblin.source.extractor.extract.google.GoogleDriveFsHelper;
-import gobblin.source.extractor.extract.google.GoogleDriveSource;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.source.extractor.Extractor;
+import org.apache.gobblin.source.extractor.extract.google.GoogleDriveExtractor;
+import org.apache.gobblin.source.extractor.extract.google.GoogleDriveFsHelper;
+import org.apache.gobblin.source.extractor.extract.google.GoogleDriveSource;
@Test(groups = { "gobblin.source.extractor.google" })
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-rest-service/gobblin-rest-api/src/main/idl/gobblin.rest.jobExecutions.restspec.json
----------------------------------------------------------------------
diff --git a/gobblin-rest-service/gobblin-rest-api/src/main/idl/gobblin.rest.jobExecutions.restspec.json b/gobblin-rest-service/gobblin-rest-api/src/main/idl/gobblin.rest.jobExecutions.restspec.json
index b93bf8a..4be751e 100644
--- a/gobblin-rest-service/gobblin-rest-api/src/main/idl/gobblin.rest.jobExecutions.restspec.json
+++ b/gobblin-rest-service/gobblin-rest-api/src/main/idl/gobblin.rest.jobExecutions.restspec.json
@@ -1,8 +1,8 @@
{
"name" : "jobExecutions",
- "namespace" : "gobblin.rest",
+ "namespace" : "org.apache.gobblin.rest",
"path" : "/jobExecutions",
- "schema" : "gobblin.rest.JobExecutionQueryResult",
+ "schema" : "org.apache.gobblin.rest.JobExecutionQueryResult",
"doc" : "A Rest.li resource for serving queries of Gobblin job executions.\n\ngenerated from: gobblin.rest.JobExecutionInfoResource",
"collection" : {
"identifier" : {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-rest-service/gobblin-rest-api/src/main/pegasus/org/apache/gobblin/rest/JobExecutionInfo.pdsc
----------------------------------------------------------------------
diff --git a/gobblin-rest-service/gobblin-rest-api/src/main/pegasus/org/apache/gobblin/rest/JobExecutionInfo.pdsc b/gobblin-rest-service/gobblin-rest-api/src/main/pegasus/org/apache/gobblin/rest/JobExecutionInfo.pdsc
index c4ea435..bc0eecb 100644
--- a/gobblin-rest-service/gobblin-rest-api/src/main/pegasus/org/apache/gobblin/rest/JobExecutionInfo.pdsc
+++ b/gobblin-rest-service/gobblin-rest-api/src/main/pegasus/org/apache/gobblin/rest/JobExecutionInfo.pdsc
@@ -1,7 +1,7 @@
{
"type": "record",
"name": "JobExecutionInfo",
- "namespace": "gobblin.rest",
+ "namesapce" : "org.apache.gobblin.rest",
"doc": "Gobblin job execution information",
"fields": [
{
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-rest-service/gobblin-rest-api/src/main/pegasus/org/apache/gobblin/rest/JobExecutionQuery.pdsc
----------------------------------------------------------------------
diff --git a/gobblin-rest-service/gobblin-rest-api/src/main/pegasus/org/apache/gobblin/rest/JobExecutionQuery.pdsc b/gobblin-rest-service/gobblin-rest-api/src/main/pegasus/org/apache/gobblin/rest/JobExecutionQuery.pdsc
index b14d779..da11866 100644
--- a/gobblin-rest-service/gobblin-rest-api/src/main/pegasus/org/apache/gobblin/rest/JobExecutionQuery.pdsc
+++ b/gobblin-rest-service/gobblin-rest-api/src/main/pegasus/org/apache/gobblin/rest/JobExecutionQuery.pdsc
@@ -1,7 +1,7 @@
{
"type": "record",
"name": "JobExecutionQuery",
- "namespace": "gobblin.rest",
+ "namesapce" : "org.apache.gobblin.rest",
"doc": "Gobblin job execution query",
"fields": [
{
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-rest-service/gobblin-rest-api/src/main/pegasus/org/apache/gobblin/rest/JobExecutionQueryResult.pdsc
----------------------------------------------------------------------
diff --git a/gobblin-rest-service/gobblin-rest-api/src/main/pegasus/org/apache/gobblin/rest/JobExecutionQueryResult.pdsc b/gobblin-rest-service/gobblin-rest-api/src/main/pegasus/org/apache/gobblin/rest/JobExecutionQueryResult.pdsc
index 8424483..cac0f88 100644
--- a/gobblin-rest-service/gobblin-rest-api/src/main/pegasus/org/apache/gobblin/rest/JobExecutionQueryResult.pdsc
+++ b/gobblin-rest-service/gobblin-rest-api/src/main/pegasus/org/apache/gobblin/rest/JobExecutionQueryResult.pdsc
@@ -1,7 +1,7 @@
{
"type": "record",
"name": "JobExecutionQueryResult",
- "namespace": "gobblin.rest",
+ "namesapce" : "org.apache.gobblin.rest",
"doc": "Gobblin job execution query result",
"fields": [
{
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-rest-service/gobblin-rest-api/src/main/pegasus/org/apache/gobblin/rest/Metric.pdsc
----------------------------------------------------------------------
diff --git a/gobblin-rest-service/gobblin-rest-api/src/main/pegasus/org/apache/gobblin/rest/Metric.pdsc b/gobblin-rest-service/gobblin-rest-api/src/main/pegasus/org/apache/gobblin/rest/Metric.pdsc
index 89f239c..c70fc74 100644
--- a/gobblin-rest-service/gobblin-rest-api/src/main/pegasus/org/apache/gobblin/rest/Metric.pdsc
+++ b/gobblin-rest-service/gobblin-rest-api/src/main/pegasus/org/apache/gobblin/rest/Metric.pdsc
@@ -1,7 +1,7 @@
{
"type": "record",
"name": "Metric",
- "namespace": "gobblin.rest",
+ "namesapce" : "org.apache.gobblin.rest",
"doc": "Gobblin metric",
"fields": [
{
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-rest-service/gobblin-rest-api/src/main/pegasus/org/apache/gobblin/rest/Table.pdsc
----------------------------------------------------------------------
diff --git a/gobblin-rest-service/gobblin-rest-api/src/main/pegasus/org/apache/gobblin/rest/Table.pdsc b/gobblin-rest-service/gobblin-rest-api/src/main/pegasus/org/apache/gobblin/rest/Table.pdsc
index 24153d8..29b5c49 100644
--- a/gobblin-rest-service/gobblin-rest-api/src/main/pegasus/org/apache/gobblin/rest/Table.pdsc
+++ b/gobblin-rest-service/gobblin-rest-api/src/main/pegasus/org/apache/gobblin/rest/Table.pdsc
@@ -1,7 +1,7 @@
{
"type": "record",
"name": "Table",
- "namespace": "gobblin.rest",
+ "namesapce" : "org.apache.gobblin.rest",
"doc": "Gobblin table definition",
"fields": [
{
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-rest-service/gobblin-rest-api/src/main/pegasus/org/apache/gobblin/rest/TaskExecutionInfo.pdsc
----------------------------------------------------------------------
diff --git a/gobblin-rest-service/gobblin-rest-api/src/main/pegasus/org/apache/gobblin/rest/TaskExecutionInfo.pdsc b/gobblin-rest-service/gobblin-rest-api/src/main/pegasus/org/apache/gobblin/rest/TaskExecutionInfo.pdsc
index b490e85..c718072 100644
--- a/gobblin-rest-service/gobblin-rest-api/src/main/pegasus/org/apache/gobblin/rest/TaskExecutionInfo.pdsc
+++ b/gobblin-rest-service/gobblin-rest-api/src/main/pegasus/org/apache/gobblin/rest/TaskExecutionInfo.pdsc
@@ -1,7 +1,7 @@
{
"type": "record",
"name": "TaskExecutionInfo",
- "namespace": "gobblin.rest",
+ "namesapce" : "org.apache.gobblin.rest",
"doc": "Gobblin task execution information",
"fields": [
{
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-rest-service/gobblin-rest-api/src/main/pegasus/org/apache/gobblin/rest/TimeRange.pdsc
----------------------------------------------------------------------
diff --git a/gobblin-rest-service/gobblin-rest-api/src/main/pegasus/org/apache/gobblin/rest/TimeRange.pdsc b/gobblin-rest-service/gobblin-rest-api/src/main/pegasus/org/apache/gobblin/rest/TimeRange.pdsc
index 45fdd8c..bd57225 100644
--- a/gobblin-rest-service/gobblin-rest-api/src/main/pegasus/org/apache/gobblin/rest/TimeRange.pdsc
+++ b/gobblin-rest-service/gobblin-rest-api/src/main/pegasus/org/apache/gobblin/rest/TimeRange.pdsc
@@ -1,7 +1,7 @@
{
"type": "record",
"name": "TimeRange",
- "namespace": "gobblin.rest",
+ "namesapce" : "org.apache.gobblin.rest",
"doc": "Query time range",
"fields": [
{
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-rest-service/gobblin-rest-api/src/main/snapshot/gobblin.rest.jobExecutions.snapshot.json
----------------------------------------------------------------------
diff --git a/gobblin-rest-service/gobblin-rest-api/src/main/snapshot/gobblin.rest.jobExecutions.snapshot.json b/gobblin-rest-service/gobblin-rest-api/src/main/snapshot/gobblin.rest.jobExecutions.snapshot.json
index 594128c..fe626e4 100644
--- a/gobblin-rest-service/gobblin-rest-api/src/main/snapshot/gobblin.rest.jobExecutions.snapshot.json
+++ b/gobblin-rest-service/gobblin-rest-api/src/main/snapshot/gobblin.rest.jobExecutions.snapshot.json
@@ -2,27 +2,27 @@
"models" : [ {
"type" : "enum",
"name" : "JobStateEnum",
- "namespace" : "gobblin.rest",
+ "namespace" : "org.apache.gobblin.rest",
"symbols" : [ "PENDING", "RUNNING", "SUCCESSFUL", "COMMITTED", "FAILED", "CANCELLED" ]
}, {
"type" : "enum",
"name" : "LauncherTypeEnum",
- "namespace" : "gobblin.rest",
+ "namespace" : "org.apache.gobblin.rest",
"symbols" : [ "LOCAL", "MAPREDUCE", "CLUSTER", "YARN" ]
}, {
"type" : "enum",
"name" : "TaskStateEnum",
- "namespace" : "gobblin.rest",
+ "namespace" : "org.apache.gobblin.rest",
"symbols" : [ "PENDING", "RUNNING", "SUCCESSFUL", "COMMITTED", "FAILED", "CANCELLED" ]
}, {
"type" : "enum",
"name" : "TableTypeEnum",
- "namespace" : "gobblin.rest",
+ "namespace" : "org.apache.gobblin.rest",
"symbols" : [ "SNAPSHOT_ONLY", "SNAPSHOT_APPEND", "APPEND_ONLY" ]
}, {
"type" : "record",
"name" : "Table",
- "namespace" : "gobblin.rest",
+ "namespace" : "org.apache.gobblin.rest",
"doc" : "Gobblin table definition",
"fields" : [ {
"name" : "namespace",
@@ -42,12 +42,12 @@
}, {
"type" : "enum",
"name" : "MetricTypeEnum",
- "namespace" : "gobblin.rest",
+ "namespace" : "org.apache.gobblin.rest",
"symbols" : [ "COUNTER", "METER", "GAUGE" ]
}, {
"type" : "record",
"name" : "Metric",
- "namespace" : "gobblin.rest",
+ "namespace" : "org.apache.gobblin.rest",
"doc" : "Gobblin metric",
"fields" : [ {
"name" : "group",
@@ -69,7 +69,7 @@
}, {
"type" : "record",
"name" : "TaskExecutionInfo",
- "namespace" : "gobblin.rest",
+ "namespace" : "org.apache.gobblin.rest",
"doc" : "Gobblin task execution information",
"fields" : [ {
"name" : "jobId",
@@ -138,7 +138,7 @@
}, {
"type" : "record",
"name" : "JobExecutionInfo",
- "namespace" : "gobblin.rest",
+ "namespace" : "org.apache.gobblin.rest",
"doc" : "Gobblin job execution information",
"fields" : [ {
"name" : "jobName",
@@ -214,7 +214,7 @@
}, {
"type" : "record",
"name" : "JobExecutionQueryResult",
- "namespace" : "gobblin.rest",
+ "namespace" : "org.apache.gobblin.rest",
"doc" : "Gobblin job execution query result",
"fields" : [ {
"name" : "jobExecutions",
@@ -227,18 +227,18 @@
}, {
"type" : "enum",
"name" : "QueryListType",
- "namespace" : "gobblin.rest",
+ "namespace" : "org.apache.gobblin.rest",
"doc" : "Listing distinct jobs fetches the most recent execution info for each job name in the database. Listing recent jobs fetches the most recent job executions, regardless of job name.",
"symbols" : [ "DISTINCT", "RECENT" ]
}, {
"type" : "enum",
"name" : "QueryIdTypeEnum",
- "namespace" : "gobblin.rest",
+ "namespace" : "org.apache.gobblin.rest",
"symbols" : [ "JOB_NAME", "JOB_ID", "TABLE", "LIST_TYPE" ]
}, {
"type" : "record",
"name" : "TimeRange",
- "namespace" : "gobblin.rest",
+ "namespace" : "org.apache.gobblin.rest",
"doc" : "Query time range",
"fields" : [ {
"name" : "startTime",
@@ -258,7 +258,7 @@
}, {
"type" : "record",
"name" : "JobExecutionQuery",
- "namespace" : "gobblin.rest",
+ "namespace" : "org.apache.gobblin.rest",
"doc" : "Gobblin job execution query",
"fields" : [ {
"name" : "id",
@@ -326,9 +326,9 @@
} ],
"schema" : {
"name" : "jobExecutions",
- "namespace" : "gobblin.rest",
+ "namespace" : "org.apache.gobblin.rest",
"path" : "/jobExecutions",
- "schema" : "gobblin.rest.JobExecutionQueryResult",
+ "schema" : "org.apache.gobblin.rest.JobExecutionQueryResult",
"doc" : "A Rest.li resource for serving queries of Gobblin job executions.\n\ngenerated from: gobblin.rest.JobExecutionInfoResource",
"collection" : {
"identifier" : {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-rest-service/gobblin-rest-client/src/main/java/org/apache/gobblin/rest/JobExecutionInfoClient.java
----------------------------------------------------------------------
diff --git a/gobblin-rest-service/gobblin-rest-client/src/main/java/org/apache/gobblin/rest/JobExecutionInfoClient.java b/gobblin-rest-service/gobblin-rest-client/src/main/java/org/apache/gobblin/rest/JobExecutionInfoClient.java
index 5537ae3..7993fc0 100644
--- a/gobblin-rest-service/gobblin-rest-client/src/main/java/org/apache/gobblin/rest/JobExecutionInfoClient.java
+++ b/gobblin-rest-service/gobblin-rest-client/src/main/java/org/apache/gobblin/rest/JobExecutionInfoClient.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.rest;
+package org.apache.gobblin.rest;
import java.io.Closeable;
import java.io.IOException;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-rest-service/gobblin-rest-server/src/main/java/org/apache/gobblin/rest/JobExecutionInfoResource.java
----------------------------------------------------------------------
diff --git a/gobblin-rest-service/gobblin-rest-server/src/main/java/org/apache/gobblin/rest/JobExecutionInfoResource.java b/gobblin-rest-service/gobblin-rest-server/src/main/java/org/apache/gobblin/rest/JobExecutionInfoResource.java
index ba04bf6..bcaa164 100644
--- a/gobblin-rest-service/gobblin-rest-server/src/main/java/org/apache/gobblin/rest/JobExecutionInfoResource.java
+++ b/gobblin-rest-service/gobblin-rest-server/src/main/java/org/apache/gobblin/rest/JobExecutionInfoResource.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.rest;
+package org.apache.gobblin.rest;
import com.linkedin.restli.server.ResourceContext;
import java.util.Map;
@@ -33,7 +33,7 @@ import com.linkedin.restli.common.EmptyRecord;
import com.linkedin.restli.server.annotations.RestLiCollection;
import com.linkedin.restli.server.resources.ComplexKeyResourceTemplate;
-import gobblin.metastore.JobHistoryStore;
+import org.apache.gobblin.metastore.JobHistoryStore;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-rest-service/gobblin-rest-server/src/main/java/org/apache/gobblin/rest/JobExecutionInfoServer.java
----------------------------------------------------------------------
diff --git a/gobblin-rest-service/gobblin-rest-server/src/main/java/org/apache/gobblin/rest/JobExecutionInfoServer.java b/gobblin-rest-service/gobblin-rest-server/src/main/java/org/apache/gobblin/rest/JobExecutionInfoServer.java
index 8d90ca9..121701d 100644
--- a/gobblin-rest-service/gobblin-rest-server/src/main/java/org/apache/gobblin/rest/JobExecutionInfoServer.java
+++ b/gobblin-rest-service/gobblin-rest-server/src/main/java/org/apache/gobblin/rest/JobExecutionInfoServer.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.rest;
+package org.apache.gobblin.rest;
import java.net.URI;
import java.util.Properties;
@@ -43,9 +43,9 @@ import com.linkedin.restli.server.mock.InjectMockResourceFactory;
import com.linkedin.restli.server.mock.SimpleBeanProvider;
import com.linkedin.restli.server.resources.ResourceFactory;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.metastore.JobHistoryStore;
-import gobblin.metastore.MetaStoreModule;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.metastore.JobHistoryStore;
+import org.apache.gobblin.metastore.MetaStoreModule;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-rest-service/gobblin-rest-server/src/test/java/org/apache/gobblin/rest/JobExecutionInfoServerTest.java
----------------------------------------------------------------------
diff --git a/gobblin-rest-service/gobblin-rest-server/src/test/java/org/apache/gobblin/rest/JobExecutionInfoServerTest.java b/gobblin-rest-service/gobblin-rest-server/src/test/java/org/apache/gobblin/rest/JobExecutionInfoServerTest.java
index 810d8ba..a97b030 100644
--- a/gobblin-rest-service/gobblin-rest-server/src/test/java/org/apache/gobblin/rest/JobExecutionInfoServerTest.java
+++ b/gobblin-rest-service/gobblin-rest-server/src/test/java/org/apache/gobblin/rest/JobExecutionInfoServerTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.rest;
+package org.apache.gobblin.rest;
import java.io.IOException;
import java.net.ServerSocket;
@@ -35,11 +35,11 @@ import com.google.inject.Injector;
import com.linkedin.data.template.StringMap;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.metastore.JobHistoryStore;
-import gobblin.metastore.MetaStoreModule;
-import gobblin.metastore.testing.ITestMetastoreDatabase;
-import gobblin.metastore.testing.TestMetastoreDatabaseFactory;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.metastore.JobHistoryStore;
+import org.apache.gobblin.metastore.MetaStoreModule;
+import org.apache.gobblin.metastore.testing.ITestMetastoreDatabase;
+import org.apache.gobblin.metastore.testing.TestMetastoreDatabaseFactory;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowconfigs.restspec.json
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowconfigs.restspec.json b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowconfigs.restspec.json
index e7dae4a..8191d60 100644
--- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowconfigs.restspec.json
+++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowconfigs.restspec.json
@@ -1,8 +1,8 @@
{
"name" : "flowconfigs",
- "namespace" : "gobblin.service",
+ "namespace" : "org.apache.gobblin.service",
"path" : "/flowconfigs",
- "schema" : "gobblin.service.FlowConfig",
+ "schema" : "org.apache.gobblin.service.FlowConfig",
"doc" : "Resource for handling flow configuration requests\n\ngenerated from: gobblin.service.FlowConfigsResource",
"collection" : {
"identifier" : {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowstatuses.restspec.json
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowstatuses.restspec.json b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowstatuses.restspec.json
index 021c38f..97f7da1 100644
--- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowstatuses.restspec.json
+++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowstatuses.restspec.json
@@ -1,8 +1,8 @@
{
"name" : "flowstatuses",
- "namespace" : "gobblin.service",
+ "namespace" : "org.apache.gobblin.service",
"path" : "/flowstatuses",
- "schema" : "gobblin.service.FlowStatus",
+ "schema" : "org.apache.gobblin.service.FlowStatus",
"doc" : "Resource for handling flow status requests\n\ngenerated from: gobblin.service.FlowStatusResource",
"collection" : {
"identifier" : {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/ExecutionStatus.pdsc
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/ExecutionStatus.pdsc b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/ExecutionStatus.pdsc
index 9baffaf..84d7c5d 100644
--- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/ExecutionStatus.pdsc
+++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/ExecutionStatus.pdsc
@@ -1,7 +1,7 @@
{
"type" : "enum",
"name" : "ExecutionStatus",
- "namespace" : "gobblin.service",
+ "namesapce" : "org.apache.gobblin.service",
"doc" : "Execution status for a flow or job",
"symbols" : ["RUNNING", "FAILED", "COMPLETE"],
"symbolDocs" : {"RUNNING":"Flow or job is currently executing", "FAILED":"Flow or job failed",
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/FlowConfig.pdsc
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/FlowConfig.pdsc b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/FlowConfig.pdsc
index d237d4d..b77c204 100644
--- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/FlowConfig.pdsc
+++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/FlowConfig.pdsc
@@ -1,7 +1,7 @@
{
"type" : "record",
"name" : "FlowConfig",
- "namespace": "gobblin.service",
+ "namesapce" : "org.apache.gobblin.service",
"doc" : "Defines a flow configuration that can be compiled into Gobblin jobs",
"fields" : [
{
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/FlowId.pdsc
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/FlowId.pdsc b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/FlowId.pdsc
index c4d81d4..6b4441b 100644
--- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/FlowId.pdsc
+++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/FlowId.pdsc
@@ -1,7 +1,7 @@
{
"type" : "record",
"name" : "FlowId",
- "namespace": "gobblin.service",
+ "namesapce" : "org.apache.gobblin.service",
"doc" : "Identifier for a Gobblin as a Service flow",
"fields" : [
{
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/FlowStatistics.pdsc
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/FlowStatistics.pdsc b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/FlowStatistics.pdsc
index 03ac8f9..34a5fa0 100644
--- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/FlowStatistics.pdsc
+++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/FlowStatistics.pdsc
@@ -1,7 +1,7 @@
{
"type" : "record",
"name" : "FlowStatistics",
- "namespace": "gobblin.service",
+ "namesapce" : "org.apache.gobblin.service",
"doc" : "Statistics from a flow execution",
"fields" : [
{
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/FlowStatus.pdsc
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/FlowStatus.pdsc b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/FlowStatus.pdsc
index c5247e0..37f9259 100644
--- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/FlowStatus.pdsc
+++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/FlowStatus.pdsc
@@ -1,7 +1,7 @@
{
"type" : "record",
"name" : "FlowStatus",
- "namespace": "gobblin.service",
+ "namesapce" : "org.apache.gobblin.service",
"doc" : "Status of a flow",
"fields" : [
{
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/FlowStatusId.pdsc
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/FlowStatusId.pdsc b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/FlowStatusId.pdsc
index 85953ac..e56de25 100644
--- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/FlowStatusId.pdsc
+++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/FlowStatusId.pdsc
@@ -1,7 +1,7 @@
{
"type" : "record",
"name" : "FlowStatusId",
- "namespace": "gobblin.service",
+ "namesapce" : "org.apache.gobblin.service",
"doc" : "Identifier for a specific execution of a flow",
"fields" : [
{
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/JobId.pdsc
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/JobId.pdsc b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/JobId.pdsc
index 801bb55..3b2907c 100644
--- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/JobId.pdsc
+++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/JobId.pdsc
@@ -1,7 +1,7 @@
{
"type" : "record",
"name" : "JobId",
- "namespace": "gobblin.service",
+ "namesapce" : "org.apache.gobblin.service",
"doc" : "Identifier for a Gobblin job",
"fields" : [
{
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/JobState.pdsc
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/JobState.pdsc b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/JobState.pdsc
index 222a8a4..b8b7e31 100644
--- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/JobState.pdsc
+++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/JobState.pdsc
@@ -1,7 +1,7 @@
{
"type" : "record",
"name" : "JobState",
- "namespace": "gobblin.service",
+ "namesapce" : "org.apache.gobblin.service",
"doc" : "Job state that is updated at the end of an execution",
"fields" : [
{
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/JobStatistics.pdsc
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/JobStatistics.pdsc b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/JobStatistics.pdsc
index 9df43a2..93b7c27 100644
--- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/JobStatistics.pdsc
+++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/JobStatistics.pdsc
@@ -1,7 +1,7 @@
{
"type" : "record",
"name" : "JobStatistics",
- "namespace": "gobblin.service",
+ "namesapce" : "org.apache.gobblin.service",
"doc" : "Statistics from a job execution",
"fields" : [
{
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/JobStatus.pdsc
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/JobStatus.pdsc b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/JobStatus.pdsc
index 15e17f2..21e0a31 100644
--- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/JobStatus.pdsc
+++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/JobStatus.pdsc
@@ -1,7 +1,7 @@
{
"type" : "record",
"name" : "JobStatus",
- "namespace": "gobblin.service",
+ "namesapce" : "org.apache.gobblin.service",
"doc" : "Execution status for a job",
"fields" : [
{
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/Schedule.pdsc
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/Schedule.pdsc b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/Schedule.pdsc
index 3984037..030a10f 100644
--- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/Schedule.pdsc
+++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/Schedule.pdsc
@@ -1,7 +1,7 @@
{
"type" : "record",
"name" : "Schedule",
- "namespace": "gobblin.service",
+ "namesapce" : "org.apache.gobblin.service",
"doc" : "Attributes for defining a job schedule",
"fields" : [
{
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowconfigs.snapshot.json
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowconfigs.snapshot.json b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowconfigs.snapshot.json
index e1e67a4..9bbdfe8 100644
--- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowconfigs.snapshot.json
+++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowconfigs.snapshot.json
@@ -2,7 +2,7 @@
"models" : [ {
"type" : "record",
"name" : "FlowId",
- "namespace" : "gobblin.service",
+ "namespace" : "org.apache.gobblin.service",
"doc" : "Identifier for a Gobblin as a Service flow",
"fields" : [ {
"name" : "flowName",
@@ -28,7 +28,7 @@
}, {
"type" : "record",
"name" : "Schedule",
- "namespace" : "gobblin.service",
+ "namespace" : "org.apache.gobblin.service",
"doc" : "Attributes for defining a job schedule",
"fields" : [ {
"name" : "cronSchedule",
@@ -46,7 +46,7 @@
}, {
"type" : "record",
"name" : "FlowConfig",
- "namespace" : "gobblin.service",
+ "namespace" : "org.apache.gobblin.service",
"doc" : "Defines a flow configuration that can be compiled into Gobblin jobs",
"fields" : [ {
"name" : "id",
@@ -84,9 +84,9 @@
} ],
"schema" : {
"name" : "flowconfigs",
- "namespace" : "gobblin.service",
+ "namespace" : "org.apache.gobblin.service",
"path" : "/flowconfigs",
- "schema" : "gobblin.service.FlowConfig",
+ "schema" : "org.apache.gobblin.service.FlowConfig",
"doc" : "Resource for handling flow configuration requests\n\ngenerated from: gobblin.service.FlowConfigsResource",
"collection" : {
"identifier" : {