Skip to content

Commit b62bad2

Browse files
committed
renaming thrift names
1 parent ce336f1 commit b62bad2

File tree

2 files changed

+4
-2
lines changed

2 files changed

+4
-2
lines changed

api/thrift/api.thrift

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -258,7 +258,9 @@ struct MetaData {
258258
// column -> tag_key -> tag_value
259259
7: optional map<string, map<string, string>> columnTags
260260

261-
8: optional list<lineage.StageColumnLineage> stageColumnLineages
261+
// A stage is a "sub-transformation" of a given node. For example a `GroupBy` can consist of selects (with SQL expressions), filters (in the form of where clauses), followed by aggregations defined in the Zipline DSL.
262+
// Each of this is a `stage` with its own column level lineage.
263+
8: optional list<lineage.StageWithLineage> stagesWithLineage
262264

263265
// marking this as true means that the conf can be served online
264266
// once marked online, a conf cannot be changed - compiling the conf won't be allowed

api/thrift/lineage.thrift

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@ struct ColumnLineage {
4848
4: optional ColumnLineageType lineageType // not present means direct
4949
}
5050

51-
struct StageColumnLineage {
51+
struct StageWithLineage {
5252
1: optional ColumnLineageStage stage
5353
2: optional list<ColumnLineage> lineage
5454
}

0 commit comments

Comments
 (0)