Class PslContinuousPartitionReaderFactory (0.4.5) 

public class PslContinuousPartitionReaderFactory implements ContinuousPartitionReaderFactory

Inheritance

java.lang.Object > PslContinuousPartitionReaderFactory

Implements

org.apache.spark.sql.connector.read.streaming.ContinuousPartitionReaderFactory

Constructors

PslContinuousPartitionReaderFactory()

public PslContinuousPartitionReaderFactory()

Methods

createReader(InputPartition inputPartition)

public ContinuousPartitionReader<InternalRow> createReader(InputPartition inputPartition)
Parameter
NameDescription
inputPartitionorg.apache.spark.sql.connector.read.InputPartition
Returns
TypeDescription
org.apache.spark.sql.connector.read.streaming.ContinuousPartitionReader<org.apache.spark.sql.catalyst.InternalRow>