Package ai.pipestream.data.v1

Class StreamMetadata.Builder

java.lang.Object
com.google.protobuf.AbstractMessageLite.Builder
com.google.protobuf.AbstractMessage.Builder<StreamMetadata.Builder>
com.google.protobuf.GeneratedMessage.Builder<StreamMetadata.Builder>
ai.pipestream.data.v1.StreamMetadata.Builder
All Implemented Interfaces:
StreamMetadataOrBuilder, com.google.protobuf.Message.Builder, com.google.protobuf.MessageLite.Builder, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Cloneable
Enclosing class:
StreamMetadata
public static final class StreamMetadata.Builder extends com.google.protobuf.GeneratedMessage.Builder<StreamMetadata.Builder> implements StreamMetadataOrBuilder
 Metadata for tracking stream processing history and context.

 Contains execution records, tracing information, error tracking, and datasource
 context for a stream.
Protobuf type ai.pipestream.data.v1.StreamMetadata

  • Method Details

    • getDescriptor

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

    • internalGetMapFieldReflection

      protected com.google.protobuf.MapFieldReflectionAccessor internalGetMapFieldReflection(int number)
      Overrides:
      internalGetMapFieldReflection in class com.google.protobuf.GeneratedMessage.Builder<StreamMetadata.Builder>

    • internalGetMutableMapFieldReflection

      protected com.google.protobuf.MapFieldReflectionAccessor internalGetMutableMapFieldReflection(int number)
      Overrides:
      internalGetMutableMapFieldReflection in class com.google.protobuf.GeneratedMessage.Builder<StreamMetadata.Builder>

    • internalGetFieldAccessorTable

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

    • clear

      public StreamMetadata.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<StreamMetadata.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<StreamMetadata.Builder>

    • getDefaultInstanceForType

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

    • build

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

    • buildPartial

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

    • mergeFrom

      public StreamMetadata.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<StreamMetadata.Builder>

    • mergeFrom

      public StreamMetadata.Builder mergeFrom(StreamMetadata other)

    • isInitialized

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

    • mergeFrom

      public StreamMetadata.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<StreamMetadata.Builder>
      Throws:
      IOException

    • getSourceId

      public String getSourceId()
       Source identifier for validation and tracking.
      string source_id = 2 [json_name = "sourceId"];
      Specified by:
      getSourceId in interface StreamMetadataOrBuilder
      Returns:
      The sourceId.

    • getSourceIdBytes

      public com.google.protobuf.ByteString getSourceIdBytes()
       Source identifier for validation and tracking.
      string source_id = 2 [json_name = "sourceId"];
      Specified by:
      getSourceIdBytes in interface StreamMetadataOrBuilder
      Returns:
      The bytes for sourceId.

    • setSourceId

      public StreamMetadata.Builder setSourceId(String value)
       Source identifier for validation and tracking.
      string source_id = 2 [json_name = "sourceId"];
      Parameters:
      value - The sourceId to set.
      Returns:
      This builder for chaining.

    • clearSourceId

      public StreamMetadata.Builder clearSourceId()
       Source identifier for validation and tracking.
      string source_id = 2 [json_name = "sourceId"];
      Returns:
      This builder for chaining.

    • setSourceIdBytes

      public StreamMetadata.Builder setSourceIdBytes(com.google.protobuf.ByteString value)
       Source identifier for validation and tracking.
      string source_id = 2 [json_name = "sourceId"];
      Parameters:
      value - The bytes for sourceId to set.
      Returns:
      This builder for chaining.

    • hasCreatedAt

      public boolean hasCreatedAt()
       Timestamp when the stream was created.
      .google.protobuf.Timestamp created_at = 3 [json_name = "createdAt"];
      Specified by:
      hasCreatedAt in interface StreamMetadataOrBuilder
      Returns:
      Whether the createdAt field is set.

    • getCreatedAt

      public com.google.protobuf.Timestamp getCreatedAt()
       Timestamp when the stream was created.
      .google.protobuf.Timestamp created_at = 3 [json_name = "createdAt"];
      Specified by:
      getCreatedAt in interface StreamMetadataOrBuilder
      Returns:
      The createdAt.

    • setCreatedAt

      public StreamMetadata.Builder setCreatedAt(com.google.protobuf.Timestamp value)
       Timestamp when the stream was created.
      .google.protobuf.Timestamp created_at = 3 [json_name = "createdAt"];

    • setCreatedAt

      public StreamMetadata.Builder setCreatedAt(com.google.protobuf.Timestamp.Builder builderForValue)
       Timestamp when the stream was created.
      .google.protobuf.Timestamp created_at = 3 [json_name = "createdAt"];

    • mergeCreatedAt

      public StreamMetadata.Builder mergeCreatedAt(com.google.protobuf.Timestamp value)
       Timestamp when the stream was created.
      .google.protobuf.Timestamp created_at = 3 [json_name = "createdAt"];

    • clearCreatedAt

      public StreamMetadata.Builder clearCreatedAt()
       Timestamp when the stream was created.
      .google.protobuf.Timestamp created_at = 3 [json_name = "createdAt"];

    • getCreatedAtBuilder

      public com.google.protobuf.Timestamp.Builder getCreatedAtBuilder()
       Timestamp when the stream was created.
      .google.protobuf.Timestamp created_at = 3 [json_name = "createdAt"];

    • getCreatedAtOrBuilder

      public com.google.protobuf.TimestampOrBuilder getCreatedAtOrBuilder()
       Timestamp when the stream was created.
      .google.protobuf.Timestamp created_at = 3 [json_name = "createdAt"];
      Specified by:
      getCreatedAtOrBuilder in interface StreamMetadataOrBuilder

    • hasLastProcessedAt

      public boolean hasLastProcessedAt()
       Timestamp when the stream was last processed.
      .google.protobuf.Timestamp last_processed_at = 4 [json_name = "lastProcessedAt"];
      Specified by:
      hasLastProcessedAt in interface StreamMetadataOrBuilder
      Returns:
      Whether the lastProcessedAt field is set.

    • getLastProcessedAt

      public com.google.protobuf.Timestamp getLastProcessedAt()
       Timestamp when the stream was last processed.
      .google.protobuf.Timestamp last_processed_at = 4 [json_name = "lastProcessedAt"];
      Specified by:
      getLastProcessedAt in interface StreamMetadataOrBuilder
      Returns:
      The lastProcessedAt.

    • setLastProcessedAt

      public StreamMetadata.Builder setLastProcessedAt(com.google.protobuf.Timestamp value)
       Timestamp when the stream was last processed.
      .google.protobuf.Timestamp last_processed_at = 4 [json_name = "lastProcessedAt"];

    • setLastProcessedAt

      public StreamMetadata.Builder setLastProcessedAt(com.google.protobuf.Timestamp.Builder builderForValue)
       Timestamp when the stream was last processed.
      .google.protobuf.Timestamp last_processed_at = 4 [json_name = "lastProcessedAt"];

    • mergeLastProcessedAt

      public StreamMetadata.Builder mergeLastProcessedAt(com.google.protobuf.Timestamp value)
       Timestamp when the stream was last processed.
      .google.protobuf.Timestamp last_processed_at = 4 [json_name = "lastProcessedAt"];

    • clearLastProcessedAt

      public StreamMetadata.Builder clearLastProcessedAt()
       Timestamp when the stream was last processed.
      .google.protobuf.Timestamp last_processed_at = 4 [json_name = "lastProcessedAt"];

    • getLastProcessedAtBuilder

      public com.google.protobuf.Timestamp.Builder getLastProcessedAtBuilder()
       Timestamp when the stream was last processed.
      .google.protobuf.Timestamp last_processed_at = 4 [json_name = "lastProcessedAt"];

    • getLastProcessedAtOrBuilder

      public com.google.protobuf.TimestampOrBuilder getLastProcessedAtOrBuilder()
       Timestamp when the stream was last processed.
      .google.protobuf.Timestamp last_processed_at = 4 [json_name = "lastProcessedAt"];
      Specified by:
      getLastProcessedAtOrBuilder in interface StreamMetadataOrBuilder

    • getTraceId

      public String getTraceId()
       Distributed tracing identifier.
      string trace_id = 5 [json_name = "traceId"];
      Specified by:
      getTraceId in interface StreamMetadataOrBuilder
      Returns:
      The traceId.

    • getTraceIdBytes

      public com.google.protobuf.ByteString getTraceIdBytes()
       Distributed tracing identifier.
      string trace_id = 5 [json_name = "traceId"];
      Specified by:
      getTraceIdBytes in interface StreamMetadataOrBuilder
      Returns:
      The bytes for traceId.

    • setTraceId

      public StreamMetadata.Builder setTraceId(String value)
       Distributed tracing identifier.
      string trace_id = 5 [json_name = "traceId"];
      Parameters:
      value - The traceId to set.
      Returns:
      This builder for chaining.

    • clearTraceId

      public StreamMetadata.Builder clearTraceId()
       Distributed tracing identifier.
      string trace_id = 5 [json_name = "traceId"];
      Returns:
      This builder for chaining.

    • setTraceIdBytes

      public StreamMetadata.Builder setTraceIdBytes(com.google.protobuf.ByteString value)
       Distributed tracing identifier.
      string trace_id = 5 [json_name = "traceId"];
      Parameters:
      value - The bytes for traceId to set.
      Returns:
      This builder for chaining.

    • getHistoryList

      public List<StepExecutionRecord> getHistoryList()
       Complete execution history of all processing steps.
      repeated .ai.pipestream.data.v1.StepExecutionRecord history = 6 [json_name = "history"];
      Specified by:
      getHistoryList in interface StreamMetadataOrBuilder

    • getHistoryCount

      public int getHistoryCount()
       Complete execution history of all processing steps.
      repeated .ai.pipestream.data.v1.StepExecutionRecord history = 6 [json_name = "history"];
      Specified by:
      getHistoryCount in interface StreamMetadataOrBuilder

    • getHistory

      public StepExecutionRecord getHistory(int index)
       Complete execution history of all processing steps.
      repeated .ai.pipestream.data.v1.StepExecutionRecord history = 6 [json_name = "history"];
      Specified by:
      getHistory in interface StreamMetadataOrBuilder

    • setHistory

      public StreamMetadata.Builder setHistory(int index, StepExecutionRecord value)
       Complete execution history of all processing steps.
      repeated .ai.pipestream.data.v1.StepExecutionRecord history = 6 [json_name = "history"];

    • setHistory

      public StreamMetadata.Builder setHistory(int index, StepExecutionRecord.Builder builderForValue)
       Complete execution history of all processing steps.
      repeated .ai.pipestream.data.v1.StepExecutionRecord history = 6 [json_name = "history"];

    • addHistory

      public StreamMetadata.Builder addHistory(StepExecutionRecord value)
       Complete execution history of all processing steps.
      repeated .ai.pipestream.data.v1.StepExecutionRecord history = 6 [json_name = "history"];

    • addHistory

      public StreamMetadata.Builder addHistory(int index, StepExecutionRecord value)
       Complete execution history of all processing steps.
      repeated .ai.pipestream.data.v1.StepExecutionRecord history = 6 [json_name = "history"];

    • addHistory

      public StreamMetadata.Builder addHistory(StepExecutionRecord.Builder builderForValue)
       Complete execution history of all processing steps.
      repeated .ai.pipestream.data.v1.StepExecutionRecord history = 6 [json_name = "history"];

    • addHistory

      public StreamMetadata.Builder addHistory(int index, StepExecutionRecord.Builder builderForValue)
       Complete execution history of all processing steps.
      repeated .ai.pipestream.data.v1.StepExecutionRecord history = 6 [json_name = "history"];

    • addAllHistory

      public StreamMetadata.Builder addAllHistory(Iterable<? extends StepExecutionRecord> values)
       Complete execution history of all processing steps.
      repeated .ai.pipestream.data.v1.StepExecutionRecord history = 6 [json_name = "history"];

    • clearHistory

      public StreamMetadata.Builder clearHistory()
       Complete execution history of all processing steps.
      repeated .ai.pipestream.data.v1.StepExecutionRecord history = 6 [json_name = "history"];

    • removeHistory

      public StreamMetadata.Builder removeHistory(int index)
       Complete execution history of all processing steps.
      repeated .ai.pipestream.data.v1.StepExecutionRecord history = 6 [json_name = "history"];

    • getHistoryBuilder

      public StepExecutionRecord.Builder getHistoryBuilder(int index)
       Complete execution history of all processing steps.
      repeated .ai.pipestream.data.v1.StepExecutionRecord history = 6 [json_name = "history"];

    • getHistoryOrBuilder

      public StepExecutionRecordOrBuilder getHistoryOrBuilder(int index)
       Complete execution history of all processing steps.
      repeated .ai.pipestream.data.v1.StepExecutionRecord history = 6 [json_name = "history"];
      Specified by:
      getHistoryOrBuilder in interface StreamMetadataOrBuilder

    • getHistoryOrBuilderList

      public List<? extends StepExecutionRecordOrBuilder> getHistoryOrBuilderList()
       Complete execution history of all processing steps.
      repeated .ai.pipestream.data.v1.StepExecutionRecord history = 6 [json_name = "history"];
      Specified by:
      getHistoryOrBuilderList in interface StreamMetadataOrBuilder

    • addHistoryBuilder

      public StepExecutionRecord.Builder addHistoryBuilder()
       Complete execution history of all processing steps.
      repeated .ai.pipestream.data.v1.StepExecutionRecord history = 6 [json_name = "history"];

    • addHistoryBuilder

      public StepExecutionRecord.Builder addHistoryBuilder(int index)
       Complete execution history of all processing steps.
      repeated .ai.pipestream.data.v1.StepExecutionRecord history = 6 [json_name = "history"];

    • getHistoryBuilderList

      public List<StepExecutionRecord.Builder> getHistoryBuilderList()
       Complete execution history of all processing steps.
      repeated .ai.pipestream.data.v1.StepExecutionRecord history = 6 [json_name = "history"];

    • hasStreamError

      public boolean hasStreamError()
       Critical stream-level errors if any occurred.
      optional .ai.pipestream.data.v1.ErrorData stream_error = 7 [json_name = "streamError"];
      Specified by:
      hasStreamError in interface StreamMetadataOrBuilder
      Returns:
      Whether the streamError field is set.

    • getStreamError

      public ErrorData getStreamError()
       Critical stream-level errors if any occurred.
      optional .ai.pipestream.data.v1.ErrorData stream_error = 7 [json_name = "streamError"];
      Specified by:
      getStreamError in interface StreamMetadataOrBuilder
      Returns:
      The streamError.

    • setStreamError

      public StreamMetadata.Builder setStreamError(ErrorData value)
       Critical stream-level errors if any occurred.
      optional .ai.pipestream.data.v1.ErrorData stream_error = 7 [json_name = "streamError"];

    • setStreamError

      public StreamMetadata.Builder setStreamError(ErrorData.Builder builderForValue)
       Critical stream-level errors if any occurred.
      optional .ai.pipestream.data.v1.ErrorData stream_error = 7 [json_name = "streamError"];

    • mergeStreamError

      public StreamMetadata.Builder mergeStreamError(ErrorData value)
       Critical stream-level errors if any occurred.
      optional .ai.pipestream.data.v1.ErrorData stream_error = 7 [json_name = "streamError"];

    • clearStreamError

      public StreamMetadata.Builder clearStreamError()
       Critical stream-level errors if any occurred.
      optional .ai.pipestream.data.v1.ErrorData stream_error = 7 [json_name = "streamError"];

    • getStreamErrorBuilder

      public ErrorData.Builder getStreamErrorBuilder()
       Critical stream-level errors if any occurred.
      optional .ai.pipestream.data.v1.ErrorData stream_error = 7 [json_name = "streamError"];

    • getStreamErrorOrBuilder

      public ErrorDataOrBuilder getStreamErrorOrBuilder()
       Critical stream-level errors if any occurred.
      optional .ai.pipestream.data.v1.ErrorData stream_error = 7 [json_name = "streamError"];
      Specified by:
      getStreamErrorOrBuilder in interface StreamMetadataOrBuilder

    • getContextParamsCount

      public int getContextParamsCount()
      Description copied from interface: StreamMetadataOrBuilder
       Stream-level context parameters for processing.
      map<string, string> context_params = 8 [json_name = "contextParams"];
      Specified by:
      getContextParamsCount in interface StreamMetadataOrBuilder

    • containsContextParams

      public boolean containsContextParams(String key)
       Stream-level context parameters for processing.
      map<string, string> context_params = 8 [json_name = "contextParams"];
      Specified by:
      containsContextParams in interface StreamMetadataOrBuilder

    • getContextParams

      @Deprecated public Map<String,String> getContextParams()
      Deprecated.
      Use getContextParamsMap() instead.
      Specified by:
      getContextParams in interface StreamMetadataOrBuilder

    • getContextParamsMap

      public Map<String,String> getContextParamsMap()
       Stream-level context parameters for processing.
      map<string, string> context_params = 8 [json_name = "contextParams"];
      Specified by:
      getContextParamsMap in interface StreamMetadataOrBuilder

    • getContextParamsOrDefault

      public String getContextParamsOrDefault(String key, String defaultValue)
       Stream-level context parameters for processing.
      map<string, string> context_params = 8 [json_name = "contextParams"];
      Specified by:
      getContextParamsOrDefault in interface StreamMetadataOrBuilder

    • getContextParamsOrThrow

      public String getContextParamsOrThrow(String key)
       Stream-level context parameters for processing.
      map<string, string> context_params = 8 [json_name = "contextParams"];
      Specified by:
      getContextParamsOrThrow in interface StreamMetadataOrBuilder

    • clearContextParams

      public StreamMetadata.Builder clearContextParams()

    • removeContextParams

      public StreamMetadata.Builder removeContextParams(String key)
       Stream-level context parameters for processing.
      map<string, string> context_params = 8 [json_name = "contextParams"];

    • getMutableContextParams

      @Deprecated public Map<String,String> getMutableContextParams()
      Deprecated.
      Use alternate mutation accessors instead.

    • putContextParams

      public StreamMetadata.Builder putContextParams(String key, String value)
       Stream-level context parameters for processing.
      map<string, string> context_params = 8 [json_name = "contextParams"];

    • putAllContextParams

      public StreamMetadata.Builder putAllContextParams(Map<String,String> values)
       Stream-level context parameters for processing.
      map<string, string> context_params = 8 [json_name = "contextParams"];

    • getDatasourceId

      public String getDatasourceId()
       DataSource identifier for tracking document origin.

 Deterministically derived from account_id and connector type.
 Used to route documents to the correct pipeline graph entry point.
      string datasource_id = 9 [json_name = "datasourceId"];
      Specified by:
      getDatasourceId in interface StreamMetadataOrBuilder
      Returns:
      The datasourceId.

    • getDatasourceIdBytes

      public com.google.protobuf.ByteString getDatasourceIdBytes()
       DataSource identifier for tracking document origin.

 Deterministically derived from account_id and connector type.
 Used to route documents to the correct pipeline graph entry point.
      string datasource_id = 9 [json_name = "datasourceId"];
      Specified by:
      getDatasourceIdBytes in interface StreamMetadataOrBuilder
      Returns:
      The bytes for datasourceId.

    • setDatasourceId

      public StreamMetadata.Builder setDatasourceId(String value)
       DataSource identifier for tracking document origin.

 Deterministically derived from account_id and connector type.
 Used to route documents to the correct pipeline graph entry point.
      string datasource_id = 9 [json_name = "datasourceId"];
      Parameters:
      value - The datasourceId to set.
      Returns:
      This builder for chaining.

    • clearDatasourceId

      public StreamMetadata.Builder clearDatasourceId()
       DataSource identifier for tracking document origin.

 Deterministically derived from account_id and connector type.
 Used to route documents to the correct pipeline graph entry point.
      string datasource_id = 9 [json_name = "datasourceId"];
      Returns:
      This builder for chaining.

    • setDatasourceIdBytes

      public StreamMetadata.Builder setDatasourceIdBytes(com.google.protobuf.ByteString value)
       DataSource identifier for tracking document origin.

 Deterministically derived from account_id and connector type.
 Used to route documents to the correct pipeline graph entry point.
      string datasource_id = 9 [json_name = "datasourceId"];
      Parameters:
      value - The bytes for datasourceId to set.
      Returns:
      This builder for chaining.

    • getAccountId

      public String getAccountId()
       Account identifier for ownership and access control.

 Links this stream to a specific tenant/customer account.
      string account_id = 10 [json_name = "accountId"];
      Specified by:
      getAccountId in interface StreamMetadataOrBuilder
      Returns:
      The accountId.

    • getAccountIdBytes

      public com.google.protobuf.ByteString getAccountIdBytes()
       Account identifier for ownership and access control.

 Links this stream to a specific tenant/customer account.
      string account_id = 10 [json_name = "accountId"];
      Specified by:
      getAccountIdBytes in interface StreamMetadataOrBuilder
      Returns:
      The bytes for accountId.

    • setAccountId

      public StreamMetadata.Builder setAccountId(String value)
       Account identifier for ownership and access control.

 Links this stream to a specific tenant/customer account.
      string account_id = 10 [json_name = "accountId"];
      Parameters:
      value - The accountId to set.
      Returns:
      This builder for chaining.

    • clearAccountId

      public StreamMetadata.Builder clearAccountId()
       Account identifier for ownership and access control.

 Links this stream to a specific tenant/customer account.
      string account_id = 10 [json_name = "accountId"];
      Returns:
      This builder for chaining.

    • setAccountIdBytes

      public StreamMetadata.Builder setAccountIdBytes(com.google.protobuf.ByteString value)
       Account identifier for ownership and access control.

 Links this stream to a specific tenant/customer account.
      string account_id = 10 [json_name = "accountId"];
      Parameters:
      value - The bytes for accountId to set.
      Returns:
      This builder for chaining.

    • getEntryNodeId

      public String getEntryNodeId()
       Entry node identifier where this stream entered the pipeline.

 Useful for tracking which connector/datasource initiated processing
 and for routing decisions in multi-entry-point graphs.
      string entry_node_id = 11 [json_name = "entryNodeId"];
      Specified by:
      getEntryNodeId in interface StreamMetadataOrBuilder
      Returns:
      The entryNodeId.

    • getEntryNodeIdBytes

      public com.google.protobuf.ByteString getEntryNodeIdBytes()
       Entry node identifier where this stream entered the pipeline.

 Useful for tracking which connector/datasource initiated processing
 and for routing decisions in multi-entry-point graphs.
      string entry_node_id = 11 [json_name = "entryNodeId"];
      Specified by:
      getEntryNodeIdBytes in interface StreamMetadataOrBuilder
      Returns:
      The bytes for entryNodeId.

    • setEntryNodeId

      public StreamMetadata.Builder setEntryNodeId(String value)
       Entry node identifier where this stream entered the pipeline.

 Useful for tracking which connector/datasource initiated processing
 and for routing decisions in multi-entry-point graphs.
      string entry_node_id = 11 [json_name = "entryNodeId"];
      Parameters:
      value - The entryNodeId to set.
      Returns:
      This builder for chaining.

    • clearEntryNodeId

      public StreamMetadata.Builder clearEntryNodeId()
       Entry node identifier where this stream entered the pipeline.

 Useful for tracking which connector/datasource initiated processing
 and for routing decisions in multi-entry-point graphs.
      string entry_node_id = 11 [json_name = "entryNodeId"];
      Returns:
      This builder for chaining.

    • setEntryNodeIdBytes

      public StreamMetadata.Builder setEntryNodeIdBytes(com.google.protobuf.ByteString value)
       Entry node identifier where this stream entered the pipeline.

 Useful for tracking which connector/datasource initiated processing
 and for routing decisions in multi-entry-point graphs.
      string entry_node_id = 11 [json_name = "entryNodeId"];
      Parameters:
      value - The bytes for entryNodeId to set.
      Returns:
      This builder for chaining.

    • hasIngestionConfig

      public boolean hasIngestionConfig()
       Ingestion configuration from connector-intake-service.

 Contains the resolved 2-tier configuration (Tier 1 + Tier 2 merged)
 for hydration, routing, and custom connector settings.
 Only present for streams that entered via intake connectors.
      optional .ai.pipestream.data.v1.IngestionConfig ingestion_config = 12 [json_name = "ingestionConfig"];
      Specified by:
      hasIngestionConfig in interface StreamMetadataOrBuilder
      Returns:
      Whether the ingestionConfig field is set.

    • getIngestionConfig

      public IngestionConfig getIngestionConfig()
       Ingestion configuration from connector-intake-service.

 Contains the resolved 2-tier configuration (Tier 1 + Tier 2 merged)
 for hydration, routing, and custom connector settings.
 Only present for streams that entered via intake connectors.
      optional .ai.pipestream.data.v1.IngestionConfig ingestion_config = 12 [json_name = "ingestionConfig"];
      Specified by:
      getIngestionConfig in interface StreamMetadataOrBuilder
      Returns:
      The ingestionConfig.

    • setIngestionConfig

      public StreamMetadata.Builder setIngestionConfig(IngestionConfig value)
       Ingestion configuration from connector-intake-service.

 Contains the resolved 2-tier configuration (Tier 1 + Tier 2 merged)
 for hydration, routing, and custom connector settings.
 Only present for streams that entered via intake connectors.
      optional .ai.pipestream.data.v1.IngestionConfig ingestion_config = 12 [json_name = "ingestionConfig"];

    • setIngestionConfig

      public StreamMetadata.Builder setIngestionConfig(IngestionConfig.Builder builderForValue)
       Ingestion configuration from connector-intake-service.

 Contains the resolved 2-tier configuration (Tier 1 + Tier 2 merged)
 for hydration, routing, and custom connector settings.
 Only present for streams that entered via intake connectors.
      optional .ai.pipestream.data.v1.IngestionConfig ingestion_config = 12 [json_name = "ingestionConfig"];

    • mergeIngestionConfig

      public StreamMetadata.Builder mergeIngestionConfig(IngestionConfig value)
       Ingestion configuration from connector-intake-service.

 Contains the resolved 2-tier configuration (Tier 1 + Tier 2 merged)
 for hydration, routing, and custom connector settings.
 Only present for streams that entered via intake connectors.
      optional .ai.pipestream.data.v1.IngestionConfig ingestion_config = 12 [json_name = "ingestionConfig"];

    • clearIngestionConfig

      public StreamMetadata.Builder clearIngestionConfig()
       Ingestion configuration from connector-intake-service.

 Contains the resolved 2-tier configuration (Tier 1 + Tier 2 merged)
 for hydration, routing, and custom connector settings.
 Only present for streams that entered via intake connectors.
      optional .ai.pipestream.data.v1.IngestionConfig ingestion_config = 12 [json_name = "ingestionConfig"];

    • getIngestionConfigBuilder

      public IngestionConfig.Builder getIngestionConfigBuilder()
       Ingestion configuration from connector-intake-service.

 Contains the resolved 2-tier configuration (Tier 1 + Tier 2 merged)
 for hydration, routing, and custom connector settings.
 Only present for streams that entered via intake connectors.
      optional .ai.pipestream.data.v1.IngestionConfig ingestion_config = 12 [json_name = "ingestionConfig"];

    • getIngestionConfigOrBuilder

      public IngestionConfigOrBuilder getIngestionConfigOrBuilder()
       Ingestion configuration from connector-intake-service.

 Contains the resolved 2-tier configuration (Tier 1 + Tier 2 merged)
 for hydration, routing, and custom connector settings.
 Only present for streams that entered via intake connectors.
      optional .ai.pipestream.data.v1.IngestionConfig ingestion_config = 12 [json_name = "ingestionConfig"];
      Specified by:
      getIngestionConfigOrBuilder in interface StreamMetadataOrBuilder