SAMZA-1313 : Rename StandaloneJobCoordinator to PassthroughJobCoordinator
authorBoris Shkolnik <boryas@apache.org>
Fri, 26 May 2017 22:45:52 +0000 (15:45 -0700)
committernavina <navina@apache.org>
Fri, 26 May 2017 22:45:52 +0000 (15:45 -0700)
Author: Boris Shkolnik <boryas@apache.org>

Reviewers: Navina Ramesh <navina@apache.org>

Closes #206 from sborya/RenameStandAloneGJobCoordinator

docs/learn/documentation/versioned/jobs/configuration-table.html
samza-core/src/main/java/org/apache/samza/standalone/PassthroughJobCoordinator.java [moved from samza-core/src/main/java/org/apache/samza/standalone/StandaloneJobCoordinator.java with 96% similarity]
samza-core/src/main/java/org/apache/samza/standalone/PassthroughJobCoordinatorFactory.java [moved from samza-core/src/main/java/org/apache/samza/standalone/StandaloneJobCoordinatorFactory.java with 89% similarity]
samza-test/src/test/java/org/apache/samza/test/StandaloneTestUtils.java

index f34146c..3eea37d 100644 (file)
                     <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>
@@ -62,13 +62,13 @@ import java.util.Map;
  *   </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;
   }
@@ -22,9 +22,9 @@ import org.apache.samza.config.Config;
 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);
   }
 }
\ No newline at end of file
index 2057a8b..93605f5 100644 (file)
@@ -25,7 +25,7 @@ import java.util.HashMap;
 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 class StandaloneTestUtils {
       {
         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);
       }