Struct googapis::google::cloud::bigquery::storage::v1beta2::ReadSession [−][src]
pub struct ReadSession {
pub name: String,
pub expire_time: Option<Timestamp>,
pub data_format: i32,
pub table: String,
pub table_modifiers: Option<TableModifiers>,
pub read_options: Option<TableReadOptions>,
pub streams: Vec<ReadStream>,
pub schema: Option<Schema>,
}
Expand description
Information about the ReadSession.
Fields
name: String
Output only. Unique identifier for the session, in the form
projects/{project_id}/locations/{location}/sessions/{session_id}
.
expire_time: Option<Timestamp>
Output only. Time at which the session becomes invalid. After this time, subsequent requests to read this Session will return errors. The expire_time is automatically assigned and currently cannot be specified or updated.
data_format: i32
Immutable. Data format of the output data.
table: String
Immutable. Table that this ReadSession is reading from, in the form `projects/{project_id}/datasets/{dataset_id}/tables/{table_id}
table_modifiers: Option<TableModifiers>
Optional. Any modifiers which are applied when reading from the specified table.
read_options: Option<TableReadOptions>
Optional. Read options for this session (e.g. column selection, filters).
streams: Vec<ReadStream>
Output only. A list of streams created with the session.
At least one stream is created with the session. In the future, larger request_stream_count values may result in this list being unpopulated, in that case, the user will need to use a List method to get the streams instead, which is not yet available.
schema: Option<Schema>
The schema for the read. If read_options.selected_fields is set, the schema may be different from the table schema as it will only contain the selected fields.
Implementations
Returns the enum value of data_format
, or the default if the field is set to an invalid enum value.
Sets data_format
to the provided enum value.
Trait Implementations
fn merge_field<B>(
&mut self,
tag: u32,
wire_type: WireType,
buf: &mut B,
ctx: DecodeContext
) -> Result<(), DecodeError> where
B: Buf,
Returns the encoded length of the message without a length delimiter.
Encodes the message to a buffer. Read more
Encodes the message to a newly allocated buffer.
Encodes the message with a length-delimiter to a buffer. Read more
Encodes the message with a length-delimiter to a newly allocated buffer.
Decodes an instance of the message from a buffer. Read more
fn decode_length_delimited<B>(buf: B) -> Result<Self, DecodeError> where
Self: Default,
B: Buf,
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.
Decodes an instance of the message from a buffer, and merges it into self
. Read more
Decodes a length-delimited instance of the message from buffer, and
merges it into self
. Read more
This method tests for self
and other
values to be equal, and is used
by ==
. Read more
This method tests for !=
.
Auto Trait Implementations
impl RefUnwindSafe for ReadSession
impl Send for ReadSession
impl Sync for ReadSession
impl Unpin for ReadSession
impl UnwindSafe for ReadSession
Blanket Implementations
Mutably borrows from an owned value. Read more
Wrap the input message T
in a tonic::Request
pub fn vzip(self) -> V
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more