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" : {
