@PublicEvolving public interface SupportsLimitPushDown
It might be beneficial to perform the limiting as early as possible in order to be close to the actual data generation.
A source can perform the limiting on a best-effort basis. During runtime, it must not guarantee that the number of emitted records is less than or equal to the limit.
Regardless if this interface is implemented or not, a limit is also applied in a subsequent operation after the source.
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.