org.apache.spark.sql.sources.v2.reader

Interface ContinuousInputPartition<T>

All Superinterfaces:

InputPartition<T>, java.io.Serializable

@InterfaceStability.Evolving
public interface ContinuousInputPartition<T>
extends InputPartition<T>

A mix-in interface for InputPartition. Continuous input partitions can implement this interface to provide creating InputPartitionReader with particular offset.

Method Summary

Modifier and Type	Method and Description
InputPartitionReader<T>	createContinuousReader(PartitionOffset offset) Create an input partition reader with particular offset as its startOffset.

Methods inherited from interface org.apache.spark.sql.sources.v2.reader.InputPartition

createPartitionReader, preferredLocations

Method Detail

createContinuousReader

InputPartitionReader<T> createContinuousReader(PartitionOffset offset)

Create an input partition reader with particular offset as its startOffset.

Parameters:

offset - offset want to set as the input partition reader's startOffset.