Class PslContinuousInputPartitionReader (0.3.4)

Version 0.3.4

• 1.0.0 (latest)
• 0.4.5
• 0.3.4

public class PslContinuousInputPartitionReader implements ContinuousInputPartitionReader<InternalRow>

Inheritance

java.lang.Object > PslContinuousInputPartitionReader

Implements

org.apache.spark.sql.sources.v2.reader.streaming.ContinuousInputPartitionReader<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.sources.v2.reader.streaming.PartitionOffset

next()

public boolean next()

Returns

Type	Description
boolean