Module meta

Modules

actor_count_per_parallelism

Nested message and enum types in ActorCountPerParallelism.

add_event_log_request

Nested message and enum types in AddEventLogRequest.

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_fragment_distribution_response

Nested message and enum types in ListFragmentDistributionResponse.

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

ActivateWorkerNodeRequest

ActivateWorkerNodeResponse

ActorCountPerParallelism

ActorIds

ActorLocation

TODO: remove this when dashboard refactored.

AddEventLogRequest

AddEventLogResponse

AddWorkerNodeRequest

Below for cluster service.

AddWorkerNodeResponse

ApplyThrottleRequest

ApplyThrottleResponse

CancelCreatingJobsRequest

CancelCreatingJobsResponse

ClusterLimit

DeleteWorkerNodeRequest

DeleteWorkerNodeResponse

EventLog

FlushRequest

FlushResponse

FragmentIdToActorIdMap

FragmentToRelationMap

FragmentWorkerSlotMapping

/ Worker slot mapping with fragment id, used for notification.

FragmentWorkerSlotMappings

GetClusterInfoRequest

GetClusterInfoResponse

GetClusterLimitsRequest

GetClusterLimitsResponse

GetClusterRecoveryStatusRequest

GetClusterRecoveryStatusResponse

GetMetaStoreInfoRequest

GetMetaStoreInfoResponse

GetServerlessStreamingJobsStatusRequest

GetServerlessStreamingJobsStatusResponse

Descriptions of MVs and sinks

GetServingVnodeMappingsRequest

GetServingVnodeMappingsResponse

GetSessionParamsRequest

GetSessionParamsResponse

GetSystemParamsRequest

GetSystemParamsResponse

GetTelemetryInfoRequest

HeartbeatRequest

HeartbeatResponse

ListActorSplitsRequest

ListActorSplitsResponse

ListActorStatesRequest

ListActorStatesResponse

ListAllNodesRequest

ListAllNodesResponse

ListEventLogRequest

ListEventLogResponse

ListFragmentDistributionRequest

ListFragmentDistributionResponse

ListIcebergTablesRequest

ListIcebergTablesResponse

ListObjectDependenciesRequest

ListObjectDependenciesResponse

ListRateLimitsRequest

ListRateLimitsResponse

ListStreamingJobStatesRequest

ListStreamingJobStatesResponse

ListTableFragmentsRequest

ListTableFragmentsResponse

MembersRequest

MembersResponse

MetaMember

MetaSnapshot

MigrationPlan

Object

ObjectGroup

PauseRequest

PauseResponse

RecoverRequest

RecoverResponse

Recovery

RelationIdInfos

/ Provides all the ids: relation_id, fragment_id, actor_id / in an hierarchical format. / relation_id -> [fragment_id] / fragment_id -> [actor_id]

RescheduleRequest

RescheduleResponse

ResumeRequest

ResumeResponse

SetSessionParamRequest

SetSessionParamResponse

SetSystemParamRequest

SetSystemParamResponse

SubscribeRequest

Below for notification service.

SubscribeResponse

SystemParams

The schema for persisted system parameters. Note on backward compatibility:

TableFragments

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 a TableCatalog.

TableParallelism

TelemetryInfoResponse

UpdateStreamingJobNodeLabelsRequest

Changes a streaming job in place by overwriting its node_label. This may cause the re-scheduling of the streaming job actors.

UpdateStreamingJobNodeLabelsResponse

We do not need to add an explicit status field here, we can just use the RPC status

UpdateWorkerNodeSchedulabilityRequest

Mark CN as schedulable or as unschedulable

UpdateWorkerNodeSchedulabilityResponse

WorkerReschedule

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

RecoveryStatus

SubscribeType

ThrottleTarget

Type Aliases

PbActivateWorkerNodeRequest

Alias for ActivateWorkerNodeRequest.

PbActivateWorkerNodeResponse

Alias for ActivateWorkerNodeResponse.

PbActorCountPerParallelism

Alias for ActorCountPerParallelism.

PbActorIds

Alias for ActorIds.

PbActorLocation

Alias for ActorLocation.

PbAddEventLogRequest

Alias for AddEventLogRequest.

PbAddEventLogResponse

Alias for AddEventLogResponse.

PbAddWorkerNodeRequest

Alias for AddWorkerNodeRequest.

PbAddWorkerNodeResponse

Alias for AddWorkerNodeResponse.

PbApplyThrottleRequest

Alias for ApplyThrottleRequest.

PbApplyThrottleResponse

Alias for ApplyThrottleResponse.

PbCancelCreatingJobsRequest

Alias for CancelCreatingJobsRequest.

PbCancelCreatingJobsResponse

Alias for CancelCreatingJobsResponse.

PbClusterLimit

Alias for ClusterLimit.

PbDeleteWorkerNodeRequest

Alias for DeleteWorkerNodeRequest.

PbDeleteWorkerNodeResponse

Alias for DeleteWorkerNodeResponse.

PbEventLog

Alias for EventLog.

PbFlushRequest

Alias for FlushRequest.

PbFlushResponse

Alias for FlushResponse.

PbFragmentIdToActorIdMap

Alias for FragmentIdToActorIdMap.

PbFragmentToRelationMap

Alias for FragmentToRelationMap.

PbFragmentWorkerSlotMapping

Alias for FragmentWorkerSlotMapping.

PbFragmentWorkerSlotMappings

Alias for FragmentWorkerSlotMappings.

PbGetClusterInfoRequest

Alias for GetClusterInfoRequest.

PbGetClusterInfoResponse

Alias for GetClusterInfoResponse.

PbGetClusterLimitsRequest

Alias for GetClusterLimitsRequest.

PbGetClusterLimitsResponse

Alias for GetClusterLimitsResponse.

PbGetClusterRecoveryStatusRequest

Alias for GetClusterRecoveryStatusRequest.

PbGetClusterRecoveryStatusResponse

Alias for GetClusterRecoveryStatusResponse.

PbGetMetaStoreInfoRequest

Alias for GetMetaStoreInfoRequest.

PbGetMetaStoreInfoResponse

Alias for GetMetaStoreInfoResponse.

PbGetServerlessStreamingJobsStatusRequest

Alias for GetServerlessStreamingJobsStatusRequest.

PbGetServerlessStreamingJobsStatusResponse

Alias for GetServerlessStreamingJobsStatusResponse.

PbGetServingVnodeMappingsRequest

Alias for GetServingVnodeMappingsRequest.

PbGetServingVnodeMappingsResponse

Alias for GetServingVnodeMappingsResponse.

PbGetSessionParamsRequest

Alias for GetSessionParamsRequest.

PbGetSessionParamsResponse

Alias for GetSessionParamsResponse.

PbGetSystemParamsRequest

Alias for GetSystemParamsRequest.

PbGetSystemParamsResponse

Alias for GetSystemParamsResponse.

PbGetTelemetryInfoRequest

Alias for GetTelemetryInfoRequest.

PbHeartbeatRequest

Alias for HeartbeatRequest.

PbHeartbeatResponse

Alias for HeartbeatResponse.

PbListActorSplitsRequest

Alias for ListActorSplitsRequest.

PbListActorSplitsResponse

Alias for ListActorSplitsResponse.

PbListActorStatesRequest

Alias for ListActorStatesRequest.

PbListActorStatesResponse

Alias for ListActorStatesResponse.

PbListAllNodesRequest

Alias for ListAllNodesRequest.

PbListAllNodesResponse

Alias for ListAllNodesResponse.

PbListEventLogRequest

Alias for ListEventLogRequest.

PbListEventLogResponse

Alias for ListEventLogResponse.

PbListFragmentDistributionRequest

Alias for ListFragmentDistributionRequest.

PbListFragmentDistributionResponse

Alias for ListFragmentDistributionResponse.

PbListIcebergTablesRequest

Alias for ListIcebergTablesRequest.

PbListIcebergTablesResponse

Alias for ListIcebergTablesResponse.

PbListObjectDependenciesRequest

Alias for ListObjectDependenciesRequest.

PbListObjectDependenciesResponse

Alias for ListObjectDependenciesResponse.

PbListRateLimitsRequest

Alias for ListRateLimitsRequest.

PbListRateLimitsResponse

Alias for ListRateLimitsResponse.

PbListStreamingJobStatesRequest

Alias for ListStreamingJobStatesRequest.

PbListStreamingJobStatesResponse

Alias for ListStreamingJobStatesResponse.

PbListTableFragmentsRequest

Alias for ListTableFragmentsRequest.

PbListTableFragmentsResponse

Alias for ListTableFragmentsResponse.

PbMembersRequest

Alias for MembersRequest.

PbMembersResponse

Alias for MembersResponse.

PbMetaMember

Alias for MetaMember.

PbMetaSnapshot

Alias for MetaSnapshot.

PbMigrationPlan

Alias for MigrationPlan.

PbObject

Alias for Object.

PbObjectGroup

Alias for ObjectGroup.

PbPauseRequest

Alias for PauseRequest.

PbPauseResponse

Alias for PauseResponse.

PbRecoverRequest

Alias for RecoverRequest.

PbRecoverResponse

Alias for RecoverResponse.

PbRecovery

Alias for Recovery.

PbRecoveryStatus

Alias for RecoveryStatus.

PbRelationIdInfos

Alias for RelationIdInfos.

PbRescheduleRequest

Alias for RescheduleRequest.

PbRescheduleResponse

Alias for RescheduleResponse.

PbResumeRequest

Alias for ResumeRequest.

PbResumeResponse

Alias for ResumeResponse.

PbSetSessionParamRequest

Alias for SetSessionParamRequest.

PbSetSessionParamResponse

Alias for SetSessionParamResponse.

PbSetSystemParamRequest

Alias for SetSystemParamRequest.

PbSetSystemParamResponse

Alias for SetSystemParamResponse.

PbSubscribeRequest

Alias for SubscribeRequest.

PbSubscribeResponse

Alias for SubscribeResponse.

PbSubscribeType

Alias for SubscribeType.

PbSystemParams

Alias for SystemParams.

PbTableFragments

Alias for TableFragments.

PbTableParallelism

Alias for TableParallelism.

PbTelemetryInfoResponse

Alias for TelemetryInfoResponse.

PbThrottleTarget

Alias for ThrottleTarget.

PbUpdateStreamingJobNodeLabelsRequest

Alias for UpdateStreamingJobNodeLabelsRequest.

PbUpdateStreamingJobNodeLabelsResponse

Alias for UpdateStreamingJobNodeLabelsResponse.

PbUpdateWorkerNodeSchedulabilityRequest

Alias for UpdateWorkerNodeSchedulabilityRequest.

PbUpdateWorkerNodeSchedulabilityResponse

Alias for UpdateWorkerNodeSchedulabilityResponse.

PbWorkerReschedule

Alias for WorkerReschedule.