Class PslMicroBatchInputPartitionReader (0.4.5)

Version 0.4.5

• 1.0.0 (latest)
• 0.4.5
• 0.3.4

public class PslMicroBatchInputPartitionReader implements PartitionReader<InternalRow>

Inheritance

java.lang.Object > PslMicroBatchInputPartitionReader

Implements

org.apache.spark.sql.connector.read.PartitionReader<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

next()

public boolean next()

Returns

Type	Description
boolean