@Test @DisplayName("GlossaryLineage") public void testGlossaryLineage() throws PropertyServerException, InvalidParameterException { try { when(openLineageClient.lineage(eq(USER_ID), eq(Scope.VERTICAL), eq(guid), eq(""), eq(true))) .thenReturn(lineageVerticesAndEdges); } catch (OpenLineageException e) { e.printStackTrace(); } Map<String, List> response = openLineageService.getVerticalLineage(USER_ID, guid, true); checkResponse(response); }
public Map<String, List> getVerticalLineage(String userId, String guid, boolean includeProcesses) { try { LineageVerticesAndEdges response = openLineageClient.lineage(userId, Scope.VERTICAL, guid, "", includeProcesses); return processResponse(response,guid); } catch (InvalidParameterException | PropertyServerException | OpenLineageException e) { LOG.error("Cannot get glossary lineage for guid {}", guid); throw new RuntimeException("glossary lineage error", e); } }
OpenLineageService { public Map<String, List> getVerticalLineage(String userId, String guid, boolean includeProcesses) { try { LineageVerticesAndEdges response = openLineageClient.lineage(userId, Scope.VERTICAL, guid, "", includeProcesses); return processResponse(response,guid); } catch (InvalidParameterException | PropertyServerException | OpenLineageException e) { LOG.error("Cannot get glossary lineage for guid {}", guid); throw new RuntimeException("glossary lineage error", e); } } }
OpenLineageService { public Map<String, List> getVerticalLineage(String userId, String guid, boolean includeProcesses) { try { LineageVerticesAndEdges response = openLineageClient.lineage(userId, Scope.VERTICAL, guid, "", includeProcesses); return processResponse(response,guid); } catch (InvalidParameterException | PropertyServerException | OpenLineageException e) { LOG.error("Cannot get glossary lineage for guid {}", guid); throw new RuntimeException("glossary lineage error", e); } } @Autowired  OpenLineageService(OpenLineageClient openLineageClient); }
OpenLineageService { public Map<String, List> getVerticalLineage(String userId, String guid, boolean includeProcesses) { try { LineageVerticesAndEdges response = openLineageClient.lineage(userId, Scope.VERTICAL, guid, "", includeProcesses); return processResponse(response,guid); } catch (InvalidParameterException | PropertyServerException | OpenLineageException e) { LOG.error("Cannot get glossary lineage for guid {}", guid); throw new RuntimeException("glossary lineage error", e); } } @Autowired  OpenLineageService(OpenLineageClient openLineageClient); Map<String, List> getUltimateSource(String userId,
                                               String guid,
                                               boolean includeProcesses); Map<String, List> getEndToEndLineage(String userId,
                                                String guid,
                                                boolean includeProcesses); Map<String, List> getUltimateDestination(String userId,
                                                    String guid,
                                                    boolean includeProcesses); Map<String, List> getVerticalLineage(String userId,
                                                String guid,
                                                boolean includeProcesses); Map<String, List> getSourceAndDestination(String userId,
                                                     String guid,
                                                     boolean includeProcesses); }
OpenLineageService { public Map<String, List> getVerticalLineage(String userId, String guid, boolean includeProcesses) { try { LineageVerticesAndEdges response = openLineageClient.lineage(userId, Scope.VERTICAL, guid, "", includeProcesses); return processResponse(response,guid); } catch (InvalidParameterException | PropertyServerException | OpenLineageException e) { LOG.error("Cannot get glossary lineage for guid {}", guid); throw new RuntimeException("glossary lineage error", e); } } @Autowired  OpenLineageService(OpenLineageClient openLineageClient); Map<String, List> getUltimateSource(String userId,
                                               String guid,
                                               boolean includeProcesses); Map<String, List> getEndToEndLineage(String userId,
                                                String guid,
                                                boolean includeProcesses); Map<String, List> getUltimateDestination(String userId,
                                                    String guid,
                                                    boolean includeProcesses); Map<String, List> getVerticalLineage(String userId,
                                                String guid,
                                                boolean includeProcesses); Map<String, List> getSourceAndDestination(String userId,
                                                     String guid,
                                                     boolean includeProcesses); static final String EDGES_LABEL; static final String NODES_LABEL; }