http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/bin/gobblin-admin.sh ---------------------------------------------------------------------- diff --git a/bin/gobblin-admin.sh b/bin/gobblin-admin.sh index 7c5e8fc..0a48e2d 100755 --- a/bin/gobblin-admin.sh +++ b/bin/gobblin-admin.sh @@ -138,5 +138,5 @@ COMMAND+="-Xloggc:$GOBBLIN_LOG_DIR/gobblin-gc.log " COMMAND+="-Dgobblin.logs.dir=$GOBBLIN_LOG_DIR " COMMAND+="-Dlog4j.configuration=file://$FWDIR_CONF/log4j-standalone.xml " COMMAND+="-cp $CLASSPATH " -COMMAND+="gobblin.cli.Cli $@" +COMMAND+="org.apache.gobblin.cli.Cli $@" $COMMAND \ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/bin/gobblin-compaction.sh ---------------------------------------------------------------------- diff --git a/bin/gobblin-compaction.sh b/bin/gobblin-compaction.sh index 56826e0..baa8a66 100755 --- a/bin/gobblin-compaction.sh +++ b/bin/gobblin-compaction.sh @@ -118,7 +118,7 @@ if [ "$TYPE" == "hive" ]; then $HADOOP_BIN_DIR/hadoop jar \ $FWDIR_LIB/gobblin-compaction-$GOBBLIN_VERSION.jar \ - "gobblin.compaction.hive.CompactionRunner" \ + "org.apache.gobblin.compaction.hive.CompactionRunner" \ --jobconfig $COMP_CONFIG_FILE else @@ -137,7 +137,7 @@ else $HADOOP_BIN_DIR/hadoop jar \ $FWDIR_LIB/gobblin-compaction-$GOBBLIN_VERSION.jar \ - "gobblin.compaction.mapreduce.MRCompactionRunner" \ + "org.apache.gobblin.compaction.mapreduce.MRCompactionRunner" \ -D mapreduce.user.classpath.first=true \ -D mapreduce.job.user.classpath.first=true \ -libjars $LIBJARS \ http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/bin/gobblin-standalone.sh ---------------------------------------------------------------------- diff --git a/bin/gobblin-standalone.sh b/bin/gobblin-standalone.sh index 1a90f67..0dd66ca 100755 --- a/bin/gobblin-standalone.sh +++ b/bin/gobblin-standalone.sh @@ -198,7 +198,7 @@ start() { COMMAND+="-cp $CLASSPATH " COMMAND+="-Dorg.quartz.properties=$FWDIR_CONF/quartz.properties " COMMAND+="$GOBBLIN_JVM_FLAGS " - COMMAND+="gobblin.scheduler.SchedulerDaemon $DEFAULT_CONFIG_FILE $GOBBLIN_CUSTOM_CONFIG_FILE" + COMMAND+="org.apache.gobblin.scheduler.SchedulerDaemon $DEFAULT_CONFIG_FILE $GOBBLIN_CUSTOM_CONFIG_FILE" echo "Running command:" echo "$COMMAND" nohup $COMMAND & echo $! > $PID http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/buildSrc/src/main/groovy/org/apache/gobblin/gradle/BuildProperties.groovy ---------------------------------------------------------------------- diff --git a/buildSrc/src/main/groovy/org/apache/gobblin/gradle/BuildProperties.groovy b/buildSrc/src/main/groovy/org/apache/gobblin/gradle/BuildProperties.groovy index 1c97089..e051673 100644 --- a/buildSrc/src/main/groovy/org/apache/gobblin/gradle/BuildProperties.groovy +++ b/buildSrc/src/main/groovy/org/apache/gobblin/gradle/BuildProperties.groovy @@ -1,4 +1,4 @@ -package gobblin.gradle; +package org.apache.gobblin.gradle; import java.util.TreeMap import org.gradle.api.Project @@ -28,22 +28,22 @@ public class BuildProperties extends TreeMap<String, BuildProperty> { // Special treatment for Boolean flags -- just specifying the property // is treated as setting to true. - if (null != defaultValue && defaultValue instanceof Boolean && + if (null != defaultValue && defaultValue instanceof Boolean && !((Boolean)defaultValue).booleanValue()) { this.project.ext.set(propName, this.project.hasProperty(propName)) - } + } else if (! this.project.hasProperty(propName)) { this.project.ext.set(propName, defaultValue) } println String.format("Build property: %s=%s", propName, this.project.ext.get(propName)) - } + } public void printHelp() { println "\n\n" println "BUILD PROPERTIES" println "" - this.each { propName, propHelp -> + this.each { propName, propHelp -> println propHelp.getHelp() } } http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/buildSrc/src/main/groovy/org/apache/gobblin/gradle/BuildProperty.groovy ---------------------------------------------------------------------- diff --git a/buildSrc/src/main/groovy/org/apache/gobblin/gradle/BuildProperty.groovy b/buildSrc/src/main/groovy/org/apache/gobblin/gradle/BuildProperty.groovy index e49c7f1..24a8349 100644 --- a/buildSrc/src/main/groovy/org/apache/gobblin/gradle/BuildProperty.groovy +++ b/buildSrc/src/main/groovy/org/apache/gobblin/gradle/BuildProperty.groovy @@ -1,4 +1,4 @@ -package gobblin.gradle; +package org.apache.gobblin.gradle; /** * Encapsulates various aspects of a project property that can be used to customize the build through http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-admin/src/main/java/org/apache/gobblin/admin/AdminWebServer.java ---------------------------------------------------------------------- diff --git a/gobblin-admin/src/main/java/org/apache/gobblin/admin/AdminWebServer.java b/gobblin-admin/src/main/java/org/apache/gobblin/admin/AdminWebServer.java index 5c3a593..d3f5f7e 100644 --- a/gobblin-admin/src/main/java/org/apache/gobblin/admin/AdminWebServer.java +++ b/gobblin-admin/src/main/java/org/apache/gobblin/admin/AdminWebServer.java @@ -14,11 +14,11 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.admin; +package org.apache.gobblin.admin; import com.google.common.base.Preconditions; import com.google.common.util.concurrent.AbstractIdleService; -import gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.ConfigurationKeys; import org.eclipse.jetty.server.Handler; import org.eclipse.jetty.server.Request; import org.eclipse.jetty.server.Server; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-admin/src/main/java/org/apache/gobblin/admin/DefaultAdminWebServerFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-admin/src/main/java/org/apache/gobblin/admin/DefaultAdminWebServerFactory.java b/gobblin-admin/src/main/java/org/apache/gobblin/admin/DefaultAdminWebServerFactory.java index 87c2112..09c2478 100644 --- a/gobblin-admin/src/main/java/org/apache/gobblin/admin/DefaultAdminWebServerFactory.java +++ b/gobblin-admin/src/main/java/org/apache/gobblin/admin/DefaultAdminWebServerFactory.java @@ -14,15 +14,15 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.admin; +package org.apache.gobblin.admin; import java.net.URI; import java.util.Properties; import com.google.common.util.concurrent.Service; -import gobblin.annotation.Alias; -import gobblin.runtime.api.AdminWebServerFactory; +import org.apache.gobblin.annotation.Alias; +import org.apache.gobblin.runtime.api.AdminWebServerFactory; /** * A factory for the default implementation of the admin web server http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-admin/src/main/java/org/apache/gobblin/cli/AdminClient.java ---------------------------------------------------------------------- diff --git a/gobblin-admin/src/main/java/org/apache/gobblin/cli/AdminClient.java b/gobblin-admin/src/main/java/org/apache/gobblin/cli/AdminClient.java index 31ecaa7..a8268eb 100644 --- a/gobblin-admin/src/main/java/org/apache/gobblin/cli/AdminClient.java +++ b/gobblin-admin/src/main/java/org/apache/gobblin/cli/AdminClient.java @@ -14,13 +14,13 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.cli; +package org.apache.gobblin.cli; import com.google.common.base.Optional; import com.google.common.io.Closer; import com.linkedin.r2.RemoteInvocationException; -import gobblin.configuration.ConfigurationKeys; -import gobblin.rest.*; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.rest.*; import java.io.IOException; import java.net.URI; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-admin/src/main/java/org/apache/gobblin/cli/Cli.java ---------------------------------------------------------------------- diff --git a/gobblin-admin/src/main/java/org/apache/gobblin/cli/Cli.java b/gobblin-admin/src/main/java/org/apache/gobblin/cli/Cli.java index 0d16bcb..61ca72d 100644 --- a/gobblin-admin/src/main/java/org/apache/gobblin/cli/Cli.java +++ b/gobblin-admin/src/main/java/org/apache/gobblin/cli/Cli.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.cli; +package org.apache.gobblin.cli; import java.util.Arrays; import java.util.Collection; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-admin/src/main/java/org/apache/gobblin/cli/CliTablePrinter.java ---------------------------------------------------------------------- diff --git a/gobblin-admin/src/main/java/org/apache/gobblin/cli/CliTablePrinter.java b/gobblin-admin/src/main/java/org/apache/gobblin/cli/CliTablePrinter.java index 400391b..3c033ab 100644 --- a/gobblin-admin/src/main/java/org/apache/gobblin/cli/CliTablePrinter.java +++ b/gobblin-admin/src/main/java/org/apache/gobblin/cli/CliTablePrinter.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.cli; +package org.apache.gobblin.cli; import java.util.ArrayList; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-admin/src/main/java/org/apache/gobblin/cli/Command.java ---------------------------------------------------------------------- diff --git a/gobblin-admin/src/main/java/org/apache/gobblin/cli/Command.java b/gobblin-admin/src/main/java/org/apache/gobblin/cli/Command.java index 0da14fc..6598da4 100644 --- a/gobblin-admin/src/main/java/org/apache/gobblin/cli/Command.java +++ b/gobblin-admin/src/main/java/org/apache/gobblin/cli/Command.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.cli; +package org.apache.gobblin.cli; /** * Represents a single command for the CLI http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-admin/src/main/java/org/apache/gobblin/cli/JobCommand.java ---------------------------------------------------------------------- diff --git a/gobblin-admin/src/main/java/org/apache/gobblin/cli/JobCommand.java b/gobblin-admin/src/main/java/org/apache/gobblin/cli/JobCommand.java index 67a9058..bb37012 100644 --- a/gobblin-admin/src/main/java/org/apache/gobblin/cli/JobCommand.java +++ b/gobblin-admin/src/main/java/org/apache/gobblin/cli/JobCommand.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.cli; +package org.apache.gobblin.cli; import java.util.List; import java.util.Map; @@ -31,8 +31,8 @@ import com.google.common.base.Optional; import com.google.common.collect.ImmutableMap; import com.linkedin.r2.RemoteInvocationException; -import gobblin.rest.JobExecutionInfo; -import gobblin.rest.QueryListType; +import org.apache.gobblin.rest.JobExecutionInfo; +import org.apache.gobblin.rest.QueryListType; /** * Logic to print out job state http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-admin/src/main/java/org/apache/gobblin/cli/JobInfoPrintUtils.java ---------------------------------------------------------------------- diff --git a/gobblin-admin/src/main/java/org/apache/gobblin/cli/JobInfoPrintUtils.java b/gobblin-admin/src/main/java/org/apache/gobblin/cli/JobInfoPrintUtils.java index 207847b..3d0c08d 100644 --- a/gobblin-admin/src/main/java/org/apache/gobblin/cli/JobInfoPrintUtils.java +++ b/gobblin-admin/src/main/java/org/apache/gobblin/cli/JobInfoPrintUtils.java @@ -14,13 +14,13 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.cli; +package org.apache.gobblin.cli; import com.google.common.base.Optional; import com.linkedin.data.template.StringMap; -import gobblin.configuration.ConfigurationKeys; -import gobblin.metrics.MetricNames; -import gobblin.rest.*; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.metrics.MetricNames; +import org.apache.gobblin.rest.*; import org.joda.time.Period; import org.joda.time.format.DateTimeFormatter; import org.joda.time.format.ISODateTimeFormat; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-admin/src/test/java/org/apache/gobblin/admin/AdminWebServerTest.java ---------------------------------------------------------------------- diff --git a/gobblin-admin/src/test/java/org/apache/gobblin/admin/AdminWebServerTest.java b/gobblin-admin/src/test/java/org/apache/gobblin/admin/AdminWebServerTest.java index 9698a01..4b17fe4 100644 --- a/gobblin-admin/src/test/java/org/apache/gobblin/admin/AdminWebServerTest.java +++ b/gobblin-admin/src/test/java/org/apache/gobblin/admin/AdminWebServerTest.java @@ -14,9 +14,9 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.admin; +package org.apache.gobblin.admin; -import gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.ConfigurationKeys; import org.apache.http.HttpEntity; import org.apache.http.client.methods.CloseableHttpResponse; import org.apache.http.client.methods.HttpGet; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/Constructs.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/Constructs.java b/gobblin-api/src/main/java/org/apache/gobblin/Constructs.java index 03e2418..4b80d75 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/Constructs.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/Constructs.java @@ -17,14 +17,14 @@ package gobblin; -import gobblin.converter.Converter; -import gobblin.fork.ForkOperator; -import gobblin.publisher.DataPublisher; -import gobblin.qualitychecker.row.RowLevelPolicy; -import gobblin.qualitychecker.task.TaskLevelPolicy; -import gobblin.source.Source; -import gobblin.source.extractor.Extractor; -import gobblin.writer.DataWriter; +import org.apache.gobblin.converter.Converter; +import org.apache.gobblin.fork.ForkOperator; +import org.apache.gobblin.publisher.DataPublisher; +import org.apache.gobblin.qualitychecker.row.RowLevelPolicy; +import org.apache.gobblin.qualitychecker.task.TaskLevelPolicy; +import org.apache.gobblin.source.Source; +import org.apache.gobblin.source.extractor.Extractor; +import org.apache.gobblin.writer.DataWriter; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/ack/Ackable.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/ack/Ackable.java b/gobblin-api/src/main/java/org/apache/gobblin/ack/Ackable.java index 35b6a49..4eb1c8e 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/ack/Ackable.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/ack/Ackable.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.ack; +package org.apache.gobblin.ack; /** * An interface for entities that can be acked http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/ack/BasicAckableForTesting.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/ack/BasicAckableForTesting.java b/gobblin-api/src/main/java/org/apache/gobblin/ack/BasicAckableForTesting.java index 4642f7f..77c8c17 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/ack/BasicAckableForTesting.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/ack/BasicAckableForTesting.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.ack; +package org.apache.gobblin.ack; /** * An ackable used for testing that just counts the times it is acked and nacked. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/ack/HierarchicalAckable.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/ack/HierarchicalAckable.java b/gobblin-api/src/main/java/org/apache/gobblin/ack/HierarchicalAckable.java index e6bb10d..fb24cba 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/ack/HierarchicalAckable.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/ack/HierarchicalAckable.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.ack; +package org.apache.gobblin.ack; import java.io.Closeable; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/annotation/Alias.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/annotation/Alias.java b/gobblin-api/src/main/java/org/apache/gobblin/annotation/Alias.java index 92e4d2f..ba8866e 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/annotation/Alias.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/annotation/Alias.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.annotation; +package org.apache.gobblin.annotation; import java.lang.annotation.Documented; import java.lang.annotation.ElementType; @@ -22,7 +22,7 @@ import java.lang.annotation.Retention; import java.lang.annotation.RetentionPolicy; import java.lang.annotation.Target; -import gobblin.util.ClassAliasResolver; +import org.apache.gobblin.util.ClassAliasResolver; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/annotation/Alpha.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/annotation/Alpha.java b/gobblin-api/src/main/java/org/apache/gobblin/annotation/Alpha.java index d0bc604..06b5406 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/annotation/Alpha.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/annotation/Alpha.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.annotation; +package org.apache.gobblin.annotation; import java.lang.annotation.Documented; import java.lang.annotation.ElementType; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/annotation/Beta.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/annotation/Beta.java b/gobblin-api/src/main/java/org/apache/gobblin/annotation/Beta.java index be60e79..551a4b1 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/annotation/Beta.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/annotation/Beta.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.annotation; +package org.apache.gobblin.annotation; import java.lang.annotation.Documented; import java.lang.annotation.ElementType; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/annotation/Stable.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/annotation/Stable.java b/gobblin-api/src/main/java/org/apache/gobblin/annotation/Stable.java index 77342ae..597c07f 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/annotation/Stable.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/annotation/Stable.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.annotation; +package org.apache.gobblin.annotation; import java.lang.annotation.Documented; import java.lang.annotation.ElementType; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/BrokerConstants.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/BrokerConstants.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/BrokerConstants.java index fbe7e36..cc1737d 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/broker/BrokerConstants.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/BrokerConstants.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.broker; +package org.apache.gobblin.broker; /** * Constants used for {@link gobblin.broker.iface.SharedResourcesBroker}. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/ResourceCoordinate.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/ResourceCoordinate.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/ResourceCoordinate.java index e9d5a77..9144a18 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/broker/ResourceCoordinate.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/ResourceCoordinate.java @@ -15,12 +15,12 @@ * limitations under the License. */ -package gobblin.broker; +package org.apache.gobblin.broker; -import gobblin.broker.iface.ScopeType; -import gobblin.broker.iface.SharedResourceFactory; -import gobblin.broker.iface.SharedResourceFactoryResponse; -import gobblin.broker.iface.SharedResourceKey; +import org.apache.gobblin.broker.iface.ScopeType; +import org.apache.gobblin.broker.iface.SharedResourceFactory; +import org.apache.gobblin.broker.iface.SharedResourceFactoryResponse; +import org.apache.gobblin.broker.iface.SharedResourceKey; import lombok.Data; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/ResourceEntry.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/ResourceEntry.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/ResourceEntry.java index a801b7d..496ee25 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/broker/ResourceEntry.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/ResourceEntry.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package gobblin.broker; +package org.apache.gobblin.broker; -import gobblin.broker.iface.SharedResourceFactoryResponse; +import org.apache.gobblin.broker.iface.SharedResourceFactoryResponse; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/SimpleScope.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/SimpleScope.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/SimpleScope.java index 0ade538..3f2bea1 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/broker/SimpleScope.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/SimpleScope.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package gobblin.broker; +package org.apache.gobblin.broker; -import gobblin.broker.iface.ScopeInstance; -import gobblin.broker.iface.ScopeType; +import org.apache.gobblin.broker.iface.ScopeInstance; +import org.apache.gobblin.broker.iface.ScopeType; import lombok.Data; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/SimpleScopeType.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/SimpleScopeType.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/SimpleScopeType.java index f1a34ba..8678226 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/broker/SimpleScopeType.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/SimpleScopeType.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.broker; +package org.apache.gobblin.broker; import java.util.Collection; import java.util.List; @@ -24,8 +24,8 @@ import java.util.Set; import com.google.common.collect.Lists; import com.google.common.collect.Sets; -import gobblin.broker.iface.ScopeInstance; -import gobblin.broker.iface.ScopeType; +import org.apache.gobblin.broker.iface.ScopeInstance; +import org.apache.gobblin.broker.iface.ScopeType; import javax.annotation.Nullable; import lombok.AllArgsConstructor; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopeInstance.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopeInstance.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopeInstance.java index 8f966b6..3229560 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopeInstance.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopeInstance.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package gobblin.broker.gobblin_scopes; +package org.apache.gobblin.broker.gobblin_scopes; -import gobblin.broker.SimpleScope; +import org.apache.gobblin.broker.SimpleScope; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopeTypes.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopeTypes.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopeTypes.java index f307d22..4a9e010 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopeTypes.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopeTypes.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.broker.gobblin_scopes; +package org.apache.gobblin.broker.gobblin_scopes; import java.util.Collection; import java.util.List; @@ -24,8 +24,8 @@ import java.util.Set; import com.google.common.collect.Lists; import com.google.common.collect.Sets; -import gobblin.broker.iface.ScopeInstance; -import gobblin.broker.iface.ScopeType; +import org.apache.gobblin.broker.iface.ScopeInstance; +import org.apache.gobblin.broker.iface.ScopeType; import javax.annotation.Nullable; import lombok.AccessLevel; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/JobScopeInstance.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/JobScopeInstance.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/JobScopeInstance.java index 3394b93..53f30cb 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/JobScopeInstance.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/JobScopeInstance.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.broker.gobblin_scopes; +package org.apache.gobblin.broker.gobblin_scopes; import lombok.Getter; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/TaskScopeInstance.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/TaskScopeInstance.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/TaskScopeInstance.java index f992e7f..35592f7 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/TaskScopeInstance.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/TaskScopeInstance.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.broker.gobblin_scopes; +package org.apache.gobblin.broker.gobblin_scopes; import lombok.Getter; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ConfigView.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ConfigView.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ConfigView.java index 94ce8ca..69237a7 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ConfigView.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ConfigView.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.broker.iface; +package org.apache.gobblin.broker.iface; import com.typesafe.config.Config; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/NoSuchScopeException.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/NoSuchScopeException.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/NoSuchScopeException.java index 7059eee..61dce6d 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/NoSuchScopeException.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/NoSuchScopeException.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.broker.iface; +package org.apache.gobblin.broker.iface; /** * Exception thrown when trying to access a {@link ScopeInstance} that is not defined in a {@link SharedResourcesBroker}. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/NotConfiguredException.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/NotConfiguredException.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/NotConfiguredException.java index f3dcc42..b3a8f2f 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/NotConfiguredException.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/NotConfiguredException.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.broker.iface; +package org.apache.gobblin.broker.iface; /** * Exception thrown by a factory if there is not enough provided configuration to create the http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ScopeInstance.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ScopeInstance.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ScopeInstance.java index edde3c0..d6eb47c 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ScopeInstance.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ScopeInstance.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.broker.iface; +package org.apache.gobblin.broker.iface; /** * A specific scope for a {@link ScopeType}. For example, each task in a process could be a different scope. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ScopeType.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ScopeType.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ScopeType.java index 5112f73..8e5ecfb 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ScopeType.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ScopeType.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.broker.iface; +package org.apache.gobblin.broker.iface; import java.util.Collection; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ScopedConfigView.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ScopedConfigView.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ScopedConfigView.java index c42b657..88062d6 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ScopedConfigView.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ScopedConfigView.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.broker.iface; +package org.apache.gobblin.broker.iface; import com.typesafe.config.Config; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourceFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourceFactory.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourceFactory.java index b5dc725..fcb4661 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourceFactory.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourceFactory.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.broker.iface; +package org.apache.gobblin.broker.iface; /** * A factory that creates {@link ScopeInstance} specific objects. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourceFactoryResponse.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourceFactoryResponse.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourceFactoryResponse.java index 84ca7f0..3579f27 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourceFactoryResponse.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourceFactoryResponse.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.broker.iface; +package org.apache.gobblin.broker.iface; /** * An empty interface for responses from a {@link SharedResourceFactory}. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourceKey.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourceKey.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourceKey.java index 3edc9ff..63b6dcb 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourceKey.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourceKey.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.broker.iface; +package org.apache.gobblin.broker.iface; /** * A key to differentiate objects generated by the same factory for a {@link SharedResourcesBroker}. The http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourcesBroker.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourcesBroker.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourcesBroker.java index 266be92..e999967 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourcesBroker.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourcesBroker.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.broker.iface; +package org.apache.gobblin.broker.iface; import java.io.Closeable; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SubscopedBrokerBuilder.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SubscopedBrokerBuilder.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SubscopedBrokerBuilder.java index 398d15a..7bb0d2f 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SubscopedBrokerBuilder.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SubscopedBrokerBuilder.java @@ -15,11 +15,11 @@ * limitations under the License. */ -package gobblin.broker.iface; +package org.apache.gobblin.broker.iface; import com.typesafe.config.Config; -import gobblin.broker.BrokerConstants; +import org.apache.gobblin.broker.BrokerConstants; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/codec/StreamCodec.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/codec/StreamCodec.java b/gobblin-api/src/main/java/org/apache/gobblin/codec/StreamCodec.java index 59c478d..a6593fa 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/codec/StreamCodec.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/codec/StreamCodec.java @@ -15,13 +15,13 @@ * limitations under the License. */ -package gobblin.codec; +package org.apache.gobblin.codec; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; -import gobblin.annotation.Alpha; +import org.apache.gobblin.annotation.Alpha; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/commit/CommitSequence.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/commit/CommitSequence.java b/gobblin-api/src/main/java/org/apache/gobblin/commit/CommitSequence.java index 0ce8bc6..92d2b1a 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/commit/CommitSequence.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/commit/CommitSequence.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.commit; +package org.apache.gobblin.commit; import java.util.List; @@ -25,7 +25,7 @@ import com.google.common.base.Throwables; import com.google.common.collect.ImmutableList; import com.google.common.collect.Lists; -import gobblin.annotation.Alpha; +import org.apache.gobblin.annotation.Alpha; import lombok.Getter; import lombok.extern.slf4j.Slf4j; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/commit/CommitSequenceStore.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/commit/CommitSequenceStore.java b/gobblin-api/src/main/java/org/apache/gobblin/commit/CommitSequenceStore.java index f32047b..5d3c254 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/commit/CommitSequenceStore.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/commit/CommitSequenceStore.java @@ -15,14 +15,14 @@ * limitations under the License. */ -package gobblin.commit; +package org.apache.gobblin.commit; import java.io.IOException; import java.util.Collection; import com.google.common.base.Optional; -import gobblin.annotation.Alpha; +import org.apache.gobblin.annotation.Alpha; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/commit/CommitStep.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/commit/CommitStep.java b/gobblin-api/src/main/java/org/apache/gobblin/commit/CommitStep.java index 8b3b98f..74e9de7 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/commit/CommitStep.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/commit/CommitStep.java @@ -15,11 +15,11 @@ * limitations under the License. */ -package gobblin.commit; +package org.apache.gobblin.commit; import java.io.IOException; -import gobblin.annotation.Alpha; +import org.apache.gobblin.annotation.Alpha; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/commit/CommitStepBase.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/commit/CommitStepBase.java b/gobblin-api/src/main/java/org/apache/gobblin/commit/CommitStepBase.java index 7c2ef10..3e9fd70 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/commit/CommitStepBase.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/commit/CommitStepBase.java @@ -15,15 +15,15 @@ * limitations under the License. */ -package gobblin.commit; +package org.apache.gobblin.commit; import java.io.IOException; import com.google.common.base.Optional; import com.google.common.base.Preconditions; -import gobblin.annotation.Alpha; -import gobblin.configuration.State; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.configuration.State; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/commit/DeliverySemantics.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/commit/DeliverySemantics.java b/gobblin-api/src/main/java/org/apache/gobblin/commit/DeliverySemantics.java index a1223d6..80f00f8 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/commit/DeliverySemantics.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/commit/DeliverySemantics.java @@ -15,14 +15,14 @@ * limitations under the License. */ -package gobblin.commit; +package org.apache.gobblin.commit; import com.google.common.base.Enums; import com.google.common.base.Optional; import com.google.common.base.Preconditions; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/compat/hadoop/TextSerializer.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/compat/hadoop/TextSerializer.java b/gobblin-api/src/main/java/org/apache/gobblin/compat/hadoop/TextSerializer.java index 8067804..a0939d6 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/compat/hadoop/TextSerializer.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/compat/hadoop/TextSerializer.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compat.hadoop; +package org.apache.gobblin.compat.hadoop; import java.io.DataInput; import java.io.DataOutput; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/compat/hadoop/WritableShim.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/compat/hadoop/WritableShim.java b/gobblin-api/src/main/java/org/apache/gobblin/compat/hadoop/WritableShim.java index ffedd29..859e9d5 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/compat/hadoop/WritableShim.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/compat/hadoop/WritableShim.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compat.hadoop; +package org.apache.gobblin.compat.hadoop; import java.io.DataInput; import java.io.DataOutput; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/configuration/ConfigurationKeys.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/configuration/ConfigurationKeys.java b/gobblin-api/src/main/java/org/apache/gobblin/configuration/ConfigurationKeys.java index 5bb8460..c77f871 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/configuration/ConfigurationKeys.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/configuration/ConfigurationKeys.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.configuration; +package org.apache.gobblin.configuration; import java.nio.charset.Charset; import java.util.concurrent.TimeUnit; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/configuration/ImmutableWorkUnitState.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/configuration/ImmutableWorkUnitState.java b/gobblin-api/src/main/java/org/apache/gobblin/configuration/ImmutableWorkUnitState.java index 5f45030..3c1cff6 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/configuration/ImmutableWorkUnitState.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/configuration/ImmutableWorkUnitState.java @@ -15,13 +15,13 @@ * limitations under the License. */ -package gobblin.configuration; +package org.apache.gobblin.configuration; import java.io.DataInput; import java.io.IOException; import java.util.Properties; -import gobblin.source.extractor.Watermark; +import org.apache.gobblin.source.extractor.Watermark; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/configuration/SourceState.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/configuration/SourceState.java b/gobblin-api/src/main/java/org/apache/gobblin/configuration/SourceState.java index 8baa280..141386a 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/configuration/SourceState.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/configuration/SourceState.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.configuration; +package org.apache.gobblin.configuration; import java.io.DataInput; import java.io.DataOutput; @@ -37,8 +37,8 @@ import com.google.common.collect.Lists; import com.google.common.collect.Maps; import com.google.common.collect.Sets; -import gobblin.source.workunit.WorkUnit; -import gobblin.source.workunit.Extract; +import org.apache.gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.source.workunit.Extract; import lombok.Getter; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/configuration/State.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/configuration/State.java b/gobblin-api/src/main/java/org/apache/gobblin/configuration/State.java index f4ac748..20b6e17 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/configuration/State.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/configuration/State.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.configuration; +package org.apache.gobblin.configuration; import java.io.DataInput; import java.io.DataOutput; @@ -40,8 +40,8 @@ import com.google.gson.JsonParser; import lombok.EqualsAndHashCode; import lombok.Getter; -import gobblin.compat.hadoop.TextSerializer; -import gobblin.compat.hadoop.WritableShim; +import org.apache.gobblin.compat.hadoop.TextSerializer; +import org.apache.gobblin.compat.hadoop.WritableShim; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/configuration/StateUtils.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/configuration/StateUtils.java b/gobblin-api/src/main/java/org/apache/gobblin/configuration/StateUtils.java index 870d15e..df1dfdc 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/configuration/StateUtils.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/configuration/StateUtils.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.configuration; +package org.apache.gobblin.configuration; import java.util.Arrays; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/configuration/WorkUnitState.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/configuration/WorkUnitState.java b/gobblin-api/src/main/java/org/apache/gobblin/configuration/WorkUnitState.java index 6d148fd61..1a8ea89 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/configuration/WorkUnitState.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/configuration/WorkUnitState.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.configuration; +package org.apache.gobblin.configuration; import java.io.DataInput; import java.io.DataOutput; @@ -29,13 +29,13 @@ import com.google.gson.Gson; import com.google.gson.JsonElement; import com.google.gson.JsonParser; -import gobblin.broker.gobblin_scopes.GobblinScopeTypes; -import gobblin.broker.iface.SharedResourcesBroker; -import gobblin.broker.iface.SubscopedBrokerBuilder; -import gobblin.source.extractor.Watermark; -import gobblin.source.workunit.Extract; -import gobblin.source.workunit.ImmutableWorkUnit; -import gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.broker.gobblin_scopes.GobblinScopeTypes; +import org.apache.gobblin.broker.iface.SharedResourcesBroker; +import org.apache.gobblin.broker.iface.SubscopedBrokerBuilder; +import org.apache.gobblin.source.extractor.Watermark; +import org.apache.gobblin.source.workunit.Extract; +import org.apache.gobblin.source.workunit.ImmutableWorkUnit; +import org.apache.gobblin.source.workunit.WorkUnit; import javax.annotation.Nullable; import lombok.Getter; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/converter/Converter.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/converter/Converter.java b/gobblin-api/src/main/java/org/apache/gobblin/converter/Converter.java index 822cb58..49544fe 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/converter/Converter.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/converter/Converter.java @@ -15,24 +15,24 @@ * limitations under the License. */ -package gobblin.converter; +package org.apache.gobblin.converter; import java.io.Closeable; import java.io.IOException; import java.util.Iterator; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.initializer.ConverterInitializer; -import gobblin.converter.initializer.NoopConverterInitializer; -import gobblin.stream.ControlMessage; -import gobblin.records.ControlMessageHandler; -import gobblin.records.RecordStreamProcessor; -import gobblin.records.RecordStreamWithMetadata; -import gobblin.stream.RecordEnvelope; -import gobblin.source.workunit.WorkUnitStream; -import gobblin.stream.StreamEntity; -import gobblin.util.FinalState; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.initializer.ConverterInitializer; +import org.apache.gobblin.converter.initializer.NoopConverterInitializer; +import org.apache.gobblin.stream.ControlMessage; +import org.apache.gobblin.records.ControlMessageHandler; +import org.apache.gobblin.records.RecordStreamProcessor; +import org.apache.gobblin.records.RecordStreamWithMetadata; +import org.apache.gobblin.stream.RecordEnvelope; +import org.apache.gobblin.source.workunit.WorkUnitStream; +import org.apache.gobblin.stream.StreamEntity; +import org.apache.gobblin.util.FinalState; import io.reactivex.Flowable; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/converter/DataConversionException.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/converter/DataConversionException.java b/gobblin-api/src/main/java/org/apache/gobblin/converter/DataConversionException.java index f9f6af7..9167b2e 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/converter/DataConversionException.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/converter/DataConversionException.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.converter; +package org.apache.gobblin.converter; /** * A type of {@link Exception} thrown when there's anything wrong http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/converter/SchemaConversionException.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/converter/SchemaConversionException.java b/gobblin-api/src/main/java/org/apache/gobblin/converter/SchemaConversionException.java index bd2e443..801e167 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/converter/SchemaConversionException.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/converter/SchemaConversionException.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package gobblin.converter; +package org.apache.gobblin.converter; -import gobblin.records.RecordStreamProcessor; +import org.apache.gobblin.records.RecordStreamProcessor; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/converter/initializer/ConverterInitializer.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/converter/initializer/ConverterInitializer.java b/gobblin-api/src/main/java/org/apache/gobblin/converter/initializer/ConverterInitializer.java index 26ea1ee..79dbebe 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/converter/initializer/ConverterInitializer.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/converter/initializer/ConverterInitializer.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package gobblin.converter.initializer; +package org.apache.gobblin.converter.initializer; -import gobblin.initializer.Initializer; +import org.apache.gobblin.initializer.Initializer; /** * ConverterInitializer is being invoked at driver which means it will only invoked once per converter. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/converter/initializer/NoopConverterInitializer.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/converter/initializer/NoopConverterInitializer.java b/gobblin-api/src/main/java/org/apache/gobblin/converter/initializer/NoopConverterInitializer.java index b9c5b90..6410b45 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/converter/initializer/NoopConverterInitializer.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/converter/initializer/NoopConverterInitializer.java @@ -15,11 +15,11 @@ * limitations under the License. */ -package gobblin.converter.initializer; +package org.apache.gobblin.converter.initializer; import lombok.ToString; -import gobblin.initializer.Initializer; -import gobblin.initializer.NoopInitializer; +import org.apache.gobblin.initializer.Initializer; +import org.apache.gobblin.initializer.NoopInitializer; @ToString http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/crypto/CredentialStore.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/crypto/CredentialStore.java b/gobblin-api/src/main/java/org/apache/gobblin/crypto/CredentialStore.java index 1dcabd2..bc313ae 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/crypto/CredentialStore.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/crypto/CredentialStore.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.crypto; +package org.apache.gobblin.crypto; import java.util.Map; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/crypto/CredentialStoreProvider.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/crypto/CredentialStoreProvider.java b/gobblin-api/src/main/java/org/apache/gobblin/crypto/CredentialStoreProvider.java index 1bc14b7..ca9c28f 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/crypto/CredentialStoreProvider.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/crypto/CredentialStoreProvider.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.crypto; +package org.apache.gobblin.crypto; import java.util.Map; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/crypto/EncryptionProvider.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/crypto/EncryptionProvider.java b/gobblin-api/src/main/java/org/apache/gobblin/crypto/EncryptionProvider.java index aa81bbf..5ea09f8 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/crypto/EncryptionProvider.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/crypto/EncryptionProvider.java @@ -14,11 +14,11 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.crypto; +package org.apache.gobblin.crypto; import java.util.Map; -import gobblin.codec.StreamCodec; +import org.apache.gobblin.codec.StreamCodec; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/dataset/Dataset.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/dataset/Dataset.java b/gobblin-api/src/main/java/org/apache/gobblin/dataset/Dataset.java index cac6a54..fb8c1fa 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/dataset/Dataset.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/dataset/Dataset.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.dataset; +package org.apache.gobblin.dataset; /** * Interface representing a dataset. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/dataset/DatasetsFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/dataset/DatasetsFinder.java b/gobblin-api/src/main/java/org/apache/gobblin/dataset/DatasetsFinder.java index cc040fa..27a4dae 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/dataset/DatasetsFinder.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/dataset/DatasetsFinder.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.dataset; +package org.apache.gobblin.dataset; import java.io.IOException; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/dataset/FileSystemDataset.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/dataset/FileSystemDataset.java b/gobblin-api/src/main/java/org/apache/gobblin/dataset/FileSystemDataset.java index 8532255..2c5051c 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/dataset/FileSystemDataset.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/dataset/FileSystemDataset.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.dataset; +package org.apache.gobblin.dataset; import org.apache.hadoop.fs.Path; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/dataset/IterableDatasetFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/dataset/IterableDatasetFinder.java b/gobblin-api/src/main/java/org/apache/gobblin/dataset/IterableDatasetFinder.java index 5b5f9cc..93f9586 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/dataset/IterableDatasetFinder.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/dataset/IterableDatasetFinder.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.dataset; +package org.apache.gobblin.dataset; import java.io.IOException; import java.util.Iterator; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/dataset/IterableDatasetFinderImpl.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/dataset/IterableDatasetFinderImpl.java b/gobblin-api/src/main/java/org/apache/gobblin/dataset/IterableDatasetFinderImpl.java index f959fd8..af09996 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/dataset/IterableDatasetFinderImpl.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/dataset/IterableDatasetFinderImpl.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.dataset; +package org.apache.gobblin.dataset; import java.io.IOException; import java.util.Iterator; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/fork/CopyHelper.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/fork/CopyHelper.java b/gobblin-api/src/main/java/org/apache/gobblin/fork/CopyHelper.java index 34a07c9..e145937 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/fork/CopyHelper.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/fork/CopyHelper.java @@ -17,7 +17,7 @@ * under the License. */ -package gobblin.fork; +package org.apache.gobblin.fork; /** * A helper class to copy things that may or may not be {@link Copyable}. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/fork/CopyNotSupportedException.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/fork/CopyNotSupportedException.java b/gobblin-api/src/main/java/org/apache/gobblin/fork/CopyNotSupportedException.java index b08ada7..93970ac 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/fork/CopyNotSupportedException.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/fork/CopyNotSupportedException.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.fork; +package org.apache.gobblin.fork; /** * A type of {@link java.lang.Exception}s thrown when copying is not supported. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/fork/Copyable.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/fork/Copyable.java b/gobblin-api/src/main/java/org/apache/gobblin/fork/Copyable.java index a8dc1b6..a57e627 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/fork/Copyable.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/fork/Copyable.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.fork; +package org.apache.gobblin.fork; /** * An interface for classes that supports making copies of their instances. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/fork/ForkOperator.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/fork/ForkOperator.java b/gobblin-api/src/main/java/org/apache/gobblin/fork/ForkOperator.java index 5dd535b..615852c 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/fork/ForkOperator.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/fork/ForkOperator.java @@ -15,12 +15,12 @@ * limitations under the License. */ -package gobblin.fork; +package org.apache.gobblin.fork; import java.io.Closeable; import java.util.List; -import gobblin.configuration.WorkUnitState; +import org.apache.gobblin.configuration.WorkUnitState; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/fork/Forker.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/fork/Forker.java b/gobblin-api/src/main/java/org/apache/gobblin/fork/Forker.java index 69e0cb3..d70e5ba 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/fork/Forker.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/fork/Forker.java @@ -15,19 +15,19 @@ * limitations under the License. */ -package gobblin.fork; +package org.apache.gobblin.fork; import java.util.List; import com.google.common.base.Preconditions; import com.google.common.collect.Lists; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.records.RecordStreamWithMetadata; -import gobblin.stream.ControlMessage; -import gobblin.stream.RecordEnvelope; -import gobblin.stream.StreamEntity; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.records.RecordStreamWithMetadata; +import org.apache.gobblin.stream.ControlMessage; +import org.apache.gobblin.stream.RecordEnvelope; +import org.apache.gobblin.stream.StreamEntity; import io.reactivex.Flowable; import io.reactivex.flowables.ConnectableFlowable; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/initializer/Initializer.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/initializer/Initializer.java b/gobblin-api/src/main/java/org/apache/gobblin/initializer/Initializer.java index bb56a0b..4454c8a 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/initializer/Initializer.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/initializer/Initializer.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.initializer; +package org.apache.gobblin.initializer; import java.io.Closeable; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/initializer/NoopInitializer.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/initializer/NoopInitializer.java b/gobblin-api/src/main/java/org/apache/gobblin/initializer/NoopInitializer.java index 68aa2af..d98e8a0 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/initializer/NoopInitializer.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/initializer/NoopInitializer.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.initializer; +package org.apache.gobblin.initializer; import lombok.ToString; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/metadata/MetadataMerger.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/metadata/MetadataMerger.java b/gobblin-api/src/main/java/org/apache/gobblin/metadata/MetadataMerger.java index 048949f..4cabedc 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/metadata/MetadataMerger.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/metadata/MetadataMerger.java @@ -14,9 +14,9 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.metadata; +package org.apache.gobblin.metadata; -import gobblin.writer.FsWriterMetrics; +import org.apache.gobblin.writer.FsWriterMetrics; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/password/PasswordManager.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/password/PasswordManager.java b/gobblin-api/src/main/java/org/apache/gobblin/password/PasswordManager.java index 50cd0b4..6df6d7e 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/password/PasswordManager.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/password/PasswordManager.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.password; +package org.apache.gobblin.password; import java.io.IOException; import java.io.InputStream; @@ -47,8 +47,8 @@ import com.google.common.cache.LoadingCache; import com.google.common.io.Closer; import com.google.common.io.LineReader; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/publisher/DataPublisher.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/publisher/DataPublisher.java b/gobblin-api/src/main/java/org/apache/gobblin/publisher/DataPublisher.java index c65d935..a190d4a 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/publisher/DataPublisher.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/publisher/DataPublisher.java @@ -15,16 +15,16 @@ * limitations under the License. */ -package gobblin.publisher; +package org.apache.gobblin.publisher; import java.io.Closeable; import java.io.IOException; import java.lang.reflect.Constructor; import java.util.Collection; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/publisher/SingleTaskDataPublisher.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/publisher/SingleTaskDataPublisher.java b/gobblin-api/src/main/java/org/apache/gobblin/publisher/SingleTaskDataPublisher.java index f8213a8..9ae84de 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/publisher/SingleTaskDataPublisher.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/publisher/SingleTaskDataPublisher.java @@ -15,14 +15,14 @@ * limitations under the License. */ -package gobblin.publisher; +package org.apache.gobblin.publisher; import java.io.IOException; import com.google.common.base.Preconditions; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/publisher/UnpublishedHandling.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/publisher/UnpublishedHandling.java b/gobblin-api/src/main/java/org/apache/gobblin/publisher/UnpublishedHandling.java index 103c038..fbce8cb 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/publisher/UnpublishedHandling.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/publisher/UnpublishedHandling.java @@ -15,12 +15,12 @@ * limitations under the License. */ -package gobblin.publisher; +package org.apache.gobblin.publisher; import java.io.IOException; import java.util.Collection; -import gobblin.configuration.WorkUnitState; +import org.apache.gobblin.configuration.WorkUnitState; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicy.java b/gobblin-api/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicy.java index a860325..de718eb 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicy.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicy.java @@ -15,14 +15,14 @@ * limitations under the License. */ -package gobblin.qualitychecker.row; +package org.apache.gobblin.qualitychecker.row; import java.io.Closeable; import java.io.IOException; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.util.FinalState; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.util.FinalState; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/qualitychecker/task/TaskLevelPolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/qualitychecker/task/TaskLevelPolicy.java b/gobblin-api/src/main/java/org/apache/gobblin/qualitychecker/task/TaskLevelPolicy.java index 2531729..d016adf 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/qualitychecker/task/TaskLevelPolicy.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/qualitychecker/task/TaskLevelPolicy.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package gobblin.qualitychecker.task; +package org.apache.gobblin.qualitychecker.task; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; public abstract class TaskLevelPolicy { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/FieldDoesNotExistException.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/FieldDoesNotExistException.java b/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/FieldDoesNotExistException.java index e58efec..05556c4 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/FieldDoesNotExistException.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/FieldDoesNotExistException.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.recordaccess; +package org.apache.gobblin.recordaccess; public class FieldDoesNotExistException extends RecordAccessorException { public FieldDoesNotExistException(String msg) { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/IncorrectTypeException.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/IncorrectTypeException.java b/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/IncorrectTypeException.java index 505bb17..adff060 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/IncorrectTypeException.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/IncorrectTypeException.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.recordaccess; +package org.apache.gobblin.recordaccess; /** * Thrown when a get() or set() call on an Accessor accesses a record with an http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/RecordAccessor.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/RecordAccessor.java b/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/RecordAccessor.java index 5139da4..5791771 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/RecordAccessor.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/RecordAccessor.java @@ -14,11 +14,11 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.recordaccess; +package org.apache.gobblin.recordaccess; import java.util.Map; -import gobblin.annotation.Alpha; +import org.apache.gobblin.annotation.Alpha; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/RecordAccessorException.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/RecordAccessorException.java b/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/RecordAccessorException.java index d0f7901..617f917 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/RecordAccessorException.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/RecordAccessorException.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.recordaccess; +package org.apache.gobblin.recordaccess; /** * Base class for exceptions thrown by RecordAccessors. Exceptions are Runtime rather http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/RecordAccessorProvider.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/RecordAccessorProvider.java b/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/RecordAccessorProvider.java index 034d5f7..d10d7af 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/RecordAccessorProvider.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/RecordAccessorProvider.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.recordaccess; +package org.apache.gobblin.recordaccess; /** * A ServiceProvider that can construct a RecordAccessor based on an object's type. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/records/ControlMessageHandler.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/records/ControlMessageHandler.java b/gobblin-api/src/main/java/org/apache/gobblin/records/ControlMessageHandler.java index 4364a45..51ec907 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/records/ControlMessageHandler.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/records/ControlMessageHandler.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package gobblin.records; +package org.apache.gobblin.records; -import gobblin.stream.ControlMessage; +import org.apache.gobblin.stream.ControlMessage; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/records/FlushControlMessageHandler.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/records/FlushControlMessageHandler.java b/gobblin-api/src/main/java/org/apache/gobblin/records/FlushControlMessageHandler.java index fe8e41e..3047a2d 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/records/FlushControlMessageHandler.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/records/FlushControlMessageHandler.java @@ -14,13 +14,13 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.records; +package org.apache.gobblin.records; import java.io.Flushable; import java.io.IOException; -import gobblin.stream.ControlMessage; -import gobblin.stream.FlushControlMessage; +import org.apache.gobblin.stream.ControlMessage; +import org.apache.gobblin.stream.FlushControlMessage; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/records/RecordStreamConsumer.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/records/RecordStreamConsumer.java b/gobblin-api/src/main/java/org/apache/gobblin/records/RecordStreamConsumer.java index 66a9592..3c53ff4 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/records/RecordStreamConsumer.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/records/RecordStreamConsumer.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.records; +package org.apache.gobblin.records; /** * An object that a {@link RecordStreamWithMetadata}. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/records/RecordStreamProcessor.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/records/RecordStreamProcessor.java b/gobblin-api/src/main/java/org/apache/gobblin/records/RecordStreamProcessor.java index 40791c1..62a9325 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/records/RecordStreamProcessor.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/records/RecordStreamProcessor.java @@ -15,11 +15,11 @@ * limitations under the License. */ -package gobblin.records; +package org.apache.gobblin.records; import java.io.IOException; -import gobblin.configuration.WorkUnitState; +import org.apache.gobblin.configuration.WorkUnitState; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/records/RecordStreamWithMetadata.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/records/RecordStreamWithMetadata.java b/gobblin-api/src/main/java/org/apache/gobblin/records/RecordStreamWithMetadata.java index 5a4197a..57c1e7c 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/records/RecordStreamWithMetadata.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/records/RecordStreamWithMetadata.java @@ -15,12 +15,12 @@ * limitations under the License. */ -package gobblin.records; +package org.apache.gobblin.records; import java.util.function.Function; -import gobblin.stream.RecordEnvelope; -import gobblin.stream.StreamEntity; +import org.apache.gobblin.stream.RecordEnvelope; +import org.apache.gobblin.stream.StreamEntity; import io.reactivex.Flowable; import lombok.Data; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/runtime/BasicTestControlMessage.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/runtime/BasicTestControlMessage.java b/gobblin-api/src/main/java/org/apache/gobblin/runtime/BasicTestControlMessage.java index b434390..5796a71 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/runtime/BasicTestControlMessage.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/runtime/BasicTestControlMessage.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package gobblin.runtime; +package org.apache.gobblin.runtime; -import gobblin.stream.ControlMessage; -import gobblin.stream.StreamEntity; +import org.apache.gobblin.stream.ControlMessage; +import org.apache.gobblin.stream.StreamEntity; import lombok.AllArgsConstructor; import lombok.EqualsAndHashCode; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/AdminWebServerFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/AdminWebServerFactory.java b/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/AdminWebServerFactory.java index f9f998d..3a448a9 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/AdminWebServerFactory.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/AdminWebServerFactory.java @@ -14,14 +14,14 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.runtime.api; +package org.apache.gobblin.runtime.api; import java.net.URI; import java.util.Properties; import com.google.common.util.concurrent.Service; -import gobblin.annotation.Alpha; +import org.apache.gobblin.annotation.Alpha; /** * A factory interface for AdminWebServer. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/Spec.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/Spec.java b/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/Spec.java index 1d9bc83..0dda7fa 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/Spec.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/Spec.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.api; +package org.apache.gobblin.runtime.api; import java.io.Serializable; import java.net.URI;
