org.apache.spark.sql.connector.read

Interface LocalScan

All Superinterfaces:

Scan

@Experimental
public interface LocalScan
extends Scan

A special Scan which will happen on Driver locally instead of Executors.

Since:

3.2.0

Method Summary

Modifier and Type	Method and Description
org.apache.spark.sql.catalyst.InternalRow[]	rows()

Methods inherited from interface org.apache.spark.sql.connector.read.Scan

description, readSchema, reportDriverMetrics, supportedCustomMetrics, toBatch, toContinuousStream, toMicroBatchStream

Method Detail

rows

org.apache.spark.sql.catalyst.InternalRow[] rows()