Package ai.pipestream.data.v1

Class PipeStream.Builder

java.lang.Object
com.google.protobuf.AbstractMessageLite.Builder
com.google.protobuf.AbstractMessage.Builder<PipeStream.Builder>
com.google.protobuf.GeneratedMessage.Builder<PipeStream.Builder>
ai.pipestream.data.v1.PipeStream.Builder
All Implemented Interfaces:
PipeStreamOrBuilder, com.google.protobuf.Message.Builder, com.google.protobuf.MessageLite.Builder, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Cloneable
Enclosing class:
PipeStream
public static final class PipeStream.Builder extends com.google.protobuf.GeneratedMessage.Builder<PipeStream.Builder> implements PipeStreamOrBuilder
 TCP-like packet header for node-to-node document processing.

 Contains the document payload, routing information, processing history,
 and configuration for the current processing step.
Protobuf type ai.pipestream.data.v1.PipeStream

  • Method Details

    • getDescriptor

      public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()

    • internalGetFieldAccessorTable

      protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()
      Specified by:
      internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessage.Builder<PipeStream.Builder>

    • clear

      public PipeStream.Builder clear()
      Specified by:
      clear in interface com.google.protobuf.Message.Builder
      Specified by:
      clear in interface com.google.protobuf.MessageLite.Builder
      Overrides:
      clear in class com.google.protobuf.GeneratedMessage.Builder<PipeStream.Builder>

    • getDescriptorForType

      public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
      Specified by:
      getDescriptorForType in interface com.google.protobuf.Message.Builder
      Specified by:
      getDescriptorForType in interface com.google.protobuf.MessageOrBuilder
      Overrides:
      getDescriptorForType in class com.google.protobuf.GeneratedMessage.Builder<PipeStream.Builder>

    • getDefaultInstanceForType

      public PipeStream getDefaultInstanceForType()
      Specified by:
      getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder
      Specified by:
      getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder

    • build

      public PipeStream build()
      Specified by:
      build in interface com.google.protobuf.Message.Builder
      Specified by:
      build in interface com.google.protobuf.MessageLite.Builder

    • buildPartial

      public PipeStream buildPartial()
      Specified by:
      buildPartial in interface com.google.protobuf.Message.Builder
      Specified by:
      buildPartial in interface com.google.protobuf.MessageLite.Builder

    • mergeFrom

      public PipeStream.Builder mergeFrom(com.google.protobuf.Message other)
      Specified by:
      mergeFrom in interface com.google.protobuf.Message.Builder
      Overrides:
      mergeFrom in class com.google.protobuf.AbstractMessage.Builder<PipeStream.Builder>

    • mergeFrom

      public PipeStream.Builder mergeFrom(PipeStream other)

    • isInitialized

      public final boolean isInitialized()
      Specified by:
      isInitialized in interface com.google.protobuf.MessageLiteOrBuilder
      Overrides:
      isInitialized in class com.google.protobuf.GeneratedMessage.Builder<PipeStream.Builder>

    • mergeFrom

      public PipeStream.Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
      Specified by:
      mergeFrom in interface com.google.protobuf.Message.Builder
      Specified by:
      mergeFrom in interface com.google.protobuf.MessageLite.Builder
      Overrides:
      mergeFrom in class com.google.protobuf.AbstractMessage.Builder<PipeStream.Builder>
      Throws:
      IOException

    • getDocumentPayloadCase

      public PipeStream.DocumentPayloadCase getDocumentPayloadCase()
      Specified by:
      getDocumentPayloadCase in interface PipeStreamOrBuilder

    • clearDocumentPayload

      public PipeStream.Builder clearDocumentPayload()

    • getStreamId

      public String getStreamId()
       Unique identifier for this processing stream.
      string stream_id = 1 [json_name = "streamId"];
      Specified by:
      getStreamId in interface PipeStreamOrBuilder
      Returns:
      The streamId.

    • getStreamIdBytes

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

    • setStreamId

      public PipeStream.Builder setStreamId(String value)
       Unique identifier for this processing stream.
      string stream_id = 1 [json_name = "streamId"];
      Parameters:
      value - The streamId to set.
      Returns:
      This builder for chaining.

    • clearStreamId

      public PipeStream.Builder clearStreamId()
       Unique identifier for this processing stream.
      string stream_id = 1 [json_name = "streamId"];
      Returns:
      This builder for chaining.

    • setStreamIdBytes

      public PipeStream.Builder setStreamIdBytes(com.google.protobuf.ByteString value)
       Unique identifier for this processing stream.
      string stream_id = 1 [json_name = "streamId"];
      Parameters:
      value - The bytes for streamId to set.
      Returns:
      This builder for chaining.

    • hasMetadata

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

    • getMetadata

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

    • setMetadata

      public PipeStream.Builder setMetadata(StreamMetadata value)
       Stream metadata including history and tracing.
      .ai.pipestream.data.v1.StreamMetadata metadata = 2 [json_name = "metadata"];

    • setMetadata

      public PipeStream.Builder setMetadata(StreamMetadata.Builder builderForValue)
       Stream metadata including history and tracing.
      .ai.pipestream.data.v1.StreamMetadata metadata = 2 [json_name = "metadata"];

    • mergeMetadata

      public PipeStream.Builder mergeMetadata(StreamMetadata value)
       Stream metadata including history and tracing.
      .ai.pipestream.data.v1.StreamMetadata metadata = 2 [json_name = "metadata"];

    • clearMetadata

      public PipeStream.Builder clearMetadata()
       Stream metadata including history and tracing.
      .ai.pipestream.data.v1.StreamMetadata metadata = 2 [json_name = "metadata"];

    • getMetadataBuilder

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

    • getMetadataOrBuilder

      public StreamMetadataOrBuilder getMetadataOrBuilder()
       Stream metadata including history and tracing.
      .ai.pipestream.data.v1.StreamMetadata metadata = 2 [json_name = "metadata"];
      Specified by:
      getMetadataOrBuilder in interface PipeStreamOrBuilder

    • hasDocument

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

    • getDocument

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

    • setDocument

      public PipeStream.Builder setDocument(PipeDoc value)
       Inline document (typically for gRPC direct path or small documents).
      .ai.pipestream.data.v1.PipeDoc document = 3 [json_name = "document"];

    • setDocument

      public PipeStream.Builder setDocument(PipeDoc.Builder builderForValue)
       Inline document (typically for gRPC direct path or small documents).
      .ai.pipestream.data.v1.PipeDoc document = 3 [json_name = "document"];

    • mergeDocument

      public PipeStream.Builder mergeDocument(PipeDoc value)
       Inline document (typically for gRPC direct path or small documents).
      .ai.pipestream.data.v1.PipeDoc document = 3 [json_name = "document"];

    • clearDocument

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

    • getDocumentBuilder

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

    • getDocumentOrBuilder

      public PipeDocOrBuilder getDocumentOrBuilder()
       Inline document (typically for gRPC direct path or small documents).
      .ai.pipestream.data.v1.PipeDoc document = 3 [json_name = "document"];
      Specified by:
      getDocumentOrBuilder in interface PipeStreamOrBuilder

    • hasDocumentRef

      public 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"];
      Specified by:
      hasDocumentRef in interface PipeStreamOrBuilder
      Returns:
      Whether the documentRef field is set.

    • getDocumentRef

      public 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"];
      Specified by:
      getDocumentRef in interface PipeStreamOrBuilder
      Returns:
      The documentRef.

    • setDocumentRef

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

    • setDocumentRef

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

    • mergeDocumentRef

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

    • clearDocumentRef

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

    • getDocumentRefBuilder

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

    • getDocumentRefOrBuilder

      public 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"];
      Specified by:
      getDocumentRefOrBuilder in interface PipeStreamOrBuilder

    • getClusterId

      public String getClusterId()
       Cluster where processing is occurring.
      string cluster_id = 4 [json_name = "clusterId"];
      Specified by:
      getClusterId in interface PipeStreamOrBuilder
      Returns:
      The clusterId.

    • getClusterIdBytes

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

    • setClusterId

      public PipeStream.Builder setClusterId(String value)
       Cluster where processing is occurring.
      string cluster_id = 4 [json_name = "clusterId"];
      Parameters:
      value - The clusterId to set.
      Returns:
      This builder for chaining.

    • clearClusterId

      public PipeStream.Builder clearClusterId()
       Cluster where processing is occurring.
      string cluster_id = 4 [json_name = "clusterId"];
      Returns:
      This builder for chaining.

    • setClusterIdBytes

      public PipeStream.Builder setClusterIdBytes(com.google.protobuf.ByteString value)
       Cluster where processing is occurring.
      string cluster_id = 4 [json_name = "clusterId"];
      Parameters:
      value - The bytes for clusterId to set.
      Returns:
      This builder for chaining.

    • getCurrentNodeId

      public String getCurrentNodeId()
       Current node processing this stream.
      string current_node_id = 5 [json_name = "currentNodeId"];
      Specified by:
      getCurrentNodeId in interface PipeStreamOrBuilder
      Returns:
      The currentNodeId.

    • getCurrentNodeIdBytes

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

    • setCurrentNodeId

      public PipeStream.Builder setCurrentNodeId(String value)
       Current node processing this stream.
      string current_node_id = 5 [json_name = "currentNodeId"];
      Parameters:
      value - The currentNodeId to set.
      Returns:
      This builder for chaining.

    • clearCurrentNodeId

      public PipeStream.Builder clearCurrentNodeId()
       Current node processing this stream.
      string current_node_id = 5 [json_name = "currentNodeId"];
      Returns:
      This builder for chaining.

    • setCurrentNodeIdBytes

      public PipeStream.Builder setCurrentNodeIdBytes(com.google.protobuf.ByteString value)
       Current node processing this stream.
      string current_node_id = 5 [json_name = "currentNodeId"];
      Parameters:
      value - The bytes for currentNodeId to set.
      Returns:
      This builder for chaining.

    • getHopCount

      public long getHopCount()
       Number of processing hops taken.
      int64 hop_count = 6 [json_name = "hopCount"];
      Specified by:
      getHopCount in interface PipeStreamOrBuilder
      Returns:
      The hopCount.

    • setHopCount

      public PipeStream.Builder setHopCount(long value)
       Number of processing hops taken.
      int64 hop_count = 6 [json_name = "hopCount"];
      Parameters:
      value - The hopCount to set.
      Returns:
      This builder for chaining.

    • clearHopCount

      public PipeStream.Builder clearHopCount()
       Number of processing hops taken.
      int64 hop_count = 6 [json_name = "hopCount"];
      Returns:
      This builder for chaining.

    • getProcessingPathList

      public com.google.protobuf.ProtocolStringList getProcessingPathList()
       Ordered list of node IDs traversed during processing.
      repeated string processing_path = 7 [json_name = "processingPath"];
      Specified by:
      getProcessingPathList in interface PipeStreamOrBuilder
      Returns:
      A list containing the processingPath.

    • getProcessingPathCount

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

    • getProcessingPath

      public String getProcessingPath(int index)
       Ordered list of node IDs traversed during processing.
      repeated string processing_path = 7 [json_name = "processingPath"];
      Specified by:
      getProcessingPath in interface PipeStreamOrBuilder
      Parameters:
      index - The index of the element to return.
      Returns:
      The processingPath at the given index.

    • getProcessingPathBytes

      public com.google.protobuf.ByteString getProcessingPathBytes(int index)
       Ordered list of node IDs traversed during processing.
      repeated string processing_path = 7 [json_name = "processingPath"];
      Specified by:
      getProcessingPathBytes in interface PipeStreamOrBuilder
      Parameters:
      index - The index of the value to return.
      Returns:
      The bytes of the processingPath at the given index.

    • setProcessingPath

      public PipeStream.Builder setProcessingPath(int index, String value)
       Ordered list of node IDs traversed during processing.
      repeated string processing_path = 7 [json_name = "processingPath"];
      Parameters:
      index - The index to set the value at.
      value - The processingPath to set.
      Returns:
      This builder for chaining.

    • addProcessingPath

      public PipeStream.Builder addProcessingPath(String value)
       Ordered list of node IDs traversed during processing.
      repeated string processing_path = 7 [json_name = "processingPath"];
      Parameters:
      value - The processingPath to add.
      Returns:
      This builder for chaining.

    • addAllProcessingPath

      public PipeStream.Builder addAllProcessingPath(Iterable<String> values)
       Ordered list of node IDs traversed during processing.
      repeated string processing_path = 7 [json_name = "processingPath"];
      Parameters:
      values - The processingPath to add.
      Returns:
      This builder for chaining.

    • clearProcessingPath

      public PipeStream.Builder clearProcessingPath()
       Ordered list of node IDs traversed during processing.
      repeated string processing_path = 7 [json_name = "processingPath"];
      Returns:
      This builder for chaining.

    • addProcessingPathBytes

      public PipeStream.Builder addProcessingPathBytes(com.google.protobuf.ByteString value)
       Ordered list of node IDs traversed during processing.
      repeated string processing_path = 7 [json_name = "processingPath"];
      Parameters:
      value - The bytes of the processingPath to add.
      Returns:
      This builder for chaining.

    • hasNodeProcessingConfig

      public boolean hasNodeProcessingConfig()
       Configuration for the current node's processing step.
      .ai.pipestream.data.v1.NodeProcessingConfig node_processing_config = 8 [json_name = "nodeProcessingConfig"];
      Specified by:
      hasNodeProcessingConfig in interface PipeStreamOrBuilder
      Returns:
      Whether the nodeProcessingConfig field is set.

    • getNodeProcessingConfig

      public NodeProcessingConfig getNodeProcessingConfig()
       Configuration for the current node's processing step.
      .ai.pipestream.data.v1.NodeProcessingConfig node_processing_config = 8 [json_name = "nodeProcessingConfig"];
      Specified by:
      getNodeProcessingConfig in interface PipeStreamOrBuilder
      Returns:
      The nodeProcessingConfig.

    • setNodeProcessingConfig

      public PipeStream.Builder setNodeProcessingConfig(NodeProcessingConfig value)
       Configuration for the current node's processing step.
      .ai.pipestream.data.v1.NodeProcessingConfig node_processing_config = 8 [json_name = "nodeProcessingConfig"];

    • setNodeProcessingConfig

      public PipeStream.Builder setNodeProcessingConfig(NodeProcessingConfig.Builder builderForValue)
       Configuration for the current node's processing step.
      .ai.pipestream.data.v1.NodeProcessingConfig node_processing_config = 8 [json_name = "nodeProcessingConfig"];

    • mergeNodeProcessingConfig

      public PipeStream.Builder mergeNodeProcessingConfig(NodeProcessingConfig value)
       Configuration for the current node's processing step.
      .ai.pipestream.data.v1.NodeProcessingConfig node_processing_config = 8 [json_name = "nodeProcessingConfig"];

    • clearNodeProcessingConfig

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

    • getNodeProcessingConfigBuilder

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

    • getNodeProcessingConfigOrBuilder

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