Class PslContinuousStream (0.4.5)

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
Type Description
org.apache.spark.sql.connector.read.streaming.ContinuousPartitionReaderFactory

mergeOffsets(PartitionOffset[] offsets)

public Offset mergeOffsets(PartitionOffset[] offsets)
Parameter
Name Description
offsets org.apache.spark.sql.connector.read.streaming.PartitionOffset[]
Returns
Type Description
org.apache.spark.sql.connector.read.streaming.Offset

needsReconfiguration()

public boolean needsReconfiguration()
Returns
Type Description
boolean

planInputPartitions(Offset start)

public InputPartition[] planInputPartitions(Offset start)
Parameter
Name Description
start org.apache.spark.sql.connector.read.streaming.Offset
Returns
Type Description
org.apache.spark.sql.connector.read.InputPartition[]