http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metrics-influxdb/src/main/java/org/apache/gobblin/metrics/influxdb/InfluxDBPusher.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metrics-influxdb/src/main/java/org/apache/gobblin/metrics/influxdb/InfluxDBPusher.java b/gobblin-modules/gobblin-metrics-influxdb/src/main/java/org/apache/gobblin/metrics/influxdb/InfluxDBPusher.java index b1e6a4e..8c82d44 100644 --- a/gobblin-modules/gobblin-metrics-influxdb/src/main/java/org/apache/gobblin/metrics/influxdb/InfluxDBPusher.java +++ b/gobblin-modules/gobblin-metrics-influxdb/src/main/java/org/apache/gobblin/metrics/influxdb/InfluxDBPusher.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics.influxdb; +package org.apache.gobblin.metrics.influxdb; import java.util.List; import java.util.concurrent.TimeUnit;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metrics-influxdb/src/main/java/org/apache/gobblin/metrics/influxdb/InfluxDBReporter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metrics-influxdb/src/main/java/org/apache/gobblin/metrics/influxdb/InfluxDBReporter.java b/gobblin-modules/gobblin-metrics-influxdb/src/main/java/org/apache/gobblin/metrics/influxdb/InfluxDBReporter.java index 6495e92..b2a8c13 100644 --- a/gobblin-modules/gobblin-metrics-influxdb/src/main/java/org/apache/gobblin/metrics/influxdb/InfluxDBReporter.java +++ b/gobblin-modules/gobblin-metrics-influxdb/src/main/java/org/apache/gobblin/metrics/influxdb/InfluxDBReporter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics.influxdb; +package org.apache.gobblin.metrics.influxdb; import java.io.IOException; import java.util.List; @@ -41,11 +41,11 @@ import com.google.common.base.Optional; import com.google.common.collect.Lists; import com.typesafe.config.Config; -import gobblin.configuration.ConfigurationKeys; -import gobblin.metrics.Measurements; -import gobblin.metrics.reporter.ConfiguredScheduledReporter; -import gobblin.util.ConfigUtils; -import static gobblin.metrics.Measurements.*; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.metrics.Measurements; +import org.apache.gobblin.metrics.reporter.ConfiguredScheduledReporter; +import org.apache.gobblin.util.ConfigUtils; +import static org.apache.gobblin.metrics.Measurements.*; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metrics-influxdb/src/test/java/org/apache/gobblin/metrics/influxdb/InfluxDBEventReporterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metrics-influxdb/src/test/java/org/apache/gobblin/metrics/influxdb/InfluxDBEventReporterTest.java b/gobblin-modules/gobblin-metrics-influxdb/src/test/java/org/apache/gobblin/metrics/influxdb/InfluxDBEventReporterTest.java index f1646c0..b832d50 100644 --- a/gobblin-modules/gobblin-metrics-influxdb/src/test/java/org/apache/gobblin/metrics/influxdb/InfluxDBEventReporterTest.java +++ b/gobblin-modules/gobblin-metrics-influxdb/src/test/java/org/apache/gobblin/metrics/influxdb/InfluxDBEventReporterTest.java @@ -15,15 +15,15 @@ * limitations under the License. */ -package gobblin.metrics.influxdb; - -import gobblin.metrics.GobblinTrackingEvent; -import gobblin.metrics.MetricContext; -import gobblin.metrics.event.EventSubmitter; -import gobblin.metrics.event.JobEvent; -import gobblin.metrics.event.MultiPartEvent; -import gobblin.metrics.event.TaskEvent; -import gobblin.metrics.test.TimestampedValue; +package org.apache.gobblin.metrics.influxdb; + +import org.apache.gobblin.metrics.GobblinTrackingEvent; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.event.EventSubmitter; +import org.apache.gobblin.metrics.event.JobEvent; +import org.apache.gobblin.metrics.event.MultiPartEvent; +import org.apache.gobblin.metrics.event.TaskEvent; +import org.apache.gobblin.metrics.test.TimestampedValue; import java.io.IOException; import java.util.Map; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metrics-influxdb/src/test/java/org/apache/gobblin/metrics/influxdb/InfluxDBReporterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metrics-influxdb/src/test/java/org/apache/gobblin/metrics/influxdb/InfluxDBReporterTest.java b/gobblin-modules/gobblin-metrics-influxdb/src/test/java/org/apache/gobblin/metrics/influxdb/InfluxDBReporterTest.java index c834b18..de0df48 100644 --- a/gobblin-modules/gobblin-metrics-influxdb/src/test/java/org/apache/gobblin/metrics/influxdb/InfluxDBReporterTest.java +++ b/gobblin-modules/gobblin-metrics-influxdb/src/test/java/org/apache/gobblin/metrics/influxdb/InfluxDBReporterTest.java @@ -15,19 +15,19 @@ * limitations under the License. */ -package gobblin.metrics.influxdb; - -import static gobblin.metrics.test.TestConstants.CONTEXT_NAME; -import static gobblin.metrics.test.TestConstants.COUNTER; -import static gobblin.metrics.test.TestConstants.GAUGE; -import static gobblin.metrics.test.TestConstants.HISTOGRAM; -import static gobblin.metrics.test.TestConstants.METER; -import static gobblin.metrics.test.TestConstants.METRIC_PREFIX; -import static gobblin.metrics.test.TestConstants.TIMER; -import gobblin.metrics.ContextAwareGauge; -import gobblin.metrics.Measurements; -import gobblin.metrics.MetricContext; -import gobblin.metrics.Tag; +package org.apache.gobblin.metrics.influxdb; + +import static org.apache.gobblin.metrics.test.TestConstants.CONTEXT_NAME; +import static org.apache.gobblin.metrics.test.TestConstants.COUNTER; +import static org.apache.gobblin.metrics.test.TestConstants.GAUGE; +import static org.apache.gobblin.metrics.test.TestConstants.HISTOGRAM; +import static org.apache.gobblin.metrics.test.TestConstants.METER; +import static org.apache.gobblin.metrics.test.TestConstants.METRIC_PREFIX; +import static org.apache.gobblin.metrics.test.TestConstants.TIMER; +import org.apache.gobblin.metrics.ContextAwareGauge; +import org.apache.gobblin.metrics.Measurements; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.Tag; import java.io.IOException; import java.util.Properties; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metrics-influxdb/src/test/java/org/apache/gobblin/metrics/influxdb/TestInfluxDB.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metrics-influxdb/src/test/java/org/apache/gobblin/metrics/influxdb/TestInfluxDB.java b/gobblin-modules/gobblin-metrics-influxdb/src/test/java/org/apache/gobblin/metrics/influxdb/TestInfluxDB.java index f75a8fd..30bfed1 100644 --- a/gobblin-modules/gobblin-metrics-influxdb/src/test/java/org/apache/gobblin/metrics/influxdb/TestInfluxDB.java +++ b/gobblin-modules/gobblin-metrics-influxdb/src/test/java/org/apache/gobblin/metrics/influxdb/TestInfluxDB.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package gobblin.metrics.influxdb; +package org.apache.gobblin.metrics.influxdb; -import gobblin.metrics.test.TimestampedValue; +import org.apache.gobblin.metrics.test.TimestampedValue; import java.util.List; import java.util.Map; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/initializer/AvroToJdbcEntryConverterInitializer.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/initializer/AvroToJdbcEntryConverterInitializer.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/initializer/AvroToJdbcEntryConverterInitializer.java index 580c313..1bfd7b3 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/initializer/AvroToJdbcEntryConverterInitializer.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/initializer/AvroToJdbcEntryConverterInitializer.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.converter.initializer; +package org.apache.gobblin.converter.initializer; import java.sql.Connection; import java.sql.SQLException; @@ -31,15 +31,15 @@ import com.google.common.annotations.VisibleForTesting; import com.google.common.base.Preconditions; import com.google.gson.Gson; -import gobblin.configuration.State; -import gobblin.converter.jdbc.AvroToJdbcEntryConverter; -import gobblin.converter.jdbc.JdbcType; -import gobblin.publisher.JdbcPublisher; -import gobblin.source.workunit.WorkUnit; -import gobblin.util.ForkOperatorUtils; -import gobblin.util.jdbc.DataSourceBuilder; -import gobblin.writer.commands.JdbcWriterCommands; -import gobblin.writer.commands.JdbcWriterCommandsFactory; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.converter.jdbc.AvroToJdbcEntryConverter; +import org.apache.gobblin.converter.jdbc.JdbcType; +import org.apache.gobblin.publisher.JdbcPublisher; +import org.apache.gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.util.ForkOperatorUtils; +import org.apache.gobblin.util.jdbc.DataSourceBuilder; +import org.apache.gobblin.writer.commands.JdbcWriterCommands; +import org.apache.gobblin.writer.commands.JdbcWriterCommandsFactory; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/jdbc/AvroToJdbcEntryConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/jdbc/AvroToJdbcEntryConverter.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/jdbc/AvroToJdbcEntryConverter.java index f4c83eb..3677874 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/jdbc/AvroToJdbcEntryConverter.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/jdbc/AvroToJdbcEntryConverter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.converter.jdbc; +package org.apache.gobblin.converter.jdbc; import java.sql.Date; import java.sql.Time; @@ -45,17 +45,17 @@ import com.google.gson.JsonObject; import com.google.gson.JsonParser; import com.google.gson.reflect.TypeToken; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.Converter; -import gobblin.converter.DataConversionException; -import gobblin.converter.SchemaConversionException; -import gobblin.converter.SingleRecordIterable; -import gobblin.converter.initializer.AvroToJdbcEntryConverterInitializer; -import gobblin.converter.initializer.ConverterInitializer; -import gobblin.source.workunit.WorkUnitStream; -import gobblin.writer.commands.JdbcWriterCommandsFactory; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.Converter; +import org.apache.gobblin.converter.DataConversionException; +import org.apache.gobblin.converter.SchemaConversionException; +import org.apache.gobblin.converter.SingleRecordIterable; +import org.apache.gobblin.converter.initializer.AvroToJdbcEntryConverterInitializer; +import org.apache.gobblin.converter.initializer.ConverterInitializer; +import org.apache.gobblin.source.workunit.WorkUnitStream; +import org.apache.gobblin.writer.commands.JdbcWriterCommandsFactory; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/jdbc/JdbcEntryData.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/jdbc/JdbcEntryData.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/jdbc/JdbcEntryData.java index e4f677b..7ee72d5 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/jdbc/JdbcEntryData.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/jdbc/JdbcEntryData.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.converter.jdbc; +package org.apache.gobblin.converter.jdbc; import java.util.Iterator; import java.util.Map; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/jdbc/JdbcEntryDatum.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/jdbc/JdbcEntryDatum.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/jdbc/JdbcEntryDatum.java index 00e4e5f..a485470 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/jdbc/JdbcEntryDatum.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/jdbc/JdbcEntryDatum.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.converter.jdbc; +package org.apache.gobblin.converter.jdbc; import lombok.EqualsAndHashCode; import lombok.ToString; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/jdbc/JdbcEntryMetaDatum.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/jdbc/JdbcEntryMetaDatum.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/jdbc/JdbcEntryMetaDatum.java index 70559f4..906bd22 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/jdbc/JdbcEntryMetaDatum.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/jdbc/JdbcEntryMetaDatum.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.converter.jdbc; +package org.apache.gobblin.converter.jdbc; import lombok.EqualsAndHashCode; import lombok.ToString; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/jdbc/JdbcEntrySchema.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/jdbc/JdbcEntrySchema.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/jdbc/JdbcEntrySchema.java index 38c2082..d7894d2 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/jdbc/JdbcEntrySchema.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/jdbc/JdbcEntrySchema.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.converter.jdbc; +package org.apache.gobblin.converter.jdbc; import java.util.Iterator; import java.util.Map; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/jdbc/JdbcType.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/jdbc/JdbcType.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/jdbc/JdbcType.java index 8e06185..e0639a3 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/jdbc/JdbcType.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/jdbc/JdbcType.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.converter.jdbc; +package org.apache.gobblin.converter.jdbc; /** * Alternative to JAVA 8 JDBCType as Gobblin needs to be Java 7 compatible. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/publisher/JdbcPublisher.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/publisher/JdbcPublisher.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/publisher/JdbcPublisher.java index 35c16d3..4503db3 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/publisher/JdbcPublisher.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/publisher/JdbcPublisher.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.publisher; +package org.apache.gobblin.publisher; import java.io.IOException; import java.sql.Connection; @@ -36,14 +36,14 @@ import com.google.common.collect.Lists; import com.google.common.collect.Maps; import com.google.common.collect.Sets; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.source.extractor.JobCommitPolicy; -import gobblin.util.ForkOperatorUtils; -import gobblin.util.jdbc.DataSourceBuilder; -import gobblin.writer.commands.JdbcWriterCommands; -import gobblin.writer.commands.JdbcWriterCommandsFactory; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.source.extractor.JobCommitPolicy; +import org.apache.gobblin.util.ForkOperatorUtils; +import org.apache.gobblin.util.jdbc.DataSourceBuilder; +import org.apache.gobblin.writer.commands.JdbcWriterCommands; +import org.apache.gobblin.writer.commands.JdbcWriterCommandsFactory; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/extractor/extract/jdbc/MysqlSource.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/extractor/extract/jdbc/MysqlSource.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/extractor/extract/jdbc/MysqlSource.java index 039c4c5..20a0823 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/extractor/extract/jdbc/MysqlSource.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/extractor/extract/jdbc/MysqlSource.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package gobblin.source.extractor.extract.jdbc; +package org.apache.gobblin.source.extractor.extract.jdbc; -import gobblin.source.extractor.Extractor; -import gobblin.source.extractor.exception.ExtractPrepareException; +import org.apache.gobblin.source.extractor.Extractor; +import org.apache.gobblin.source.extractor.exception.ExtractPrepareException; import java.io.IOException; import org.slf4j.Logger; @@ -26,9 +26,9 @@ import org.slf4j.LoggerFactory; import com.google.gson.JsonArray; import com.google.gson.JsonElement; -import gobblin.configuration.WorkUnitState; -import gobblin.source.extractor.extract.QueryBasedSource; -import gobblin.source.jdbc.MysqlExtractor; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.source.extractor.extract.QueryBasedSource; +import org.apache.gobblin.source.jdbc.MysqlExtractor; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/extractor/extract/jdbc/OracleSource.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/extractor/extract/jdbc/OracleSource.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/extractor/extract/jdbc/OracleSource.java index c8d81ac..5ca305e 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/extractor/extract/jdbc/OracleSource.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/extractor/extract/jdbc/OracleSource.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package gobblin.source.extractor.extract.jdbc; +package org.apache.gobblin.source.extractor.extract.jdbc; -import gobblin.source.extractor.Extractor; -import gobblin.source.extractor.exception.ExtractPrepareException; +import org.apache.gobblin.source.extractor.Extractor; +import org.apache.gobblin.source.extractor.exception.ExtractPrepareException; import java.io.IOException; import org.slf4j.Logger; @@ -26,9 +26,9 @@ import org.slf4j.LoggerFactory; import com.google.gson.JsonArray; import com.google.gson.JsonElement; -import gobblin.configuration.WorkUnitState; -import gobblin.source.extractor.extract.QueryBasedSource; -import gobblin.source.jdbc.OracleExtractor; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.source.extractor.extract.QueryBasedSource; +import org.apache.gobblin.source.jdbc.OracleExtractor; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/extractor/extract/jdbc/SqlServerSource.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/extractor/extract/jdbc/SqlServerSource.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/extractor/extract/jdbc/SqlServerSource.java index 5166dc2..b9f0386 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/extractor/extract/jdbc/SqlServerSource.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/extractor/extract/jdbc/SqlServerSource.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package gobblin.source.extractor.extract.jdbc; +package org.apache.gobblin.source.extractor.extract.jdbc; -import gobblin.source.extractor.Extractor; -import gobblin.source.extractor.exception.ExtractPrepareException; +import org.apache.gobblin.source.extractor.Extractor; +import org.apache.gobblin.source.extractor.exception.ExtractPrepareException; import java.io.IOException; import org.slf4j.Logger; @@ -26,9 +26,9 @@ import org.slf4j.LoggerFactory; import com.google.gson.JsonArray; import com.google.gson.JsonElement; -import gobblin.configuration.WorkUnitState; -import gobblin.source.extractor.extract.QueryBasedSource; -import gobblin.source.jdbc.SqlServerExtractor; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.source.extractor.extract.QueryBasedSource; +import org.apache.gobblin.source.jdbc.SqlServerExtractor; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/extractor/extract/jdbc/TeradataSource.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/extractor/extract/jdbc/TeradataSource.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/extractor/extract/jdbc/TeradataSource.java index 82cf971..b6a9065 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/extractor/extract/jdbc/TeradataSource.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/extractor/extract/jdbc/TeradataSource.java @@ -15,16 +15,16 @@ * limitations under the License. */ -package gobblin.source.extractor.extract.jdbc; +package org.apache.gobblin.source.extractor.extract.jdbc; import java.io.IOException; import lombok.extern.slf4j.Slf4j; -import gobblin.configuration.WorkUnitState; -import gobblin.source.extractor.Extractor; -import gobblin.source.extractor.extract.QueryBasedSource; -import gobblin.source.extractor.exception.ExtractPrepareException; -import gobblin.source.jdbc.TeradataExtractor; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.source.extractor.Extractor; +import org.apache.gobblin.source.extractor.extract.QueryBasedSource; +import org.apache.gobblin.source.extractor.exception.ExtractPrepareException; +import org.apache.gobblin.source.jdbc.TeradataExtractor; import com.google.gson.JsonArray; import com.google.gson.JsonElement; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/JdbcCommand.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/JdbcCommand.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/JdbcCommand.java index 1fc4371..083991a 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/JdbcCommand.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/JdbcCommand.java @@ -15,15 +15,15 @@ * limitations under the License. */ -package gobblin.source.jdbc; +package org.apache.gobblin.source.jdbc; -import gobblin.source.extractor.extract.CommandType; +import org.apache.gobblin.source.extractor.extract.CommandType; import java.util.ArrayList; import java.util.Collection; import java.util.List; import com.google.common.base.Joiner; -import gobblin.source.extractor.extract.Command; +import org.apache.gobblin.source.extractor.extract.Command; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/JdbcCommandFormatException.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/JdbcCommandFormatException.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/JdbcCommandFormatException.java index bdb85d1..15eacce 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/JdbcCommandFormatException.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/JdbcCommandFormatException.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.jdbc; +package org.apache.gobblin.source.jdbc; /** * Exception if jdbc command is failed to execute http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/JdbcCommandOutput.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/JdbcCommandOutput.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/JdbcCommandOutput.java index 6377e11..b1d4fe7 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/JdbcCommandOutput.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/JdbcCommandOutput.java @@ -15,13 +15,13 @@ * limitations under the License. */ -package gobblin.source.jdbc; +package org.apache.gobblin.source.jdbc; import java.sql.ResultSet; import java.util.HashMap; import java.util.Map; -import gobblin.source.extractor.extract.CommandOutput; +import org.apache.gobblin.source.extractor.extract.CommandOutput; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/JdbcExtractor.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/JdbcExtractor.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/JdbcExtractor.java index 63ffa1f..94f087c 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/JdbcExtractor.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/JdbcExtractor.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.jdbc; +package org.apache.gobblin.source.jdbc; import java.io.IOException; import java.sql.Blob; @@ -52,26 +52,26 @@ import com.google.gson.JsonArray; import com.google.gson.JsonElement; import com.google.gson.JsonObject; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.password.PasswordManager; -import gobblin.source.extractor.DataRecordException; -import gobblin.source.extractor.exception.HighWatermarkException; -import gobblin.source.extractor.exception.RecordCountException; -import gobblin.source.extractor.exception.SchemaException; -import gobblin.source.extractor.extract.Command; -import gobblin.source.extractor.extract.CommandOutput; -import gobblin.source.extractor.extract.QueryBasedExtractor; -import gobblin.source.extractor.extract.SourceSpecificLayer; -import gobblin.source.jdbc.JdbcCommand.JdbcCommandType; -import gobblin.source.extractor.resultset.RecordSetList; -import gobblin.source.extractor.schema.ColumnAttributes; -import gobblin.source.extractor.schema.ColumnNameCase; -import gobblin.source.extractor.schema.Schema; -import gobblin.source.extractor.utils.Utils; -import gobblin.source.extractor.watermark.Predicate; -import gobblin.source.extractor.watermark.WatermarkType; -import gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.password.PasswordManager; +import org.apache.gobblin.source.extractor.DataRecordException; +import org.apache.gobblin.source.extractor.exception.HighWatermarkException; +import org.apache.gobblin.source.extractor.exception.RecordCountException; +import org.apache.gobblin.source.extractor.exception.SchemaException; +import org.apache.gobblin.source.extractor.extract.Command; +import org.apache.gobblin.source.extractor.extract.CommandOutput; +import org.apache.gobblin.source.extractor.extract.QueryBasedExtractor; +import org.apache.gobblin.source.extractor.extract.SourceSpecificLayer; +import org.apache.gobblin.source.jdbc.JdbcCommand.JdbcCommandType; +import org.apache.gobblin.source.extractor.resultset.RecordSetList; +import org.apache.gobblin.source.extractor.schema.ColumnAttributes; +import org.apache.gobblin.source.extractor.schema.ColumnNameCase; +import org.apache.gobblin.source.extractor.schema.Schema; +import org.apache.gobblin.source.extractor.utils.Utils; +import org.apache.gobblin.source.extractor.watermark.Predicate; +import org.apache.gobblin.source.extractor.watermark.WatermarkType; +import org.apache.gobblin.source.workunit.WorkUnit; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/JdbcProvider.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/JdbcProvider.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/JdbcProvider.java index b5cf525..6775f22 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/JdbcProvider.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/JdbcProvider.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package gobblin.source.jdbc; +package org.apache.gobblin.source.jdbc; -import gobblin.tunnel.Tunnel; +import org.apache.gobblin.tunnel.Tunnel; import org.apache.commons.dbcp.BasicDataSource; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/JdbcSpecificLayer.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/JdbcSpecificLayer.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/JdbcSpecificLayer.java index 693d039..2b922f6 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/JdbcSpecificLayer.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/JdbcSpecificLayer.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.jdbc; +package org.apache.gobblin.source.jdbc; /** * Interface for JDBC sources http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/MysqlExtractor.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/MysqlExtractor.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/MysqlExtractor.java index 9c0335f..c2f201d 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/MysqlExtractor.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/MysqlExtractor.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.jdbc; +package org.apache.gobblin.source.jdbc; import java.io.IOException; import java.util.ArrayList; @@ -29,17 +29,17 @@ import org.apache.commons.lang3.StringUtils; import com.google.common.collect.ImmutableMap; import com.google.gson.JsonElement; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.source.extractor.DataRecordException; -import gobblin.source.extractor.exception.HighWatermarkException; -import gobblin.source.extractor.exception.RecordCountException; -import gobblin.source.extractor.exception.SchemaException; -import gobblin.source.extractor.extract.Command; -import gobblin.source.extractor.utils.Utils; -import gobblin.source.extractor.watermark.Predicate; -import gobblin.source.extractor.watermark.WatermarkType; -import gobblin.source.workunit.WorkUnit; +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.exception.HighWatermarkException; +import org.apache.gobblin.source.extractor.exception.RecordCountException; +import org.apache.gobblin.source.extractor.exception.SchemaException; +import org.apache.gobblin.source.extractor.extract.Command; +import org.apache.gobblin.source.extractor.utils.Utils; +import org.apache.gobblin.source.extractor.watermark.Predicate; +import org.apache.gobblin.source.extractor.watermark.WatermarkType; +import org.apache.gobblin.source.workunit.WorkUnit; import lombok.extern.slf4j.Slf4j; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/OracleExtractor.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/OracleExtractor.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/OracleExtractor.java index 99e560b..b3b6ac2 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/OracleExtractor.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/OracleExtractor.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.jdbc; +package org.apache.gobblin.source.jdbc; import java.io.IOException; import java.util.ArrayList; @@ -34,17 +34,17 @@ import com.google.common.base.Preconditions; import com.google.common.collect.ImmutableMap; import com.google.gson.JsonElement; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.source.extractor.DataRecordException; -import gobblin.source.extractor.exception.HighWatermarkException; -import gobblin.source.extractor.exception.RecordCountException; -import gobblin.source.extractor.exception.SchemaException; -import gobblin.source.extractor.extract.Command; -import gobblin.source.extractor.utils.Utils; -import gobblin.source.extractor.watermark.Predicate; -import gobblin.source.extractor.watermark.WatermarkType; -import gobblin.source.workunit.WorkUnit; +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.exception.HighWatermarkException; +import org.apache.gobblin.source.extractor.exception.RecordCountException; +import org.apache.gobblin.source.extractor.exception.SchemaException; +import org.apache.gobblin.source.extractor.extract.Command; +import org.apache.gobblin.source.extractor.utils.Utils; +import org.apache.gobblin.source.extractor.watermark.Predicate; +import org.apache.gobblin.source.extractor.watermark.WatermarkType; +import org.apache.gobblin.source.workunit.WorkUnit; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/SqlQueryUtils.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/SqlQueryUtils.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/SqlQueryUtils.java index f93ac38..4c22905 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/SqlQueryUtils.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/SqlQueryUtils.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.source.jdbc; +package org.apache.gobblin.source.jdbc; import static com.google.common.base.Preconditions.checkArgument; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/SqlServerExtractor.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/SqlServerExtractor.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/SqlServerExtractor.java index 4a731e3..4e698b7 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/SqlServerExtractor.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/SqlServerExtractor.java @@ -15,13 +15,13 @@ * limitations under the License. */ -package gobblin.source.jdbc; +package org.apache.gobblin.source.jdbc; -import gobblin.source.extractor.DataRecordException; -import gobblin.source.extractor.exception.HighWatermarkException; -import gobblin.source.extractor.utils.Utils; -import gobblin.source.extractor.watermark.Predicate; -import gobblin.source.extractor.watermark.WatermarkType; +import org.apache.gobblin.source.extractor.DataRecordException; +import org.apache.gobblin.source.extractor.exception.HighWatermarkException; +import org.apache.gobblin.source.extractor.utils.Utils; +import org.apache.gobblin.source.extractor.watermark.Predicate; +import org.apache.gobblin.source.extractor.watermark.WatermarkType; import java.io.IOException; import java.util.ArrayList; @@ -35,12 +35,12 @@ import org.apache.commons.lang3.StringUtils; import com.google.common.collect.ImmutableMap; import com.google.gson.JsonElement; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.source.extractor.exception.RecordCountException; -import gobblin.source.extractor.exception.SchemaException; -import gobblin.source.extractor.extract.Command; -import gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.source.extractor.exception.RecordCountException; +import org.apache.gobblin.source.extractor.exception.SchemaException; +import org.apache.gobblin.source.extractor.extract.Command; +import org.apache.gobblin.source.workunit.WorkUnit; import lombok.extern.slf4j.Slf4j; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/TeradataExtractor.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/TeradataExtractor.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/TeradataExtractor.java index 1a319cb..013bc15 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/TeradataExtractor.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/TeradataExtractor.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.jdbc; +package org.apache.gobblin.source.jdbc; import java.io.IOException; import java.sql.ResultSet; @@ -35,19 +35,19 @@ import com.google.gson.JsonArray; import com.google.gson.JsonElement; import com.google.gson.JsonObject; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.source.extractor.DataRecordException; -import gobblin.source.extractor.exception.HighWatermarkException; -import gobblin.source.extractor.exception.RecordCountException; -import gobblin.source.extractor.exception.SchemaException; -import gobblin.source.extractor.extract.Command; -import gobblin.source.extractor.extract.CommandOutput; -import gobblin.source.extractor.schema.Schema; -import gobblin.source.extractor.utils.Utils; -import gobblin.source.extractor.watermark.Predicate; -import gobblin.source.extractor.watermark.WatermarkType; -import gobblin.source.workunit.WorkUnit; +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.exception.HighWatermarkException; +import org.apache.gobblin.source.extractor.exception.RecordCountException; +import org.apache.gobblin.source.extractor.exception.SchemaException; +import org.apache.gobblin.source.extractor.extract.Command; +import org.apache.gobblin.source.extractor.extract.CommandOutput; +import org.apache.gobblin.source.extractor.schema.Schema; +import org.apache.gobblin.source.extractor.utils.Utils; +import org.apache.gobblin.source.extractor.watermark.Predicate; +import org.apache.gobblin.source.extractor.watermark.WatermarkType; +import org.apache.gobblin.source.workunit.WorkUnit; /** * Teradata extractor using JDBC protocol http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/JdbcWriter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/JdbcWriter.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/JdbcWriter.java index 8e7ed11..5fc2ef6 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/JdbcWriter.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/JdbcWriter.java @@ -15,16 +15,16 @@ * limitations under the License. */ -package gobblin.writer; - -import gobblin.publisher.JdbcPublisher; -import gobblin.util.ForkOperatorUtils; -import gobblin.util.jdbc.DataSourceBuilder; -import gobblin.writer.commands.JdbcWriterCommands; -import gobblin.writer.commands.JdbcWriterCommandsFactory; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.converter.jdbc.JdbcEntryData; +package org.apache.gobblin.writer; + +import org.apache.gobblin.publisher.JdbcPublisher; +import org.apache.gobblin.util.ForkOperatorUtils; +import org.apache.gobblin.util.jdbc.DataSourceBuilder; +import org.apache.gobblin.writer.commands.JdbcWriterCommands; +import org.apache.gobblin.writer.commands.JdbcWriterCommandsFactory; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.converter.jdbc.JdbcEntryData; import java.io.IOException; import java.sql.Connection; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/JdbcWriterBuilder.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/JdbcWriterBuilder.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/JdbcWriterBuilder.java index f39fbc4..e9dae3c 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/JdbcWriterBuilder.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/JdbcWriterBuilder.java @@ -15,15 +15,15 @@ * limitations under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; -import gobblin.configuration.State; -import gobblin.converter.jdbc.JdbcEntryData; -import gobblin.converter.jdbc.JdbcEntrySchema; -import gobblin.source.workunit.WorkUnitStream; -import gobblin.writer.commands.JdbcWriterCommandsFactory; -import gobblin.writer.initializer.JdbcWriterInitializer; -import gobblin.writer.initializer.WriterInitializer; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.converter.jdbc.JdbcEntryData; +import org.apache.gobblin.converter.jdbc.JdbcEntrySchema; +import org.apache.gobblin.source.workunit.WorkUnitStream; +import org.apache.gobblin.writer.commands.JdbcWriterCommandsFactory; +import org.apache.gobblin.writer.initializer.JdbcWriterInitializer; +import org.apache.gobblin.writer.initializer.WriterInitializer; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/BaseJdbcBufferedInserter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/BaseJdbcBufferedInserter.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/BaseJdbcBufferedInserter.java index 105e2bb..cd791d5 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/BaseJdbcBufferedInserter.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/BaseJdbcBufferedInserter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.writer.commands; +package org.apache.gobblin.writer.commands; import java.sql.Connection; import java.sql.PreparedStatement; @@ -34,9 +34,9 @@ import com.github.rholder.retry.WaitStrategies; import com.google.common.base.Joiner; import com.google.common.collect.Lists; -import gobblin.configuration.State; -import gobblin.converter.jdbc.JdbcEntryData; -import gobblin.converter.jdbc.JdbcEntryDatum; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.converter.jdbc.JdbcEntryData; +import org.apache.gobblin.converter.jdbc.JdbcEntryDatum; import lombok.ToString; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/GenericJdbcBufferedInserter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/GenericJdbcBufferedInserter.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/GenericJdbcBufferedInserter.java index ffc2b08..58d4442 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/GenericJdbcBufferedInserter.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/GenericJdbcBufferedInserter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.writer.commands; +package org.apache.gobblin.writer.commands; import java.sql.Connection; import java.sql.PreparedStatement; @@ -24,9 +24,9 @@ import java.sql.SQLException; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import gobblin.configuration.State; -import gobblin.converter.jdbc.JdbcEntryData; -import gobblin.converter.jdbc.JdbcEntryDatum; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.converter.jdbc.JdbcEntryData; +import org.apache.gobblin.converter.jdbc.JdbcEntryDatum; public class GenericJdbcBufferedInserter extends BaseJdbcBufferedInserter { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/JdbcBufferedInserter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/JdbcBufferedInserter.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/JdbcBufferedInserter.java index d7e9de1..babc9cf 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/JdbcBufferedInserter.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/JdbcBufferedInserter.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package gobblin.writer.commands; +package org.apache.gobblin.writer.commands; -import static gobblin.configuration.ConfigurationKeys.WRITER_PREFIX; -import gobblin.converter.jdbc.JdbcEntryData; +import static org.apache.gobblin.configuration.ConfigurationKeys.WRITER_PREFIX; +import org.apache.gobblin.converter.jdbc.JdbcEntryData; import java.sql.SQLException; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/JdbcWriterCommands.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/JdbcWriterCommands.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/JdbcWriterCommands.java index e4114f9..5750435 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/JdbcWriterCommands.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/JdbcWriterCommands.java @@ -14,9 +14,9 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.writer.commands; +package org.apache.gobblin.writer.commands; -import gobblin.converter.jdbc.JdbcType; +import org.apache.gobblin.converter.jdbc.JdbcType; import java.sql.Connection; import java.sql.SQLException; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/JdbcWriterCommandsFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/JdbcWriterCommandsFactory.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/JdbcWriterCommandsFactory.java index bbcedb9..aaf832f 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/JdbcWriterCommandsFactory.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/JdbcWriterCommandsFactory.java @@ -15,17 +15,17 @@ * limitations under the License. */ -package gobblin.writer.commands; +package org.apache.gobblin.writer.commands; import java.sql.Connection; import com.google.common.base.Preconditions; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.util.ForkOperatorUtils; -import gobblin.writer.Destination; -import gobblin.writer.Destination.DestinationType; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.util.ForkOperatorUtils; +import org.apache.gobblin.writer.Destination; +import org.apache.gobblin.writer.Destination.DestinationType; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/MySqlBufferedInserter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/MySqlBufferedInserter.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/MySqlBufferedInserter.java index 27aef3f..e44ba60 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/MySqlBufferedInserter.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/MySqlBufferedInserter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.writer.commands; +package org.apache.gobblin.writer.commands; import java.sql.Connection; import java.sql.PreparedStatement; @@ -24,9 +24,9 @@ import java.sql.SQLException; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import gobblin.configuration.State; -import gobblin.converter.jdbc.JdbcEntryData; -import gobblin.converter.jdbc.JdbcEntryDatum; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.converter.jdbc.JdbcEntryData; +import org.apache.gobblin.converter.jdbc.JdbcEntryDatum; import lombok.ToString; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/MySqlWriterCommands.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/MySqlWriterCommands.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/MySqlWriterCommands.java index 082cc16..7009256 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/MySqlWriterCommands.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/MySqlWriterCommands.java @@ -15,11 +15,11 @@ * limitations under the License. */ -package gobblin.writer.commands; +package org.apache.gobblin.writer.commands; -import gobblin.configuration.State; -import gobblin.converter.jdbc.JdbcType; -import gobblin.converter.jdbc.JdbcEntryData; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.converter.jdbc.JdbcType; +import org.apache.gobblin.converter.jdbc.JdbcEntryData; import java.sql.Connection; import java.sql.PreparedStatement; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/TeradataBufferedInserter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/TeradataBufferedInserter.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/TeradataBufferedInserter.java index 9329e67..6843a05 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/TeradataBufferedInserter.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/TeradataBufferedInserter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.writer.commands; +package org.apache.gobblin.writer.commands; import java.sql.BatchUpdateException; import java.sql.Connection; @@ -30,9 +30,9 @@ import org.slf4j.LoggerFactory; import com.google.common.collect.Maps; -import gobblin.configuration.State; -import gobblin.converter.jdbc.JdbcEntryData; -import gobblin.converter.jdbc.JdbcEntryDatum; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.converter.jdbc.JdbcEntryData; +import org.apache.gobblin.converter.jdbc.JdbcEntryDatum; import lombok.ToString; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/TeradataWriterCommands.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/TeradataWriterCommands.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/TeradataWriterCommands.java index 10004fb..39212e9 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/TeradataWriterCommands.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/TeradataWriterCommands.java @@ -15,13 +15,13 @@ * limitations under the License. */ -package gobblin.writer.commands; +package org.apache.gobblin.writer.commands; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.converter.jdbc.JdbcType; -import gobblin.source.extractor.JobCommitPolicy; -import gobblin.converter.jdbc.JdbcEntryData; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.converter.jdbc.JdbcType; +import org.apache.gobblin.source.extractor.JobCommitPolicy; +import org.apache.gobblin.converter.jdbc.JdbcEntryData; import java.sql.Connection; import java.sql.PreparedStatement; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/initializer/JdbcWriterInitializer.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/initializer/JdbcWriterInitializer.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/initializer/JdbcWriterInitializer.java index 5b9f8eb..a293349 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/initializer/JdbcWriterInitializer.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/initializer/JdbcWriterInitializer.java @@ -15,19 +15,19 @@ * limitations under the License. */ -package gobblin.writer.initializer; - -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.publisher.JdbcPublisher; -import gobblin.source.workunit.WorkUnit; -import gobblin.util.ForkOperatorUtils; -import gobblin.util.jdbc.DataSourceBuilder; -import gobblin.writer.Destination; -import gobblin.writer.Destination.DestinationType; -import gobblin.writer.commands.JdbcWriterCommands; -import gobblin.writer.commands.JdbcWriterCommandsFactory; -import gobblin.source.extractor.JobCommitPolicy; +package org.apache.gobblin.writer.initializer; + +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.publisher.JdbcPublisher; +import org.apache.gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.util.ForkOperatorUtils; +import org.apache.gobblin.util.jdbc.DataSourceBuilder; +import org.apache.gobblin.writer.Destination; +import org.apache.gobblin.writer.Destination.DestinationType; +import org.apache.gobblin.writer.commands.JdbcWriterCommands; +import org.apache.gobblin.writer.commands.JdbcWriterCommandsFactory; +import org.apache.gobblin.source.extractor.JobCommitPolicy; import java.sql.Connection; import java.sql.ResultSet; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/converter/jdbc/AvroToJdbcEntryConverterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/converter/jdbc/AvroToJdbcEntryConverterTest.java b/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/converter/jdbc/AvroToJdbcEntryConverterTest.java index 919bd6e..de1f0a3 100644 --- a/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/converter/jdbc/AvroToJdbcEntryConverterTest.java +++ b/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/converter/jdbc/AvroToJdbcEntryConverterTest.java @@ -15,17 +15,17 @@ * limitations under the License. */ -package gobblin.converter.jdbc; +package org.apache.gobblin.converter.jdbc; import static org.mockito.Mockito.*; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.SchemaConversionException; -import gobblin.publisher.JdbcPublisher; -import gobblin.writer.Destination.DestinationType; -import gobblin.writer.commands.JdbcWriterCommands; -import gobblin.writer.commands.JdbcWriterCommandsFactory; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.SchemaConversionException; +import org.apache.gobblin.publisher.JdbcPublisher; +import org.apache.gobblin.writer.Destination.DestinationType; +import org.apache.gobblin.writer.commands.JdbcWriterCommands; +import org.apache.gobblin.writer.commands.JdbcWriterCommandsFactory; import java.io.IOException; import java.sql.Connection; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/source/TimestampWatermarkTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/source/TimestampWatermarkTest.java b/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/source/TimestampWatermarkTest.java index a2fa5e7..a173a7c 100644 --- a/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/source/TimestampWatermarkTest.java +++ b/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/source/TimestampWatermarkTest.java @@ -15,17 +15,17 @@ * limitations under the License. */ -package gobblin.source; +package org.apache.gobblin.source; import org.testng.Assert; import org.testng.annotations.BeforeClass; import org.testng.annotations.Test; -import gobblin.configuration.WorkUnitState; -import gobblin.source.extractor.watermark.TimestampWatermark; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.source.extractor.watermark.TimestampWatermark; -import gobblin.source.jdbc.MysqlExtractor; -import gobblin.source.jdbc.SqlServerExtractor; +import org.apache.gobblin.source.jdbc.MysqlExtractor; +import org.apache.gobblin.source.jdbc.SqlServerExtractor; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/source/jdbc/JdbcExtractorTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/source/jdbc/JdbcExtractorTest.java b/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/source/jdbc/JdbcExtractorTest.java index 868655f..c6d53f1 100644 --- a/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/source/jdbc/JdbcExtractorTest.java +++ b/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/source/jdbc/JdbcExtractorTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.jdbc; +package org.apache.gobblin.source.jdbc; import static org.testng.Assert.assertEquals; import static org.testng.Assert.assertTrue; @@ -35,12 +35,12 @@ import com.google.gson.JsonElement; import com.google.gson.JsonObject; import com.mockrunner.mock.jdbc.MockResultSet; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.source.extractor.exception.SchemaException; -import gobblin.source.extractor.extract.Command; -import gobblin.source.extractor.extract.CommandOutput; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.source.extractor.exception.SchemaException; +import org.apache.gobblin.source.extractor.extract.Command; +import org.apache.gobblin.source.extractor.extract.CommandOutput; @Test(groups = { "gobblin.source.jdbc" }) http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/source/jdbc/MockJdbcColumn.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/source/jdbc/MockJdbcColumn.java b/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/source/jdbc/MockJdbcColumn.java index 1386193..4fab579 100644 --- a/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/source/jdbc/MockJdbcColumn.java +++ b/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/source/jdbc/MockJdbcColumn.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.jdbc; +package org.apache.gobblin.source.jdbc; import lombok.AllArgsConstructor; import lombok.Getter; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/source/jdbc/OracleExtractorTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/source/jdbc/OracleExtractorTest.java b/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/source/jdbc/OracleExtractorTest.java index ce4cd97..ab82a07 100644 --- a/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/source/jdbc/OracleExtractorTest.java +++ b/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/source/jdbc/OracleExtractorTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.jdbc; +package org.apache.gobblin.source.jdbc; import static org.testng.Assert.assertEquals; @@ -30,9 +30,9 @@ import org.testng.annotations.Test; import com.google.common.collect.ImmutableList; import com.mockrunner.mock.jdbc.MockResultSet; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.source.extractor.extract.CommandOutput; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.source.extractor.extract.CommandOutput; @Test(groups = { "gobblin.source.jdbc" }) http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/source/jdbc/SqlQueryUtilsTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/source/jdbc/SqlQueryUtilsTest.java b/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/source/jdbc/SqlQueryUtilsTest.java index 2b4c69f..2678580 100644 --- a/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/source/jdbc/SqlQueryUtilsTest.java +++ b/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/source/jdbc/SqlQueryUtilsTest.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.source.jdbc; +package org.apache.gobblin.source.jdbc; import org.testng.Assert; import org.testng.annotations.Test; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/writer/JdbcBufferedInserterTestBase.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/writer/JdbcBufferedInserterTestBase.java b/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/writer/JdbcBufferedInserterTestBase.java index b99f683..7cd4e4d 100644 --- a/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/writer/JdbcBufferedInserterTestBase.java +++ b/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/writer/JdbcBufferedInserterTestBase.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import static org.mockito.Mockito.mock; @@ -30,10 +30,10 @@ import org.apache.commons.lang.RandomStringUtils; import org.testng.annotations.BeforeMethod; import org.testng.annotations.Test; -import gobblin.configuration.State; -import gobblin.converter.jdbc.JdbcEntryData; -import gobblin.converter.jdbc.JdbcEntryDatum; -import gobblin.writer.commands.JdbcBufferedInserter; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.converter.jdbc.JdbcEntryData; +import org.apache.gobblin.converter.jdbc.JdbcEntryDatum; +import org.apache.gobblin.writer.commands.JdbcBufferedInserter; @Test(groups = {"gobblin.writer"}, singleThreaded=true) public abstract class JdbcBufferedInserterTestBase { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/writer/JdbcPublisherTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/writer/JdbcPublisherTest.java b/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/writer/JdbcPublisherTest.java index ef7e79c..09d9691 100644 --- a/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/writer/JdbcPublisherTest.java +++ b/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/writer/JdbcPublisherTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import static org.mockito.Mockito.*; @@ -25,12 +25,12 @@ import java.sql.SQLException; import java.util.ArrayList; import java.util.Collection; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.publisher.JdbcPublisher; -import gobblin.writer.commands.JdbcWriterCommands; -import gobblin.writer.commands.JdbcWriterCommandsFactory; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.publisher.JdbcPublisher; +import org.apache.gobblin.writer.commands.JdbcWriterCommands; +import org.apache.gobblin.writer.commands.JdbcWriterCommandsFactory; import org.mockito.InOrder; import org.testng.Assert; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/writer/JdbcWriterCommandsTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/writer/JdbcWriterCommandsTest.java b/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/writer/JdbcWriterCommandsTest.java index b8d1581..b8e2c1c 100644 --- a/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/writer/JdbcWriterCommandsTest.java +++ b/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/writer/JdbcWriterCommandsTest.java @@ -15,12 +15,12 @@ * limitations under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import static org.mockito.Mockito.*; -import gobblin.configuration.State; -import gobblin.converter.jdbc.JdbcType; -import gobblin.writer.commands.MySqlWriterCommands; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.converter.jdbc.JdbcType; +import org.apache.gobblin.writer.commands.MySqlWriterCommands; import java.sql.Connection; import java.sql.PreparedStatement; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/writer/JdbcWriterInitializerTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/writer/JdbcWriterInitializerTest.java b/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/writer/JdbcWriterInitializerTest.java index c8efab7..ea6c6d0 100644 --- a/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/writer/JdbcWriterInitializerTest.java +++ b/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/writer/JdbcWriterInitializerTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import static org.mockito.Mockito.*; @@ -25,15 +25,15 @@ import java.sql.ResultSet; import java.sql.SQLException; import java.util.List; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.publisher.JdbcPublisher; -import gobblin.source.workunit.WorkUnit; -import gobblin.writer.Destination; -import gobblin.writer.Destination.DestinationType; -import gobblin.writer.commands.JdbcWriterCommands; -import gobblin.writer.commands.JdbcWriterCommandsFactory; -import gobblin.writer.initializer.JdbcWriterInitializer; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.publisher.JdbcPublisher; +import org.apache.gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.writer.Destination; +import org.apache.gobblin.writer.Destination.DestinationType; +import org.apache.gobblin.writer.commands.JdbcWriterCommands; +import org.apache.gobblin.writer.commands.JdbcWriterCommandsFactory; +import org.apache.gobblin.writer.initializer.JdbcWriterInitializer; import org.apache.commons.lang.StringUtils; import org.mockito.InOrder; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/writer/JdbcWriterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/writer/JdbcWriterTest.java b/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/writer/JdbcWriterTest.java index b9d5b6c..a27dd09 100644 --- a/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/writer/JdbcWriterTest.java +++ b/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/writer/JdbcWriterTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import static org.mockito.Mockito.*; @@ -26,10 +26,10 @@ import java.sql.SQLException; import org.testng.Assert; import org.testng.annotations.Test; -import gobblin.configuration.State; -import gobblin.converter.jdbc.JdbcEntryData; -import gobblin.writer.JdbcWriter; -import gobblin.writer.commands.JdbcWriterCommands; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.converter.jdbc.JdbcEntryData; +import org.apache.gobblin.writer.JdbcWriter; +import org.apache.gobblin.writer.commands.JdbcWriterCommands; @Test(groups = {"gobblin.writer"}) public class JdbcWriterTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/writer/MySqlBufferedInserterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/writer/MySqlBufferedInserterTest.java b/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/writer/MySqlBufferedInserterTest.java index 4399016..b33be6a 100644 --- a/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/writer/MySqlBufferedInserterTest.java +++ b/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/writer/MySqlBufferedInserterTest.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; -import static gobblin.writer.commands.JdbcBufferedInserter.WRITER_JDBC_INSERT_BATCH_SIZE; -import static gobblin.writer.commands.JdbcBufferedInserter.WRITER_JDBC_MAX_PARAM_SIZE; +import static org.apache.gobblin.writer.commands.JdbcBufferedInserter.WRITER_JDBC_INSERT_BATCH_SIZE; +import static org.apache.gobblin.writer.commands.JdbcBufferedInserter.WRITER_JDBC_MAX_PARAM_SIZE; import static org.mockito.Matchers.anyInt; import static org.mockito.Matchers.anyObject; import static org.mockito.Matchers.anyString; @@ -35,10 +35,10 @@ import java.util.List; import org.testng.annotations.Test; -import gobblin.configuration.State; -import gobblin.converter.jdbc.JdbcEntryData; -import gobblin.writer.commands.JdbcBufferedInserter; -import gobblin.writer.commands.MySqlBufferedInserter; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.converter.jdbc.JdbcEntryData; +import org.apache.gobblin.writer.commands.JdbcBufferedInserter; +import org.apache.gobblin.writer.commands.MySqlBufferedInserter; @Test(groups = {"gobblin.writer"}, singleThreaded=true) public class MySqlBufferedInserterTest extends JdbcBufferedInserterTestBase { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/writer/TeradataBufferedInserterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/writer/TeradataBufferedInserterTest.java b/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/writer/TeradataBufferedInserterTest.java index 37ce52c..c67d121 100644 --- a/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/writer/TeradataBufferedInserterTest.java +++ b/gobblin-modules/gobblin-sql/src/test/java/org/apache/gobblin/writer/TeradataBufferedInserterTest.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; -import static gobblin.writer.commands.JdbcBufferedInserter.WRITER_JDBC_INSERT_BATCH_SIZE; +import static org.apache.gobblin.writer.commands.JdbcBufferedInserter.WRITER_JDBC_INSERT_BATCH_SIZE; import static org.mockito.Matchers.anyInt; import static org.mockito.Matchers.anyObject; import static org.mockito.Matchers.anyString; @@ -36,10 +36,10 @@ import org.testng.annotations.Test; import com.mockrunner.mock.jdbc.MockParameterMetaData; -import gobblin.configuration.State; -import gobblin.converter.jdbc.JdbcEntryData; -import gobblin.writer.commands.JdbcBufferedInserter; -import gobblin.writer.commands.TeradataBufferedInserter; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.converter.jdbc.JdbcEntryData; +import org.apache.gobblin.writer.commands.JdbcBufferedInserter; +import org.apache.gobblin.writer.commands.TeradataBufferedInserter; @Test(groups = { "gobblin.writer" }, singleThreaded = true) http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/AsyncIteratorWithDataSink.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/AsyncIteratorWithDataSink.java b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/AsyncIteratorWithDataSink.java index fae950c..bd8c525 100644 --- a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/AsyncIteratorWithDataSink.java +++ b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/AsyncIteratorWithDataSink.java @@ -1,4 +1,4 @@ -package gobblin.ingestion.google; +package org.apache.gobblin.ingestion.google; import java.util.Iterator; import java.util.NoSuchElementException; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/DayPartitioner.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/DayPartitioner.java b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/DayPartitioner.java index b6e5f2b..af661dc 100644 --- a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/DayPartitioner.java +++ b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/DayPartitioner.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.ingestion.google; +package org.apache.gobblin.ingestion.google; import org.apache.avro.Schema; import org.apache.avro.SchemaBuilder; @@ -26,8 +26,8 @@ import org.joda.time.DateTime; import org.joda.time.format.DateTimeFormat; import org.joda.time.format.DateTimeFormatter; -import gobblin.configuration.State; -import gobblin.writer.partitioner.WriterPartitioner; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.writer.partitioner.WriterPartitioner; /** @@ -76,7 +76,7 @@ public class DayPartitioner implements WriterPartitioner<GenericRecord> { _dateColumn = state.getProp(GoggleIngestionConfigurationKeys.KEY_DATE_COLUMN_NAME, DEFAULT_DATE_COLUMN); _dateFormatter = DateTimeFormat.forPattern(state.getProp(GoggleIngestionConfigurationKeys.KEY_DATE_FORMAT, DEFAULT_DATE_FORMAT)); - + SchemaBuilder.FieldAssembler<Schema> assembler = SchemaBuilder.record(NAME).namespace(NAME_SPACE).fields(); Schema stringType = Schema.create(Schema.Type.STRING); http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/GoggleIngestionConfigurationKeys.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/GoggleIngestionConfigurationKeys.java b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/GoggleIngestionConfigurationKeys.java index 9073729..147b949 100644 --- a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/GoggleIngestionConfigurationKeys.java +++ b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/GoggleIngestionConfigurationKeys.java @@ -1,4 +1,4 @@ -package gobblin.ingestion.google; +package org.apache.gobblin.ingestion.google; public class GoggleIngestionConfigurationKeys { public static final String DAY_PARTITIONER_KEY_PREFIX = "writer.partitioner.google_ingestion"; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/util/SchemaUtil.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/util/SchemaUtil.java b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/util/SchemaUtil.java index e4e2f58..88c4ce0 100644 --- a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/util/SchemaUtil.java +++ b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/util/SchemaUtil.java @@ -1,8 +1,8 @@ -package gobblin.ingestion.google.util; +package org.apache.gobblin.ingestion.google.util; import com.google.gson.JsonObject; -import gobblin.converter.avro.JsonElementConversionFactory; +import org.apache.gobblin.converter.avro.JsonElementConversionFactory; public class SchemaUtil { 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/GoogleWebMasterSource.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebMasterSource.java b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebMasterSource.java index a0c6c6d..ce43c54 100644 --- a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebMasterSource.java +++ b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebMasterSource.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; @@ -29,14 +29,14 @@ import com.google.gson.JsonArray; import com.google.gson.JsonElement; import com.google.gson.JsonParser; -import gobblin.annotation.Alpha; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.avro.JsonElementConversionFactory; -import gobblin.ingestion.google.util.SchemaUtil; -import gobblin.source.extractor.Extractor; -import gobblin.source.extractor.extract.QueryBasedSource; -import gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.avro.JsonElementConversionFactory; +import org.apache.gobblin.ingestion.google.util.SchemaUtil; +import org.apache.gobblin.source.extractor.Extractor; +import org.apache.gobblin.source.extractor.extract.QueryBasedSource; +import org.apache.gobblin.source.workunit.WorkUnit; /**
