Interface ReadLimit

All Known Implementing Classes:
CompositeReadLimit, ReadAllAvailable, ReadMaxBytes, ReadMaxFiles, ReadMaxRows, ReadMinRows

@Evolving public interface ReadLimit
Interface representing limits on how much to read from a MicroBatchStream when it implements SupportsAdmissionControl. There are several child interfaces representing various kinds of limits.
Since:
3.0.0
See Also:
  • Method Details

    • minRows

      static ReadLimit minRows(long rows, long maxTriggerDelayMs)
    • maxRows

      static ReadLimit maxRows(long rows)
    • maxFiles

      static ReadLimit maxFiles(int files)
    • maxBytes

      static ReadLimit maxBytes(long bytes)
    • allAvailable

      static ReadLimit allAvailable()
    • compositeLimit

      static ReadLimit compositeLimit(ReadLimit[] readLimits)