Renamed all packages to use the new package naming convention and rep…

…laced every occurrences of 'uif' with 'gobblin'

Jira: ETL-2476

Signed-off-by: Yinan Li <[email protected]>

azkaban/src/main/java/com/linkedin/uif/azkaban/AzkabanJobLauncher.java → azkaban/src/main/java/gobblin/azkaban/AzkabanJobLauncher.java

@@ -9,7 +9,7 @@
  * CONDITIONS OF ANY KIND, either express or implied.
  */
 
-package com.linkedin.uif.azkaban;
+package gobblin.azkaban;
 
 import java.util.Properties;
 
@@ -20,10 +20,10 @@
 
 import azkaban.jobExecutor.AbstractJob;
 
-import com.linkedin.uif.configuration.ConfigurationKeys;
-import com.linkedin.uif.runtime.EmailNotificationJobListener;
-import com.linkedin.uif.runtime.JobLauncher;
-import com.linkedin.uif.runtime.JobLauncherFactory;
+import gobblin.configuration.ConfigurationKeys;
+import gobblin.runtime.EmailNotificationJobListener;
+import gobblin.runtime.JobLauncher;
+import gobblin.runtime.JobLauncherFactory;
 
 
 /**

bin/gobblin-mapreduce.sh

@@ -31,7 +31,7 @@ GOBBLIN_CONFIG_FILE=$FWDIR/conf/gobblin-mapreduce.properties
 # Launch the job to run on Hadoop
 $HADOOP_BIN_DIR/hadoop jar \
         $FWDIR/lib/runtime.jar \
-        com.linkedin.uif.runtime.mapreduce.CliMRJobLauncher \
+        gobblin.runtime.mapreduce.CliMRJobLauncher \
         -jt $JOB_TRACKER_URL \
         -fs $FS_URL \
         -libjars $LIBJARS \

bin/gobblin-standalone.sh

@@ -62,7 +62,7 @@ start() {
   COMMAND+="-Dlog4j.configuration=file://$FWDIR/conf/log4j-standalone.xml "
   COMMAND+="-cp $CLASSPATH "
   COMMAND+="-Dorg.quartz.properties=$FWDIR/conf/quartz.properties "
-  COMMAND+="com.linkedin.uif.scheduler.SchedulerDaemon $CONFIG_FILE"
+  COMMAND+="gobblin.scheduler.SchedulerDaemon $CONFIG_FILE"
   echo "Running command:"
   echo "$COMMAND"
   nohup $COMMAND & echo $! > $PID

common-api/src/main/java/com/linkedin/uif/configuration/ConfigurationKeys.java → common-api/src/main/java/gobblin/configuration/ConfigurationKeys.java

@@ -9,7 +9,7 @@
  * CONDITIONS OF ANY KIND, either express or implied.
  */
 
-package com.linkedin.uif.configuration;
+package gobblin.configuration;
 
 /**
  * A central place for all Gobblin configuration property keys.
@@ -84,7 +84,7 @@ public class ConfigurationKeys {
   public static final String SOURCE_CLASS_KEY = "source.class";
   public static final String CONVERTER_CLASSES_KEY = "converter.classes";
   public static final String FORK_OPERATOR_CLASS_KEY = "fork.operator.class";
-  public static final String DEFAULT_FORK_OPERATOR_CLASS = "com.linkedin.uif.fork.IdentityForkOperator";
+  public static final String DEFAULT_FORK_OPERATOR_CLASS = "gobblin.fork.IdentityForkOperator";
   public static final String JOB_COMMIT_POLICY_KEY = "job.commit.policy";
   public static final String DEFAULT_JOB_COMMIT_POLICY = "full";
   public static final String WORK_UNIT_RETRY_POLICY_KEY = "workunit.retry.policy";
@@ -172,7 +172,7 @@ public class ConfigurationKeys {
   public static final String WRITER_STAGING_DIR = WRITER_PREFIX + ".staging.dir";
   public static final String WRITER_OUTPUT_DIR = WRITER_PREFIX + ".output.dir";
   public static final String WRITER_BUILDER_CLASS = WRITER_PREFIX + ".builder.class";
-  public static final String DEFAULT_WRITER_BUILDER_CLASS = "com.linkedin.uif.writer.AvroDataWriterBuilder";
+  public static final String DEFAULT_WRITER_BUILDER_CLASS = "gobblin.writer.AvroDataWriterBuilder";
   public static final String WRITER_FILE_NAME = WRITER_PREFIX + ".file.name";
   public static final String WRITER_FILE_PATH = WRITER_PREFIX + ".file.path";
   public static final String WRITER_BUFFER_SIZE = WRITER_PREFIX + ".buffer.size";
@@ -210,7 +210,7 @@ public class ConfigurationKeys {
    */
   public static final String DATA_PUBLISHER_PREFIX = "data.publisher";
   public static final String DATA_PUBLISHER_TYPE = DATA_PUBLISHER_PREFIX + ".type";
-  public static final String DEFAULT_DATA_PUBLISHER_TYPE = "com.linkedin.uif.publisher.BaseDataPublisher";
+  public static final String DEFAULT_DATA_PUBLISHER_TYPE = "gobblin.publisher.BaseDataPublisher";
   public static final String DATA_PUBLISHER_FINAL_DIR = DATA_PUBLISHER_PREFIX + ".final.dir";
   public static final String DATA_PUBLISHER_REPLACE_FINAL_DIR = DATA_PUBLISHER_PREFIX + ".replace.final.dir";
   public static final String DATA_PUBLISHER_FINAL_NAME = DATA_PUBLISHER_PREFIX + ".final.name";

common-api/src/main/java/com/linkedin/uif/configuration/SourceState.java → common-api/src/main/java/gobblin/configuration/SourceState.java

@@ -1,16 +1,17 @@
 /* (c) 2014 LinkedIn Corp. All rights reserved.
- * 
+ *
  * Licensed under the Apache License, Version 2.0 (the "License"); you may not use
  * this file except in compliance with the License. You may obtain a copy of the
  * License at  http://www.apache.org/licenses/LICENSE-2.0
- * 
+ *
  * Unless required by applicable law or agreed to in writing, software distributed
  * under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
  * CONDITIONS OF ANY KIND, either express or implied.
  */
 
-package com.linkedin.uif.configuration;
+package gobblin.configuration;
 
+import gobblin.source.workunit.Extract;
 import java.io.DataInput;
 import java.io.DataOutput;
 import java.io.IOException;
@@ -27,9 +28,7 @@
 import com.google.common.collect.Lists;
 import com.google.common.collect.Sets;
 
-import com.linkedin.uif.source.workunit.Extract;
-import com.linkedin.uif.source.workunit.Extract.TableType;
-import com.linkedin.uif.source.workunit.WorkUnit;
+import gobblin.source.workunit.WorkUnit;
 
 
 /**
@@ -39,7 +38,7 @@
  * <p>
  *   Properties can be overwritten at runtime and persisted upon job completion. Persisted
  *   properties will be loaded in the next run and made available to use by the
- *   {@link com.linkedin.uif.source.Source}.
+ *   {@link gobblin.source.Source}.
  * </p>
  *
  * @author kgoodhop
@@ -83,12 +82,12 @@ public List<WorkUnitState> getPreviousWorkUnitStates() {
    *   This method should always return a new unique {@link Extract} instance.
    * </p>
    *
-   * @param type {@link TableType} 
+   * @param type {@link gobblin.source.workunit.Extract.TableType}
    * @param namespace namespace of the table this extract belongs to
    * @param table name of the table this extract belongs to
    * @return a new unique {@link Extract} instance
    */
-  public synchronized Extract createExtract(TableType type, String namespace, String table) {
+  public synchronized Extract createExtract(Extract.TableType type, String namespace, String table) {
     Extract extract = new Extract(this, type, namespace, table);
     while (extractSet.contains(extract)) {
       DateTime extractDateTime = DTF.parseDateTime(extract.getExtractId());

common-api/src/main/java/com/linkedin/uif/configuration/State.java → common-api/src/main/java/gobblin/configuration/State.java

@@ -1,15 +1,15 @@
 /* (c) 2014 LinkedIn Corp. All rights reserved.
- * 
+ *
  * Licensed under the Apache License, Version 2.0 (the "License"); you may not use
  * this file except in compliance with the License. You may obtain a copy of the
  * License at  http://www.apache.org/licenses/LICENSE-2.0
- * 
+ *
  * Unless required by applicable law or agreed to in writing, software distributed
  * under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
  * CONDITIONS OF ANY KIND, either express or implied.
  */
 
-package com.linkedin.uif.configuration;
+package gobblin.configuration;
 
 import java.io.DataInput;
 import java.io.DataOutput;

common-api/src/main/java/com/linkedin/uif/configuration/WorkUnitState.java → common-api/src/main/java/gobblin/configuration/WorkUnitState.java

@@ -1,26 +1,26 @@
 /* (c) 2014 LinkedIn Corp. All rights reserved.
- * 
+ *
  * Licensed under the Apache License, Version 2.0 (the "License"); you may not use
  * this file except in compliance with the License. You may obtain a copy of the
  * License at  http://www.apache.org/licenses/LICENSE-2.0
- * 
+ *
  * Unless required by applicable law or agreed to in writing, software distributed
  * under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
  * CONDITIONS OF ANY KIND, either express or implied.
  */
 
-package com.linkedin.uif.configuration;
+package gobblin.configuration;
 
+import gobblin.source.workunit.Extract;
 import java.io.DataInput;
 import java.io.DataOutput;
 import java.io.IOException;
 import java.util.Set;
 
 import com.google.common.collect.Sets;
 
-import com.linkedin.uif.source.workunit.Extract;
-import com.linkedin.uif.source.workunit.ImmutableWorkUnit;
-import com.linkedin.uif.source.workunit.WorkUnit;
+import gobblin.source.workunit.ImmutableWorkUnit;
+import gobblin.source.workunit.WorkUnit;
 
 
 /**
@@ -108,7 +108,7 @@ public void setWorkingState(WorkingState state) {
   }
 
   /**
-   * Get the high watermark as set in {@link com.linkedin.uif.source.extractor.Extractor}.
+   * Get the high watermark as set in {@link gobblin.source.extractor.Extractor}.
    *
    * @return high watermark
    */
@@ -159,9 +159,9 @@ public boolean contains(String key) {
   }
 
   /**
-   * Get the {@link Extract} associated with the {@link WorkUnit}.
+   * Get the {@link gobblin.source.workunit.Extract} associated with the {@link WorkUnit}.
    *
-   * @return {@link Extract} associated with the {@link WorkUnit}
+   * @return {@link gobblin.source.workunit.Extract} associated with the {@link WorkUnit}
    */
   public Extract getExtract() {
     Extract curExtract = new Extract(workunit.getExtract());

common-api/src/main/java/com/linkedin/uif/converter/AvroToAvroConverterBase.java → common-api/src/main/java/gobblin/converter/AvroToAvroConverterBase.java

@@ -9,12 +9,12 @@
  * CONDITIONS OF ANY KIND, either express or implied.
  */
 
-package com.linkedin.uif.converter;
+package gobblin.converter;
 
 import org.apache.avro.Schema;
 import org.apache.avro.generic.GenericRecord;
 
-import com.linkedin.uif.configuration.WorkUnitState;
+import gobblin.configuration.WorkUnitState;
 
 
 /**

common-api/src/main/java/com/linkedin/uif/converter/Converter.java → common-api/src/main/java/gobblin/converter/Converter.java

@@ -9,9 +9,9 @@
  * CONDITIONS OF ANY KIND, either express or implied.
  */
 
-package com.linkedin.uif.converter;
+package gobblin.converter;
 
-import com.linkedin.uif.configuration.WorkUnitState;
+import gobblin.configuration.WorkUnitState;
 
 
 /**

common-api/src/main/java/com/linkedin/uif/converter/DataConversionException.java → common-api/src/main/java/gobblin/converter/DataConversionException.java

@@ -1,15 +1,15 @@
 /* (c) 2014 LinkedIn Corp. All rights reserved.
- * 
+ *
  * Licensed under the Apache License, Version 2.0 (the "License"); you may not use
  * this file except in compliance with the License. You may obtain a copy of the
  * License at  http://www.apache.org/licenses/LICENSE-2.0
- * 
+ *
  * Unless required by applicable law or agreed to in writing, software distributed
  * under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
  * CONDITIONS OF ANY KIND, either express or implied.
  */
 
-package com.linkedin.uif.converter;
+package gobblin.converter;
 
 /**
  * A type of {@link Exception} thrown when there's anything wrong

common-api/src/main/java/com/linkedin/uif/converter/EmptyIterable.java → common-api/src/main/java/gobblin/converter/EmptyIterable.java

@@ -9,7 +9,7 @@
  * CONDITIONS OF ANY KIND, either express or implied.
  */
 
-package com.linkedin.uif.converter;
+package gobblin.converter;
 
 import java.util.Iterator;
 

common-api/src/main/java/com/linkedin/uif/converter/SchemaConversionException.java → common-api/src/main/java/gobblin/converter/SchemaConversionException.java

@@ -1,15 +1,15 @@
 /* (c) 2014 LinkedIn Corp. All rights reserved.
- * 
+ *
  * Licensed under the Apache License, Version 2.0 (the "License"); you may not use
  * this file except in compliance with the License. You may obtain a copy of the
  * License at  http://www.apache.org/licenses/LICENSE-2.0
- * 
+ *
  * Unless required by applicable law or agreed to in writing, software distributed
  * under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
  * CONDITIONS OF ANY KIND, either express or implied.
  */
 
-package com.linkedin.uif.converter;
+package gobblin.converter;
 
 /**
  * A type of {@link Exception} thrown when there's anything wrong

common-api/src/main/java/com/linkedin/uif/converter/SingleRecordIterable.java → common-api/src/main/java/gobblin/converter/SingleRecordIterable.java

@@ -9,7 +9,7 @@
  * CONDITIONS OF ANY KIND, either express or implied.
  */
 
-package com.linkedin.uif.converter;
+package gobblin.converter;
 
 import java.util.Iterator;
 

common-api/src/main/java/com/linkedin/uif/converter/ToAvroConverterBase.java → common-api/src/main/java/gobblin/converter/ToAvroConverterBase.java

@@ -9,12 +9,12 @@
  * CONDITIONS OF ANY KIND, either express or implied.
  */
 
-package com.linkedin.uif.converter;
+package gobblin.converter;
 
 import org.apache.avro.Schema;
 import org.apache.avro.generic.GenericRecord;
 
-import com.linkedin.uif.configuration.WorkUnitState;
+import gobblin.configuration.WorkUnitState;
 
 
 /**

common-api/src/main/java/com/linkedin/uif/fork/CopyNotSupportedException.java → common-api/src/main/java/gobblin/fork/CopyNotSupportedException.java

@@ -1,15 +1,15 @@
 /* (c) 2014 LinkedIn Corp. All rights reserved.
- * 
+ *
  * Licensed under the Apache License, Version 2.0 (the "License"); you may not use
  * this file except in compliance with the License. You may obtain a copy of the
  * License at  http://www.apache.org/licenses/LICENSE-2.0
- * 
+ *
  * Unless required by applicable law or agreed to in writing, software distributed
  * under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
  * CONDITIONS OF ANY KIND, either express or implied.
  */
 
-package com.linkedin.uif.fork;
+package gobblin.fork;
 
 /**
  * A type of {@link java.lang.Exception}s thrown when copying is not supported.

common-api/src/main/java/com/linkedin/uif/fork/Copyable.java → common-api/src/main/java/gobblin/fork/Copyable.java

@@ -1,15 +1,15 @@
 /* (c) 2014 LinkedIn Corp. All rights reserved.
- * 
+ *
  * Licensed under the Apache License, Version 2.0 (the "License"); you may not use
  * this file except in compliance with the License. You may obtain a copy of the
  * License at  http://www.apache.org/licenses/LICENSE-2.0
- * 
+ *
  * Unless required by applicable law or agreed to in writing, software distributed
  * under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
  * CONDITIONS OF ANY KIND, either express or implied.
  */
 
-package com.linkedin.uif.fork;
+package gobblin.fork;
 
 /**
  * An interface for classes that supports making copies of their instances.

common-api/src/main/java/com/linkedin/uif/fork/CopyableGenericRecord.java → common-api/src/main/java/gobblin/fork/CopyableGenericRecord.java

@@ -1,15 +1,15 @@
 /* (c) 2014 LinkedIn Corp. All rights reserved.
- * 
+ *
  * Licensed under the Apache License, Version 2.0 (the "License"); you may not use
  * this file except in compliance with the License. You may obtain a copy of the
  * License at  http://www.apache.org/licenses/LICENSE-2.0
- * 
+ *
  * Unless required by applicable law or agreed to in writing, software distributed
  * under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
  * CONDITIONS OF ANY KIND, either express or implied.
  */
 
-package com.linkedin.uif.fork;
+package gobblin.fork;
 
 import org.apache.avro.generic.GenericData;
 import org.apache.avro.generic.GenericRecord;

common-api/src/main/java/com/linkedin/uif/fork/CopyableSchema.java → common-api/src/main/java/gobblin/fork/CopyableSchema.java

@@ -9,7 +9,7 @@
  * CONDITIONS OF ANY KIND, either express or implied.
  */
 
-package com.linkedin.uif.fork;
+package gobblin.fork;
 
 import org.apache.avro.Schema;
 

common-api/src/main/java/com/linkedin/uif/fork/ForkOperator.java → common-api/src/main/java/gobblin/fork/ForkOperator.java

@@ -1,20 +1,20 @@
 /* (c) 2014 LinkedIn Corp. All rights reserved.
- * 
+ *
  * Licensed under the Apache License, Version 2.0 (the "License"); you may not use
  * this file except in compliance with the License. You may obtain a copy of the
  * License at  http://www.apache.org/licenses/LICENSE-2.0
- * 
+ *
  * Unless required by applicable law or agreed to in writing, software distributed
  * under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
  * CONDITIONS OF ANY KIND, either express or implied.
  */
 
-package com.linkedin.uif.fork;
+package gobblin.fork;
 
 import java.io.Closeable;
 import java.util.List;
 
-import com.linkedin.uif.configuration.WorkUnitState;
+import gobblin.configuration.WorkUnitState;
 
 
 /**