File tree Expand file tree Collapse file tree 2 files changed +24
-1
lines changed
com/linkedin/metadata/internal
pegasus/com/linkedin/metadata/events Expand file tree Collapse file tree 2 files changed +24
-1
lines changed Original file line number Diff line number Diff line change @@ -2,6 +2,7 @@ namespace com.linkedin.metadata.internal
2
2
3
3
import com.linkedin.metadata.events.IngestionMode
4
4
import com.linkedin.metadata.events.IngestionTrackingContext
5
+ import pegasus.com.linkedin.metadata.events.IngestionAspectETag
5
6
6
7
/**
7
8
* Record defining ingestion-related parameters that can be passed into DAO API calls.
@@ -22,4 +23,9 @@ record IngestionParams {
22
23
* For validation purposes. And no MAE will be emitted during the persistance
23
24
*/
24
25
testMode: boolean = false
25
- }
26
+
27
+ /**
28
+ * eTag for aspect ingestion optimistic locking
29
+ */
30
+ ingestionETags: optional array[IngestionAspectETag] = [ ]
31
+ }
Original file line number Diff line number Diff line change
1
+ namespace pegasus.com.linkedin.metadata.events
2
+
3
+ /**
4
+ * eTag used for atomic aspect updating
5
+ */
6
+ record IngestionAspectETag {
7
+
8
+ /**
9
+ * aspect FQCN
10
+ */
11
+ aspect_name: optional string = ""
12
+
13
+ /**
14
+ * e.g. timestamp used for optimistic locking when writing new aspect value
15
+ */
16
+ eTag: optional long = 0
17
+ }
You can’t perform that action at this time.
0 commit comments