SupportsLimitPushDowninstead. See FLIP-95 for more information.
@Deprecated @Experimental public interface LimitableTableSource<T>
TableSourceextending this interface is able to limit the number of records.
After pushing down, source only needs to try its best to limit the number of output records, but does not need to guarantee that the number must be less than or equal to the limit.
|Modifier and Type||Method and Description|
Check and push down the limit to the table source.
Return the flag to indicate whether limit push down has been tried.
TableSource<T> applyLimit(long limit)
limit- the value which limit the number of records.
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.