com.asakusafw.windgate.hadoopfs.jsch

Class JschHadoopFsMirror

java.lang.Object

com.asakusafw.windgate.core.resource.ResourceMirror

com.asakusafw.windgate.hadoopfs.ssh.AbstractSshHadoopFsMirror

com.asakusafw.windgate.hadoopfs.jsch.JschHadoopFsMirror

All Implemented Interfaces:

Closeable, AutoCloseable

@SimulationSupport
public class JschHadoopFsMirror
extends AbstractSshHadoopFsMirror

An implementation of ResourceMirror using Hadoop File System via JSch connection.

Since:

0.2.2

Version:

0.4.0

See Also:

FileProcess

Constructor Summary

Constructors

Constructor and Description
JschHadoopFsMirror(org.apache.hadoop.conf.Configuration configuration, SshProfile profile, ParameterList arguments) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
protected SshConnection	openConnection(SshProfile profile, List<String> command) Opens a new SSH command connection.

Methods inherited from class com.asakusafw.windgate.hadoopfs.ssh.AbstractSshHadoopFsMirror

close, createDrain, createSource, getName, prepare

Methods inherited from class com.asakusafw.windgate.core.resource.ResourceMirror

isTransactional, onSessionCompleting, onSessionCreated

Methods inherited from class java.lang.Object

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

Constructor Detail

JschHadoopFsMirror

public JschHadoopFsMirror(org.apache.hadoop.conf.Configuration configuration,
                          SshProfile profile,
                          ParameterList arguments)

Creates a new instance.

Parameters:

configuration - the hadoop configuration

profile - the profile

arguments - the arguments

Throws:

IllegalArgumentException - if any parameter is null

Method Detail

openConnection

protected SshConnection openConnection(SshProfile profile,
                                       List<String> command)
                                throws IOException

Description copied from class: AbstractSshHadoopFsMirror

Opens a new SSH command connection.

Specified by:

openConnection in class AbstractSshHadoopFsMirror

Parameters:

profile - the ssh profile

command - target command

Returns:

the opened connection

Throws:

IOException - if failed to open