public final class ReadSession extends GeneratedMessageV3 implements ReadSessionOrBuilder
Information about the ReadSession.
Protobuf type google.cloud.bigquery.storage.v1.ReadSession
Static Fields
ARROW_SCHEMA_FIELD_NUMBER
public static final int ARROW_SCHEMA_FIELD_NUMBER
Field Value
AVRO_SCHEMA_FIELD_NUMBER
public static final int AVRO_SCHEMA_FIELD_NUMBER
Field Value
public static final int DATA_FORMAT_FIELD_NUMBER
Field Value
ESTIMATED_TOTAL_BYTES_SCANNED_FIELD_NUMBER
public static final int ESTIMATED_TOTAL_BYTES_SCANNED_FIELD_NUMBER
Field Value
EXPIRE_TIME_FIELD_NUMBER
public static final int EXPIRE_TIME_FIELD_NUMBER
Field Value
NAME_FIELD_NUMBER
public static final int NAME_FIELD_NUMBER
Field Value
READ_OPTIONS_FIELD_NUMBER
public static final int READ_OPTIONS_FIELD_NUMBER
Field Value
STREAMS_FIELD_NUMBER
public static final int STREAMS_FIELD_NUMBER
Field Value
TABLE_FIELD_NUMBER
public static final int TABLE_FIELD_NUMBER
Field Value
TABLE_MODIFIERS_FIELD_NUMBER
public static final int TABLE_MODIFIERS_FIELD_NUMBER
Field Value
TRACE_ID_FIELD_NUMBER
public static final int TRACE_ID_FIELD_NUMBER
Field Value
Static Methods
getDefaultInstance()
public static ReadSession getDefaultInstance()
Returns
getDescriptor()
public static final Descriptors.Descriptor getDescriptor()
Returns
newBuilder()
public static ReadSession.Builder newBuilder()
Returns
newBuilder(ReadSession prototype)
public static ReadSession.Builder newBuilder(ReadSession prototype)
Parameter
Returns
public static ReadSession parseDelimitedFrom(InputStream input)
Parameter
Returns
Exceptions
public static ReadSession parseDelimitedFrom(InputStream input, ExtensionRegistryLite extensionRegistry)
Parameters
Returns
Exceptions
parseFrom(byte[] data)
public static ReadSession parseFrom(byte[] data)
Parameter
| Name | Description |
| data | byte[]
|
Returns
Exceptions
parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)
public static ReadSession parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)
Parameters
Returns
Exceptions
parseFrom(ByteString data)
public static ReadSession parseFrom(ByteString data)
Parameter
Returns
Exceptions
parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)
public static ReadSession parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)
Parameters
Returns
Exceptions
public static ReadSession parseFrom(CodedInputStream input)
Parameter
Returns
Exceptions
public static ReadSession parseFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)
Parameters
Returns
Exceptions
public static ReadSession parseFrom(InputStream input)
Parameter
Returns
Exceptions
public static ReadSession parseFrom(InputStream input, ExtensionRegistryLite extensionRegistry)
Parameters
Returns
Exceptions
parseFrom(ByteBuffer data)
public static ReadSession parseFrom(ByteBuffer data)
Parameter
Returns
Exceptions
parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)
public static ReadSession parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)
Parameters
Returns
Exceptions
parser()
public static Parser<ReadSession> parser()
Returns
Methods
equals(Object obj)
public boolean equals(Object obj)
Parameter
Returns
Overrides
getArrowSchema()
public ArrowSchema getArrowSchema()
Output only. Arrow schema.
.google.cloud.bigquery.storage.v1.ArrowSchema arrow_schema = 5 [(.google.api.field_behavior) = OUTPUT_ONLY];
getArrowSchemaOrBuilder()
public ArrowSchemaOrBuilder getArrowSchemaOrBuilder()
Output only. Arrow schema.
.google.cloud.bigquery.storage.v1.ArrowSchema arrow_schema = 5 [(.google.api.field_behavior) = OUTPUT_ONLY];
getAvroSchema()
public AvroSchema getAvroSchema()
Output only. Avro schema.
.google.cloud.bigquery.storage.v1.AvroSchema avro_schema = 4 [(.google.api.field_behavior) = OUTPUT_ONLY];
getAvroSchemaOrBuilder()
public AvroSchemaOrBuilder getAvroSchemaOrBuilder()
Output only. Avro schema.
.google.cloud.bigquery.storage.v1.AvroSchema avro_schema = 4 [(.google.api.field_behavior) = OUTPUT_ONLY];
public DataFormat getDataFormat()
Immutable. Data format of the output data.
.google.cloud.bigquery.storage.v1.DataFormat data_format = 3 [(.google.api.field_behavior) = IMMUTABLE];
public int getDataFormatValue()
Immutable. Data format of the output data.
.google.cloud.bigquery.storage.v1.DataFormat data_format = 3 [(.google.api.field_behavior) = IMMUTABLE];
| Type | Description |
| int | The enum numeric value on the wire for dataFormat.
|
getDefaultInstanceForType()
public ReadSession getDefaultInstanceForType()
Returns
getEstimatedTotalBytesScanned()
public long getEstimatedTotalBytesScanned()
Output only. An estimate on the number of bytes this session will scan when
all streams are completely consumed. This estimate is based on
metadata from the table which might be incomplete or stale.
int64 estimated_total_bytes_scanned = 12 [(.google.api.field_behavior) = OUTPUT_ONLY];
| Type | Description |
| long | The estimatedTotalBytesScanned.
|
getExpireTime()
public Timestamp getExpireTime()
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.
.google.protobuf.Timestamp expire_time = 2 [(.google.api.field_behavior) = OUTPUT_ONLY];
getExpireTimeOrBuilder()
public TimestampOrBuilder getExpireTimeOrBuilder()
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.
.google.protobuf.Timestamp expire_time = 2 [(.google.api.field_behavior) = OUTPUT_ONLY];
getName()
Output only. Unique identifier for the session, in the form
projects/{project_id}/locations/{location}/sessions/{session_id}.
string name = 1 [(.google.api.field_behavior) = OUTPUT_ONLY];
| Type | Description |
| String | The name.
|
getNameBytes()
public ByteString getNameBytes()
Output only. Unique identifier for the session, in the form
projects/{project_id}/locations/{location}/sessions/{session_id}.
string name = 1 [(.google.api.field_behavior) = OUTPUT_ONLY];
getParserForType()
public Parser<ReadSession> getParserForType()
Returns
Overrides
getReadOptions()
public ReadSession.TableReadOptions getReadOptions()
Optional. Read options for this session (e.g. column selection, filters).
.google.cloud.bigquery.storage.v1.ReadSession.TableReadOptions read_options = 8 [(.google.api.field_behavior) = OPTIONAL];
getReadOptionsOrBuilder()
public ReadSession.TableReadOptionsOrBuilder getReadOptionsOrBuilder()
Optional. Read options for this session (e.g. column selection, filters).
.google.cloud.bigquery.storage.v1.ReadSession.TableReadOptions read_options = 8 [(.google.api.field_behavior) = OPTIONAL];
getSchemaCase()
public ReadSession.SchemaCase getSchemaCase()
Returns
getSerializedSize()
public int getSerializedSize()
Returns
Overrides
getStreams(int index)
public ReadStream getStreams(int index)
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.
repeated .google.cloud.bigquery.storage.v1.ReadStream streams = 10 [(.google.api.field_behavior) = OUTPUT_ONLY];
getStreamsCount()
public int getStreamsCount()
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.
repeated .google.cloud.bigquery.storage.v1.ReadStream streams = 10 [(.google.api.field_behavior) = OUTPUT_ONLY];
getStreamsList()
public List<ReadStream> getStreamsList()
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.
repeated .google.cloud.bigquery.storage.v1.ReadStream streams = 10 [(.google.api.field_behavior) = OUTPUT_ONLY];
getStreamsOrBuilder(int index)
public ReadStreamOrBuilder getStreamsOrBuilder(int index)
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.
repeated .google.cloud.bigquery.storage.v1.ReadStream streams = 10 [(.google.api.field_behavior) = OUTPUT_ONLY];
getStreamsOrBuilderList()
public List<? extends ReadStreamOrBuilder> getStreamsOrBuilderList()
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.
repeated .google.cloud.bigquery.storage.v1.ReadStream streams = 10 [(.google.api.field_behavior) = OUTPUT_ONLY];
| Type | Description |
| List<? extends com.google.cloud.bigquery.storage.v1.ReadStreamOrBuilder> | |
getTable()
Immutable. Table that this ReadSession is reading from, in the form
projects/{project_id}/datasets/{dataset_id}/tables/{table_id}
string table = 6 [(.google.api.field_behavior) = IMMUTABLE, (.google.api.resource_reference) = { ... }
| Type | Description |
| String | The table.
|
getTableBytes()
public ByteString getTableBytes()
Immutable. Table that this ReadSession is reading from, in the form
projects/{project_id}/datasets/{dataset_id}/tables/{table_id}
string table = 6 [(.google.api.field_behavior) = IMMUTABLE, (.google.api.resource_reference) = { ... }
getTableModifiers()
public ReadSession.TableModifiers getTableModifiers()
Optional. Any modifiers which are applied when reading from the specified table.
.google.cloud.bigquery.storage.v1.ReadSession.TableModifiers table_modifiers = 7 [(.google.api.field_behavior) = OPTIONAL];
getTableModifiersOrBuilder()
public ReadSession.TableModifiersOrBuilder getTableModifiersOrBuilder()
Optional. Any modifiers which are applied when reading from the specified table.
.google.cloud.bigquery.storage.v1.ReadSession.TableModifiers table_modifiers = 7 [(.google.api.field_behavior) = OPTIONAL];
getTraceId()
public String getTraceId()
Optional. ID set by client to annotate a session identity. This does not need
to be strictly unique, but instead the same ID should be used to group
logically connected sessions (e.g. All using the same ID for all sessions
needed to complete a Spark SQL query is reasonable).
Maximum length is 256 bytes.
string trace_id = 13 [(.google.api.field_behavior) = OPTIONAL];
| Type | Description |
| String | The traceId.
|
getTraceIdBytes()
public ByteString getTraceIdBytes()
Optional. ID set by client to annotate a session identity. This does not need
to be strictly unique, but instead the same ID should be used to group
logically connected sessions (e.g. All using the same ID for all sessions
needed to complete a Spark SQL query is reasonable).
Maximum length is 256 bytes.
string trace_id = 13 [(.google.api.field_behavior) = OPTIONAL];
getUnknownFields()
public final UnknownFieldSet getUnknownFields()
Returns
Overrides
hasArrowSchema()
public boolean hasArrowSchema()
Output only. Arrow schema.
.google.cloud.bigquery.storage.v1.ArrowSchema arrow_schema = 5 [(.google.api.field_behavior) = OUTPUT_ONLY];
| Type | Description |
| boolean | Whether the arrowSchema field is set.
|
hasAvroSchema()
public boolean hasAvroSchema()
Output only. Avro schema.
.google.cloud.bigquery.storage.v1.AvroSchema avro_schema = 4 [(.google.api.field_behavior) = OUTPUT_ONLY];
| Type | Description |
| boolean | Whether the avroSchema field is set.
|
hasExpireTime()
public boolean hasExpireTime()
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.
.google.protobuf.Timestamp expire_time = 2 [(.google.api.field_behavior) = OUTPUT_ONLY];
| Type | Description |
| boolean | Whether the expireTime field is set.
|
hasReadOptions()
public boolean hasReadOptions()
Optional. Read options for this session (e.g. column selection, filters).
.google.cloud.bigquery.storage.v1.ReadSession.TableReadOptions read_options = 8 [(.google.api.field_behavior) = OPTIONAL];
| Type | Description |
| boolean | Whether the readOptions field is set.
|
hasTableModifiers()
public boolean hasTableModifiers()
Optional. Any modifiers which are applied when reading from the specified table.
.google.cloud.bigquery.storage.v1.ReadSession.TableModifiers table_modifiers = 7 [(.google.api.field_behavior) = OPTIONAL];
| Type | Description |
| boolean | Whether the tableModifiers field is set.
|
hashCode()
Returns
Overrides
internalGetFieldAccessorTable()
protected GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
Returns
Overrides
isInitialized()
public final boolean isInitialized()
Returns
Overrides
newBuilderForType()
public ReadSession.Builder newBuilderForType()
Returns
newBuilderForType(GeneratedMessageV3.BuilderParent parent)
protected ReadSession.Builder newBuilderForType(GeneratedMessageV3.BuilderParent parent)
Parameter
Returns
Overrides
newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)
protected Object newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)
Parameter
Returns
Overrides
toBuilder()
public ReadSession.Builder toBuilder()
Returns
writeTo(CodedOutputStream output)
public void writeTo(CodedOutputStream output)
Parameter
Overrides
Exceptions
