Thanks for driving this discussion, JiaTao, the Flink way: Extend the digest through getQualifiedName is hacky somehow.
We actually need some interfaces to reflect/represent the pushed info, the pushed fields or filter expression. Best, Danny Chan 在 2020年10月9日 +0800 PM3:35,[email protected],写道: > > getQualifiedName
