Struct googapis::google::cloud::bigquery::storage::v1beta1::StreamStatus

pub struct StreamStatus {
    pub estimated_row_count: i64,
    pub fraction_consumed: f32,
    pub progress: Option<Progress>,
    pub is_splittable: bool,
}

Progress information for a given Stream.

Fields

estimated_row_count: i64

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.

fraction_consumed: f32

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.

progress: Option<Progress>

Represents the progress of the current stream.

is_splittable: bool

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.

Trait Implementations

impl Clone for StreamStatus

fn clone(&self) -> StreamStatus

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for StreamStatus

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for StreamStatus

fn default() -> Self

Returns the “default value” for a type.

impl Message for StreamStatus

fn encode_raw<B>(&self, buf: &mut B) where
    B: BufMut, 

fn merge_field<B>(
    &mut self,
    tag: u32,
    wire_type: WireType,
    buf: &mut B,
    ctx: DecodeContext
) -> Result<(), DecodeError> where
    B: Buf, 

fn encoded_len(&self) -> usize

Returns the encoded length of the message without a length delimiter.

fn clear(&mut self)

Clears the message, resetting all fields to their default.

fn encode<B>(&self, buf: &mut B) -> Result<(), EncodeError> where
    B: BufMut, 

Encodes the message to a buffer.

fn encode_to_vec(&self) -> Vec<u8, Global>

Encodes the message to a newly allocated buffer.

fn encode_length_delimited<B>(&self, buf: &mut B) -> Result<(), EncodeError> where
    B: BufMut, 

Encodes the message with a length-delimiter to a buffer.

fn encode_length_delimited_to_vec(&self) -> Vec<u8, Global>

Encodes the message with a length-delimiter to a newly allocated buffer.

fn decode<B>(buf: B) -> Result<Self, DecodeError> where
    Self: Default,
    B: Buf, 

Decodes an instance of the message from a buffer.

fn decode_length_delimited<B>(buf: B) -> Result<Self, DecodeError> where
    Self: Default,
    B: Buf, 

Decodes a length-delimited instance of the message from the buffer.

fn merge<B>(&mut self, buf: B) -> Result<(), DecodeError> where
    B: Buf, 

Decodes an instance of the message from a buffer, and merges it into self.

fn merge_length_delimited<B>(&mut self, buf: B) -> Result<(), DecodeError> where
    B: Buf, 

Decodes a length-delimited instance of the message from buffer, and merges it into self.

impl PartialEq<StreamStatus> for StreamStatus

fn eq(&self, other: &StreamStatus) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &StreamStatus) -> bool

This method tests for !=.

impl StructuralPartialEq for StreamStatus