@InterfaceStability.Unstable public interface SupportsScanUnsafeRow extends DataSourceReader
DataSourceReader
. Data source readers can implement this
interface to output UnsafeRow
directly and avoid the row copy at Spark side.
This is an experimental and unstable interface, as UnsafeRow
is not public and may get
changed in the future Spark versions.Modifier and Type | Method and Description |
---|---|
default java.util.List<DataReaderFactory<Row>> |
createDataReaderFactories()
Returns a list of reader factories.
|
java.util.List<DataReaderFactory<org.apache.spark.sql.catalyst.expressions.UnsafeRow>> |
createUnsafeRowReaderFactories()
Similar to
DataSourceReader.createDataReaderFactories() ,
but returns data in unsafe row format. |
readSchema
default java.util.List<DataReaderFactory<Row>> createDataReaderFactories()
DataSourceReader
createDataReaderFactories
in interface DataSourceReader
java.util.List<DataReaderFactory<org.apache.spark.sql.catalyst.expressions.UnsafeRow>> createUnsafeRowReaderFactories()
DataSourceReader.createDataReaderFactories()
,
but returns data in unsafe row format.