Class PEInputPort

java.lang.Object
com.teracloud.streams.rest.Element
com.teracloud.streams.rest.PEInputPort

public class PEInputPort extends Element
An Input Port of the Streams Processing Element
  • Constructor Details

    • PEInputPort

      public PEInputPort()
  • Method Details

    • getIndexWithinPE

      public long getIndexWithinPE()
      Gets the index of this input port within the processing element
      Returns:
      the index number as a long
    • getMetrics

      public List<Metric> getMetrics() throws IOException
      Gets the metrics for this processing element input port
      Returns:
      List of Streams Metrics
      Throws:
      IOException
    • getTransportType

      public String getTransportType()
      Gets the transport type for this processing element input port
      Returns:
      the transport type containing one of the following possible values:
      • tcp
      • llm-rum-tcp
      • llm-rum-ib
    • getResourceType

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