acceptable-architect-70237
08/10/2020, 6:05 PMSchemaField -> SchemaField to describe metadata related to dataset schema. This can be expanded to a new entity DatasetField which represents a field in the schema of the dataset.
- how would it look like?brave-appointment-76997
03/31/2021, 11:05 AMminiature-eye-9764
08/24/2021, 10:43 PMmillions-engineer-56536
09/16/2021, 7:46 PMnumerous-camera-74294
03/22/2022, 2:55 PMrhythmic-stone-77840
04/08/2022, 9:08 PMgentle-father-80172
04/13/2022, 7:38 PMlittle-megabyte-1074
05/04/2022, 9:29 PMminiature-television-17996
05/17/2022, 3:31 PMhandsome-football-66174
06/07/2022, 2:50 PMwooden-chef-22394
06/24/2022, 1:48 AMbland-orange-13353
07/29/2022, 2:49 AMaverage-rocket-98592
08/11/2022, 8:28 AMrhythmic-stone-77840
09/06/2022, 3:01 PMrhythmic-stone-77840
09/06/2022, 3:02 PMhigh-hospital-85984
10/14/2022, 7:55 AMdamp-school-97151
10/18/2022, 11:40 PMsome-chef-85850
11/15/2022, 9:49 AMacceptable-terabyte-34789
11/22/2022, 8:35 AMfull-helicopter-95955
11/30/2022, 6:14 PMdef test_Lineage():
fineGrainedLineages = [
FineGrainedLineage(
upstreamType=FineGrainedLineageUpstreamType.FIELD_SET,
upstreams=[fldUrn("bar2", "c1"), fldUrn("bar4", "c1")],
downstreamType=FineGrainedLineageDownstreamType.FIELD,
downstreams=[fldUrn("bar", "c1")],
),
FineGrainedLineage(
upstreamType=FineGrainedLineageUpstreamType.FIELD_SET,
upstreams=[fldUrn("bar3", "c2")],
downstreamType=FineGrainedLineageDownstreamType.FIELD,
downstreams=[fldUrn("bar", "c2")],
confidenceScore=0.8,
transformOperation="myfunc",
),
FineGrainedLineage(
upstreamType=FineGrainedLineageUpstreamType.FIELD_SET,
upstreams=[fldUrn("bar2", "c2"), fldUrn("bar2", "c3"), fldUrn("bar3", "c1")],
downstreamType=FineGrainedLineageDownstreamType.FIELD_SET,
downstreams=[fldUrn("bar", "c3"), fldUrn("bar", "c4")],
confidenceScore=0.7,
),
FineGrainedLineage(
upstreamType=FineGrainedLineageUpstreamType.DATASET,
upstreams=[datasetUrn("bar3")],
downstreamType=FineGrainedLineageDownstreamType.FIELD,
downstreams=[fldUrn("bar", "c5")],
),
FineGrainedLineage(
upstreamType=FineGrainedLineageUpstreamType.DATASET,
upstreams=[datasetUrn("bar4")],
downstreamType=FineGrainedLineageDownstreamType.FIELD_SET,
downstreams=[fldUrn("bar", "c6"), fldUrn("bar", "c7")],
)]
upstream = Upstream(dataset=datasetUrn("bar2"), type=DatasetLineageType.TRANSFORMED)
fieldLineages = UpstreamLineage(
upstreams=[upstream], fineGrainedLineages=fineGrainedLineages
)
lineageMcp = MetadataChangeProposalWrapper(
entityType="dataset",
changeType=ChangeTypeClass.UPSERT,
entityUrn=datasetUrn("bar"),
aspectName="upstreamLineage",
aspect=fieldLineages,
)
emitter = DatahubRestEmitter("<http://localhost:8080>")
# Emit metadata!
emitter.emit_mcp(lineageMcp)
future-iron-16086
12/21/2022, 6:27 PMcrooked-coat-48406
01/31/2023, 5:24 PMwhite-horse-97256
02/10/2023, 10:28 PMgreen-lock-62163
02/15/2023, 1:42 PMminiature-xylophone-2277
03/01/2023, 7:29 PMmelodic-guitar-21477
03/07/2023, 11:42 PMgreen-lock-62163
03/16/2023, 4:30 PMrhythmic-stone-77840
03/22/2023, 5:34 PMrhythmic-stone-77840
03/22/2023, 5:34 PM