diff --git a/proto/catalog.proto b/proto/catalog.proto index 9f70353725b31..391d252885bfa 100644 --- a/proto/catalog.proto +++ b/proto/catalog.proto @@ -420,6 +420,10 @@ message Table { // empty/null node_labels map. // A node with an empty/null node_labels map can only host streaming jobs with an empty node_labels map. optional map node_labels = 101; + + // If this is a materialized view: True if backfill is done, else false. + // If this is a regular table: Always true. + bool backfill_done = 102; } enum HandleConflictBehavior { diff --git a/proto/meta.proto b/proto/meta.proto index 89f066da15547..0eb4ec6a6925b 100644 --- a/proto/meta.proto +++ b/proto/meta.proto @@ -485,20 +485,6 @@ service NotificationService { rpc Subscribe(SubscribeRequest) returns (stream SubscribeResponse); } -message BackfillResponse { - // holds all materialized views which have completed their backfill operations - // contains IDs from catalog.Table.id - repeated uint32 materializedViewsBackfillCompleted = 1; -} - -message BackfillRequest { - string requestId = 1; // UUID so meta can drop duplicate requests -} - -service BackfillService { - rpc GetBackfill(BackfillRequest) returns (BackfillResponse); -} - message GetClusterInfoRequest {} message GetClusterInfoResponse { @@ -560,10 +546,10 @@ message UpdateStreamingJobRequest { // We do not need to add an explicit status field here, we can just use the RPC status message UpdateStreamingJobResponse {} -message ListStreamingJobsRequest {} +message GetStreamingJobsRequest {} // returns descriptions of MVs and sinks -message ListStreamingJobResponse { +message GetStreamingJobResponse { repeated catalog.Table materialized_views = 1; repeated catalog.Sink sinks = 2; } @@ -572,7 +558,7 @@ service ScaleService { rpc GetClusterInfo(GetClusterInfoRequest) returns (GetClusterInfoResponse); rpc Reschedule(RescheduleRequest) returns (RescheduleResponse); rpc UpdateStreamingJob(UpdateStreamingJobRequest) returns (UpdateStreamingJobResponse); - rpc ListStreamingJobs(ListStreamingJobsRequest) returns (ListStreamingJobResponse); + rpc GetStreamingJobs(GetStreamingJobsRequest) returns (GetStreamingJobResponse); } message MembersRequest {}