Package com.google.cloud.bigquery.storage.v1beta1

Class Storage.StreamStatus.Builder

java.lang.Object
com.google.protobuf.AbstractMessageLite.Builder
com.google.protobuf.AbstractMessage.Builder<BuilderT>
com.google.protobuf.GeneratedMessage.Builder<Storage.StreamStatus.Builder>
com.google.cloud.bigquery.storage.v1beta1.Storage.StreamStatus.Builder
All Implemented Interfaces:
Storage.StreamStatusOrBuilder, com.google.protobuf.Message.Builder, com.google.protobuf.MessageLite.Builder, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Cloneable
Enclosing class:
Storage.StreamStatus
public static final class Storage.StreamStatus.Builder extends com.google.protobuf.GeneratedMessage.Builder<Storage.StreamStatus.Builder> implements Storage.StreamStatusOrBuilder
 Progress information for a given Stream.
Protobuf type google.cloud.bigquery.storage.v1beta1.StreamStatus

  • 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<Storage.StreamStatus.Builder>

    • clear

      public Storage.StreamStatus.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<Storage.StreamStatus.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<Storage.StreamStatus.Builder>

    • getDefaultInstanceForType

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

    • build

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

    • buildPartial

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

    • mergeFrom

      public Storage.StreamStatus.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<Storage.StreamStatus.Builder>

    • mergeFrom

      public Storage.StreamStatus.Builder mergeFrom(Storage.StreamStatus other)

    • isInitialized

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

    • mergeFrom

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

    • getEstimatedRowCount

      public long getEstimatedRowCount()
       Number of estimated rows in the current stream. May change over time as
 different readers in the stream progress at rates which are relatively fast
 or slow.
      int64 estimated_row_count = 1;
      Specified by:
      getEstimatedRowCount in interface Storage.StreamStatusOrBuilder
      Returns:
      The estimatedRowCount.

    • setEstimatedRowCount

      public Storage.StreamStatus.Builder setEstimatedRowCount(long value)
       Number of estimated rows in the current stream. May change over time as
 different readers in the stream progress at rates which are relatively fast
 or slow.
      int64 estimated_row_count = 1;
      Parameters:
      value - The estimatedRowCount to set.
      Returns:
      This builder for chaining.

    • clearEstimatedRowCount

      public Storage.StreamStatus.Builder clearEstimatedRowCount()
       Number of estimated rows in the current stream. May change over time as
 different readers in the stream progress at rates which are relatively fast
 or slow.
      int64 estimated_row_count = 1;
      Returns:
      This builder for chaining.

    • getFractionConsumed

      public float getFractionConsumed()
       A value in the range [0.0, 1.0] that represents the fraction of rows
 assigned to this stream that have been processed by the server. In the
 presence of read filters, the server may process more rows than it returns,
 so this value reflects progress through the pre-filtering rows.

 This value is only populated for sessions created through the BALANCED
 sharding strategy.
      float fraction_consumed = 2;
      Specified by:
      getFractionConsumed in interface Storage.StreamStatusOrBuilder
      Returns:
      The fractionConsumed.

    • setFractionConsumed

      public Storage.StreamStatus.Builder setFractionConsumed(float value)
       A value in the range [0.0, 1.0] that represents the fraction of rows
 assigned to this stream that have been processed by the server. In the
 presence of read filters, the server may process more rows than it returns,
 so this value reflects progress through the pre-filtering rows.

 This value is only populated for sessions created through the BALANCED
 sharding strategy.
      float fraction_consumed = 2;
      Parameters:
      value - The fractionConsumed to set.
      Returns:
      This builder for chaining.

    • clearFractionConsumed

      public Storage.StreamStatus.Builder clearFractionConsumed()
       A value in the range [0.0, 1.0] that represents the fraction of rows
 assigned to this stream that have been processed by the server. In the
 presence of read filters, the server may process more rows than it returns,
 so this value reflects progress through the pre-filtering rows.

 This value is only populated for sessions created through the BALANCED
 sharding strategy.
      float fraction_consumed = 2;
      Returns:
      This builder for chaining.

    • hasProgress

      public boolean hasProgress()
       Represents the progress of the current stream.
      .google.cloud.bigquery.storage.v1beta1.Progress progress = 4;
      Specified by:
      hasProgress in interface Storage.StreamStatusOrBuilder
      Returns:
      Whether the progress field is set.

    • getProgress

      public Storage.Progress getProgress()
       Represents the progress of the current stream.
      .google.cloud.bigquery.storage.v1beta1.Progress progress = 4;
      Specified by:
      getProgress in interface Storage.StreamStatusOrBuilder
      Returns:
      The progress.

    • setProgress

      public Storage.StreamStatus.Builder setProgress(Storage.Progress value)
       Represents the progress of the current stream.
      .google.cloud.bigquery.storage.v1beta1.Progress progress = 4;

    • setProgress

      public Storage.StreamStatus.Builder setProgress(Storage.Progress.Builder builderForValue)
       Represents the progress of the current stream.
      .google.cloud.bigquery.storage.v1beta1.Progress progress = 4;

    • mergeProgress

      public Storage.StreamStatus.Builder mergeProgress(Storage.Progress value)
       Represents the progress of the current stream.
      .google.cloud.bigquery.storage.v1beta1.Progress progress = 4;

    • clearProgress

      public Storage.StreamStatus.Builder clearProgress()
       Represents the progress of the current stream.
      .google.cloud.bigquery.storage.v1beta1.Progress progress = 4;

    • getProgressBuilder

      public Storage.Progress.Builder getProgressBuilder()
       Represents the progress of the current stream.
      .google.cloud.bigquery.storage.v1beta1.Progress progress = 4;

    • getProgressOrBuilder

      public Storage.ProgressOrBuilder getProgressOrBuilder()
       Represents the progress of the current stream.
      .google.cloud.bigquery.storage.v1beta1.Progress progress = 4;
      Specified by:
      getProgressOrBuilder in interface Storage.StreamStatusOrBuilder

    • getIsSplittable

      public boolean getIsSplittable()
       Whether this stream can be split. For sessions that use the LIQUID sharding
 strategy, this value is always false. For BALANCED sessions, this value is
 false when enough data have been read such that no more splits are possible
 at that point or beyond. For small tables or streams that are the result of
 a chain of splits, this value may never be true.
      bool is_splittable = 3;
      Specified by:
      getIsSplittable in interface Storage.StreamStatusOrBuilder
      Returns:
      The isSplittable.

    • setIsSplittable

      public Storage.StreamStatus.Builder setIsSplittable(boolean value)
       Whether this stream can be split. For sessions that use the LIQUID sharding
 strategy, this value is always false. For BALANCED sessions, this value is
 false when enough data have been read such that no more splits are possible
 at that point or beyond. For small tables or streams that are the result of
 a chain of splits, this value may never be true.
      bool is_splittable = 3;
      Parameters:
      value - The isSplittable to set.
      Returns:
      This builder for chaining.

    • clearIsSplittable

      public Storage.StreamStatus.Builder clearIsSplittable()
       Whether this stream can be split. For sessions that use the LIQUID sharding
 strategy, this value is always false. For BALANCED sessions, this value is
 false when enough data have been read such that no more splits are possible
 at that point or beyond. For small tables or streams that are the result of
 a chain of splits, this value may never be true.
      bool is_splittable = 3;
      Returns:
      This builder for chaining.