| Modifier and Type | Method and Description |
|---|---|
dataflow |
IDataFlowAnalyzer.getDataFlow() |
dataflow |
DataFlowAnalyzer.getDataFlow() |
dataflow |
ParallelDataFlowAnalyzer.getDataFlow() |
dataflow |
DataFlowAnalyzer.getSimpleDataflow(dataflow instance,
boolean simpleOutput) |
dataflow |
DataFlowAnalyzer.getSimpleDataflow(dataflow instance,
boolean simpleOutput,
List<String> types) |
static dataflow |
DataFlowAnalyzer.mergeTables(dataflow dataflow,
Long startId) |
static dataflow |
DataFlowAnalyzer.mergeTables(dataflow dataflow,
Long startId,
Option option) |
| Modifier and Type | Method and Description |
|---|---|
dataflow |
DataFlowAnalyzer.getSimpleDataflow(dataflow instance,
boolean simpleOutput) |
dataflow |
DataFlowAnalyzer.getSimpleDataflow(dataflow instance,
boolean simpleOutput,
List<String> types) |
static Dataflow |
DataFlowAnalyzer.getSqlflowJSONModel(dataflow dataflow)
Deprecated.
|
static Dataflow |
DataFlowAnalyzer.getSqlflowJSONModel(dataflow dataflow,
EDbVendor vendor) |
static Dataflow |
DataFlowAnalyzer.getSqlflowJSONModel(EDbVendor vendor,
dataflow dataflow,
boolean normalizeIdentifier) |
static dataflow |
DataFlowAnalyzer.mergeTables(dataflow dataflow,
Long startId) |
static dataflow |
DataFlowAnalyzer.mergeTables(dataflow dataflow,
Long startId,
Option option) |
| Modifier and Type | Method and Description |
|---|---|
static void |
CommentBindingProjection.offset(dataflow flow,
UnaryOperator<String> offset) |
static void |
CommentBindingProjection.remap(dataflow flow,
Map<String,String> objects,
Map<String,String> columns,
Map<String,String> relations) |
static void |
CommentBindingProjection.retain(dataflow flow)
Remove dangling projections, preserving the occurrence and its original owner.
|
static void |
CommentBindingProjection.retain(dataflow flow,
boolean filtering) |
| Modifier and Type | Method and Description |
|---|---|
default void |
DataFlowHandleListener.endAnalyze(dataflow dataflow) |
| Modifier and Type | Method and Description |
|---|---|
dataflow |
MetadataAnalyzer.analyzeMetadata(EDbVendor vendor,
T metadata) |
| Modifier and Type | Method and Description |
|---|---|
dataflow |
GrabitMetadataAnalyzer.analyzeMetadata(EDbVendor vendor,
String metadata) |
| Modifier and Type | Method and Description |
|---|---|
dataflow |
SQLDepMetadataAnalyzer.analyzeMetadata(EDbVendor vendor,
String metadata) |
| Modifier and Type | Method and Description |
|---|---|
dataflow |
SQLEnvMetadataAnalyzer.analyzeMetadata(EDbVendor metadataVendor,
TSQLEnv sqlenv) |
| Modifier and Type | Method and Description |
|---|---|
dataflow |
SqlflowMetadataAnalyzer.analyzeMetadata(EDbVendor metadataVendor,
String metadata) |
| Modifier and Type | Method and Description |
|---|---|
dataflow |
SqlflowShardedMetadataAnalyzer.analyzeMetadata(EDbVendor metadataVendor,
String metadata) |
| Modifier and Type | Method and Description |
|---|---|
static List<table> |
dataflow.getAllTables(dataflow dataflow) |
| Modifier and Type | Method and Description |
|---|---|
static Set<ShadowLeafEdgeComparator.LeafEdgeKey> |
ShadowLeafEdgeComparator.leafKeysOf(EDbVendor vendor,
dataflow df)
Canonical leaf-edge keys of an analyzed dataflow: its relation graph's
boundary→boundary reachability projection (identical machinery to the
summary extraction closure, applied to the WHOLE unit's model).
|
| Modifier and Type | Method and Description |
|---|---|
String |
DataFlowGraphGenerator.genDlineageGraph(EDbVendor vendor,
boolean isIndirect,
dataflow dataflow) |
String |
DataFlowGraphGenerator.genDlineageGraph(EDbVendor vendor,
boolean isIndirect,
dataflow dataflow,
boolean includeIsolatedNodes)
Graph JSON of
dataflow. |
Pair3<String,Boolean,Set<String>> |
DataFlowGraph.generateDataFlowGraph(dataflow dataflow,
boolean showLinkOnly,
boolean hideColumn,
List<RelationshipType> relationshipTypes,
Map<String,String> tooltipMap) |
Pair3<String,Boolean,Set<String>> |
DataFlowGraph.generateDataFlowGraph(dataflow dataflow,
boolean showLinkOnly,
boolean hideColumn,
List<RelationshipType> relationshipTypes,
Map<String,String> tooltipMap,
boolean includeIsolatedNodes) |
String |
DataFlowGraphGenerator.genERGraph(EDbVendor vendor,
dataflow dataflow) |
| Modifier and Type | Method and Description |
|---|---|
protected static void |
MetadataUtil.appendPackages(Sqlflow sqlflow,
EDbVendor vendor,
dataflow dataflow) |
protected static void |
MetadataUtil.appendProcesses(Sqlflow sqlflow,
EDbVendor vendor,
dataflow dataflow) |
protected static void |
MetadataUtil.appendTables(Sqlflow sqlflow,
EDbVendor vendor,
dataflow dataflow) |
static Sqlflow |
MetadataUtil.convertDataflowToMetadata(EDbVendor vendor,
dataflow dataflow) |
| Modifier and Type | Method and Description |
|---|---|
static dataflow |
DataflowUtility.cloneDataflow(dataflow dataflow) |
static dataflow |
DataflowUtility.convertTableLevelToFunctionCallDataflow(dataflow dataflow,
boolean showBuiltIn,
EDbVendor dbVendor) |
static dataflow |
DataflowUtility.convertToSchemaLevelDataflow(dataflow dataflow,
EDbVendor dbVendor) |
static dataflow |
DataflowUtility.convertToSchemaLevelDataflow(dataflow dataflow,
EDbVendor dbVendor,
boolean isSimple) |
static dataflow |
DataflowUtility.convertToTableLevelDataflow(dataflow dataflow) |
static dataflow |
TableFlowUtility.generateLeftMostTableFlow(DataFlowAnalyzer analyzer,
dataflow instance,
String tableNamePattern,
String tableColumn,
boolean isSimple) |
static dataflow |
ProcessUtility.generateTableLevelLineage(DataFlowAnalyzer analyzer,
dataflow instance) |
static dataflow |
ProcessUtility.generateTableLevelLineage(DataFlowAnalyzer analyzer,
dataflow instance,
boolean ignoreSelfLineage,
boolean isSimple) |
static dataflow |
DataflowUtility.iterativeMergeDataflowsFromFiles(List<File> tempFiles,
EDbVendor vendor)
从一组临时 XML 文件迭代加载并合并 dataflow,节约内存。
|
static dataflow |
DataflowUtility.iterativeMergeDataflowsFromFilesByStartId(List<File> tempFiles,
long startId)
从一组临时 XML 文件迭代加载并合并 dataflow,调用方需保证文件中的 dataflow ID 空间互不冲突,
且已设置好 ModelBindingManager。
|
static dataflow |
DataflowUtility.iterativeMergeDataflowsFromFilesByStartId(List<File> tempFiles,
long startId,
BiConsumer<File,dataflow> afterLoad)
The same merge, calling
afterLoad with each file's dataflow as soon as it is read, before
any id is remapped: a spilled model's same-run state that XML does not carry (its tables' carried
identities, see DataflowUtility.carriedIdentities(gudusoft.gsqlparser.dlineage.dataflow.model.xml.dataflow)) is put back there. |
static dataflow |
DataflowUtility.mergeDataflows(Collection<dataflow> dataflows,
EDbVendor vendor)
合并一组 startId 都为 0(即 ID 空间相互冲突)的 dataflow。
|
static dataflow |
DataflowUtility.mergeDataflows(Collection<dataflow> dataflows,
EDbVendor vendor,
IdentifierProfile identifierProfile)
Merge under an explicit identifier configuration — the configuration the analyses that
produced
dataflows ran under. |
static dataflow |
DataflowUtility.mergeDataflowsByStartId(Collection<dataflow> dataflows,
long startId)
内部合并实现:调用方需保证所有输入 dataflow 的 ID 空间不冲突,并且已提前设置好 ModelBindingManager。
|
static dataflow |
DataflowUtility.mergeDataflowsWithDifferentStartId(Collection<dataflow> dataflows,
EDbVendor vendor) |
static dataflow |
DataflowUtility.mergeDataflowsWithDifferentStartId(Collection<dataflow> dataflows,
EDbVendor vendor,
IdentifierProfile identifierProfile)
As
DataflowUtility.mergeDataflowsWithDifferentStartId(Collection, EDbVendor), under an explicit
identifier configuration. |
static dataflow |
DataflowUtility.mergeFunctionCallDataflow(dataflow dataflow,
EDbVendor dbVendor) |
static dataflow |
DataflowUtility.readDataflowFromCsvMetadata(String csvMetadata) |
static dataflow |
DataflowUtility.readDataflowFromCsvMetadata(String csvMetadata,
EDbVendor vendor) |
dataflow |
DataflowRemoveHelper.remove(dataflow instance,
EDbVendor dbVendor,
DataflowRemoveOption option) |
dataflow |
RemoveDataflowFunction.removeFunction(dataflow instance,
EDbVendor dbVendor) |
| Modifier and Type | Method and Description |
|---|---|
static DataflowUtility.SpilledIdentities |
DataflowUtility.carriedIdentities(dataflow df)
Captures the
DataflowUtility.SpilledIdentities of a dataflow about to be serialized. |
static dataflow |
DataflowUtility.cloneDataflow(dataflow dataflow) |
static dataflow |
DataflowUtility.convertTableLevelToFunctionCallDataflow(dataflow dataflow,
boolean showBuiltIn,
EDbVendor dbVendor) |
static dataflow |
DataflowUtility.convertToSchemaLevelDataflow(dataflow dataflow,
EDbVendor dbVendor) |
static dataflow |
DataflowUtility.convertToSchemaLevelDataflow(dataflow dataflow,
EDbVendor dbVendor,
boolean isSimple) |
static dataflow |
DataflowUtility.convertToTableLevelDataflow(dataflow dataflow) |
static String |
ProcessUtility.generateColumnLevelLineageCsv(DataFlowAnalyzer analyzer,
dataflow instance) |
static String |
ProcessUtility.generateColumnLevelLineageCsv(DataFlowAnalyzer analyzer,
dataflow instance,
boolean isSimple,
String delimiter) |
static String |
ProcessUtility.generateColumnLevelLineageCsv(DataFlowAnalyzer analyzer,
dataflow instance,
String delimiter) |
static String |
ProcessUtility.generateColumnLevelLineageCsvSimple(DataFlowAnalyzer analyzer,
dataflow instance,
String delimiter)
Simplified column level lineage output.
|
static String |
TableFlowUtility.generateLeftMostTable(DataFlowAnalyzer analyzer,
dataflow instance,
String tableNamePattern,
String tableColumn,
boolean isSimple) |
static String |
TableFlowUtility.generateLeftMostTable(DataFlowAnalyzer analyzer,
dataflow instance,
String tableNamePattern,
String tableColumn,
boolean isSimple,
String outputType,
String delimiter) |
static dataflow |
TableFlowUtility.generateLeftMostTableFlow(DataFlowAnalyzer analyzer,
dataflow instance,
String tableNamePattern,
String tableColumn,
boolean isSimple) |
static dataflow |
ProcessUtility.generateTableLevelLineage(DataFlowAnalyzer analyzer,
dataflow instance) |
static dataflow |
ProcessUtility.generateTableLevelLineage(DataFlowAnalyzer analyzer,
dataflow instance,
boolean ignoreSelfLineage,
boolean isSimple) |
static String |
ProcessUtility.generateTableLevelLineageCsv(DataFlowAnalyzer analyzer,
dataflow instance) |
static String |
ProcessUtility.generateTableLevelLineageCsv(DataFlowAnalyzer analyzer,
dataflow instance,
String delimiter) |
static Map<String,table> |
DataflowUtility.getDataflowDbObjMap(dataflow dataflow) |
static Map<String,table> |
DataflowUtility.getDataflowDbObjNameMap(dataflow dataflow) |
String |
TableColumnUtility.getTableColumnDetail(dataflow dataflow) |
String |
TableColumnUtility.getTableColumnSummary(dataflow dataflow) |
static void |
DataflowUtility.labelEndpoints(dataflow flow)
DataflowUtility.labelEndpoints(gudusoft.gsqlparser.dlineage.dataflow.model.xml.relationship, java.util.Map<java.lang.String, java.lang.String>) for every relationship of flow, once its merge is done; then a relationship that
now repeats another in every attribute but its id (DataflowUtility.exactKey(gudusoft.gsqlparser.dlineage.dataflow.model.xml.relationship): coordinates and the endpoints' ids
included, so no evidence site and no edge is lost) is dropped, and the comment bindings that named it follow the
one kept. |
static dataflow |
DataflowUtility.mergeFunctionCallDataflow(dataflow dataflow,
EDbVendor dbVendor) |
static Map<String,column> |
DlineageUtil.outputColumnsById(dataflow document)
The published columns of a document by id, for
DlineageUtil.isStarEndpoint(java.util.Map<java.lang.String, gudusoft.gsqlparser.dlineage.dataflow.model.xml.column>, java.lang.String, java.lang.String). |
static Map<String,String> |
DataflowUtility.publishedColumnNames(dataflow flow)
The published name of every column of
flow, by the column's parent and its own id: what a relationship
endpoint that names the column by those ids is labelled (DataflowUtility.labelEndpoints(gudusoft.gsqlparser.dlineage.dataflow.model.xml.relationship, java.util.Map<java.lang.String, java.lang.String>)). |
dataflow |
DataflowRemoveHelper.remove(dataflow instance,
EDbVendor dbVendor,
DataflowRemoveOption option) |
dataflow |
RemoveDataflowFunction.removeFunction(dataflow instance,
EDbVendor dbVendor) |
static void |
DataflowUtility.restoreCarriedIdentities(dataflow df,
DataflowUtility.SpilledIdentities identities) |
| Modifier and Type | Method and Description |
|---|---|
static dataflow |
DataflowUtility.iterativeMergeDataflowsFromFilesByStartId(List<File> tempFiles,
long startId,
BiConsumer<File,dataflow> afterLoad)
The same merge, calling
afterLoad with each file's dataflow as soon as it is read, before
any id is remapped: a spilled model's same-run state that XML does not carry (its tables' carried
identities, see DataflowUtility.carriedIdentities(gudusoft.gsqlparser.dlineage.dataflow.model.xml.dataflow)) is put back there. |
static dataflow |
DataflowUtility.mergeDataflows(Collection<dataflow> dataflows,
EDbVendor vendor)
合并一组 startId 都为 0(即 ID 空间相互冲突)的 dataflow。
|
static dataflow |
DataflowUtility.mergeDataflows(Collection<dataflow> dataflows,
EDbVendor vendor,
IdentifierProfile identifierProfile)
Merge under an explicit identifier configuration — the configuration the analyses that
produced
dataflows ran under. |
static Dataflow |
DataflowUtility.mergeDataflowsAndCsv(List<Pair<EDbVendor,dataflow>> pairs,
String csvMetadata) |
static dataflow |
DataflowUtility.mergeDataflowsByStartId(Collection<dataflow> dataflows,
long startId)
内部合并实现:调用方需保证所有输入 dataflow 的 ID 空间不冲突,并且已提前设置好 ModelBindingManager。
|
static dataflow |
DataflowUtility.mergeDataflowsWithDifferentStartId(Collection<dataflow> dataflows,
EDbVendor vendor) |
static dataflow |
DataflowUtility.mergeDataflowsWithDifferentStartId(Collection<dataflow> dataflows,
EDbVendor vendor,
IdentifierProfile identifierProfile)
As
DataflowUtility.mergeDataflowsWithDifferentStartId(Collection, EDbVendor), under an explicit
identifier configuration. |
| Modifier and Type | Method and Description |
|---|---|
LegacyAdaptation |
LegacyDlineageAdapter.adapt(dataflow legacy,
LegacyAdapterContext context) |
LegacyDualBuildResult |
LegacyDualBuildHarness.compare(dataflow completedResult,
String legacyOutput,
LegacyAdapterContext context) |
List<LegacyAdapterContext.ForeignKeyBinding> |
LegacyAdapterContext.CompositeForeignKeyResolver.resolve(dataflow completed) |