Class PslContinuousPartitionReader (0.4.5)

Version 0.4.5

• 1.0.0 (latest)
• 0.4.5
• 0.3.4

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>

Inherited Members

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Methods

close()

public void close()

get()

public InternalRow get()

Returns

Type	Description
org.apache.spark.sql.catalyst.InternalRow

getOffset()

public PartitionOffset getOffset()

Returns

Type	Description
org.apache.spark.sql.connector.read.streaming.PartitionOffset

next()

public boolean next()

Returns

Type	Description
boolean