Class PslMicroBatchPartitionReaderFactory (1.0.0)

Version latest

• 1.0.0 (latest)
• 0.4.5
• 0.3.4

public class PslMicroBatchPartitionReaderFactory implements PartitionReaderFactory

Inheritance

java.lang.Object > PslMicroBatchPartitionReaderFactory

Implements

org.apache.spark.sql.connector.read.PartitionReaderFactory

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)

Constructors

PslMicroBatchPartitionReaderFactory()

public PslMicroBatchPartitionReaderFactory()

Methods

createReader(InputPartition inputPartition)

public PartitionReader<InternalRow> createReader(InputPartition inputPartition)

Parameter
Name	Description
inputPartition	org.apache.spark.sql.connector.read.InputPartition

Returns
Type	Description
org.apache.spark.sql.connector.read.PartitionReader<org.apache.spark.sql.catalyst.InternalRow>