public class Util
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
VERSION_HINT_FILENAME |
Modifier and Type | Method and Description |
---|---|
static java.lang.String[] |
blockLocations(CombinedScanTask task,
org.apache.hadoop.conf.Configuration conf) |
static java.lang.String[] |
blockLocations(FileIO io,
ScanTaskGroup<?> taskGroup) |
static org.apache.hadoop.fs.FileSystem |
getFs(org.apache.hadoop.fs.Path path,
org.apache.hadoop.conf.Configuration conf) |
static boolean |
mayHaveBlockLocations(FileIO io,
java.lang.String location) |
static java.lang.String |
uriToString(java.net.URI uri)
From Apache Spark
|
public static final java.lang.String VERSION_HINT_FILENAME
public static org.apache.hadoop.fs.FileSystem getFs(org.apache.hadoop.fs.Path path, org.apache.hadoop.conf.Configuration conf)
public static java.lang.String[] blockLocations(CombinedScanTask task, org.apache.hadoop.conf.Configuration conf)
public static java.lang.String[] blockLocations(FileIO io, ScanTaskGroup<?> taskGroup)
public static boolean mayHaveBlockLocations(FileIO io, java.lang.String location)
public static java.lang.String uriToString(java.net.URI uri)
Convert URI to String. Since URI.toString does not decode the uri, e.g. change '%25' to '%'. Here we create a hadoop Path with the given URI, and rely on Path.toString to decode the uri
uri
- the URI of the path