spark技术分享DataReaderFactory
DataReaderFactory is a contract…FIXME
|
1 2 3 4 5 6 7 8 9 10 11 |
package org.apache.spark.sql.sources.v2.reader; public interface DataReaderFactory<T> extends Serializable { // only required methods that have no implementation // the others follow DataReader<T> createDataReader(); } |
|
Note
|
In other words, using the contract is as treading on thin ice. |
| Method | Description |
|---|---|
|
Used when…FIXME |
Specifying Preferred Locations — preferredLocations Method
|
1 2 3 4 5 |
default String[] preferredLocations() |
preferredLocations defaults to an empty collection of host names (as the preferred locations) which simply means that this task has no location preference.
|
Note
|
|
