com.asakusafw.operation.tools.directio.file

Class DataSourceParameter

java.lang.Object

com.asakusafw.operation.tools.directio.file.DataSourceParameter

public class DataSourceParameter
extends Object

Handles parameters about Direct I/O data source.

Since:

0.10.0

Constructor Summary

Constructors

Constructor and Description
DataSourceParameter()

Method Summary

Modifier and Type	Method and Description
List<DataSourceInfo>	getAllDataSourceInfo() Returns the all available Direct I/O data sources.
org.apache.hadoop.conf.Configuration	getConfiguration() Returns the Hadoop configuration.
Optional<DataSourceInfo>	getDataSourceInfo() Returns the data source information.
DataSourceInfo	getDataSourceInfo(BasePath path) Returns the data source information for the path.
org.apache.hadoop.fs.FileSystem	getHadoopFileSystem(org.apache.hadoop.fs.Path path) Returns the Hadoop file system for the path.
DirectDataSourceRepository	getRepository() Returns the repository.
DirectIoPath	resolve(String path) Resolves the given path.
org.apache.hadoop.fs.Path	resolveAsHadoopPath(String path) Resolves the given path as Hadoop file system path.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DataSourceParameter

public DataSourceParameter()

Method Detail

getConfiguration

public org.apache.hadoop.conf.Configuration getConfiguration()

Returns the Hadoop configuration.

Returns:

the Hadoop configuration

getRepository

public DirectDataSourceRepository getRepository()

Returns the repository.

Returns:

the repository

getDataSourceInfo

public Optional<DataSourceInfo> getDataSourceInfo()

Returns the data source information.

Returns:

the data source information, or empty if it is not specified.

getDataSourceInfo

public DataSourceInfo getDataSourceInfo(BasePath path)

Returns the data source information for the path.

Parameters:

path - the target path

Returns:

the data source information

getAllDataSourceInfo

public List<DataSourceInfo> getAllDataSourceInfo()

Returns the all available Direct I/O data sources.

Returns:

the data sources

resolve

public DirectIoPath resolve(String path)

Resolves the given path.

Parameters:

path - the path string

Returns:

the corresponded Direct I/O path

resolveAsHadoopPath

public org.apache.hadoop.fs.Path resolveAsHadoopPath(String path)

Resolves the given path as Hadoop file system path.

Parameters:

path - the Direct I/O path string

Returns:

the corresponded Hadoop file system path

getHadoopFileSystem

public org.apache.hadoop.fs.FileSystem getHadoopFileSystem(org.apache.hadoop.fs.Path path)

Returns the Hadoop file system for the path.

Parameters:

path - the target path

Returns:

the corresponded file system object