Modules§
- actor_
count_ per_ parallelism - Nested message and enum types in
ActorCountPerParallelism. - add_
event_ log_ request - Nested message and enum types in
AddEventLogRequest. - alter_
connector_ props_ request - Nested message and enum types in
AlterConnectorPropsRequest. - cancel_
creating_ jobs_ request - Nested message and enum types in
CancelCreatingJobsRequest. - cluster_
limit - Nested message and enum types in
ClusterLimit. - cluster_
limit_ service_ client - Generated client implementations.
- cluster_
limit_ service_ server - Generated server implementations.
- cluster_
service_ client - Generated client implementations.
- cluster_
service_ server - Generated server implementations.
- event_
log - Nested message and enum types in
EventLog. - event_
log_ service_ client - Generated client implementations.
- event_
log_ service_ server - Generated server implementations.
- get_
serverless_ streaming_ jobs_ status_ response - Nested message and enum types in
GetServerlessStreamingJobsStatusResponse. - heartbeat_
service_ client - Generated client implementations.
- heartbeat_
service_ server - Generated server implementations.
- hosted_
iceberg_ catalog_ service_ client - Generated client implementations.
- hosted_
iceberg_ catalog_ service_ server - Generated server implementations.
- list_
actor_ splits_ response - Nested message and enum types in
ListActorSplitsResponse. - list_
actor_ states_ response - Nested message and enum types in
ListActorStatesResponse. - list_
iceberg_ tables_ response - Nested message and enum types in
ListIcebergTablesResponse. - list_
object_ dependencies_ response - Nested message and enum types in
ListObjectDependenciesResponse. - list_
rate_ limits_ response - Nested message and enum types in
ListRateLimitsResponse. - list_
streaming_ job_ states_ response - Nested message and enum types in
ListStreamingJobStatesResponse. - list_
table_ fragments_ response - Nested message and enum types in
ListTableFragmentsResponse. - meta_
member_ service_ client - Generated client implementations.
- meta_
member_ service_ server - Generated server implementations.
- meta_
snapshot - Nested message and enum types in
MetaSnapshot. - notification_
service_ client - Generated client implementations.
- notification_
service_ server - Generated server implementations.
- object
- Nested message and enum types in
Object. - scale_
service_ client - Generated client implementations.
- scale_
service_ server - Generated server implementations.
- serving_
service_ client - Generated client implementations.
- serving_
service_ server - Generated server implementations.
- session_
param_ service_ client - Generated client implementations.
- session_
param_ service_ server - Generated server implementations.
- stream_
manager_ service_ client - Generated client implementations.
- stream_
manager_ service_ server - Generated server implementations.
- subscribe_
response - Nested message and enum types in
SubscribeResponse. - system_
params_ service_ client - Generated client implementations.
- system_
params_ service_ server - Generated server implementations.
- table_
fragments - Nested message and enum types in
TableFragments. - table_
parallelism - Nested message and enum types in
TableParallelism. - telemetry_
info_ service_ client - Generated client implementations.
- telemetry_
info_ service_ server - Generated server implementations.
- update_
worker_ node_ schedulability_ request - Nested message and enum types in
UpdateWorkerNodeSchedulabilityRequest.
Structs§
- Activate
Worker Node Request - Activate
Worker Node Response - Actor
Count PerParallelism - Actor
Ids - Actor
Location - TODO: remove this when dashboard refactored.
- AddEvent
LogRequest - AddEvent
LogResponse - AddWorker
Node Request - Below for cluster service.
- AddWorker
Node Response - Alter
Connector Props Request - Alter
Connector Props Response - Apply
Throttle Request - Apply
Throttle Response - Cancel
Creating Jobs Request - Cancel
Creating Jobs Response - Cluster
Limit - Delete
Worker Node Request - Delete
Worker Node Response - Event
Log - Flush
Request - Flush
Response - Fragment
Distribution - Fragment
IdTo Actor IdMap - Fragment
ToRelation Map - Fragment
Worker Slot Mapping - / Worker slot mapping with fragment id, used for notification.
- Fragment
Worker Slot Mappings - GetCluster
Info Request - GetCluster
Info Response - GetCluster
Limits Request - GetCluster
Limits Response - GetCluster
Recovery Status Request - GetCluster
Recovery Status Response - GetFragment
ById Request - GetFragment
ById Response - GetMeta
Store Info Request - GetMeta
Store Info Response - GetServerless
Streaming Jobs Status Request - GetServerless
Streaming Jobs Status Response - Descriptions of MVs and sinks
- GetServing
Vnode Mappings Request - GetServing
Vnode Mappings Response - GetSession
Params Request - GetSession
Params Response - GetSystem
Params Request - GetSystem
Params Response - GetTelemetry
Info Request - Heartbeat
Request - Heartbeat
Response - List
Actor Splits Request - List
Actor Splits Response - List
Actor States Request - List
Actor States Response - List
AllNodes Request - List
AllNodes Response - List
Event LogRequest - List
Event LogResponse - List
Fragment Distribution Request - List
Fragment Distribution Response - List
Iceberg Tables Request - List
Iceberg Tables Response - List
Object Dependencies Request - List
Object Dependencies Response - List
Rate Limits Request - List
Rate Limits Response - List
Streaming JobStates Request - List
Streaming JobStates Response - List
Table Fragments Request - List
Table Fragments Response - Members
Request - Members
Response - Meta
Member - Meta
Snapshot - Migration
Plan - Object
- Object
Group - Pause
Request - Pause
Response - Recover
Request - Recover
Response - Recovery
- Relation
IdInfos - / Provides all the ids: relation_id, fragment_id, actor_id / in an hierarchical format. / relation_id -> [fragment_id] / fragment_id -> [actor_id]
- Reschedule
Request - Reschedule
Response - Resume
Request - Resume
Response - SetSession
Param Request - SetSession
Param Response - SetSystem
Param Request - SetSystem
Param Response - Subscribe
Request - Below for notification service.
- Subscribe
Response - System
Params - The schema for persisted system parameters. Note on backward compatibility:
- Table
Fragments - Fragments of a Streaming Job.
It’s for all kinds of streaming jobs, and ideally should be called
StreamingJobFragments. It’s not the same as a storage table correlated with aTableCatalog. - Table
Parallelism - Telemetry
Info Response - Update
Streaming JobNode Labels Request - Changes a streaming job in place by overwriting its node_label. This may cause the re-scheduling of the streaming job actors.
- Update
Streaming JobNode Labels Response - We do not need to add an explicit status field here, we can just use the RPC status
- Update
Worker Node Schedulability Request - Mark CN as schedulable or as unschedulable
- Update
Worker Node Schedulability Response - Worker
Reschedule - For each fragment that needs to be rescheduled, there will be a WorkerReschedule, indicating on which workers the actors of this fragment need to be changed and by how many.
Enums§
Type Aliases§
- PbActivate
Worker Node Request - PbActivate
Worker Node Response - PbActor
Count PerParallelism - PbActor
Ids - PbActor
Location - PbAdd
Event LogRequest - PbAdd
Event LogResponse - PbAdd
Worker Node Request - PbAdd
Worker Node Response - PbAlter
Connector Props Request - PbAlter
Connector Props Response - PbApply
Throttle Request - PbApply
Throttle Response - PbCancel
Creating Jobs Request - PbCancel
Creating Jobs Response - PbCluster
Limit - PbDelete
Worker Node Request - PbDelete
Worker Node Response - PbEvent
Log - PbFlush
Request - PbFlush
Response - PbFragment
Distribution - PbFragment
IdTo Actor IdMap - PbFragment
ToRelation Map - PbFragment
Worker Slot Mapping - PbFragment
Worker Slot Mappings - PbGet
Cluster Info Request - PbGet
Cluster Info Response - PbGet
Cluster Limits Request - PbGet
Cluster Limits Response - PbGet
Cluster Recovery Status Request - PbGet
Cluster Recovery Status Response - PbGet
Fragment ById Request - PbGet
Fragment ById Response - PbGet
Meta Store Info Request - PbGet
Meta Store Info Response - PbGet
Serverless Streaming Jobs Status Request - PbGet
Serverless Streaming Jobs Status Response - PbGet
Serving Vnode Mappings Request - PbGet
Serving Vnode Mappings Response - PbGet
Session Params Request - PbGet
Session Params Response - PbGet
System Params Request - PbGet
System Params Response - PbGet
Telemetry Info Request - PbHeartbeat
Request - PbHeartbeat
Response - PbList
Actor Splits Request - PbList
Actor Splits Response - PbList
Actor States Request - PbList
Actor States Response - PbList
AllNodes Request - PbList
AllNodes Response - PbList
Event LogRequest - PbList
Event LogResponse - PbList
Fragment Distribution Request - PbList
Fragment Distribution Response - PbList
Iceberg Tables Request - PbList
Iceberg Tables Response - PbList
Object Dependencies Request - PbList
Object Dependencies Response - PbList
Rate Limits Request - PbList
Rate Limits Response - PbList
Streaming JobStates Request - PbList
Streaming JobStates Response - PbList
Table Fragments Request - PbList
Table Fragments Response - PbMembers
Request - PbMembers
Response - PbMeta
Member - PbMeta
Snapshot - PbMigration
Plan - PbObject
- PbObject
Group - PbPause
Request - PbPause
Response - PbRecover
Request - PbRecover
Response - PbRecovery
- PbRecovery
Status - PbRelation
IdInfos - PbReschedule
Request - PbReschedule
Response - PbResume
Request - PbResume
Response - PbSet
Session Param Request - PbSet
Session Param Response - PbSet
System Param Request - PbSet
System Param Response - PbSubscribe
Request - PbSubscribe
Response - PbSubscribe
Type - PbSystem
Params - PbTable
Fragments - PbTable
Parallelism - PbTelemetry
Info Response - PbThrottle
Target - PbUpdate
Streaming JobNode Labels Request - PbUpdate
Streaming JobNode Labels Response - PbUpdate
Worker Node Schedulability Request - PbUpdate
Worker Node Schedulability Response - PbWorker
Reschedule