Modules§
- batch_
exchange_ service_ client - Generated client implementations.
- batch_
exchange_ service_ server - Generated server implementations.
- fast_
insert_ response - Nested message and enum types in
FastInsertResponse. - get_
stream_ request - Nested message and enum types in
GetStreamRequest. - ingest_
dml_ request - Nested message and enum types in
IngestDmlRequest. - ingest_
dml_ response - Nested message and enum types in
IngestDmlResponse. - permits
- Nested message and enum types in
Permits. - stream_
exchange_ service_ client - Generated client implementations.
- stream_
exchange_ service_ server - Generated server implementations.
- task_
info_ response - Nested message and enum types in
TaskInfoResponse. - task_
service_ client - Generated client implementations.
- task_
service_ server - Generated server implementations.
Structs§
- Cancel
Task Request - Cancel
Task Response - Create
Task Request - Execute
Request - Fast
Insert Request - Fast
Insert Response - GetData
Request - GetData
Response - GetStream
Request - GetStream
Response - GetTask
Info Request - Ingest
DmlAck Response - Ingest
DmlInit Request - Ingest
DmlInit Response - Ingest
DmlPayload Request - Ingest
DmlRequest - Ingest
DmlResponse - Permits
- The structure for permit-based back-pressure.
- TaskId
- Task is a running instance of Stage.
- Task
Info Response
Type Aliases§
- PbCancel
Task Request - PbCancel
Task Response - PbCreate
Task Request - PbExecute
Request - PbFast
Insert Request - PbFast
Insert Response - PbGet
Data Request - PbGet
Data Response - PbGet
Stream Request - PbGet
Stream Response - PbGet
Task Info Request - PbIngest
DmlAck Response - PbIngest
DmlInit Request - PbIngest
DmlInit Response - PbIngest
DmlPayload Request - PbIngest
DmlRequest - PbIngest
DmlResponse - PbPermits
- PbTask
Id - PbTask
Info Response