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信息和其有界还是无界。
> >
>

回复