gudusoft.gsqlparser.dlineage.util

Class DataflowUtility

Object

gudusoft.gsqlparser.dlineage.util.DataflowUtility

public class DataflowUtility
extends Object

Constructor Summary

Constructors

Constructor and Description
DataflowUtility()

Method Summary

Modifier and Type	Method and Description
static dataflow	cloneDataflow(dataflow dataflow)
static dataflow	convertTableLevelToFunctionCallDataflow(dataflow dataflow, boolean showBuiltIn, EDbVendor dbVendor)
static dataflow	convertToSchemaLevelDataflow(dataflow dataflow, EDbVendor dbVendor)
static dataflow	convertToSchemaLevelDataflow(dataflow dataflow, EDbVendor dbVendor, boolean isSimple)
static dataflow	convertToTableLevelDataflow(dataflow dataflow)
static Map<String,table>	getDataflowDbObjMap(dataflow dataflow)
static Map<String,table>	getDataflowDbObjNameMap(dataflow dataflow)
static dataflow	iterativeMergeDataflowsFromFiles(List<File> tempFiles, EDbVendor vendor) 从一组临时 XML 文件迭代加载并合并 dataflow，节约内存。
static dataflow	iterativeMergeDataflowsFromFilesByStartId(List<File> tempFiles, long startId) 从一组临时 XML 文件迭代加载并合并 dataflow，调用方需保证文件中的 dataflow ID 空间互不冲突， 且已设置好 ModelBindingManager。
static dataflow	mergeDataflows(Collection<dataflow> dataflows, EDbVendor vendor) 合并一组 startId 都为 0（即 ID 空间相互冲突）的 dataflow。
static Dataflow	mergeDataflowsAndCsv(List<Pair<EDbVendor,dataflow>> pairs, String csvMetadata)
static dataflow	mergeDataflowsByStartId(Collection<dataflow> dataflows, long startId) 内部合并实现：调用方需保证所有输入 dataflow 的 ID 空间不冲突，并且已提前设置好 ModelBindingManager。
static dataflow	mergeDataflowsWithDifferentStartId(Collection<dataflow> dataflows, EDbVendor vendor)
static dataflow	mergeFunctionCallDataflow(dataflow dataflow, EDbVendor dbVendor)
static dataflow	readDataflowFromCsvMetadata(String csvMetadata)
static dataflow	readDataflowFromCsvMetadata(String csvMetadata, EDbVendor vendor)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DataflowUtility

public DataflowUtility()

Method Detail

mergeFunctionCallDataflow

public static dataflow mergeFunctionCallDataflow(dataflow dataflow,
                                                 EDbVendor dbVendor)

convertTableLevelToFunctionCallDataflow

public static dataflow convertTableLevelToFunctionCallDataflow(dataflow dataflow,
                                                               boolean showBuiltIn,
                                                               EDbVendor dbVendor)

convertToTableLevelDataflow

public static dataflow convertToTableLevelDataflow(dataflow dataflow)

convertToSchemaLevelDataflow

public static dataflow convertToSchemaLevelDataflow(dataflow dataflow,
                                                    EDbVendor dbVendor)
                                             throws Exception

Throws:

Exception

convertToSchemaLevelDataflow

public static dataflow convertToSchemaLevelDataflow(dataflow dataflow,
                                                    EDbVendor dbVendor,
                                                    boolean isSimple)
                                             throws Exception

Throws:

Exception

cloneDataflow

public static dataflow cloneDataflow(dataflow dataflow)

getDataflowDbObjMap

public static Map<String,table> getDataflowDbObjMap(dataflow dataflow)

getDataflowDbObjNameMap

public static Map<String,table> getDataflowDbObjNameMap(dataflow dataflow)

mergeDataflowsWithDifferentStartId

public static dataflow mergeDataflowsWithDifferentStartId(Collection<dataflow> dataflows,
                                                          EDbVendor vendor)

mergeDataflowsByStartId

public static dataflow mergeDataflowsByStartId(Collection<dataflow> dataflows,
                                               long startId)

内部合并实现：调用方需保证所有输入 dataflow 的 ID 空间不冲突，并且已提前设置好 ModelBindingManager。

该方法代替之前位于 ParallelDataFlowAnalyzer 的同名实现，外部调用者应使用 mergeDataflowsWithDifferentStartId(Collection, EDbVendor) 或 mergeDataflows(Collection, EDbVendor)。

mergeDataflows

public static dataflow mergeDataflows(Collection<dataflow> dataflows,
                                      EDbVendor vendor)

合并一组 startId 都为 0（即 ID 空间相互冲突）的 dataflow。

标准合并 mergeDataflowsWithDifferentStartId(Collection, EDbVendor) 的前提是 每个 dataflow 在生成时已通过 optionCopy.setStartId(5000000L * i) 占用了 不重叠的 ID 段；当外部调用方拿到的 dataflow 都是用默认 startId=0 生成时，直接合并 会因为 ID 冲突而错乱。本方法会先按下标把每个 dataflow 的全部 ID 偏移 DATAFLOW_ID_RANGE * index，再委托给标准合并逻辑。

注意：此方法会原地修改入参 dataflow 的 ID（与标准合并行为一致）。

iterativeMergeDataflowsFromFiles

public static dataflow iterativeMergeDataflowsFromFiles(List<File> tempFiles,
                                                        EDbVendor vendor)

从一组临时 XML 文件迭代加载并合并 dataflow，节约内存。

与 iterativeMergeDataflowsFromFilesByStartId(List, long) 不同的是，本方法假定文件中的 dataflow 是用默认 startId=0 生成的（ID 空间互相冲突），因此会按下标先做 ID 偏移再合并。

注意：本方法按入参 tempFiles 顺序迭代合并，不做任何排序。 coordinate 第三维 fileIdx 的偏移也是严格按入参顺序累积的， 调用方传入的顺序应与原始源文件的语义顺序保持一致。

iterativeMergeDataflowsFromFilesByStartId

public static dataflow iterativeMergeDataflowsFromFilesByStartId(List<File> tempFiles,
                                                                 long startId)

从一组临时 XML 文件迭代加载并合并 dataflow，调用方需保证文件中的 dataflow ID 空间互不冲突， 且已设置好 ModelBindingManager。

主要供 ParallelDataFlowAnalyzer 等内部生成方使用：每个临时文件中的 dataflow 已通过 optionCopy.setStartId(DATAFLOW_ID_RANGE * i) 占用了不重叠的 ID 段。

注意：本方法按入参 tempFiles 顺序迭代合并，不做任何排序。 coordinate 第三维 fileIdx 的偏移严格按入参顺序累积。

readDataflowFromCsvMetadata

public static dataflow readDataflowFromCsvMetadata(String csvMetadata,
                                                   EDbVendor vendor)

mergeDataflowsAndCsv

public static Dataflow mergeDataflowsAndCsv(List<Pair<EDbVendor,dataflow>> pairs,
                                            String csvMetadata)

readDataflowFromCsvMetadata

public static dataflow readDataflowFromCsvMetadata(String csvMetadata)