public class LoadFuncHelper extends Object
Modifier and Type | Field and Description |
---|---|
static String |
FILE_EXTENSION_LOADERS |
Constructor and Description |
---|
LoadFuncHelper(org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.fs.Path |
determineFirstFile(String location)
If location is a directory the first file found is returned
|
FuncSpec |
determineFunction(String location)
If location is a directory the first file found in the directory is used.
The file extension of the file will be searched against the file.extension.loaders mappings. |
FuncSpec |
determineFunction(String location,
org.apache.hadoop.fs.Path path)
The file extension of the file will be searched against the
file.extension.loaders mappings.
|
public static final String FILE_EXTENSION_LOADERS
public LoadFuncHelper(org.apache.hadoop.conf.Configuration conf) throws IOException
IOException
public org.apache.hadoop.fs.Path determineFirstFile(String location) throws IOException
location
- IOException
- if no file is found a FrontendException is thrownpublic FuncSpec determineFunction(String location) throws IOException
location
- IOException
public FuncSpec determineFunction(String location, org.apache.hadoop.fs.Path path) throws IOException
path
- location
- IOException
Copyright © 2007-2017 The Apache Software Foundation