Class CompositePipelineAction

Method Details

• apply

  public DataReader apply(DataReader reader) throws Throwable

  Description copied from interface: DataReaderAction

  Returns a reader that applies this action to the records of the given reader, usually by wrapping it.

  Throws:

  Throwable

• getActions

  public List<PipelineAction> getActions()

  Returns a read-only view of the nested actions.

• getActionCount

  public int getActionCount()

• addAction

  public CompositePipelineAction addAction(PipelineAction action)

  Appends a nested action and attaches it to this action's pipeline.

• addAction

  public CompositePipelineAction addAction(Integer index, PipelineAction action)

  Inserts a nested action at the given 0-based index (or appends it if the index is null) and attaches it to this action's pipeline.

• setPipeline

  public PipelineAction setPipeline(Pipeline pipeline)

  Description copied from class: PipelineAction

  Sets the pipeline this action belongs to; called by Pipeline when the action is added to it.

  Overrides:

  setPipeline in class PipelineAction

• setAction

  public CompositePipelineAction setAction(int index, PipelineAction action)

  Replaces the nested action at the given 0-based index and attaches it to this action's pipeline.

• setActions

  public CompositePipelineAction setActions(List<PipelineAction> actions)

  Replaces the nested actions with the given list and attaches each of them to this action's pipeline.

• generateJavaCode

  public void generateJavaCode(JavaCodeBuilder code)

  Description copied from interface: JavaCodeGenerator

  Appends Java source code representing this object to the given builder.

  Specified by:

  generateJavaCode in interface JavaCodeGenerator

  Overrides:

  generateJavaCode in class PipelineAction

• getJavaCode

  public JavaCodeBuilder getJavaCode()

  Returns a Java program, a DataPipelineDesktop class whose main method holds the nested actions' generated code.

• toRecord

  public Record toRecord()

  Description copied from interface: RecordSerializable

  Converts this object's state to a record that RecordSerializable.fromRecord(Record) can load.

  Specified by:

  toRecord in interface RecordSerializable

  Overrides:

  toRecord in class PipelineAction

• fromJson

  public CompositePipelineAction fromJson(String jsonString)

  Description copied from interface: JsonSerializable

  Loads this object's state from the given JSON text.

• fromRecord

  public CompositePipelineAction fromRecord(Record source)

  Description copied from interface: RecordSerializable

  Loads this instance's state from a record and returns this (for fluid API call chaining). For fluid API call chaining, the overridden method should change the declared return type to its class.

  Specified by:

  fromRecord in interface RecordSerializable

  Overrides:

  fromRecord in class PipelineAction

  Parameters:

  source -

  Returns:

  this instance.

• toXmlElement

  public Element toXmlElement(Document document)

  Description copied from interface: XmlSerializable

  Returns an element, created with document, describing this object; the default implementation throws a DataException.

  Specified by:

  toXmlElement in interface XmlSerializable

  Overrides:

  toXmlElement in class PipelineAction

• fromXmlElement

  public PipelineAction fromXmlElement(Element element)

  Specified by:

  fromXmlElement in interface XmlSerializable

  Overrides:

  fromXmlElement in class PipelineAction