Class PslContinuousStream (1.0.0)

public class PslContinuousStream extends BaseDataStream implements ContinuousStream

Inheritance

java.lang.Object > BaseDataStream > PslContinuousStream

Implements

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

Methods

createContinuousReaderFactory()

public ContinuousPartitionReaderFactory createContinuousReaderFactory()
Returns
TypeDescription
org.apache.spark.sql.connector.read.streaming.ContinuousPartitionReaderFactory

mergeOffsets(PartitionOffset[] offsets)

public Offset mergeOffsets(PartitionOffset[] offsets)
Parameter
NameDescription
offsetsorg.apache.spark.sql.connector.read.streaming.PartitionOffset[]
Returns
TypeDescription
org.apache.spark.sql.connector.read.streaming.Offset

needsReconfiguration()

public boolean needsReconfiguration()
Returns
TypeDescription
boolean

planInputPartitions(Offset start)

public InputPartition[] planInputPartitions(Offset start)
Parameter
NameDescription
startorg.apache.spark.sql.connector.read.streaming.Offset
Returns
TypeDescription
org.apache.spark.sql.connector.read.InputPartition[]