Skip to content
Permalink
Browse files
BATCHEE-52 Scott Kurz patch supporting jobProperties substitution in …
…partition level components
  • Loading branch information
rmannibucau committed Aug 24, 2014
1 parent 1f57df1 commit e62c3ee54cb448e9d8086c7a2940523b0f0332a7
Showing 1 changed file with 5 additions and 5 deletions.
@@ -44,23 +44,23 @@ public Partition substituteProperties(final Partition partition, final Propertie

// Resolve all the properties defined for a partition
if (partition.getMapper() != null) {
PropertyResolverFactory.createPartitionMapperPropertyResolver(this.isPartitionedStep).substituteProperties(partition.getMapper(), submittedProps, null);
PropertyResolverFactory.createPartitionMapperPropertyResolver(this.isPartitionedStep).substituteProperties(partition.getMapper(), submittedProps, parentProps);
}

if (partition.getPlan() != null) {
PropertyResolverFactory.createPartitionPlanPropertyResolver(this.isPartitionedStep).substituteProperties(partition.getPlan(), submittedProps, null);
PropertyResolverFactory.createPartitionPlanPropertyResolver(this.isPartitionedStep).substituteProperties(partition.getPlan(), submittedProps, parentProps);
}

if (partition.getCollector() != null) {
PropertyResolverFactory.createCollectorPropertyResolver(this.isPartitionedStep).substituteProperties(partition.getCollector(), submittedProps, null);
PropertyResolverFactory.createCollectorPropertyResolver(this.isPartitionedStep).substituteProperties(partition.getCollector(), submittedProps, parentProps);
}

if (partition.getAnalyzer() != null) {
PropertyResolverFactory.createAnalyzerPropertyResolver(this.isPartitionedStep).substituteProperties(partition.getAnalyzer(), submittedProps, null);
PropertyResolverFactory.createAnalyzerPropertyResolver(this.isPartitionedStep).substituteProperties(partition.getAnalyzer(), submittedProps, parentProps);
}

if (partition.getReducer() != null) {
PropertyResolverFactory.createPartitionReducerPropertyResolver(this.isPartitionedStep).substituteProperties(partition.getReducer(), submittedProps, null);
PropertyResolverFactory.createPartitionReducerPropertyResolver(this.isPartitionedStep).substituteProperties(partition.getReducer(), submittedProps, parentProps);
}

return partition;

0 comments on commit e62c3ee

Please sign in to comment.