com.asakusafw.windgate.hadoopfs

Class HadoopFsProfile

java.lang.Object

com.asakusafw.windgate.hadoopfs.HadoopFsProfile

public class HadoopFsProfile
extends Object

A structured profile for HadoopFsMirror.

Since:

0.2.2

Version:

0.7.0

Field Summary

Fields

Modifier and Type	Field and Description
static String	KEY_BASE_PATH The key of base path.
static String	KEY_COMPRESSION The key of CompressionCodec class name.

Constructor Summary

Constructors

Constructor and Description
HadoopFsProfile(String resourceName, org.apache.hadoop.fs.Path basePath) Creates a new instance.
HadoopFsProfile(String resourceName, org.apache.hadoop.fs.Path basePath, org.apache.hadoop.io.compress.CompressionCodec compressionCodec) Deprecated. Use HadoopFsProfile(String, Path) instead

Method Summary

Modifier and Type	Method and Description
static HadoopFsProfile	convert(org.apache.hadoop.conf.Configuration configuration, ResourceProfile profile) Converts ResourceProfile into SshProfile.
org.apache.hadoop.fs.Path	getBasePath() Returns the target base path.
org.apache.hadoop.io.compress.CompressionCodec	getCompressionCodec() Deprecated. from 0.7.0, WindGate does not use sequence files
String	getResourceName() Returns the resource name.

Methods inherited from class java.lang.Object

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

Field Detail

KEY_BASE_PATH

public static final String KEY_BASE_PATH

The key of base path.

See Also:

Constant Field Values

KEY_COMPRESSION

public static final String KEY_COMPRESSION

The key of CompressionCodec class name.

See Also:

Constant Field Values

Constructor Detail

HadoopFsProfile

@Deprecated
public HadoopFsProfile(String resourceName,
                                   org.apache.hadoop.fs.Path basePath,
                                   org.apache.hadoop.io.compress.CompressionCodec compressionCodec)

Deprecated. Use HadoopFsProfile(String, Path) instead

Creates a new instance.

Parameters:

resourceName - the resource name

basePath - the base path

compressionCodec - the compression codec, or null if does not compress

Throws:

IllegalArgumentException - if any parameter is null

HadoopFsProfile

public HadoopFsProfile(String resourceName,
                       org.apache.hadoop.fs.Path basePath)

Creates a new instance.

Parameters:

resourceName - the resource name

basePath - the base path

Throws:

IllegalArgumentException - if any parameter is null

Since:

0.7.0

Method Detail

convert

public static HadoopFsProfile convert(org.apache.hadoop.conf.Configuration configuration,
                                      ResourceProfile profile)
                               throws IOException

Converts ResourceProfile into SshProfile.

Parameters:

configuration - the current configuration

profile - target profile

Returns:

the converted profile

Throws:

IOException - if failed to initialize file system

IllegalArgumentException - if profile is not valid, or any parameter is null

getResourceName

public String getResourceName()

Returns the resource name.

Returns:

the resource name

getBasePath

public org.apache.hadoop.fs.Path getBasePath()

Returns the target base path.

Returns:

the target base path

Since:

0.4.0

getCompressionCodec

@Deprecated
public org.apache.hadoop.io.compress.CompressionCodec getCompressionCodec()

Deprecated. from 0.7.0, WindGate does not use sequence files

Returns the compression codec of putting sequence files.

Returns:

the compression codec, or null if does not compress