public final class CreateReadSessionRequest extends GeneratedMessageV3 implements CreateReadSessionRequestOrBuilder Request message for CreateReadSession.
Protobuf type google.cloud.bigquery.storage.v1.CreateReadSessionRequest
Inheritance
Object > AbstractMessageLite<MessageType,BuilderType> > AbstractMessage > GeneratedMessageV3 > CreateReadSessionRequestImplements
CreateReadSessionRequestOrBuilderStatic Fields
MAX_STREAM_COUNT_FIELD_NUMBER
public static final int MAX_STREAM_COUNT_FIELD_NUMBER| Type | Description |
int |
PARENT_FIELD_NUMBER
public static final int PARENT_FIELD_NUMBER| Type | Description |
int |
PREFERRED_MIN_STREAM_COUNT_FIELD_NUMBER
public static final int PREFERRED_MIN_STREAM_COUNT_FIELD_NUMBER| Type | Description |
int |
READ_SESSION_FIELD_NUMBER
public static final int READ_SESSION_FIELD_NUMBER| Type | Description |
int |
Static Methods
getDefaultInstance()
public static CreateReadSessionRequest getDefaultInstance()| Type | Description |
CreateReadSessionRequest |
getDescriptor()
public static final Descriptors.Descriptor getDescriptor()| Type | Description |
Descriptor |
newBuilder()
public static CreateReadSessionRequest.Builder newBuilder()| Type | Description |
CreateReadSessionRequest.Builder |
newBuilder(CreateReadSessionRequest prototype)
public static CreateReadSessionRequest.Builder newBuilder(CreateReadSessionRequest prototype)| Name | Description |
prototype | CreateReadSessionRequest |
| Type | Description |
CreateReadSessionRequest.Builder |
parseDelimitedFrom(InputStream input)
public static CreateReadSessionRequest parseDelimitedFrom(InputStream input)| Name | Description |
input | InputStream |
| Type | Description |
CreateReadSessionRequest |
| Type | Description |
IOException |
parseDelimitedFrom(InputStream input, ExtensionRegistryLite extensionRegistry)
public static CreateReadSessionRequest parseDelimitedFrom(InputStream input, ExtensionRegistryLite extensionRegistry)| Name | Description |
input | InputStream |
extensionRegistry | ExtensionRegistryLite |
| Type | Description |
CreateReadSessionRequest |
| Type | Description |
IOException |
parseFrom(byte[] data)
public static CreateReadSessionRequest parseFrom(byte[] data)| Name | Description |
data | byte[] |
| Type | Description |
CreateReadSessionRequest |
| Type | Description |
InvalidProtocolBufferException |
parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)
public static CreateReadSessionRequest parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)| Name | Description |
data | byte[] |
extensionRegistry | ExtensionRegistryLite |
| Type | Description |
CreateReadSessionRequest |
| Type | Description |
InvalidProtocolBufferException |
parseFrom(ByteString data)
public static CreateReadSessionRequest parseFrom(ByteString data)| Name | Description |
data | ByteString |
| Type | Description |
CreateReadSessionRequest |
| Type | Description |
InvalidProtocolBufferException |
parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)
public static CreateReadSessionRequest parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)| Name | Description |
data | ByteString |
extensionRegistry | ExtensionRegistryLite |
| Type | Description |
CreateReadSessionRequest |
| Type | Description |
InvalidProtocolBufferException |
parseFrom(CodedInputStream input)
public static CreateReadSessionRequest parseFrom(CodedInputStream input)| Name | Description |
input | CodedInputStream |
| Type | Description |
CreateReadSessionRequest |
| Type | Description |
IOException |
parseFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)
public static CreateReadSessionRequest parseFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)| Name | Description |
input | CodedInputStream |
extensionRegistry | ExtensionRegistryLite |
| Type | Description |
CreateReadSessionRequest |
| Type | Description |
IOException |
parseFrom(InputStream input)
public static CreateReadSessionRequest parseFrom(InputStream input)| Name | Description |
input | InputStream |
| Type | Description |
CreateReadSessionRequest |
| Type | Description |
IOException |
parseFrom(InputStream input, ExtensionRegistryLite extensionRegistry)
public static CreateReadSessionRequest parseFrom(InputStream input, ExtensionRegistryLite extensionRegistry)| Name | Description |
input | InputStream |
extensionRegistry | ExtensionRegistryLite |
| Type | Description |
CreateReadSessionRequest |
| Type | Description |
IOException |
parseFrom(ByteBuffer data)
public static CreateReadSessionRequest parseFrom(ByteBuffer data)| Name | Description |
data | ByteBuffer |
| Type | Description |
CreateReadSessionRequest |
| Type | Description |
InvalidProtocolBufferException |
parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)
public static CreateReadSessionRequest parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)| Name | Description |
data | ByteBuffer |
extensionRegistry | ExtensionRegistryLite |
| Type | Description |
CreateReadSessionRequest |
| Type | Description |
InvalidProtocolBufferException |
parser()
public static Parser<CreateReadSessionRequest> parser()| Type | Description |
Parser<CreateReadSessionRequest> |
Methods
equals(Object obj)
public boolean equals(Object obj)| Name | Description |
obj | Object |
| Type | Description |
boolean |
getDefaultInstanceForType()
public CreateReadSessionRequest getDefaultInstanceForType()| Type | Description |
CreateReadSessionRequest |
getMaxStreamCount()
public int getMaxStreamCount()Max initial number of streams. If unset or zero, the server will provide a value of streams so as to produce reasonable throughput. Must be non-negative. The number of streams may be lower than the requested number, depending on the amount parallelism that is reasonable for the table. There is a default system max limit of 1,000. This must be greater than or equal to preferred_min_stream_count. Typically, clients should either leave this unset to let the system to determine an upper bound OR set this a size for the maximum "units of work" it can gracefully handle.
int32 max_stream_count = 3;
| Type | Description |
int | The maxStreamCount. |
getParent()
public String getParent() Required. The request project that owns the session, in the form of
projects/{project_id}.
string parent = 1 [(.google.api.field_behavior) = REQUIRED, (.google.api.resource_reference) = { ... }
| Type | Description |
String | The parent. |
getParentBytes()
public ByteString getParentBytes() Required. The request project that owns the session, in the form of
projects/{project_id}.
string parent = 1 [(.google.api.field_behavior) = REQUIRED, (.google.api.resource_reference) = { ... }
| Type | Description |
ByteString | The bytes for parent. |
getParserForType()
public Parser<CreateReadSessionRequest> getParserForType()| Type | Description |
Parser<CreateReadSessionRequest> |
getPreferredMinStreamCount()
public int getPreferredMinStreamCount()The minimum preferred stream count. This parameter can be used to inform the service that there is a desired lower bound on the number of streams. This is typically a target parallelism of the client (e.g. a Spark cluster with N-workers would set this to a low multiple of N to ensure good cluster utilization). The system will make a best effort to provide at least this number of streams, but in some cases might provide less.
int32 preferred_min_stream_count = 4;
| Type | Description |
int | The preferredMinStreamCount. |
getReadSession()
public ReadSession getReadSession()Required. Session to be created.
.google.cloud.bigquery.storage.v1.ReadSession read_session = 2 [(.google.api.field_behavior) = REQUIRED];
| Type | Description |
ReadSession | The readSession. |
getReadSessionOrBuilder()
public ReadSessionOrBuilder getReadSessionOrBuilder()Required. Session to be created.
.google.cloud.bigquery.storage.v1.ReadSession read_session = 2 [(.google.api.field_behavior) = REQUIRED];
| Type | Description |
ReadSessionOrBuilder |
getSerializedSize()
public int getSerializedSize()| Type | Description |
int |
getUnknownFields()
public final UnknownFieldSet getUnknownFields()| Type | Description |
UnknownFieldSet |
hasReadSession()
public boolean hasReadSession()Required. Session to be created.
.google.cloud.bigquery.storage.v1.ReadSession read_session = 2 [(.google.api.field_behavior) = REQUIRED];
| Type | Description |
boolean | Whether the readSession field is set. |
hashCode()
public int hashCode()| Type | Description |
int |
internalGetFieldAccessorTable()
protected GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()| Type | Description |
FieldAccessorTable |
isInitialized()
public final boolean isInitialized()| Type | Description |
boolean |
newBuilderForType()
public CreateReadSessionRequest.Builder newBuilderForType()| Type | Description |
CreateReadSessionRequest.Builder |
newBuilderForType(GeneratedMessageV3.BuilderParent parent)
protected CreateReadSessionRequest.Builder newBuilderForType(GeneratedMessageV3.BuilderParent parent)| Name | Description |
parent | BuilderParent |
| Type | Description |
CreateReadSessionRequest.Builder |
newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)
protected Object newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)| Name | Description |
unused | UnusedPrivateParameter |
| Type | Description |
Object |
toBuilder()
public CreateReadSessionRequest.Builder toBuilder()| Type | Description |
CreateReadSessionRequest.Builder |
writeTo(CodedOutputStream output)
public void writeTo(CodedOutputStream output)| Name | Description |
output | CodedOutputStream |
| Type | Description |
IOException |