SAMZA-1313 : Rename StandaloneJobCoordinator to PassthroughJobCoordinator

Author: Boris Shkolnik <[email protected]>

Reviewers: Navina Ramesh <[email protected]>

Closes apache#206 from sborya/RenameStandAloneGJobCoordinator

Author: sborya

docs/learn/documentation/versioned/jobs/configuration-table.html

@@ -420,7 +420,7 @@ <h1>Samza Configuration Reference</h1>
                     <td class="description">
 			Class to use for job coordination. Currently available values are:
                        <dl>
-                            <dt><code>org.apache.samza.standalone.StandaloneJobCoordinatorFactory</code></dt>
+                            <dt><code>org.apache.samza.standalone.PassthroughJobCoordinatorFactory</code></dt>
                             <dd>Fixed partition mapping. No Zoookeeper. </dd>
                             <dt><code>org.apache.samza.zk.ZkJobCoordinatorFactory</code></dt>
                             <dd>Zookeeper-based coordination. </dd>

samza-core/src/main/java/org/apache/samza/standalone/StandaloneJobCoordinator.java renamed to samza-core/src/main/java/org/apache/samza/standalone/PassthroughJobCoordinator.java

@@ -62,13 +62,13 @@
  *   </li>
  * </ul>
  * */
-public class StandaloneJobCoordinator implements JobCoordinator {
-  private static final Logger LOGGER = LoggerFactory.getLogger(StandaloneJobCoordinator.class);
+public class PassthroughJobCoordinator implements JobCoordinator {
+  private static final Logger LOGGER = LoggerFactory.getLogger(PassthroughJobCoordinator.class);
   private final String processorId;
   private final Config config;
   private JobCoordinatorListener coordinatorListener = null;
 
-  public StandaloneJobCoordinator(Config config) {
+  public PassthroughJobCoordinator(Config config) {
     this.processorId = createProcessorId(config);
     this.config = config;
   }

samza-core/src/main/java/org/apache/samza/standalone/StandaloneJobCoordinatorFactory.java renamed to samza-core/src/main/java/org/apache/samza/standalone/PassthroughJobCoordinatorFactory.java

@@ -22,9 +22,9 @@
 import org.apache.samza.coordinator.JobCoordinator;
 import org.apache.samza.coordinator.JobCoordinatorFactory;
 
-public class StandaloneJobCoordinatorFactory implements JobCoordinatorFactory {
+public class PassthroughJobCoordinatorFactory implements JobCoordinatorFactory {
   @Override
   public JobCoordinator getJobCoordinator(Config config) {
-    return new StandaloneJobCoordinator(config);
+    return new PassthroughJobCoordinator(config);
   }
 }

samza-test/src/test/java/org/apache/samza/test/StandaloneTestUtils.java

@@ -25,7 +25,7 @@
 import java.util.Map;
 
 public class StandaloneTestUtils {
-  private static final String STANDALONE_JOB_COORDINATOR_FACTORY = "org.apache.samza.standalone.StandaloneJobCoordinatorFactory";
+  private static final String PASSTHROUGH_JOB_COORDINATOR_FACTORY = "org.apache.samza.standalone.PassthroughJobCoordinatorFactory";
   private static final String STANDALONE_SSP_GROUPER_FACTORY = "org.apache.samza.container.grouper.stream.AllSspToSingleTaskGrouperFactory";
   private static final String STANDALONE_TASK_NAME_GROUPER_FACTORY = "org.apache.samza.container.grouper.task.SingleContainerGrouperFactory";
   private static final String KAFKA_SYSTEM_FACTORY = "org.apache.samza.system.kafka.KafkaSystemFactory";
@@ -55,7 +55,7 @@ public static Map<String, String> getStandaloneConfigs(final String jobName, fin
       {
         put(JOB_NAME, jobName);
         put(TASK_CLASS, taskClass);
-        put(JobCoordinatorConfig.JOB_COORDINATOR_FACTORY, STANDALONE_JOB_COORDINATOR_FACTORY);
+        put(JobCoordinatorConfig.JOB_COORDINATOR_FACTORY, PASSTHROUGH_JOB_COORDINATOR_FACTORY);
         put(SSP_GROUPER_FACTORY, STANDALONE_SSP_GROUPER_FACTORY);
         put(TASK_NAME_GROUPER_FACTORY, STANDALONE_TASK_NAME_GROUPER_FACTORY);
       }