Package com.teracloud.streams.rest

Class Operator

java.lang.Object
com.teracloud.streams.rest.Element
com.teracloud.streams.rest.Operator
public class Operator extends Element
An object describing an Streams Operator

  • Constructor Details

    • Operator

      public Operator()

  • Method Details

    • getLogicalName

      public String getLogicalName()
      The logical name of this operator.
      Returns:
      the logical name of the operator, which is just the name if the operator is not part of a parallel region.
      Since:
      1.9

    • getMetrics

      public List<Metric> getMetrics() throws IOException
      Gets a list of metrics for this operator
      Returns:
      List of Streams Metrics
      Throws:
      IOException

    • getIndexWithinJob

      public long getIndexWithinJob()
      Gets the index of this operator within the Job
      Returns:
      the index as a long

    • getInputPorts

      public List<InputPort> getInputPorts() throws IOException
      Gets a list of input ports for this operator
      Returns:
      List of Input Ports for this operator
      Throws:
      IOException

    • getName

      public String getName()
      Name of this operator
      Returns:
      the operator name

    • getOperatorKind

      public String getOperatorKind()
      SPL primitive operator type for this operator
      Returns:
      the SPL primitive operator type

    • getOutputPorts

      public List<OutputPort> getOutputPorts() throws IOException
      Gets a list of output ports for this operator
      Returns:
      List of Output Ports for this operator
      Throws:
      IOException

    • getResourceType

      public String getResourceType()
      Identifies the REST resource type
      Returns:
      "operator"

    • getPE

      public ProcessingElement getPE() throws IOException
      Get the PE for this operator.
      Returns:
      PE for this operator.
      Throws:
      IOException
      Since:
      1.9