Class PslContinuousPartitionReader (1.0.0) 

public class PslContinuousPartitionReader implements ContinuousPartitionReader<InternalRow>

Inheritance

java.lang.Object > PslContinuousPartitionReader

Implements

org.apache.spark.sql.connector.read.streaming.ContinuousPartitionReader<org.apache.spark.sql.catalyst.InternalRow>

Methods

close()

public void close()

get()

public InternalRow get()
Returns
TypeDescription
org.apache.spark.sql.catalyst.InternalRow

getOffset()

public PartitionOffset getOffset()
Returns
TypeDescription
org.apache.spark.sql.connector.read.streaming.PartitionOffset

next()

public boolean next()
Returns
TypeDescription
boolean