test_class.declarator: srcMiniDFS
test_class.modifier: private
test_class.original_string: private EmbeddedCluster srcMiniDFS;
test_class.type: EmbeddedCluster
test_class.var_name: srcMiniDFS
test_class.declarator: trgMiniDFS
test_class.modifier: private
test_class.original_string: private EmbeddedCluster trgMiniDFS;
test_class.type: EmbeddedCluster
test_class.var_name: trgMiniDFS
test_class.declarator: store = ConfigurationStore.get()
test_class.original_string: ConfigurationStore store = ConfigurationStore.get();
test_class.type: ConfigurationStore
test_class.var_name: store
test_class.declarator: srcCluster
test_class.original_string: Cluster srcCluster;
test_class.type: Cluster
test_class.var_name: srcCluster
test_class.declarator: trgCluster
test_class.original_string: Cluster trgCluster;
test_class.type: Cluster
test_class.var_name: trgCluster
test_class.declarator: feed
test_class.original_string: Feed feed;
test_class.type: Feed
test_class.var_name: feed
test_class.declarator: SRC_CLUSTER_PATH = "/src-cluster.xml"
test_class.modifier: private static final
test_class.original_string: private static final String SRC_CLUSTER_PATH = "/src-cluster.xml";
test_class.type: String
test_class.var_name: SRC_CLUSTER_PATH
test_class.declarator: TRG_CLUSTER_PATH = "/trg-cluster.xml"
test_class.modifier: private static final
test_class.original_string: private static final String TRG_CLUSTER_PATH = "/trg-cluster.xml";
test_class.type: String
test_class.var_name: TRG_CLUSTER_PATH
test_class.declarator: FEED = "/feed.xml"
test_class.modifier: private static final
test_class.original_string: private static final String FEED = "/feed.xml";
test_class.type: String
test_class.var_name: FEED
test_class.file: feed/src/test/java/org/apache/ivory/converter/OozieFeedMapperTest.java
test_class.identifier: OozieFeedMapperTest
test_case.body: @Test
  	public void testReplicationCoords() throws IvoryException {
  		OozieFeedMapper feedMapper = new OozieFeedMapper(feed);
  		List<COORDINATORAPP> coords = feedMapper.getCoordinators(trgCluster,
  				new Path("/projects/ivory/"));
  		COORDINATORAPP coord = coords.get(0);
  		Assert.assertEquals("2010-01-01T00:40Z", coord.getStart());		
  		Assert.assertEquals("${nameNode}/projects/ivory/REPLICATION", coord
  				.getAction().getWorkflow().getAppPath());
  		Assert.assertEquals("IVORY_FEED_REPLICATION_" + feed.getName() + "_"
  				+ srcCluster.getName(), coord.getName());
  		Assert.assertEquals("${coord:minutes(20)}", coord.getFrequency());
  		SYNCDATASET inputDataset = (SYNCDATASET) coord.getDatasets()
  				.getDatasetOrAsyncDataset().get(0);
  		SYNCDATASET outputDataset = (SYNCDATASET) coord.getDatasets()
  				.getDatasetOrAsyncDataset().get(1);
  
  		Assert.assertEquals("${coord:minutes(20)}", inputDataset.getFrequency());
  		Assert.assertEquals("input-dataset", inputDataset.getName());
  		Assert.assertEquals(
  				ClusterHelper.getStorageUrl(srcCluster)
  						+ "/examples/input-data/rawLogs/${YEAR}/${MONTH}/${DAY}/${HOUR}/${MINUTE}",
  				inputDataset.getUriTemplate());
  
  		Assert.assertEquals("${coord:minutes(20)}",
  				outputDataset.getFrequency());
  		Assert.assertEquals("output-dataset", outputDataset.getName());
  		Assert.assertEquals(
  				"${nameNode}"
  						+ "/examples/input-data/rawLogs/${YEAR}/${MONTH}/${DAY}/${HOUR}/${MINUTE}",
  				outputDataset.getUriTemplate());
  		
  		String inEventName =coord.getInputEvents().getDataIn().get(0).getName();
  		String inEventDataset =coord.getInputEvents().getDataIn().get(0).getDataset();
  		String inEventInstance = coord.getInputEvents().getDataIn().get(0).getInstance().get(0);
  		Assert.assertEquals("input", inEventName);
  		Assert.assertEquals("input-dataset", inEventDataset);
  		Assert.assertEquals("${now(0,-40)}", inEventInstance);
  
  		String outEventInstance = coord.getOutputEvents().getDataOut().get(0).getInstance();
  		Assert.assertEquals("${now(0,-40)}", outEventInstance);
  		
          for(Property prop:coord.getAction().getWorkflow().getConfiguration().getProperty()){
          	if(prop.getName().equals("mapred.job.priority")){
          		assertEquals(prop.getValue(), "NORMAL");
          		break;
          	}
          }
  
  	}
test_case.class_method_signature: OozieFeedMapperTest.testReplicationCoords()
test_case.full_signature: @Test public void testReplicationCoords()
test_case.identifier: testReplicationCoords
test_case.invocations: getCoordinators get assertEquals getStart assertEquals getAppPath getWorkflow getAction assertEquals getName getName getName assertEquals getFrequency get getDatasetOrAsyncDataset getDatasets get getDatasetOrAsyncDataset getDatasets assertEquals getFrequency assertEquals getName assertEquals getStorageUrl getUriTemplate assertEquals getFrequency assertEquals getName assertEquals getUriTemplate getName get getDataIn getInputEvents getDataset get getDataIn getInputEvents get getInstance get getDataIn getInputEvents assertEquals assertEquals assertEquals getInstance get getDataOut getOutputEvents assertEquals getProperty getConfiguration getWorkflow getAction equals getName assertEquals getValue
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testReplicationCoords()
focal_class.declarator: LOG = Logger.getLogger(OozieFeedMapper.class)
focal_class.modifier: private static
focal_class.original_string: private static Logger LOG = Logger.getLogger(OozieFeedMapper.class);
focal_class.type: Logger
focal_class.var_name: LOG
focal_class.declarator: THIRTY_MINUTES = 30 * 60 * 1000
focal_class.modifier: private static final
focal_class.original_string: private static final int THIRTY_MINUTES = 30 * 60 * 1000;
focal_class.type: int
focal_class.var_name: THIRTY_MINUTES
focal_class.declarator: RETENTION_WF_TEMPLATE = "/config/workflow/retention-workflow.xml"
focal_class.modifier: private static final
focal_class.original_string: private static final String RETENTION_WF_TEMPLATE = "/config/workflow/retention-workflow.xml";
focal_class.type: String
focal_class.var_name: RETENTION_WF_TEMPLATE
focal_class.declarator: REPLICATION_COORD_TEMPLATE = "/config/coordinator/replication-coordinator.xml"
focal_class.modifier: private static final
focal_class.original_string: private static final String REPLICATION_COORD_TEMPLATE = "/config/coordinator/replication-coordinator.xml";
focal_class.type: String
focal_class.var_name: REPLICATION_COORD_TEMPLATE
focal_class.declarator: REPLICATION_WF_TEMPLATE = "/config/workflow/replication-workflow.xml"
focal_class.modifier: private static final
focal_class.original_string: private static final String REPLICATION_WF_TEMPLATE = "/config/workflow/replication-workflow.xml";
focal_class.type: String
focal_class.var_name: REPLICATION_WF_TEMPLATE
focal_class.declarator: FEED_PATH_SEP="#"
focal_class.modifier: private static final
focal_class.original_string: private static final String FEED_PATH_SEP="#";
focal_class.type: String
focal_class.var_name: FEED_PATH_SEP
focal_class.declarator: TIMEOUT = "timeout"
focal_class.modifier: private static final
focal_class.original_string: private static final String TIMEOUT = "timeout";
focal_class.type: String
focal_class.var_name: TIMEOUT
focal_class.declarator: PARALLEL = "parallel"
focal_class.modifier: private static final
focal_class.original_string: private static final String PARALLEL = "parallel";
focal_class.type: String
focal_class.var_name: PARALLEL
focal_class.file: feed/src/main/java/org/apache/ivory/converter/OozieFeedMapper.java
focal_class.identifier: OozieFeedMapper
focal_class.class_method_signature: OozieFeedMapper.OozieFeedMapper(Feed feed)
focal_class.full_signature: public  OozieFeedMapper(Feed feed)
focal_class.identifier: OozieFeedMapper
focal_class.modifiers: public
focal_class.parameters: (Feed feed)
focal_class.signature:  OozieFeedMapper(Feed feed)
focal_class.class_method_signature: OozieFeedMapper.getCoordinators(Cluster cluster, Path bundlePath)
focal_class.full_signature: @Override protected List<COORDINATORAPP> getCoordinators(Cluster cluster, Path bundlePath)
focal_class.identifier: getCoordinators
focal_class.modifiers: @Override protected
focal_class.parameters: (Cluster cluster, Path bundlePath)
focal_class.return: List<COORDINATORAPP>
focal_class.signature: List<COORDINATORAPP> getCoordinators(Cluster cluster, Path bundlePath)
focal_class.class_method_signature: OozieFeedMapper.getRetentionCoordinator(Cluster cluster, Path bundlePath)
focal_class.full_signature: private COORDINATORAPP getRetentionCoordinator(Cluster cluster, Path bundlePath)
focal_class.identifier: getRetentionCoordinator
focal_class.modifiers: private
focal_class.parameters: (Cluster cluster, Path bundlePath)
focal_class.return: COORDINATORAPP
focal_class.signature: COORDINATORAPP getRetentionCoordinator(Cluster cluster, Path bundlePath)
focal_class.class_method_signature: OozieFeedMapper.getRetentionWorkflowAction(Cluster cluster, Path wfPath, String wfName)
focal_class.full_signature: private ACTION getRetentionWorkflowAction(Cluster cluster, Path wfPath, String wfName)
focal_class.identifier: getRetentionWorkflowAction
focal_class.modifiers: private
focal_class.parameters: (Cluster cluster, Path wfPath, String wfName)
focal_class.return: ACTION
focal_class.signature: ACTION getRetentionWorkflowAction(Cluster cluster, Path wfPath, String wfName)
focal_class.class_method_signature: OozieFeedMapper.getReplicationCoordinators(Cluster targetCluster, Path bundlePath)
focal_class.full_signature: private List<COORDINATORAPP> getReplicationCoordinators(Cluster targetCluster, Path bundlePath)
focal_class.identifier: getReplicationCoordinators
focal_class.modifiers: private
focal_class.parameters: (Cluster targetCluster, Path bundlePath)
focal_class.return: List<COORDINATORAPP>
focal_class.signature: List<COORDINATORAPP> getReplicationCoordinators(Cluster targetCluster, Path bundlePath)
focal_class.class_method_signature: OozieFeedMapper.createAndGetCoord(Feed feed, Cluster srcCluster, Cluster trgCluster, Path bundlePath)
focal_class.full_signature: private COORDINATORAPP createAndGetCoord(Feed feed, Cluster srcCluster, Cluster trgCluster, Path bundlePath)
focal_class.identifier: createAndGetCoord
focal_class.modifiers: private
focal_class.parameters: (Feed feed, Cluster srcCluster, Cluster trgCluster, Path bundlePath)
focal_class.return: COORDINATORAPP
focal_class.signature: COORDINATORAPP createAndGetCoord(Feed feed, Cluster srcCluster, Cluster trgCluster, Path bundlePath)
focal_class.class_method_signature: OozieFeedMapper.setDatasetValues(SYNCDATASET dataset, Feed feed, Cluster cluster)
focal_class.full_signature: private void setDatasetValues(SYNCDATASET dataset, Feed feed, Cluster cluster)
focal_class.identifier: setDatasetValues
focal_class.modifiers: private
focal_class.parameters: (SYNCDATASET dataset, Feed feed, Cluster cluster)
focal_class.return: void
focal_class.signature: void setDatasetValues(SYNCDATASET dataset, Feed feed, Cluster cluster)
focal_class.class_method_signature: OozieFeedMapper.getReplicationWorkflowAction(Cluster srcCluster, Cluster trgCluster, Path wfPath, String wfName)
focal_class.full_signature: private ACTION getReplicationWorkflowAction(Cluster srcCluster, Cluster trgCluster, Path wfPath, String wfName)
focal_class.identifier: getReplicationWorkflowAction
focal_class.modifiers: private
focal_class.parameters: (Cluster srcCluster, Cluster trgCluster, Path wfPath, String wfName)
focal_class.return: ACTION
focal_class.signature: ACTION getReplicationWorkflowAction(Cluster srcCluster, Cluster trgCluster, Path wfPath, String wfName)
focal_class.class_method_signature: OozieFeedMapper.createReplicatonWorkflow(Cluster cluster, Path wfPath, String wfName)
focal_class.full_signature: private void createReplicatonWorkflow(Cluster cluster, Path wfPath, String wfName)
focal_class.identifier: createReplicatonWorkflow
focal_class.modifiers: private
focal_class.parameters: (Cluster cluster, Path wfPath, String wfName)
focal_class.return: void
focal_class.signature: void createReplicatonWorkflow(Cluster cluster, Path wfPath, String wfName)
focal_class.class_method_signature: OozieFeedMapper.createRetentionWorkflow(Cluster cluster)
focal_class.full_signature: private WORKFLOWAPP createRetentionWorkflow(Cluster cluster)
focal_class.identifier: createRetentionWorkflow
focal_class.modifiers: private
focal_class.parameters: (Cluster cluster)
focal_class.return: WORKFLOWAPP
focal_class.signature: WORKFLOWAPP createRetentionWorkflow(Cluster cluster)
focal_class.class_method_signature: OozieFeedMapper.getEntityProperties()
focal_class.full_signature: @Override protected Map<String, String> getEntityProperties()
focal_class.identifier: getEntityProperties
focal_class.modifiers: @Override protected
focal_class.parameters: ()
focal_class.return: Map<String, String>
focal_class.signature: Map<String, String> getEntityProperties()
focal_class.class_method_signature: OozieFeedMapper.getLocationURI(Cluster cluster, Feed feed, LocationType type)
focal_class.full_signature: private String getLocationURI(Cluster cluster, Feed feed, LocationType type)
focal_class.identifier: getLocationURI
focal_class.modifiers: private
focal_class.parameters: (Cluster cluster, Feed feed, LocationType type)
focal_class.return: String
focal_class.signature: String getLocationURI(Cluster cluster, Feed feed, LocationType type)
focal_class.superclass: extends AbstractOozieEntityMapper<Feed>
focal_method.body: @Override
      protected List<COORDINATORAPP> getCoordinators(Cluster cluster, Path bundlePath) throws IvoryException {
          List<COORDINATORAPP> coords = new ArrayList<COORDINATORAPP>();
          COORDINATORAPP retentionCoord = getRetentionCoordinator(cluster, bundlePath);
          if (retentionCoord != null) {
              coords.add(retentionCoord);
          }
          List<COORDINATORAPP> replicationCoords = getReplicationCoordinators(cluster, bundlePath);
          coords.addAll(replicationCoords);
          return coords;
      }
focal_method.class_method_signature: OozieFeedMapper.getCoordinators(Cluster cluster, Path bundlePath)
focal_method.full_signature: @Override protected List<COORDINATORAPP> getCoordinators(Cluster cluster, Path bundlePath)
focal_method.identifier: getCoordinators
focal_method.invocations: getRetentionCoordinator add getReplicationCoordinators addAll
focal_method.modifiers: @Override protected
focal_method.parameters: (Cluster cluster, Path bundlePath)
focal_method.return: List<COORDINATORAPP>
focal_method.signature: List<COORDINATORAPP> getCoordinators(Cluster cluster, Path bundlePath)