import javax.batch.api.chunk.ItemWriter; //导入依赖的package包/类
public static ItemWriterProxy createItemWriterProxy(String id, InjectionReferences injectionRefs, StepContextImpl stepContext) throws ArtifactValidationException {
    ItemWriter loadedArtifact = (ItemWriter)loadArtifact(id, injectionRefs);
    ItemWriterProxy proxy = new ItemWriterProxy(loadedArtifact);
    proxy.setStepContext(stepContext);
    
    return proxy;
}
 

import javax.batch.api.chunk.ItemWriter; //导入依赖的package包/类
@Override
public void initializeUI(UIBuilder builder) throws Exception {
	reader.setCompleter(new BatchUICompleter(AbstractItemReader.class,
			ItemReader.class));
	processor.setCompleter(new BatchUICompleter(null, ItemProcessor.class));
	writer.setCompleter(new BatchUICompleter(AbstractItemWriter.class,
			ItemWriter.class));
	
	reader.addValidator(new NamedValidator());
	processor.addValidator(new NamedValidator());
	writer.addValidator(new NamedValidator());

	jobXML.addValidator(new UIValidator() {

		@Override
		public void validate(UIValidationContext context) {
			String jobXMLName = ((String)context.getCurrentInputComponent().getValue());
			
			FileResource<?> resource = getJobXMLResource(context.getUIContext(),
					jobXMLName);
			if (resource.exists()) {
				context.addValidationError(context.getCurrentInputComponent(), resource.getFullyQualifiedName() + " already exists");
			}
		}

	});
	builder.add(jobXML).add(reader).add(processor).add(writer);
}
 

import javax.batch.api.chunk.ItemWriter; //导入依赖的package包/类
public CheckpointManager(final ItemReader reader, final ItemWriter writer,
                         final CheckpointAlgorithm chkptAlg,
                         final long jobInstanceID, final String stepId,
                         final PersistenceManagerService persistenceManagerService,
                         final DataRepresentationService dataRepresentationService) {
    this.readerProxy = reader;
    this.writerProxy = writer;
    this.checkpointAlgorithm = chkptAlg;
    this.stepId = stepId;
    this.jobInstanceID = jobInstanceID;

    this.persistenceManagerService = persistenceManagerService;
    this.dataRepresentationService = dataRepresentationService;
}
 

import javax.batch.api.chunk.ItemWriter; //导入依赖的package包/类
ItemWriterProxy(ItemWriter delegate) {     	
     super(delegate);
}
 

import javax.batch.api.chunk.ItemWriter; //导入依赖的package包/类
public static ItemWriter createItemWriterProxy(final BatchArtifactFactory factory, final String id, final InjectionReferences injectionRefs,
                                               final RuntimeJobExecution execution) {
    final ItemWriter loadedArtifact = (ItemWriter) loadArtifact(factory, id, injectionRefs, execution);
    return createProxy(loadedArtifact, injectionRefs, "writeItems");
}
 

import javax.batch.api.chunk.ItemWriter; //导入依赖的package包/类
@Override
public void open(final Serializable checkpoint) throws Exception {
    groovyInstance = Groovys.newInstance(ItemWriter.class, scriptPath, jobContext, stepContext);
    delegate = groovyInstance.getInstance();
    delegate.open(checkpoint);
}
 

import javax.batch.api.chunk.ItemWriter; //导入依赖的package包/类
protected MultiWriterBase(final ItemWriter writer1, final ItemWriter writer2) {
    init(writer1, writer2);
}
 

import javax.batch.api.chunk.ItemWriter; //导入依赖的package包/类
protected void init(final ItemWriter writer1, final ItemWriter writer2) {
    this.writer1 = writer1;
    this.writer2 = writer2;
}