public static final class Storage.ReadSession extends GeneratedMessageV3 implements Storage.ReadSessionOrBuilder
Information returned from a CreateReadSession request.
Protobuf type google.cloud.bigquery.storage.v1beta1.ReadSession
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
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
SHARDING_STRATEGY_FIELD_NUMBER
public static final int SHARDING_STRATEGY_FIELD_NUMBER
Field Value
STREAMS_FIELD_NUMBER
public static final int STREAMS_FIELD_NUMBER
Field Value
TABLE_MODIFIERS_FIELD_NUMBER
public static final int TABLE_MODIFIERS_FIELD_NUMBER
Field Value
TABLE_REFERENCE_FIELD_NUMBER
public static final int TABLE_REFERENCE_FIELD_NUMBER
Field Value
Methods
equals(Object obj)
public boolean equals(Object obj)
Parameter
Returns
Overrides
getArrowSchema()
public ArrowProto.ArrowSchema getArrowSchema()
Arrow schema.
.google.cloud.bigquery.storage.v1beta1.ArrowSchema arrow_schema = 6;
getArrowSchemaOrBuilder()
public ArrowProto.ArrowSchemaOrBuilder getArrowSchemaOrBuilder()
Arrow schema.
.google.cloud.bigquery.storage.v1beta1.ArrowSchema arrow_schema = 6;
getAvroSchema()
public AvroProto.AvroSchema getAvroSchema()
Avro schema.
.google.cloud.bigquery.storage.v1beta1.AvroSchema avro_schema = 5;
getAvroSchemaOrBuilder()
public AvroProto.AvroSchemaOrBuilder getAvroSchemaOrBuilder()
Avro schema.
.google.cloud.bigquery.storage.v1beta1.AvroSchema avro_schema = 5;
getDefaultInstance()
public static Storage.ReadSession getDefaultInstance()
Returns
getDefaultInstanceForType()
public Storage.ReadSession getDefaultInstanceForType()
Returns
getDescriptor()
public static final Descriptors.Descriptor getDescriptor()
Returns
getExpireTime()
public Timestamp getExpireTime()
Time at which the session becomes invalid. After this time, subsequent
requests to read this Session will return errors.
.google.protobuf.Timestamp expire_time = 2;
getExpireTimeOrBuilder()
public TimestampOrBuilder getExpireTimeOrBuilder()
Time at which the session becomes invalid. After this time, subsequent
requests to read this Session will return errors.
.google.protobuf.Timestamp expire_time = 2;
getName()
Unique identifier for the session, in the form
projects/{project_id}/locations/{location}/sessions/{session_id}.
string name = 1;
| Type | Description |
| String | The name.
|
getNameBytes()
public ByteString getNameBytes()
Unique identifier for the session, in the form
projects/{project_id}/locations/{location}/sessions/{session_id}.
string name = 1;
getParserForType()
public Parser<Storage.ReadSession> getParserForType()
Returns
Overrides
getSchemaCase()
public Storage.ReadSession.SchemaCase getSchemaCase()
Returns
getSerializedSize()
public int getSerializedSize()
Returns
Overrides
getShardingStrategy()
public Storage.ShardingStrategy getShardingStrategy()
The strategy to use for distributing data among the streams.
.google.cloud.bigquery.storage.v1beta1.ShardingStrategy sharding_strategy = 9;
getShardingStrategyValue()
public int getShardingStrategyValue()
The strategy to use for distributing data among the streams.
.google.cloud.bigquery.storage.v1beta1.ShardingStrategy sharding_strategy = 9;
| Type | Description |
| int | The enum numeric value on the wire for shardingStrategy.
|
getStreams(int index)
public Storage.Stream getStreams(int index)
Streams associated with this session.
repeated .google.cloud.bigquery.storage.v1beta1.Stream streams = 4;
getStreamsCount()
public int getStreamsCount()
Streams associated with this session.
repeated .google.cloud.bigquery.storage.v1beta1.Stream streams = 4;
getStreamsList()
public List<Storage.Stream> getStreamsList()
Streams associated with this session.
repeated .google.cloud.bigquery.storage.v1beta1.Stream streams = 4;
getStreamsOrBuilder(int index)
public Storage.StreamOrBuilder getStreamsOrBuilder(int index)
Streams associated with this session.
repeated .google.cloud.bigquery.storage.v1beta1.Stream streams = 4;
getStreamsOrBuilderList()
public List<? extends Storage.StreamOrBuilder> getStreamsOrBuilderList()
Streams associated with this session.
repeated .google.cloud.bigquery.storage.v1beta1.Stream streams = 4;
| Type | Description |
| List<? extends com.google.cloud.bigquery.storage.v1beta1.Storage.StreamOrBuilder> | |
getTableModifiers()
public TableReferenceProto.TableModifiers getTableModifiers()
Any modifiers which are applied when reading from the specified table.
.google.cloud.bigquery.storage.v1beta1.TableModifiers table_modifiers = 8;
getTableModifiersOrBuilder()
public TableReferenceProto.TableModifiersOrBuilder getTableModifiersOrBuilder()
Any modifiers which are applied when reading from the specified table.
.google.cloud.bigquery.storage.v1beta1.TableModifiers table_modifiers = 8;
getTableReference()
public TableReferenceProto.TableReference getTableReference()
Table that this ReadSession is reading from.
.google.cloud.bigquery.storage.v1beta1.TableReference table_reference = 7;
getTableReferenceOrBuilder()
public TableReferenceProto.TableReferenceOrBuilder getTableReferenceOrBuilder()
Table that this ReadSession is reading from.
.google.cloud.bigquery.storage.v1beta1.TableReference table_reference = 7;
getUnknownFields()
public final UnknownFieldSet getUnknownFields()
Returns
Overrides
hasArrowSchema()
public boolean hasArrowSchema()
Arrow schema.
.google.cloud.bigquery.storage.v1beta1.ArrowSchema arrow_schema = 6;
| Type | Description |
| boolean | Whether the arrowSchema field is set.
|
hasAvroSchema()
public boolean hasAvroSchema()
Avro schema.
.google.cloud.bigquery.storage.v1beta1.AvroSchema avro_schema = 5;
| Type | Description |
| boolean | Whether the avroSchema field is set.
|
hasExpireTime()
public boolean hasExpireTime()
Time at which the session becomes invalid. After this time, subsequent
requests to read this Session will return errors.
.google.protobuf.Timestamp expire_time = 2;
| Type | Description |
| boolean | Whether the expireTime field is set.
|
hasTableModifiers()
public boolean hasTableModifiers()
Any modifiers which are applied when reading from the specified table.
.google.cloud.bigquery.storage.v1beta1.TableModifiers table_modifiers = 8;
| Type | Description |
| boolean | Whether the tableModifiers field is set.
|
hasTableReference()
public boolean hasTableReference()
Table that this ReadSession is reading from.
.google.cloud.bigquery.storage.v1beta1.TableReference table_reference = 7;
| Type | Description |
| boolean | Whether the tableReference field is set.
|
hashCode()
Returns
Overrides
internalGetFieldAccessorTable()
protected GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
Returns
Overrides
isInitialized()
public final boolean isInitialized()
Returns
Overrides
newBuilder()
public static Storage.ReadSession.Builder newBuilder()
Returns
newBuilder(Storage.ReadSession prototype)
public static Storage.ReadSession.Builder newBuilder(Storage.ReadSession prototype)
Parameter
Returns
newBuilderForType()
public Storage.ReadSession.Builder newBuilderForType()
Returns
newBuilderForType(GeneratedMessageV3.BuilderParent parent)
protected Storage.ReadSession.Builder newBuilderForType(GeneratedMessageV3.BuilderParent parent)
Parameter
Returns
Overrides
newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)
protected Object newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)
Parameter
Returns
Overrides
public static Storage.ReadSession parseDelimitedFrom(InputStream input)
Parameter
Returns
Exceptions
public static Storage.ReadSession parseDelimitedFrom(InputStream input, ExtensionRegistryLite extensionRegistry)
Parameters
Returns
Exceptions
parseFrom(byte[] data)
public static Storage.ReadSession parseFrom(byte[] data)
Parameter
| Name | Description |
| data | byte[]
|
Returns
Exceptions
parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)
public static Storage.ReadSession parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)
Parameters
Returns
Exceptions
parseFrom(ByteString data)
public static Storage.ReadSession parseFrom(ByteString data)
Parameter
Returns
Exceptions
parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)
public static Storage.ReadSession parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)
Parameters
Returns
Exceptions
public static Storage.ReadSession parseFrom(CodedInputStream input)
Parameter
Returns
Exceptions
public static Storage.ReadSession parseFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)
Parameters
Returns
Exceptions
public static Storage.ReadSession parseFrom(InputStream input)
Parameter
Returns
Exceptions
public static Storage.ReadSession parseFrom(InputStream input, ExtensionRegistryLite extensionRegistry)
Parameters
Returns
Exceptions
parseFrom(ByteBuffer data)
public static Storage.ReadSession parseFrom(ByteBuffer data)
Parameter
Returns
Exceptions
parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)
public static Storage.ReadSession parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)
Parameters
Returns
Exceptions
parser()
public static Parser<Storage.ReadSession> parser()
Returns
toBuilder()
public Storage.ReadSession.Builder toBuilder()
Returns
writeTo(CodedOutputStream output)
public void writeTo(CodedOutputStream output)
Parameter
Overrides
Exceptions
