• 如果您觉得本站非常有看点,那么赶紧使用Ctrl+D 收藏吧

Java Edits类的典型用法和代码示例

java 1次浏览

本文整理汇总了Java中org.apache.taverna.workflowmodel.Edits的典型用法代码示例。如果您正苦于以下问题:Java Edits类的具体用法?Java Edits怎么用?Java Edits使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

Edits类属于org.apache.taverna.workflowmodel包,在下文中一共展示了Edits类的26个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: LocalExecution

点赞 3

import org.apache.taverna.workflowmodel.Edits; //导入依赖的package包/类
/**
 * Constructs an Execution for executing Taverna workflows on a local
 * Taverna Dataflow Engine.
 * 
 * @param workflowBundle
 *            the <code>WorkflowBundle</code> containing the
 *            <code>Workflow</code>s required for execution
 * @param workflow
 *            the <code>Workflow</code> to execute
 * @param profile
 *            the <code>Profile</code> to use when executing the
 *            <code>Workflow</code>
 * @param dataBundle
 *            the <code>Bundle</code> containing the data values for the
 *            <code>Workflow</code>
 * @param referenceService
 *            the <code>ReferenceService</code> used to register inputs,
 *            outputs and intermediate values
 * @throws InvalidWorkflowException
 *             if the specified workflow is invalid
 */
public LocalExecution(WorkflowBundle workflowBundle, Workflow workflow,
		Profile profile, Bundle dataBundle,
		ReferenceService referenceService, Edits edits,
		ActivityService activityService,
		DispatchLayerService dispatchLayerService)
		throws InvalidWorkflowException {
	super(workflowBundle, workflow, profile, dataBundle);
	this.referenceService = referenceService;
	try {
		mapping = new WorkflowToDataflowMapper(workflowBundle, profile,
				edits, activityService, dispatchLayerService);
		Dataflow dataflow = mapping.getDataflow(workflow);
		for (DataflowInputPort dataflowInputPort : dataflow.getInputPorts())
			inputPorts.put(dataflowInputPort.getName(), dataflowInputPort);
		facade = edits.createWorkflowInstanceFacade(dataflow,
				createContext(), "");
		executionMonitor = new LocalExecutionMonitor(getWorkflowReport(),
				getDataBundle(), mapping, facade.getIdentifier());
	} catch (InvalidDataflowException e) {
		throw new InvalidWorkflowException(e);
	}
}
 

开发者ID:apache,
项目名称:incubator-taverna-engine,
代码行数:44,
代码来源:LocalExecution.java

示例2: WorkflowToDataflowMapper

点赞 3

import org.apache.taverna.workflowmodel.Edits; //导入依赖的package包/类
public WorkflowToDataflowMapper(WorkflowBundle workflowBundle,
		Profile profile, Edits edits, ActivityService activityService,
		DispatchLayerService dispatchLayerService) {
	this.workflowBundle = workflowBundle;
	this.profile = profile;
	this.edits = edits;
	this.activityService = activityService;
	this.dispatchLayerService = dispatchLayerService;
	inputPorts = new IdentityHashMap<>();
	outputPorts = new IdentityHashMap<>();
	merges = new IdentityHashMap<>();
	workflowToDataflow = new IdentityHashMap<>();
	dataflowToWorkflow = new HashMap<>();
	workflowToDataflowProcessors = new IdentityHashMap<>();
	dataflowToWorkflowProcessors = new HashMap<>();
	workflowToDataflowActivities = new IdentityHashMap<>();
	dataflowToWorkflowActivities = new HashMap<>();
}
 

开发者ID:apache,
项目名称:incubator-taverna-engine,
代码行数:19,
代码来源:WorkflowToDataflowMapper.java

示例3: testConfigureDataflowActivityConfigurationBean

点赞 3

import org.apache.taverna.workflowmodel.Edits; //导入依赖的package包/类
@Test
public void testConfigureDataflowActivityConfigurationBean() throws Exception {
	activity.setNestedDataflow(dataflow);
	assertEquals(dataflow, activity.getNestedDataflow());

	Edits edits = new EditsImpl();
	dataflow = edits.createDataflow();
	edits.getAddActivityInputPortEdit(activity, new ActivityInputPortImpl("input", 0)).doEdit();
	edits.getAddActivityOutputPortEdit(activity, new ActivityOutputPortImpl("output", 0, 0))
			.doEdit();

	assertEquals(1, activity.getInputPorts().size());
	assertEquals("input", activity.getInputPorts().iterator().next().getName());
	assertEquals(1, activity.getOutputPorts().size());
	assertEquals("output", activity.getOutputPorts().iterator().next().getName());

	Map<String, Object> inputs = new HashMap<String, Object>();
	inputs.put("input", "aString");
	Map<String, Class<?>> expectedOutputs = new HashMap<String, Class<?>>();
	expectedOutputs.put("output", String.class);

	Map<String, Object> outputs = ActivityInvoker.invokeAsyncActivity(activity, inputs,
			expectedOutputs);
	assertTrue("there should be an output named output", outputs.containsKey("output"));
	assertEquals("output should have the value aString", "aString", outputs.get("output"));
}
 

开发者ID:apache,
项目名称:incubator-taverna-engine,
代码行数:27,
代码来源:DataflowActivityTest.java

示例4: getDisconnectDatalinkAndRemovePortsEdit

点赞 3

import org.apache.taverna.workflowmodel.Edits; //导入依赖的package包/类
public static Edit<?> getDisconnectDatalinkAndRemovePortsEdit(
		Datalink datalink, Edits edits) {
	List<Edit<?>> editList = new ArrayList<>();
	editList.add(edits.getDisconnectDatalinkEdit(datalink));
	if (datalink.getSource() instanceof ProcessorOutputPort) {
		ProcessorOutputPort processorOutputPort = (ProcessorOutputPort) datalink
				.getSource();
		if (processorOutputPort.getOutgoingLinks().size() == 1)
			editList.add(getRemoveProcessorOutputPortEdit(
					processorOutputPort, edits));
	}
	if (datalink.getSink() instanceof ProcessorInputPort)
		editList.add(getRemoveProcessorInputPortEdit(
				(ProcessorInputPort) datalink.getSink(), edits));
	return new CompoundEdit(editList);
}
 

开发者ID:apache,
项目名称:incubator-taverna-engine,
代码行数:17,
代码来源:Tools.java

示例5: addDataflowIdentification

点赞 3

import org.apache.taverna.workflowmodel.Edits; //导入依赖的package包/类
/**
 * Add the identification of a Dataflow into its identification annotation
 * chain (if necessary)
 * 
 * @return Whether an identification needed to be added
 */
public static boolean addDataflowIdentification(Dataflow dataflow,
		String internalId, Edits edits) {
	IdentificationAssertion ia = (IdentificationAssertion) getAnnotation(
			dataflow, IdentificationAssertion.class);
	if (ia != null && ia.getIdentification().equals(internalId))
		return false;
	IdentificationAssertion newIa = new IdentificationAssertion();
	newIa.setIdentification(internalId);
	try {
		addAnnotation(dataflow, newIa, edits).doEdit();
		return true;
	} catch (EditException e) {
		return false;
	}
}
 

开发者ID:apache,
项目名称:incubator-taverna-engine,
代码行数:22,
代码来源:Tools.java

示例6: simpleScript

点赞 3

import org.apache.taverna.workflowmodel.Edits; //导入依赖的package包/类
/**
 * Tests a simple script (String output = input + "_returned") to ensure the script is invoked correctly.
 * @throws Exception
 */
@Test
public void simpleScript() throws Exception {
	BeanshellActivity activity = new BeanshellActivity(null);
	Edits edits = new EditsImpl();
	edits.getAddActivityInputPortEdit(activity, new ActivityInputPortImpl("input", 0, false, null, String.class)).doEdit();
	edits.getAddActivityOutputPortEdit(activity, new ActivityOutputPortImpl("output", 0, 0)).doEdit();

	configuration.put("script", "String output = input + \"_returned\";");

	activity.configure(configuration);
	assertEquals("There should be 1 input port",1,activity.getInputPorts().size());
	assertEquals("There should be 1 output port",1,activity.getOutputPorts().size());

	assertEquals("The input should be called input", "input",((AbstractPort)activity.getInputPorts().toArray()[0]).getName());
	assertEquals("The output should be called output", "output",((AbstractPort)activity.getOutputPorts().toArray()[0]).getName());

	Map<String,Object> inputs = new HashMap<String, Object>();
	inputs.put("input", "aString");
	Map<String, Class<?>> expectedOutputs = new HashMap<String, Class<?>>();
	expectedOutputs.put("output", String.class);

	Map<String,Object> outputs = ActivityInvoker.invokeAsyncActivity(activity, inputs, expectedOutputs);
	assertTrue("there should be an output named output",outputs.containsKey("output"));
	assertEquals("output should have the value aString_returned","aString_returned",outputs.get("output"));
}
 

开发者ID:apache,
项目名称:incubator-taverna-common-activities,
代码行数:30,
代码来源:BeanshellActivityTest.java

示例7: addProvenanceLayerToProcessors

点赞 2

import org.apache.taverna.workflowmodel.Edits; //导入依赖的package包/类
private void addProvenanceLayerToProcessors(WorkflowProvenanceItem workflowItem) {
	// TODO Shouldn't we use a bean for this? 
	Edits edits = new EditsImpl();
	for (Processor processor : dataflow.getProcessors())
		/*
		 * Synchronized per processor as we might be modifying its dispatch
		 * stack (fixes T3-929)
		 */
	    synchronized (processor) {               
	        DispatchStack dispatchStack = processor.getDispatchStack();
   			List<DispatchLayer<?>> layers = dispatchStack.getLayers();
   			if (isProvenanceAlreadyAdded(layers))
   				continue;
   			IntermediateProvenance provenance = new IntermediateProvenance();
			provenance.setWorkflow(workflowItem);
			provenance.setReporter(context.getProvenanceReporter());

			try {
				edits.getAddDispatchLayerEdit(dispatchStack, provenance,
				        provenancePosition(layers)).doEdit();
				break;
			} catch (EditException e) {
				logger.warn("adding provenance layer to dispatch stack failed "
								+ e.toString());
			}
	    }
}
 

开发者ID:apache,
项目名称:incubator-taverna-engine,
代码行数:28,
代码来源:WorkflowInstanceFacadeImpl.java

示例8: setUp

点赞 2

import org.apache.taverna.workflowmodel.Edits; //导入依赖的package包/类
@Before
public void setUp() throws Exception {
	activity = new DataflowActivity();
	Edits edits = new EditsImpl();
	activity.setEdits(edits);
	dataflow = edits.createDataflow();
	edits.getCreateDataflowInputPortEdit(dataflow, "input", 0, 0).doEdit();
	edits.getCreateDataflowOutputPortEdit(dataflow, "output").doEdit();
	Datalink datalink = edits.createDatalink(dataflow.getInputPorts().get(0)
			.getInternalOutputPort(), dataflow.getOutputPorts().get(0).getInternalInputPort());
	edits.getConnectDatalinkEdit(datalink).doEdit();
}
 

开发者ID:apache,
项目名称:incubator-taverna-engine,
代码行数:13,
代码来源:DataflowActivityTest.java

示例9: setAnnotationString

点赞 2

import org.apache.taverna.workflowmodel.Edits; //导入依赖的package包/类
public static Edit<?> setAnnotationString(Annotated<?> annotated,
		Class<?> c, String value, Edits edits) {
	AbstractTextualValueAssertion a = null;
	try {
		logger.info("Setting " + c.getCanonicalName() + " to " + value);
		a = (AbstractTextualValueAssertion) c.newInstance();
	} catch (InstantiationException | IllegalAccessException e) {
		logger.error(e);
		throw new RuntimeException(e);
	}
	a.setText(value);
	return addAnnotation(annotated, a, edits);
}
 

开发者ID:apache,
项目名称:incubator-taverna-engine,
代码行数:14,
代码来源:AnnotationTools.java

示例10: getMoveDatalinkSinkEdit

点赞 2

import org.apache.taverna.workflowmodel.Edits; //导入依赖的package包/类
public static Edit<?> getMoveDatalinkSinkEdit(Dataflow dataflow,
		Datalink datalink, EventHandlingInputPort sink, Edits edits) {
	List<Edit<?>> editList = new ArrayList<>();
	editList.add(edits.getDisconnectDatalinkEdit(datalink));
	if (datalink.getSink() instanceof ProcessorInputPort)
		editList.add(getRemoveProcessorInputPortEdit(
				(ProcessorInputPort) datalink.getSink(), edits));
	editList.add(getCreateAndConnectDatalinkEdit(dataflow,
			datalink.getSource(), sink, edits));
	return new CompoundEdit(editList);
}
 

开发者ID:apache,
项目名称:incubator-taverna-engine,
代码行数:12,
代码来源:Tools.java

示例11: getRemoveProcessorOutputPortEdit

点赞 2

import org.apache.taverna.workflowmodel.Edits; //导入依赖的package包/类
public static Edit<?> getRemoveProcessorOutputPortEdit(
		ProcessorOutputPort port, Edits edits) {
	List<Edit<?>> editList = new ArrayList<>();
	Processor processor = port.getProcessor();
	editList.add(edits.getRemoveProcessorOutputPortEdit(
			port.getProcessor(), port));
	for (Activity<?> activity : processor.getActivityList())
		editList.add(edits.getRemoveActivityOutputPortMappingEdit(activity,
				port.getName()));
	return new CompoundEdit(editList);
}
 

开发者ID:apache,
项目名称:incubator-taverna-engine,
代码行数:12,
代码来源:Tools.java

示例12: getRemoveProcessorInputPortEdit

点赞 2

import org.apache.taverna.workflowmodel.Edits; //导入依赖的package包/类
public static Edit<?> getRemoveProcessorInputPortEdit(
		ProcessorInputPort port, Edits edits) {
	List<Edit<?>> editList = new ArrayList<>();
	Processor processor = port.getProcessor();
	editList.add(edits.getRemoveProcessorInputPortEdit(port.getProcessor(),
			port));
	for (Activity<?> activity : processor.getActivityList())
		editList.add(edits.getRemoveActivityInputPortMappingEdit(activity,
				port.getName()));
	return new CompoundEdit(editList);
}
 

开发者ID:apache,
项目名称:incubator-taverna-engine,
代码行数:12,
代码来源:Tools.java

示例13: getEdits

点赞 2

import org.apache.taverna.workflowmodel.Edits; //导入依赖的package包/类
/**
 * @return the edits
 */
public Edits getEdits() {
	if (edits == null)
		throw new IllegalStateException(
				"Unable to run this meathod until setEdits has been called");
	return edits;
}
 

开发者ID:apache,
项目名称:incubator-taverna-engine,
代码行数:10,
代码来源:AbstractActivity.java

示例14: ComponentActivity

点赞 2

import org.apache.taverna.workflowmodel.Edits; //导入依赖的package包/类
ComponentActivity(ComponentUtil util, ComponentImplementationCache cache,
		Edits edits, SystemUtils system, AnnotationUtils annUtils, ComponentExceptionFactory exnFactory) {
	this.util = util;
	this.cache = cache;
	this.system = system;
	this.annUtils = annUtils;
	setEdits(edits);
	this.componentRealization = new DataflowActivity();
	this.cef = exnFactory;
}
 

开发者ID:apache,
项目名称:incubator-taverna-plugin-component,
代码行数:11,
代码来源:ComponentActivity.java

示例15: AddXMLSplitterEdit

点赞 2

import org.apache.taverna.workflowmodel.Edits; //导入依赖的package包/类
public AddXMLSplitterEdit(Dataflow dataflow, Activity<?> activity,
		String portName, boolean isInput, Edits edits) {
	this.dataflow = dataflow;
	this.activity = activity;
	this.portName = portName;
	this.isInput = isInput;
	this.edits = edits;
}
 

开发者ID:apache,
项目名称:incubator-taverna-common-activities,
代码行数:9,
代码来源:AddXMLSplitterEdit.java

示例16: setEdits

点赞 2

import org.apache.taverna.workflowmodel.Edits; //导入依赖的package包/类
public void setEdits(Edits edits) {
	this.edits = edits;
}
 

开发者ID:apache,
项目名称:incubator-taverna-engine,
代码行数:4,
代码来源:DataflowActivityFactory.java

示例17: addAnnotation

点赞 2

import org.apache.taverna.workflowmodel.Edits; //导入依赖的package包/类
public static Edit<?> addAnnotation(Annotated<?> annotated,
		AnnotationBeanSPI a, Edits edits) {
	return edits.getAddAnnotationChainEdit(annotated, a);
}
 

开发者ID:apache,
项目名称:incubator-taverna-engine,
代码行数:5,
代码来源:AnnotationTools.java

示例18: findEventHandlingInputPort

点赞 2

import org.apache.taverna.workflowmodel.Edits; //导入依赖的package包/类
/**
 * Find (and possibly create) an EventHandlingInputPort.
 * <p>
 * If the given inputPort is an instance of {@link EventHandlingInputPort},
 * it is returned directly. If it is an ActivityInputPort - the owning
 * processors (found by searching the dataflow) will be searced for a mapped
 * input port. If this cannot be found, one will be created and mapped. The
 * edits for this will be added to the editList and needs to be executed by
 * the caller.
 * 
 * @see #findEventHandlingOutputPort(List, Dataflow, OutputPort)
 * @param editList
 *            List of {@link Edit}s to append any required edits (yet to be
 *            performed) to
 * @param dataflow
 *            Dataflow containing the processors
 * @param inputPort
 *            An EventHandlingInputPort or ActivityInputPort
 * @return The found or created EventHandlingInputPort
 */
protected static EventHandlingInputPort findEventHandlingInputPort(
		List<Edit<?>> editList, Dataflow dataflow, InputPort inputPort,
		Edits edits) {
	if (inputPort instanceof EventHandlingInputPort)
		return (EventHandlingInputPort) inputPort;
	else if (!(inputPort instanceof ActivityInputPort))
		throw new IllegalArgumentException("Unknown input port type for "
				+ inputPort);

	ActivityInputPort activityInput = (ActivityInputPort) inputPort;
	Collection<Processor> processors = getProcessorsWithActivityInputPort(
			dataflow, activityInput);
	if (processors.isEmpty())
		throw new IllegalArgumentException("Can't find ActivityInputPort "
				+ activityInput.getName() + " in workflow " + dataflow);

	// FIXME: Assumes only one matching processor
	Processor processor = processors.iterator().next();
	Activity<?> activity = null;
	for (Activity<?> checkActivity : processor.getActivityList())
		if (checkActivity.getInputPorts().contains(activityInput)) {
			activity = checkActivity;
			break;
		}
	if (activity == null)
		throw new IllegalArgumentException("Can't find activity for port "
				+ activityInput.getName() + "within processor " + processor);

	ProcessorInputPort input = getProcessorInputPort(processor, activity,
			activityInput);
	if (input != null)
		return input;
	// port doesn't exist so create a processor port and map it
	String processorPortName = uniquePortName(activityInput.getName(),
			processor.getInputPorts());
	ProcessorInputPort processorInputPort = edits.createProcessorInputPort(
			processor, processorPortName, activityInput.getDepth());
	editList.add(edits.getAddProcessorInputPortEdit(processor,
			processorInputPort));
	editList.add(edits.getAddActivityInputPortMappingEdit(activity,
			processorPortName, activityInput.getName()));
	return processorInputPort;
}
 

开发者ID:apache,
项目名称:incubator-taverna-engine,
代码行数:64,
代码来源:Tools.java

示例19: findEventHandlingOutputPort

点赞 2

import org.apache.taverna.workflowmodel.Edits; //导入依赖的package包/类
/**
 * Find (and possibly create) an EventForwardingOutputPort.
 * <p>
 * If the given outputPort is an instance of
 * {@link EventForwardingOutputPort}, it is returned directly. If it is an
 * ActivityOutputPort - the owning processors (found by searching the
 * dataflow) will be searced for a mapped output port. If this cannot be
 * found, one will be created and mapped. The edits for this will be added
 * to the editList and needs to be executed by the caller.
 * 
 * @see #findEventHandlingInputPort(List, Dataflow, InputPort)
 * @param editList
 *            List of {@link Edit}s to append any required edits (yet to be
 *            performed) to
 * @param dataflow
 *            Dataflow containing the processors
 * @param outputPort
 *            An EventForwardingOutputPort or ActivityOutputPort
 * @return The found or created EventForwardingOutputPort
 */
protected static EventForwardingOutputPort findEventHandlingOutputPort(
		List<Edit<?>> editList, Dataflow dataflow, OutputPort outputPort,
		Edits edits) {
	if (outputPort instanceof EventForwardingOutputPort)
		return (EventForwardingOutputPort) outputPort;
	else if (!(outputPort instanceof ActivityOutputPort))
		throw new IllegalArgumentException("Unknown output port type for "
				+ outputPort);

	ActivityOutputPort activityOutput = (ActivityOutputPort) outputPort;
	Collection<Processor> processors = getProcessorsWithActivityOutputPort(
			dataflow, activityOutput);
	if (processors.isEmpty())
		throw new IllegalArgumentException("Can't find ActivityOutputPort "
				+ activityOutput.getName() + " in workflow " + dataflow);

	// FIXME: Assumes only one matching processor
	Processor processor = processors.iterator().next();
	Activity<?> activity = null;
	for (Activity<?> checkActivity : processor.getActivityList())
		if (checkActivity.getOutputPorts().contains(activityOutput)) {
			activity = checkActivity;
			break;
		}
	if (activity == null)
		throw new IllegalArgumentException("Can't find activity for port "
				+ activityOutput.getName() + "within processor "
				+ processor);

	ProcessorOutputPort processorOutputPort = Tools.getProcessorOutputPort(
			processor, activity, activityOutput);
	if (processorOutputPort != null)
		return processorOutputPort;

	// port doesn't exist so create a processor port and map it
	String processorPortName = uniquePortName(activityOutput.getName(),
			processor.getOutputPorts());
	processorOutputPort = edits.createProcessorOutputPort(processor,
			processorPortName, activityOutput.getDepth(),
			activityOutput.getGranularDepth());
	editList.add(edits.getAddProcessorOutputPortEdit(processor,
			processorOutputPort));
	editList.add(edits.getAddActivityOutputPortMappingEdit(activity,
			processorPortName, activityOutput.getName()));

	return processorOutputPort;
}
 

开发者ID:apache,
项目名称:incubator-taverna-engine,
代码行数:68,
代码来源:Tools.java

示例20: setEdits

点赞 2

import org.apache.taverna.workflowmodel.Edits; //导入依赖的package包/类
@Override
public void setEdits(Edits edits) {
	if (edits == null)
		throw new IllegalArgumentException("Edits can not be null.");
	this.edits = edits;
}
 

开发者ID:apache,
项目名称:incubator-taverna-engine,
代码行数:7,
代码来源:AbstractActivity.java

示例21: setEdits

点赞 2

import org.apache.taverna.workflowmodel.Edits; //导入依赖的package包/类
@Required
public void setEdits(Edits edits) {
	this.edits = edits;
}
 

开发者ID:apache,
项目名称:incubator-taverna-plugin-component,
代码行数:5,
代码来源:ComponentActivityFactory.java

示例22: getEdits

点赞 2

import org.apache.taverna.workflowmodel.Edits; //导入依赖的package包/类
private Edits getEdits() {
	return new EditsImpl();
}
 

开发者ID:apache,
项目名称:incubator-taverna-workbench,
代码行数:4,
代码来源:WorkbenchTest.java

示例23: getCreateAndConnectDatalinkEdit

点赞 1

import org.apache.taverna.workflowmodel.Edits; //导入依赖的package包/类
/**
 * Get an {@link Edit} that will link the given output port to the given
 * input port.
 * <p>
 * The output port can be an {@link EventForwardingOutputPort} (such as an
 * {@link ProcessorOutputPort}, or an {@link ActivityOutputPort}. The input
 * port can be an {@link EventHandlingInputPort} (such as an
 * {@link ProcessorInputPort}, or an {@link ActivityInputPort}.
 * <p>
 * If an input and/or output port is an activity port, processors in the
 * given dataflow will be searched for matching mappings, create the
 * processor port and mapping if needed, before constructing the edits for
 * adding the datalink.
 * 
 * @param dataflow
 *            Dataflow (indirectly) containing ports
 * @param outputPort
 *            An {@link EventForwardingOutputPort} or an
 *            {@link ActivityOutputPort}
 * @param inputPort
 *            An {@link EventHandlingInputPort} or an
 *            {@link ActivityInputPort}
 * @return A compound edit for creating and connecting the datalink and any
 *         neccessary processor ports and mappings
 */
public static Edit<?> getCreateAndConnectDatalinkEdit(Dataflow dataflow,
		OutputPort outputPort, InputPort inputPort, Edits edits) {
	List<Edit<?>> editList = new ArrayList<>();
	EventHandlingInputPort sink = findEventHandlingInputPort(editList,
			dataflow, inputPort, edits);
	EventForwardingOutputPort source = findEventHandlingOutputPort(
			editList, dataflow, outputPort, edits);
	editList.add(getCreateAndConnectDatalinkEdit(dataflow, source, sink,
			edits));
	return new CompoundEdit(editList);
}
 

开发者ID:apache,
项目名称:incubator-taverna-engine,
代码行数:37,
代码来源:Tools.java

示例24: setEdits

点赞 1

import org.apache.taverna.workflowmodel.Edits; //导入依赖的package包/类
/**
 * Sets the edits property.
 * <p>
 * This method is used by Spring. The property name must match the property specified
 * in the Spring context file.
 *
 * @param edits the <code>Edits</code> used to create input/output ports
 */
public void setEdits(Edits edits) {
	this.edits = edits;
}
 

开发者ID:apache,
项目名称:incubator-taverna-plugin-gis,
代码行数:12,
代码来源:GisActivityFactory.java

示例25: setEdits

点赞 1

import org.apache.taverna.workflowmodel.Edits; //导入依赖的package包/类
/**
 * Sets the Edits Service for creating Taverna Dataflows.
 *
 * @param edits
 *            the Edits Service for creating Taverna Dataflows
 */
public void setEdits(Edits edits) {
	this.edits = edits;
}
 

开发者ID:apache,
项目名称:incubator-taverna-engine,
代码行数:10,
代码来源:LocalExecutionService.java

示例26: setEdits

点赞 1

import org.apache.taverna.workflowmodel.Edits; //导入依赖的package包/类
void setEdits(Edits edits); 

开发者ID:apache,
项目名称:incubator-taverna-engine,
代码行数:2,
代码来源:Activity.java


版权声明:本文转自网络文章,转载此文章仅为分享知识,如有侵权,请联系管理员进行删除。
喜欢 (0)