Class PslContinuousPartitionReaderFactory (1.0.0)

Version latest

• 1.0.0 (latest)
• 0.4.5
• 0.3.4

public class PslContinuousPartitionReaderFactory implements ContinuousPartitionReaderFactory

Inheritance

java.lang.Object > PslContinuousPartitionReaderFactory

Implements

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

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

PslContinuousPartitionReaderFactory()

public PslContinuousPartitionReaderFactory()

Methods

createReader(InputPartition inputPartition)

public ContinuousPartitionReader<InternalRow> createReader(InputPartition inputPartition)

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

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