Hi, junjie: 我想先了解一下你的目的是什么,为什么需要在Table API中判断Source的Boundness,这些信息对你的场景的帮助是什么?
Best regards, Weijie junjie.m...@goupwith.com <junjie.m...@goupwith.com> 于2022年10月28日周五 15:36写道: > public static DynamicTableSource FactoryUtil.createTableSource(@Nullable > Catalog catalog,ObjectIdentifier objectIdentifier, ResolvedCatalogTable > catalogTable, ReadableConfig configuration, ClassLoader classLoader, > boolean isTemporary)可以得到但是需要传入的参数太多了,这些参数不知道如何获取 > > 发件人: junjie.m...@goupwith.com > 发送时间: 2022-10-28 15:33 > 收件人: user-zh > 主题: Re: Re: 关于如何得到管道中哪些源是有界和无界的问题 > 问题是如何拿到ScanTableSource呢?目前我没发现哪里可以得到 > > > 发件人: TonyChen > 发送时间: 2022-10-28 15:21 > 收件人: user-zh > 主题: Re: 关于如何得到管道中哪些源是有界和无界的问题 > 是不是可以看下这个 > > https://github.com/apache/flink/blob/master/flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/ScanTableSource.java#L94 > Best, > TonyChen > > 2022年10月28日 15:12,junjie.m...@goupwith.com 写道: > > > > 大家好: > > 有个问题判断Table是有界还是无界,或者通过TableEnv如何能得到source table信息和其有界还是无界。 > > >