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 classStorage.ReadSession.BuilderInformation returned from a `CreateReadSession` request.static classStorage.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 intARROW_SCHEMA_FIELD_NUMBERstatic intAVRO_SCHEMA_FIELD_NUMBERstatic intEXPIRE_TIME_FIELD_NUMBERstatic intNAME_FIELD_NUMBERstatic intSHARDING_STRATEGY_FIELD_NUMBERstatic intSTREAMS_FIELD_NUMBERstatic intTABLE_MODIFIERS_FIELD_NUMBERstatic intTABLE_REFERENCE_FIELD_NUMBER
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanequals(Object obj)ArrowProto.ArrowSchemagetArrowSchema()Arrow schema.ArrowProto.ArrowSchemaOrBuildergetArrowSchemaOrBuilder()Arrow schema.AvroProto.AvroSchemagetAvroSchema()Avro schema.AvroProto.AvroSchemaOrBuildergetAvroSchemaOrBuilder()Avro schema.static Storage.ReadSessiongetDefaultInstance()Storage.ReadSessiongetDefaultInstanceForType()static com.google.protobuf.Descriptors.DescriptorgetDescriptor()com.google.protobuf.TimestampgetExpireTime()Time at which the session becomes invalid.com.google.protobuf.TimestampOrBuildergetExpireTimeOrBuilder()Time at which the session becomes invalid.StringgetName()Unique identifier for the session, in the form `projects/{project_id}/locations/{location}/sessions/{session_id}`.com.google.protobuf.ByteStringgetNameBytes()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.SchemaCasegetSchemaCase()intgetSerializedSize()Storage.ShardingStrategygetShardingStrategy()The strategy to use for distributing data among the streams.intgetShardingStrategyValue()The strategy to use for distributing data among the streams.Storage.StreamgetStreams(int index)Streams associated with this session.intgetStreamsCount()Streams associated with this session.List<Storage.Stream>getStreamsList()Streams associated with this session.Storage.StreamOrBuildergetStreamsOrBuilder(int index)Streams associated with this session.List<? extends Storage.StreamOrBuilder>getStreamsOrBuilderList()Streams associated with this session.TableReferenceProto.TableModifiersgetTableModifiers()Any modifiers which are applied when reading from the specified table.TableReferenceProto.TableModifiersOrBuildergetTableModifiersOrBuilder()Any modifiers which are applied when reading from the specified table.TableReferenceProto.TableReferencegetTableReference()Table that this ReadSession is reading from.TableReferenceProto.TableReferenceOrBuildergetTableReferenceOrBuilder()Table that this ReadSession is reading from.booleanhasArrowSchema()Arrow schema.booleanhasAvroSchema()Avro schema.booleanhasExpireTime()Time at which the session becomes invalid.inthashCode()booleanhasTableModifiers()Any modifiers which are applied when reading from the specified table.booleanhasTableReference()Table that this ReadSession is reading from.protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTableinternalGetFieldAccessorTable()booleanisInitialized()static Storage.ReadSession.BuildernewBuilder()static Storage.ReadSession.BuildernewBuilder(Storage.ReadSession prototype)Storage.ReadSession.BuildernewBuilderForType()protected Storage.ReadSession.BuildernewBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)protected ObjectnewInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)static Storage.ReadSessionparseDelimitedFrom(InputStream input)static Storage.ReadSessionparseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static Storage.ReadSessionparseFrom(byte[] data)static Storage.ReadSessionparseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static Storage.ReadSessionparseFrom(com.google.protobuf.ByteString data)static Storage.ReadSessionparseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static Storage.ReadSessionparseFrom(com.google.protobuf.CodedInputStream input)static Storage.ReadSessionparseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static Storage.ReadSessionparseFrom(InputStream input)static Storage.ReadSessionparseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static Storage.ReadSessionparseFrom(ByteBuffer data)static Storage.ReadSessionparseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static com.google.protobuf.Parser<Storage.ReadSession>parser()Storage.ReadSession.BuildertoBuilder()voidwriteTo(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:
newInstancein classcom.google.protobuf.GeneratedMessageV3
-
getDescriptor
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
-
internalGetFieldAccessorTable
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
- Specified by:
internalGetFieldAccessorTablein classcom.google.protobuf.GeneratedMessageV3
-
getSchemaCase
public Storage.ReadSession.SchemaCase getSchemaCase()
- Specified by:
getSchemaCasein 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:
getNamein 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:
getNameBytesin 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:
hasExpireTimein 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:
getExpireTimein 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:
getExpireTimeOrBuilderin interfaceStorage.ReadSessionOrBuilder
-
hasAvroSchema
public boolean hasAvroSchema()
Avro schema.
.google.cloud.bigquery.storage.v1beta1.AvroSchema avro_schema = 5;- Specified by:
hasAvroSchemain 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:
getAvroSchemain interfaceStorage.ReadSessionOrBuilder- Returns:
- The avroSchema.
-
getAvroSchemaOrBuilder
public AvroProto.AvroSchemaOrBuilder getAvroSchemaOrBuilder()
Avro schema.
.google.cloud.bigquery.storage.v1beta1.AvroSchema avro_schema = 5;- Specified by:
getAvroSchemaOrBuilderin interfaceStorage.ReadSessionOrBuilder
-
hasArrowSchema
public boolean hasArrowSchema()
Arrow schema.
.google.cloud.bigquery.storage.v1beta1.ArrowSchema arrow_schema = 6;- Specified by:
hasArrowSchemain 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:
getArrowSchemain interfaceStorage.ReadSessionOrBuilder- Returns:
- The arrowSchema.
-
getArrowSchemaOrBuilder
public ArrowProto.ArrowSchemaOrBuilder getArrowSchemaOrBuilder()
Arrow schema.
.google.cloud.bigquery.storage.v1beta1.ArrowSchema arrow_schema = 6;- Specified by:
getArrowSchemaOrBuilderin interfaceStorage.ReadSessionOrBuilder
-
getStreamsList
public List<Storage.Stream> getStreamsList()
Streams associated with this session.
repeated .google.cloud.bigquery.storage.v1beta1.Stream streams = 4;- Specified by:
getStreamsListin 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:
getStreamsOrBuilderListin interfaceStorage.ReadSessionOrBuilder
-
getStreamsCount
public int getStreamsCount()
Streams associated with this session.
repeated .google.cloud.bigquery.storage.v1beta1.Stream streams = 4;- Specified by:
getStreamsCountin 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:
getStreamsin 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:
getStreamsOrBuilderin interfaceStorage.ReadSessionOrBuilder
-
hasTableReference
public boolean hasTableReference()
Table that this ReadSession is reading from.
.google.cloud.bigquery.storage.v1beta1.TableReference table_reference = 7;- Specified by:
hasTableReferencein 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:
getTableReferencein 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:
getTableReferenceOrBuilderin 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:
hasTableModifiersin 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:
getTableModifiersin 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:
getTableModifiersOrBuilderin 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:
getShardingStrategyValuein 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:
getShardingStrategyin interfaceStorage.ReadSessionOrBuilder- Returns:
- The shardingStrategy.
-
isInitialized
public final boolean isInitialized()
- Specified by:
isInitializedin interfacecom.google.protobuf.MessageLiteOrBuilder- Overrides:
isInitializedin classcom.google.protobuf.GeneratedMessageV3
-
writeTo
public void writeTo(com.google.protobuf.CodedOutputStream output) throws IOException- Specified by:
writeToin interfacecom.google.protobuf.MessageLite- Overrides:
writeToin classcom.google.protobuf.GeneratedMessageV3- Throws:
IOException
-
getSerializedSize
public int getSerializedSize()
- Specified by:
getSerializedSizein interfacecom.google.protobuf.MessageLite- Overrides:
getSerializedSizein classcom.google.protobuf.GeneratedMessageV3
-
equals
public boolean equals(Object obj)
- Specified by:
equalsin interfacecom.google.protobuf.Message- Overrides:
equalsin classcom.google.protobuf.AbstractMessage
-
hashCode
public int hashCode()
- Specified by:
hashCodein interfacecom.google.protobuf.Message- Overrides:
hashCodein 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:
newBuilderForTypein interfacecom.google.protobuf.Message- Specified by:
newBuilderForTypein 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:
toBuilderin interfacecom.google.protobuf.Message- Specified by:
toBuilderin interfacecom.google.protobuf.MessageLite
-
newBuilderForType
protected Storage.ReadSession.Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
- Specified by:
newBuilderForTypein 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:
getParserForTypein interfacecom.google.protobuf.Message- Specified by:
getParserForTypein interfacecom.google.protobuf.MessageLite- Overrides:
getParserForTypein classcom.google.protobuf.GeneratedMessageV3
-
getDefaultInstanceForType
public Storage.ReadSession getDefaultInstanceForType()
- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageLiteOrBuilder- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageOrBuilder
-
-