Skip to content

Commit e35cc14

Browse files
authored
Update Beam model protos with element metadata (#34971)
As part of https://s.apache.org/beam-element-extended-metadata we want to add ElementMetadata that will hold in the future additional metadata fields e.g. drainMode, element kind or tracing metadata.
1 parent 5dab4a5 commit e35cc14

File tree

2 files changed

+10
-0
lines changed

2 files changed

+10
-0
lines changed

model/fn-execution/src/main/proto/org/apache/beam/model/fn_execution/v1/beam_fn_api.proto

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -740,6 +740,12 @@ message Elements {
740740
bool is_last = 4;
741741
}
742742

743+
// Element metadata passed as part of WindowedValue to make WindowedValue
744+
// extensible and backward compatible
745+
message ElementMetadata {
746+
// empty message - add drain, kind, tracing metadata in the future
747+
}
748+
743749
// Represent the encoded user timer for a given instruction, transform and
744750
// timer id.
745751
message Timers {

model/pipeline/src/main/proto/org/apache/beam/model/pipeline/v1/beam_runner_api.proto

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1677,6 +1677,10 @@ message StandardProtocols {
16771677
// Indicates whether the SDK supports ordered list state.
16781678
ORDERED_LIST_STATE = 10
16791679
[(beam_urn) = "beam:protocol:ordered_list_state:v1"];
1680+
1681+
// Indicates support for reading, writing and propagating Element's metadata
1682+
ELEMENT_METADATA = 11
1683+
[(beam_urn) = "beam:protocol:element_metadata:v1"];
16801684
}
16811685
}
16821686

0 commit comments

Comments
 (0)