@InterfaceStability.Evolving public interface SupportsReportPartitioning extends DataSourceReader
DataSourceReader
. Data source readers can implement this
interface to report data partitioning and try to avoid shuffle at Spark side.Modifier and Type | Method and Description |
---|---|
Partitioning |
outputPartitioning()
Returns the output data partitioning that this reader guarantees.
|
createDataReaderFactories, readSchema
Partitioning outputPartitioning()