Send feedback
Class StreamWriterV2.Builder (3.9.1)
Stay organized with collections
Save and categorize content based on your preferences.
Version 3.9.1 keyboard_arrow_down
public static final class StreamWriterV2.Builder
Methods
build()
public StreamWriterV2 build()
Builds the StreamWriterV2
.
setChannelProvider(TransportChannelProvider channelProvider)
public StreamWriterV2.Builder setChannelProvider(TransportChannelProvider channelProvider)
ChannelProvider
to use to create Channels, which must point at Cloud BigQuery Storage
API endpoint.
For performance, this client benefits from having multiple underlying connections. See
com.google.api.gax.grpc.InstantiatingGrpcChannelProvider.Builder#setPoolSize(int) .
setCredentialsProvider(CredentialsProvider credentialsProvider)
public StreamWriterV2.Builder setCredentialsProvider(CredentialsProvider credentialsProvider)
CredentialsProvider
to use to create Credentials to authenticate calls.
setEndpoint(String endpoint)
public StreamWriterV2.Builder setEndpoint(String endpoint)
Gives the ability to override the gRPC endpoint.
Parameter
Name
Description
endpoint
String
setMaxInflightBytes(long value)
public StreamWriterV2.Builder setMaxInflightBytes(long value)
Parameter
Name
Description
value
long
setMaxInflightRequests(long value)
public StreamWriterV2.Builder setMaxInflightRequests(long value)
Parameter
Name
Description
value
long
setTraceId(String traceId)
public StreamWriterV2.Builder setTraceId(String traceId)
Sets traceId for debuging purpose. TraceId must follow the format of
CustomerDomain:DebugString, e.g. DATAFLOW:job_id_x.
Parameter
Name
Description
traceId
String
setWriterSchema(ProtoSchema writerSchema)
public StreamWriterV2.Builder setWriterSchema(ProtoSchema writerSchema)
Sets the proto schema of the rows.
Send feedback
Except as otherwise noted, the content of this page is licensed under the Creative Commons Attribution 4.0 License , and code samples are licensed under the Apache 2.0 License . For details, see the Google Developers Site Policies . Java is a registered trademark of Oracle and/or its affiliates.
Last updated 2024-10-04 UTC.
[{
"type": "thumb-down",
"id": "hardToUnderstand",
"label":"Hard to understand"
},{
"type": "thumb-down",
"id": "incorrectInformationOrSampleCode",
"label":"Incorrect information or sample code"
},{
"type": "thumb-down",
"id": "missingTheInformationSamplesINeed",
"label":"Missing the information/samples I need"
},{
"type": "thumb-down",
"id": "otherDown",
"label":"Other"
}]
[{
"type": "thumb-up",
"id": "easyToUnderstand",
"label":"Easy to understand"
},{
"type": "thumb-up",
"id": "solvedMyProblem",
"label":"Solved my problem"
},{
"type": "thumb-up",
"id": "otherUp",
"label":"Other"
}]
Need to tell us more?
{"lastModified": "Last updated 2024-10-04 UTC."}
[[["Easy to understand","easyToUnderstand","thumb-up"],["Solved my problem","solvedMyProblem","thumb-up"],["Other","otherUp","thumb-up"]],[["Hard to understand","hardToUnderstand","thumb-down"],["Incorrect information or sample code","incorrectInformationOrSampleCode","thumb-down"],["Missing the information/samples I need","missingTheInformationSamplesINeed","thumb-down"],["Other","otherDown","thumb-down"]],["Last updated 2024-10-04 UTC."]]