Package 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	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 java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

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