Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
45 changes: 45 additions & 0 deletions protos/plugin/v3/plugin.proto
Original file line number Diff line number Diff line change
Expand Up @@ -70,6 +70,12 @@ message Sync {
// marshalled arrow.Schema
bytes table = 1;
}
message MessageDeleteRecord {
string table_name = 1;
repeated PredicatesGroup where_clause = 2;
repeated TableRelation table_relations = 3;
}

message BackendOptions {
// table name to use for state backend
string table_name = 1;
Expand All @@ -87,6 +93,7 @@ message Sync {
oneof message {
Sync.MessageMigrateTable migrate_table = 1;
Sync.MessageInsert insert = 2;
Sync.MessageDeleteRecord delete_record = 3;
}
}
}
Expand All @@ -102,6 +109,38 @@ message Read {
}
}

message TableRelation {
string table_name = 1;
string parent_table = 2;
}



message Predicate {
enum Operator {
EQ = 0;
// LT = 1;
// LTE = 2;
// GT = 3;
// GTE = 4;
}

Operator operator = 1;
string column = 2;
// marshalled arrow.Record
bytes record = 3;
}

message PredicatesGroup {
enum GroupingType {
AND = 0;
OR = 1;
}
GroupingType grouping_type = 1;
repeated Predicate predicates = 2;

}

message Write {
message MessageMigrateTable {
// marshalled arrow.Schema
Expand All @@ -119,11 +158,17 @@ message Write {
google.protobuf.Timestamp sync_time = 3;
string table_name = 4;
}
message MessageDeleteRecord {
string table_name = 1;
repeated PredicatesGroup where_clause = 2;
repeated TableRelation table_relations = 3;
}
message Request {
oneof message {
Write.MessageMigrateTable migrate_table = 1;
Write.MessageInsert insert = 2;
Write.MessageDeleteStale delete = 3;
Write.MessageDeleteRecord delete_record = 4;
}
}
message Response {}
Expand Down
Loading