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 [json_name = "streamId"];
      Returns:
      The streamId.

    • getStreamIdBytes

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

    • hasMetadata

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

    • getMetadata

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

    • getMetadataOrBuilder

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

    • hasDocument

      boolean hasDocument()
       Inline document (typically for gRPC direct path or small documents).
      .ai.pipestream.data.v1.PipeDoc document = 3 [json_name = "document"];
      Returns:
      Whether the document field is set.

    • getDocument

      PipeDoc getDocument()
       Inline document (typically for gRPC direct path or small documents).
      .ai.pipestream.data.v1.PipeDoc document = 3 [json_name = "document"];
      Returns:
      The document.

    • getDocumentOrBuilder

      PipeDocOrBuilder getDocumentOrBuilder()
       Inline document (typically for gRPC direct path or small documents).
      .ai.pipestream.data.v1.PipeDoc document = 3 [json_name = "document"];

    • hasDocumentRef

      boolean hasDocumentRef()
       Reference to document stored in repository (typically for Kafka path or large documents).
      .ai.pipestream.data.v1.DocumentReference document_ref = 9 [json_name = "documentRef"];
      Returns:
      Whether the documentRef field is set.

    • getDocumentRef

      DocumentReference getDocumentRef()
       Reference to document stored in repository (typically for Kafka path or large documents).
      .ai.pipestream.data.v1.DocumentReference document_ref = 9 [json_name = "documentRef"];
      Returns:
      The documentRef.

    • getDocumentRefOrBuilder

      DocumentReferenceOrBuilder getDocumentRefOrBuilder()
       Reference to document stored in repository (typically for Kafka path or large documents).
      .ai.pipestream.data.v1.DocumentReference document_ref = 9 [json_name = "documentRef"];

    • getClusterId

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

    • getClusterIdBytes

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

    • getCurrentNodeId

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

    • getCurrentNodeIdBytes

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

    • getHopCount

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

    • getProcessingPathList

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

    • getProcessingPathCount

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

    • getProcessingPath

      String getProcessingPath(int index)
       Ordered list of node IDs traversed during processing.
      repeated string processing_path = 7 [json_name = "processingPath"];
      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 [json_name = "processingPath"];
      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 [json_name = "nodeProcessingConfig"];
      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 [json_name = "nodeProcessingConfig"];
      Returns:
      The nodeProcessingConfig.

    • getNodeProcessingConfigOrBuilder

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

    • getDocumentPayloadCase

      PipeStream.DocumentPayloadCase getDocumentPayloadCase()