GetStreamingJob

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<string, string> 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 {

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 {}