Updated package names, imports and shell scripts

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

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 \

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

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()
         }
     }

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

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;

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

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;

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;

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;

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

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.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

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;

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;

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;
 
 
 /**

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

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.

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;

gobblin-api/src/main/java/org/apache/gobblin/annotation/Alias.java

@@ -14,15 +14,15 @@
  * 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;
 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;
 
 
 /**

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;

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;

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;

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}.

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;
 
 

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;
 
 
 /**

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;
 

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 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;

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;
 
 
 /**