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, and error tracking 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;
      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;
      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;
      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;
      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;
      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;
      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;
      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;

    • setCreatedAt

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

    • mergeCreatedAt

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

    • clearCreatedAt

      public StreamMetadata.Builder clearCreatedAt()
       Timestamp when the stream was created.
      .google.protobuf.Timestamp created_at = 3;

    • getCreatedAtBuilder

      public com.google.protobuf.Timestamp.Builder getCreatedAtBuilder()
       Timestamp when the stream was created.
      .google.protobuf.Timestamp created_at = 3;

    • getCreatedAtOrBuilder

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

    • hasLastProcessedAt

      public boolean hasLastProcessedAt()
       Timestamp when the stream was last processed.
      .google.protobuf.Timestamp last_processed_at = 4;
      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;
      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;

    • 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;

    • mergeLastProcessedAt

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

    • clearLastProcessedAt

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

    • getLastProcessedAtBuilder

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

    • getLastProcessedAtOrBuilder

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

    • getTraceId

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

    • getTraceIdBytes

      public com.google.protobuf.ByteString getTraceIdBytes()
       Distributed tracing identifier.
      string trace_id = 5;
      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;
      Parameters:
      value - The traceId to set.
      Returns:
      This builder for chaining.

    • clearTraceId

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

    • setTraceIdBytes

      public StreamMetadata.Builder setTraceIdBytes(com.google.protobuf.ByteString value)
       Distributed tracing identifier.
      string trace_id = 5;
      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;
      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;
      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;
      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;

    • 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;

    • addHistory

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

    • addHistory

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

    • addHistory

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

    • 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;

    • addAllHistory

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

    • clearHistory

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

    • removeHistory

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

    • getHistoryBuilder

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

    • getHistoryOrBuilder

      public StepExecutionRecordOrBuilder getHistoryOrBuilder(int index)
       Complete execution history of all processing steps.
      repeated .ai.pipestream.data.v1.StepExecutionRecord history = 6;
      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;
      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;

    • addHistoryBuilder

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

    • getHistoryBuilderList

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

    • hasStreamError

      public boolean hasStreamError()
       Critical stream-level errors if any occurred.
      optional .ai.pipestream.data.v1.ErrorData stream_error = 7;
      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;
      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;

    • setStreamError

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

    • mergeStreamError

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

    • clearStreamError

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

    • getStreamErrorBuilder

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

    • getStreamErrorOrBuilder

      public ErrorDataOrBuilder getStreamErrorOrBuilder()
       Critical stream-level errors if any occurred.
      optional .ai.pipestream.data.v1.ErrorData stream_error = 7;
      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;
      Specified by:
      getContextParamsCount in interface StreamMetadataOrBuilder

    • containsContextParams

      public boolean containsContextParams(String key)
       Stream-level context parameters for processing.
      map<string, string> context_params = 8;
      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;
      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;
      Specified by:
      getContextParamsOrDefault in interface StreamMetadataOrBuilder

    • getContextParamsOrThrow

      public String getContextParamsOrThrow(String key)
       Stream-level context parameters for processing.
      map<string, string> context_params = 8;
      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;

    • 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;

    • putAllContextParams

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