留意到咱们也成功了一个自定义的SQL解析器,其实该解析器并没有做太多的事件。只是在判别假设该语句蕴含insert的时刻就将SQLText(SQL语句)设置到一个为FIELD_LINE_AGE_SQL,之所以将SQLText放到FIELD_LINE_AGE_SQL外面。由于在DheckRule 外面是拿不到SparkPlan的咱们须要对SQL再次解析拿到SprkPlan,而FieldLineageCheckRuleV3的成功也特意便捷,关键的在另一个线程成功外面。
© 版权声明
留意到咱们也成功了一个自定义的SQL解析器,其实该解析器并没有做太多的事件。只是在判别假设该语句蕴含insert的时刻就将SQLText(SQL语句)设置到一个为FIELD_LINE_AGE_SQL,之所以将SQLText放到FIELD_LINE_AGE_SQL外面。由于在DheckRule 外面是拿不到SparkPlan的咱们须要对SQL再次解析拿到SprkPlan,而FieldLineageCheckRuleV3的成功也特意便捷,关键的在另一个线程成功外面。