Examples of PartitionMapper

javax.batch.api.partition.PartitionMapper
PartitionMapper receives control at the start of a partitioned execution. A PartitionMapper is responsible to provide unique batch properties for each partition.
org.jberet.job.PartitionMapper
3.org/2001/XMLSchema}anyType"> <sequence> <element name="properties" type="{http://xmlns.jcp.org/xml/ns/javaee}Properties" minOccurs="0"/> </sequence> <attribute name="ref" use="required" type="{http://xmlns.jcp.org/xml/ns/javaee}artifactRef" /> </restriction> </complexContent> </complexType>

Examples of javax.batch.api.partition.PartitionMapper

    assertEquals(3, count);
  }


  @Test
  public void testMapperProvidesPartitionsAndThreads() throws Exception {
    handler.setPartitionMapper(new PartitionMapper() {


      @Override
      public PartitionPlan mapPartitions() throws Exception {
        PartitionPlan plan = new PartitionPlanImpl();
        plan.setPartitions(3);

View Full Code Here

Examples of javax.batch.api.partition.PartitionMapper

    assertEquals(3, count);
  }


  @Test
  public void testMapperWithProperties() throws Exception {
    handler.setPartitionMapper(new PartitionMapper() {


      @Override
      public PartitionPlan mapPartitions() throws Exception {
        PartitionPlan plan = new PartitionPlanImpl();
        Properties [] props = new Properties[2];

View Full Code Here

Examples of org.jberet.job.PartitionMapper

                for (org.jberet.job.Properties p : plan.getProperties()) {
                    resolve(p, true);
                }
            }
        }
        PartitionMapper mapper = partition.getMapper();
        if (mapper != null) {
            oldVal = mapper.getRef();
            newVal = resolve(oldVal);
            if (!oldVal.equals(newVal)) {
                mapper.setRef(newVal);
            }
            //mapper properties should be resolved at job load time (1st pass)
            if (!resolvePartitionPlanProperties) {
                resolve(mapper.getProperties(), true);
            }
        }
    }

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.