public class DataflowActivityFactory extends Object implements ActivityFactory
ActivityFactory
for creating DataflowActivity
.Constructor and Description |
---|
DataflowActivityFactory() |
Modifier and Type | Method and Description |
---|---|
DataflowActivity |
createActivity()
Creates a new
Activity instance. |
com.fasterxml.jackson.databind.JsonNode |
getActivityConfigurationSchema()
Returns the JSON Schema for the configuration required by the
Activity . |
URI |
getActivityType()
What type of
Activity s can this factory create? |
Set<ActivityInputPort> |
getInputPorts(com.fasterxml.jackson.databind.JsonNode configuration)
Returns the
ActivityInputPort s that the
Activity requires to be present in order to execute with the
specified configuration. |
Set<ActivityOutputPort> |
getOutputPorts(com.fasterxml.jackson.databind.JsonNode configuration)
Returns the
ActivityOutputPort s that the
Activity requires to be present in order to execute with the
specified configuration. |
void |
setEdits(Edits edits) |
public DataflowActivity createActivity()
ActivityFactory
Activity
instance.createActivity
in interface ActivityFactory
Activity
instancepublic URI getActivityType()
ActivityFactory
Activity
s can this factory create?getActivityType
in interface ActivityFactory
Activity
s that this factory can
createpublic com.fasterxml.jackson.databind.JsonNode getActivityConfigurationSchema()
ActivityFactory
Activity
.getActivityConfigurationSchema
in interface ActivityFactory
Activity
public Set<ActivityInputPort> getInputPorts(com.fasterxml.jackson.databind.JsonNode configuration)
ActivityFactory
ActivityInputPort
s that the
Activity
requires to be present in order to execute with the
specified configuration.
If the Activity
does not require any input port for the
configuration then an empty set is returned.
getInputPorts
in interface ActivityFactory
configuration
- the configurationActivityInputPort
s that the
Activity
requires to be present in order to executepublic Set<ActivityOutputPort> getOutputPorts(com.fasterxml.jackson.databind.JsonNode configuration)
ActivityFactory
ActivityOutputPort
s that the
Activity
requires to be present in order to execute with the
specified configuration.
If the Activity
does not require any output ports for the
configuration then an empty set is returned.
getOutputPorts
in interface ActivityFactory
configuration
- the configurationActivityOutputPort
s that the
Activity
requires to be present in order to executepublic void setEdits(Edits edits)
Copyright © 2015–2016 The Apache Software Foundation. All rights reserved.