@@ -1848,48 +1848,6 @@ private void updateAssetHasLineageStatus(AtlasVertex assetVertex, AtlasEdge curr
18481848
18491849 }
18501850
1851- private boolean updateAssetHasLineageStatusWithDirection (AtlasVertex assetVertex , AtlasEdge currentEdge , AtlasEdgeDirection direction , Set <String > exclusionList ) {
1852- GraphTraversal <Edge , Map <String , Object >> edgeTraversal ;
1853-
1854- // Create the appropriate directional traversal
1855- if (AtlasEdgeDirection .OUT .equals (direction )) {
1856- edgeTraversal = ((AtlasJanusGraph ) graph ).V (assetVertex .getId ())
1857- .outE (PROCESS_EDGE_LABELS );
1858- } else if (AtlasEdgeDirection .IN .equals (direction )) {
1859- edgeTraversal = ((AtlasJanusGraph ) graph ).V (assetVertex .getId ())
1860- .inE (PROCESS_EDGE_LABELS );
1861- } else {
1862- edgeTraversal = ((AtlasJanusGraph ) graph ).V (assetVertex .getId ())
1863- .bothE (PROCESS_EDGE_LABELS );
1864- }
1865-
1866-
1867- return edgeTraversal
1868- .has (STATE_PROPERTY_KEY , ACTIVE_STATE_VALUE )
1869- .has (RELATIONSHIP_GUID_PROPERTY_KEY )
1870- // Exclude edges by id; prefer using actual edge-id objects if possible.
1871- .filter (__ .id ().is (P .without (exclusionList )))
1872- // Check lineage on the edge's out-vertex
1873- .filter (__ .outV ().has ("__hasLineage" , true ))
1874- .limit (1 )
1875- .tryNext ()
1876- .isPresent ();
1877- }
1878-
1879- private boolean updateAssetHasLineageStatusWithOUTDirection (AtlasVertex assetVertex , AtlasEdge currentEdge , Set <String > exclusionList ) {
1880- AtlasPerfMetrics .MetricRecorder metricRecorder = RequestContext .get ().startMetricRecord ("updateAssetHasLineageStatusWithOUTDirection" );
1881- boolean hasLineage = updateAssetHasLineageStatusWithDirection (assetVertex , currentEdge , AtlasEdgeDirection .OUT , exclusionList );
1882- RequestContext .get ().endMetricRecord (metricRecorder );
1883- return hasLineage ;
1884- }
1885-
1886- private boolean updateAssetHasLineageStatusWithINDirection (AtlasVertex assetVertex , AtlasEdge currentEdge , Set <String > exclusionList ) {
1887- AtlasPerfMetrics .MetricRecorder metricRecorder = RequestContext .get ().startMetricRecord ("updateAssetHasLineageStatusWithINDirection" );
1888- boolean hasLineage = updateAssetHasLineageStatusWithDirection (assetVertex , currentEdge , AtlasEdgeDirection .IN , exclusionList );
1889- RequestContext .get ().endMetricRecord (metricRecorder );
1890- return hasLineage ;
1891- }
1892-
18931851 private void updateAssetHasLineageStatusV1 (AtlasVertex assetVertex , AtlasEdge currentEdge , Collection <AtlasEdge > removedEdges ) {
18941852 AtlasPerfMetrics .MetricRecorder metricRecorder = RequestContext .get ().startMetricRecord ("updateAssetHasLineageStatusV1" );
18951853
0 commit comments