org.apache.spark.sql.connector.read.streaming

Class ReadMinRows

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:

SupportsAdmissionControl.latestOffset(Offset, ReadLimit)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
int	hashCode()
long	maxTriggerDelayMs() Approximate maximum trigger delay.
long	minRows() Approximate minimum rows to scan.
String	toString()

Methods inherited from class Object

getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.spark.sql.connector.read.streaming.ReadLimit

allAvailable, compositeLimit, maxFiles, maxRows, minRows

Method Detail

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