Package ai.pipestream.data.v1

Interface PipeStreamOrBuilder

All Superinterfaces:
com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder
All Known Implementing Classes:
PipeStream, PipeStream.Builder
@Generated public interface PipeStreamOrBuilder extends com.google.protobuf.MessageOrBuilder

  • Method Details

    • getStreamId

      String getStreamId()
       Unique identifier for this processing stream.
      string stream_id = 1;
      Returns:
      The streamId.

    • getStreamIdBytes

      com.google.protobuf.ByteString getStreamIdBytes()
       Unique identifier for this processing stream.
      string stream_id = 1;
      Returns:
      The bytes for streamId.

    • hasMetadata

      boolean hasMetadata()
       Stream metadata including history and tracing.
      .ai.pipestream.data.v1.StreamMetadata metadata = 2;
      Returns:
      Whether the metadata field is set.

    • getMetadata

      StreamMetadata getMetadata()
       Stream metadata including history and tracing.
      .ai.pipestream.data.v1.StreamMetadata metadata = 2;
      Returns:
      The metadata.

    • getMetadataOrBuilder

      StreamMetadataOrBuilder getMetadataOrBuilder()
       Stream metadata including history and tracing.
      .ai.pipestream.data.v1.StreamMetadata metadata = 2;

    • hasDocument

      boolean hasDocument()
       The document being processed.
      .ai.pipestream.data.v1.PipeDoc document = 3;
      Returns:
      Whether the document field is set.

    • getDocument

      PipeDoc getDocument()
       The document being processed.
      .ai.pipestream.data.v1.PipeDoc document = 3;
      Returns:
      The document.

    • getDocumentOrBuilder

      PipeDocOrBuilder getDocumentOrBuilder()
       The document being processed.
      .ai.pipestream.data.v1.PipeDoc document = 3;

    • getClusterId

      String getClusterId()
       Cluster where processing is occurring.
      string cluster_id = 4;
      Returns:
      The clusterId.

    • getClusterIdBytes

      com.google.protobuf.ByteString getClusterIdBytes()
       Cluster where processing is occurring.
      string cluster_id = 4;
      Returns:
      The bytes for clusterId.

    • getCurrentNodeId

      String getCurrentNodeId()
       Current node processing this stream.
      string current_node_id = 5;
      Returns:
      The currentNodeId.

    • getCurrentNodeIdBytes

      com.google.protobuf.ByteString getCurrentNodeIdBytes()
       Current node processing this stream.
      string current_node_id = 5;
      Returns:
      The bytes for currentNodeId.

    • getHopCount

      long getHopCount()
       Number of processing hops taken.
      int64 hop_count = 6;
      Returns:
      The hopCount.

    • getProcessingPathList

      List<String> getProcessingPathList()
       Ordered list of node IDs traversed during processing.
      repeated string processing_path = 7;
      Returns:
      A list containing the processingPath.

    • getProcessingPathCount

      int getProcessingPathCount()
       Ordered list of node IDs traversed during processing.
      repeated string processing_path = 7;
      Returns:
      The count of processingPath.

    • getProcessingPath

      String getProcessingPath(int index)
       Ordered list of node IDs traversed during processing.
      repeated string processing_path = 7;
      Parameters:
      index - The index of the element to return.
      Returns:
      The processingPath at the given index.

    • getProcessingPathBytes

      com.google.protobuf.ByteString getProcessingPathBytes(int index)
       Ordered list of node IDs traversed during processing.
      repeated string processing_path = 7;
      Parameters:
      index - The index of the value to return.
      Returns:
      The bytes of the processingPath at the given index.

    • hasNodeProcessingConfig

      boolean hasNodeProcessingConfig()
       Configuration for the current node's processing step.
      .ai.pipestream.data.v1.NodeProcessingConfig node_processing_config = 8;
      Returns:
      Whether the nodeProcessingConfig field is set.

    • getNodeProcessingConfig

      NodeProcessingConfig getNodeProcessingConfig()
       Configuration for the current node's processing step.
      .ai.pipestream.data.v1.NodeProcessingConfig node_processing_config = 8;
      Returns:
      The nodeProcessingConfig.

    • getNodeProcessingConfigOrBuilder

      NodeProcessingConfigOrBuilder getNodeProcessingConfigOrBuilder()
       Configuration for the current node's processing step.
      .ai.pipestream.data.v1.NodeProcessingConfig node_processing_config = 8;