Class Storage.ReadSession
- java.lang.Object
-
- com.google.protobuf.AbstractMessageLite
-
- com.google.protobuf.AbstractMessage
-
- com.google.protobuf.GeneratedMessageV3
-
- com.google.cloud.bigquery.storage.v1beta1.Storage.ReadSession
-
- All Implemented Interfaces:
Storage.ReadSessionOrBuilder
,com.google.protobuf.Message
,com.google.protobuf.MessageLite
,com.google.protobuf.MessageLiteOrBuilder
,com.google.protobuf.MessageOrBuilder
,Serializable
- Enclosing class:
- Storage
public static final class Storage.ReadSession extends com.google.protobuf.GeneratedMessageV3 implements Storage.ReadSessionOrBuilder
Information returned from a `CreateReadSession` request.
Protobuf typegoogle.cloud.bigquery.storage.v1beta1.ReadSession
- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
Storage.ReadSession.Builder
Information returned from a `CreateReadSession` request.static class
Storage.ReadSession.SchemaCase
-
Nested classes/interfaces inherited from class com.google.protobuf.GeneratedMessageV3
com.google.protobuf.GeneratedMessageV3.BuilderParent, com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageT extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT>,BuilderT extends com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageT,BuilderT>>, com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessageV3.ExtendableMessageOrBuilder<MessageT extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessageV3.FieldAccessorTable, com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter
-
-
Field Summary
Fields Modifier and Type Field Description static int
ARROW_SCHEMA_FIELD_NUMBER
static int
AVRO_SCHEMA_FIELD_NUMBER
static int
EXPIRE_TIME_FIELD_NUMBER
static int
NAME_FIELD_NUMBER
static int
SHARDING_STRATEGY_FIELD_NUMBER
static int
STREAMS_FIELD_NUMBER
static int
TABLE_MODIFIERS_FIELD_NUMBER
static int
TABLE_REFERENCE_FIELD_NUMBER
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
equals(Object obj)
ArrowProto.ArrowSchema
getArrowSchema()
Arrow schema.ArrowProto.ArrowSchemaOrBuilder
getArrowSchemaOrBuilder()
Arrow schema.AvroProto.AvroSchema
getAvroSchema()
Avro schema.AvroProto.AvroSchemaOrBuilder
getAvroSchemaOrBuilder()
Avro schema.static Storage.ReadSession
getDefaultInstance()
Storage.ReadSession
getDefaultInstanceForType()
static com.google.protobuf.Descriptors.Descriptor
getDescriptor()
com.google.protobuf.Timestamp
getExpireTime()
Time at which the session becomes invalid.com.google.protobuf.TimestampOrBuilder
getExpireTimeOrBuilder()
Time at which the session becomes invalid.String
getName()
Unique identifier for the session, in the form `projects/{project_id}/locations/{location}/sessions/{session_id}`.com.google.protobuf.ByteString
getNameBytes()
Unique identifier for the session, in the form `projects/{project_id}/locations/{location}/sessions/{session_id}`.com.google.protobuf.Parser<Storage.ReadSession>
getParserForType()
Storage.ReadSession.SchemaCase
getSchemaCase()
int
getSerializedSize()
Storage.ShardingStrategy
getShardingStrategy()
The strategy to use for distributing data among the streams.int
getShardingStrategyValue()
The strategy to use for distributing data among the streams.Storage.Stream
getStreams(int index)
Streams associated with this session.int
getStreamsCount()
Streams associated with this session.List<Storage.Stream>
getStreamsList()
Streams associated with this session.Storage.StreamOrBuilder
getStreamsOrBuilder(int index)
Streams associated with this session.List<? extends Storage.StreamOrBuilder>
getStreamsOrBuilderList()
Streams associated with this session.TableReferenceProto.TableModifiers
getTableModifiers()
Any modifiers which are applied when reading from the specified table.TableReferenceProto.TableModifiersOrBuilder
getTableModifiersOrBuilder()
Any modifiers which are applied when reading from the specified table.TableReferenceProto.TableReference
getTableReference()
Table that this ReadSession is reading from.TableReferenceProto.TableReferenceOrBuilder
getTableReferenceOrBuilder()
Table that this ReadSession is reading from.boolean
hasArrowSchema()
Arrow schema.boolean
hasAvroSchema()
Avro schema.boolean
hasExpireTime()
Time at which the session becomes invalid.int
hashCode()
boolean
hasTableModifiers()
Any modifiers which are applied when reading from the specified table.boolean
hasTableReference()
Table that this ReadSession is reading from.protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable()
boolean
isInitialized()
static Storage.ReadSession.Builder
newBuilder()
static Storage.ReadSession.Builder
newBuilder(Storage.ReadSession prototype)
Storage.ReadSession.Builder
newBuilderForType()
protected Storage.ReadSession.Builder
newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
protected Object
newInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)
static Storage.ReadSession
parseDelimitedFrom(InputStream input)
static Storage.ReadSession
parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Storage.ReadSession
parseFrom(byte[] data)
static Storage.ReadSession
parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Storage.ReadSession
parseFrom(com.google.protobuf.ByteString data)
static Storage.ReadSession
parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Storage.ReadSession
parseFrom(com.google.protobuf.CodedInputStream input)
static Storage.ReadSession
parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Storage.ReadSession
parseFrom(InputStream input)
static Storage.ReadSession
parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Storage.ReadSession
parseFrom(ByteBuffer data)
static Storage.ReadSession
parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static com.google.protobuf.Parser<Storage.ReadSession>
parser()
Storage.ReadSession.Builder
toBuilder()
void
writeTo(com.google.protobuf.CodedOutputStream output)
-
Methods inherited from class com.google.protobuf.GeneratedMessageV3
canUseUnsafe, computeStringSize, computeStringSizeNoTag, emptyBooleanList, emptyDoubleList, emptyFloatList, emptyIntList, emptyLongList, getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, internalGetMapField, isStringEmpty, makeExtensionsImmutable, makeMutableCopy, mergeFromAndMakeImmutableInternal, mutableCopy, mutableCopy, mutableCopy, mutableCopy, mutableCopy, newBooleanList, newBuilderForType, newDoubleList, newFloatList, newIntList, newLongList, parseDelimitedWithIOException, parseDelimitedWithIOException, parseUnknownField, parseUnknownFieldProto3, parseWithIOException, parseWithIOException, parseWithIOException, parseWithIOException, serializeBooleanMapTo, serializeIntegerMapTo, serializeLongMapTo, serializeStringMapTo, writeReplace, writeString, writeStringNoTag
-
Methods inherited from class com.google.protobuf.AbstractMessage
findInitializationErrors, getInitializationErrorString, hashBoolean, hashEnum, hashEnumList, hashFields, hashLong, toString
-
Methods inherited from class com.google.protobuf.AbstractMessageLite
addAll, addAll, checkByteStringIsUtf8, toByteArray, toByteString, writeDelimitedTo, writeTo
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
-
-
-
Field Detail
-
NAME_FIELD_NUMBER
public static final int NAME_FIELD_NUMBER
- See Also:
- Constant Field Values
-
EXPIRE_TIME_FIELD_NUMBER
public static final int EXPIRE_TIME_FIELD_NUMBER
- See Also:
- Constant Field Values
-
AVRO_SCHEMA_FIELD_NUMBER
public static final int AVRO_SCHEMA_FIELD_NUMBER
- See Also:
- Constant Field Values
-
ARROW_SCHEMA_FIELD_NUMBER
public static final int ARROW_SCHEMA_FIELD_NUMBER
- See Also:
- Constant Field Values
-
STREAMS_FIELD_NUMBER
public static final int STREAMS_FIELD_NUMBER
- See Also:
- Constant Field Values
-
TABLE_REFERENCE_FIELD_NUMBER
public static final int TABLE_REFERENCE_FIELD_NUMBER
- See Also:
- Constant Field Values
-
TABLE_MODIFIERS_FIELD_NUMBER
public static final int TABLE_MODIFIERS_FIELD_NUMBER
- See Also:
- Constant Field Values
-
SHARDING_STRATEGY_FIELD_NUMBER
public static final int SHARDING_STRATEGY_FIELD_NUMBER
- See Also:
- Constant Field Values
-
-
Method Detail
-
newInstance
protected Object newInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)
- Overrides:
newInstance
in classcom.google.protobuf.GeneratedMessageV3
-
getDescriptor
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
-
internalGetFieldAccessorTable
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
- Specified by:
internalGetFieldAccessorTable
in classcom.google.protobuf.GeneratedMessageV3
-
getSchemaCase
public Storage.ReadSession.SchemaCase getSchemaCase()
- Specified by:
getSchemaCase
in interfaceStorage.ReadSessionOrBuilder
-
getName
public String getName()
Unique identifier for the session, in the form `projects/{project_id}/locations/{location}/sessions/{session_id}`.
string name = 1;
- Specified by:
getName
in interfaceStorage.ReadSessionOrBuilder
- Returns:
- The name.
-
getNameBytes
public com.google.protobuf.ByteString getNameBytes()
Unique identifier for the session, in the form `projects/{project_id}/locations/{location}/sessions/{session_id}`.
string name = 1;
- Specified by:
getNameBytes
in interfaceStorage.ReadSessionOrBuilder
- Returns:
- The bytes for name.
-
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;
- Specified by:
hasExpireTime
in interfaceStorage.ReadSessionOrBuilder
- Returns:
- Whether the expireTime field is set.
-
getExpireTime
public com.google.protobuf.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;
- Specified by:
getExpireTime
in interfaceStorage.ReadSessionOrBuilder
- Returns:
- The expireTime.
-
getExpireTimeOrBuilder
public com.google.protobuf.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;
- Specified by:
getExpireTimeOrBuilder
in interfaceStorage.ReadSessionOrBuilder
-
hasAvroSchema
public boolean hasAvroSchema()
Avro schema.
.google.cloud.bigquery.storage.v1beta1.AvroSchema avro_schema = 5;
- Specified by:
hasAvroSchema
in interfaceStorage.ReadSessionOrBuilder
- Returns:
- Whether the avroSchema field is set.
-
getAvroSchema
public AvroProto.AvroSchema getAvroSchema()
Avro schema.
.google.cloud.bigquery.storage.v1beta1.AvroSchema avro_schema = 5;
- Specified by:
getAvroSchema
in interfaceStorage.ReadSessionOrBuilder
- Returns:
- The avroSchema.
-
getAvroSchemaOrBuilder
public AvroProto.AvroSchemaOrBuilder getAvroSchemaOrBuilder()
Avro schema.
.google.cloud.bigquery.storage.v1beta1.AvroSchema avro_schema = 5;
- Specified by:
getAvroSchemaOrBuilder
in interfaceStorage.ReadSessionOrBuilder
-
hasArrowSchema
public boolean hasArrowSchema()
Arrow schema.
.google.cloud.bigquery.storage.v1beta1.ArrowSchema arrow_schema = 6;
- Specified by:
hasArrowSchema
in interfaceStorage.ReadSessionOrBuilder
- Returns:
- Whether the arrowSchema field is set.
-
getArrowSchema
public ArrowProto.ArrowSchema getArrowSchema()
Arrow schema.
.google.cloud.bigquery.storage.v1beta1.ArrowSchema arrow_schema = 6;
- Specified by:
getArrowSchema
in interfaceStorage.ReadSessionOrBuilder
- Returns:
- The arrowSchema.
-
getArrowSchemaOrBuilder
public ArrowProto.ArrowSchemaOrBuilder getArrowSchemaOrBuilder()
Arrow schema.
.google.cloud.bigquery.storage.v1beta1.ArrowSchema arrow_schema = 6;
- Specified by:
getArrowSchemaOrBuilder
in interfaceStorage.ReadSessionOrBuilder
-
getStreamsList
public List<Storage.Stream> getStreamsList()
Streams associated with this session.
repeated .google.cloud.bigquery.storage.v1beta1.Stream streams = 4;
- Specified by:
getStreamsList
in interfaceStorage.ReadSessionOrBuilder
-
getStreamsOrBuilderList
public List<? extends Storage.StreamOrBuilder> getStreamsOrBuilderList()
Streams associated with this session.
repeated .google.cloud.bigquery.storage.v1beta1.Stream streams = 4;
- Specified by:
getStreamsOrBuilderList
in interfaceStorage.ReadSessionOrBuilder
-
getStreamsCount
public int getStreamsCount()
Streams associated with this session.
repeated .google.cloud.bigquery.storage.v1beta1.Stream streams = 4;
- Specified by:
getStreamsCount
in interfaceStorage.ReadSessionOrBuilder
-
getStreams
public Storage.Stream getStreams(int index)
Streams associated with this session.
repeated .google.cloud.bigquery.storage.v1beta1.Stream streams = 4;
- Specified by:
getStreams
in interfaceStorage.ReadSessionOrBuilder
-
getStreamsOrBuilder
public Storage.StreamOrBuilder getStreamsOrBuilder(int index)
Streams associated with this session.
repeated .google.cloud.bigquery.storage.v1beta1.Stream streams = 4;
- Specified by:
getStreamsOrBuilder
in interfaceStorage.ReadSessionOrBuilder
-
hasTableReference
public boolean hasTableReference()
Table that this ReadSession is reading from.
.google.cloud.bigquery.storage.v1beta1.TableReference table_reference = 7;
- Specified by:
hasTableReference
in interfaceStorage.ReadSessionOrBuilder
- Returns:
- Whether the tableReference field is set.
-
getTableReference
public TableReferenceProto.TableReference getTableReference()
Table that this ReadSession is reading from.
.google.cloud.bigquery.storage.v1beta1.TableReference table_reference = 7;
- Specified by:
getTableReference
in interfaceStorage.ReadSessionOrBuilder
- Returns:
- The tableReference.
-
getTableReferenceOrBuilder
public TableReferenceProto.TableReferenceOrBuilder getTableReferenceOrBuilder()
Table that this ReadSession is reading from.
.google.cloud.bigquery.storage.v1beta1.TableReference table_reference = 7;
- Specified by:
getTableReferenceOrBuilder
in interfaceStorage.ReadSessionOrBuilder
-
hasTableModifiers
public boolean hasTableModifiers()
Any modifiers which are applied when reading from the specified table.
.google.cloud.bigquery.storage.v1beta1.TableModifiers table_modifiers = 8;
- Specified by:
hasTableModifiers
in interfaceStorage.ReadSessionOrBuilder
- Returns:
- Whether the tableModifiers field is set.
-
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;
- Specified by:
getTableModifiers
in interfaceStorage.ReadSessionOrBuilder
- Returns:
- The tableModifiers.
-
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;
- Specified by:
getTableModifiersOrBuilder
in interfaceStorage.ReadSessionOrBuilder
-
getShardingStrategyValue
public int getShardingStrategyValue()
The strategy to use for distributing data among the streams.
.google.cloud.bigquery.storage.v1beta1.ShardingStrategy sharding_strategy = 9;
- Specified by:
getShardingStrategyValue
in interfaceStorage.ReadSessionOrBuilder
- Returns:
- The enum numeric value on the wire for shardingStrategy.
-
getShardingStrategy
public Storage.ShardingStrategy getShardingStrategy()
The strategy to use for distributing data among the streams.
.google.cloud.bigquery.storage.v1beta1.ShardingStrategy sharding_strategy = 9;
- Specified by:
getShardingStrategy
in interfaceStorage.ReadSessionOrBuilder
- Returns:
- The shardingStrategy.
-
isInitialized
public final boolean isInitialized()
- Specified by:
isInitialized
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Overrides:
isInitialized
in classcom.google.protobuf.GeneratedMessageV3
-
writeTo
public void writeTo(com.google.protobuf.CodedOutputStream output) throws IOException
- Specified by:
writeTo
in interfacecom.google.protobuf.MessageLite
- Overrides:
writeTo
in classcom.google.protobuf.GeneratedMessageV3
- Throws:
IOException
-
getSerializedSize
public int getSerializedSize()
- Specified by:
getSerializedSize
in interfacecom.google.protobuf.MessageLite
- Overrides:
getSerializedSize
in classcom.google.protobuf.GeneratedMessageV3
-
equals
public boolean equals(Object obj)
- Specified by:
equals
in interfacecom.google.protobuf.Message
- Overrides:
equals
in classcom.google.protobuf.AbstractMessage
-
hashCode
public int hashCode()
- Specified by:
hashCode
in interfacecom.google.protobuf.Message
- Overrides:
hashCode
in classcom.google.protobuf.AbstractMessage
-
parseFrom
public static Storage.ReadSession parseFrom(ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static Storage.ReadSession parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static Storage.ReadSession parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static Storage.ReadSession parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static Storage.ReadSession parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static Storage.ReadSession parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static Storage.ReadSession parseFrom(InputStream input) throws IOException
- Throws:
IOException
-
parseFrom
public static Storage.ReadSession parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Throws:
IOException
-
parseDelimitedFrom
public static Storage.ReadSession parseDelimitedFrom(InputStream input) throws IOException
- Throws:
IOException
-
parseDelimitedFrom
public static Storage.ReadSession parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Throws:
IOException
-
parseFrom
public static Storage.ReadSession parseFrom(com.google.protobuf.CodedInputStream input) throws IOException
- Throws:
IOException
-
parseFrom
public static Storage.ReadSession parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Throws:
IOException
-
newBuilderForType
public Storage.ReadSession.Builder newBuilderForType()
- Specified by:
newBuilderForType
in interfacecom.google.protobuf.Message
- Specified by:
newBuilderForType
in interfacecom.google.protobuf.MessageLite
-
newBuilder
public static Storage.ReadSession.Builder newBuilder()
-
newBuilder
public static Storage.ReadSession.Builder newBuilder(Storage.ReadSession prototype)
-
toBuilder
public Storage.ReadSession.Builder toBuilder()
- Specified by:
toBuilder
in interfacecom.google.protobuf.Message
- Specified by:
toBuilder
in interfacecom.google.protobuf.MessageLite
-
newBuilderForType
protected Storage.ReadSession.Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
- Specified by:
newBuilderForType
in classcom.google.protobuf.GeneratedMessageV3
-
getDefaultInstance
public static Storage.ReadSession getDefaultInstance()
-
parser
public static com.google.protobuf.Parser<Storage.ReadSession> parser()
-
getParserForType
public com.google.protobuf.Parser<Storage.ReadSession> getParserForType()
- Specified by:
getParserForType
in interfacecom.google.protobuf.Message
- Specified by:
getParserForType
in interfacecom.google.protobuf.MessageLite
- Overrides:
getParserForType
in classcom.google.protobuf.GeneratedMessageV3
-
getDefaultInstanceForType
public Storage.ReadSession getDefaultInstanceForType()
- Specified by:
getDefaultInstanceForType
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Specified by:
getDefaultInstanceForType
in interfacecom.google.protobuf.MessageOrBuilder
-
-