Object
org.apache.spark.sql.connector.read.streaming.ReadMinRows
All Implemented Interfaces:
ReadLimit

@Evolving public final class ReadMinRows extends Object implements ReadLimit
Represents a ReadLimit where the MicroBatchStream should scan approximately at least the given minimum number of rows.
Since:
3.2.0
See Also:
  • Method Details

    • minRows

      public long minRows()
      Approximate minimum rows to scan.
    • maxTriggerDelayMs

      public long maxTriggerDelayMs()
      Approximate maximum trigger delay.
    • toString

      public String toString()
      Overrides:
      toString in class Object
    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object
    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object