org.springframework.xd.shell.hadoop

Class FsShellCommands

java.lang.Object

org.springframework.xd.shell.hadoop.ConfigurationAware

org.springframework.xd.shell.hadoop.FsShellCommands

All Implemented Interfaces:

java.util.EventListener, org.springframework.context.ApplicationListener<ConfigurationModifiedEvent>, CommandMarker, ExecutionProcessor

@Component
public class FsShellCommands
extends ConfigurationAware
implements ExecutionProcessor

HDFS shell commands

Author:

Jarred Li

Field Summary

Fields inherited from class org.springframework.xd.shell.hadoop.ConfigurationAware

LOG

Constructor Summary

Constructors

Constructor and Description
FsShellCommands()

Method Summary

Methods

Modifier and Type	Method and Description
ParseResult	beforeInvocation(ParseResult invocationContext)
void	cat(java.lang.String path)
void	chgrp(boolean recursive, java.lang.String group, java.lang.String path)
void	chmod(boolean recursive, java.lang.String mode, java.lang.String path)
void	chown(boolean recursive, java.lang.String owner, java.lang.String path)
protected boolean	configurationChanged() Called before invoking a command in case the configuration changed.
void	copyFromLocal(java.lang.String source, java.lang.String dest)
void	copyMergeToLocal(java.lang.String source, java.lang.String dest, boolean endline)
void	copyToLocal(java.lang.String source, java.lang.String dest, boolean ignoreCrc, boolean crc)
void	count(boolean quota, java.lang.String path)
void	cp(java.lang.String source, java.lang.String dest)
void	du(java.lang.String path, boolean summary)
void	expunge()
protected java.lang.String	failedComponentName()
void	get(java.lang.String source, java.lang.String dest, boolean ignoreCrc, boolean crc)
void	init()
void	ls(java.lang.String path, boolean recursive)
void	mkdir(java.lang.String dir)
void	moveFromLocal(java.lang.String source, java.lang.String dest)
void	mv(java.lang.String source, java.lang.String dest)
void	put(java.lang.String source, java.lang.String dest)
void	rm(java.lang.String path, boolean skipTrash, boolean recursive)
void	setrep(java.lang.String path, int replica, boolean recursive, boolean waiting)
void	tail(java.lang.String path, boolean file)
void	text(java.lang.String path)
void	touchz(java.lang.String path)

Methods inherited from class org.springframework.xd.shell.hadoop.ConfigurationAware

afterReturningInvocation, afterThrowingInvocation, getHadoopConfiguration, logUpdateError, onApplicationEvent

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.shell.core.ExecutionProcessor

afterReturningInvocation, afterThrowingInvocation

Constructor Detail

FsShellCommands

public FsShellCommands()

Method Detail

init

@PostConstruct
public void init()

failedComponentName

protected java.lang.String failedComponentName()

Overrides:

failedComponentName in class ConfigurationAware

configurationChanged

protected boolean configurationChanged()

Description copied from class: ConfigurationAware

Called before invoking a command in case the configuration changed. Should return true if the change has been acknowledged, false otherwise. Implementation are encouraged to update their name accordingly through ConfigurationAware.failedComponentName() to provide proper error messages.

Specified by:

configurationChanged in class ConfigurationAware

Returns:

true if the change has been acknowledged, false otherwise.

See Also:

ConfigurationAware.failedComponentName(), ConfigurationAware.logUpdateError(Exception)

beforeInvocation

public ParseResult beforeInvocation(ParseResult invocationContext)

Specified by:

beforeInvocation in interface ExecutionProcessor

Overrides:

beforeInvocation in class ConfigurationAware

ls

public void ls(java.lang.String path,
      boolean recursive)

cat

public void cat(java.lang.String path)

chgrp

public void chgrp(boolean recursive,
         java.lang.String group,
         java.lang.String path)

chown

public void chown(boolean recursive,
         java.lang.String owner,
         java.lang.String path)

chmod

public void chmod(boolean recursive,
         java.lang.String mode,
         java.lang.String path)

copyFromLocal

public void copyFromLocal(java.lang.String source,
                 java.lang.String dest)

put

public void put(java.lang.String source,
       java.lang.String dest)

moveFromLocal

public void moveFromLocal(java.lang.String source,
                 java.lang.String dest)

copyToLocal

public void copyToLocal(java.lang.String source,
               java.lang.String dest,
               boolean ignoreCrc,
               boolean crc)

copyMergeToLocal

public void copyMergeToLocal(java.lang.String source,
                    java.lang.String dest,
                    boolean endline)

get

public void get(java.lang.String source,
       java.lang.String dest,
       boolean ignoreCrc,
       boolean crc)

count

public void count(boolean quota,
         java.lang.String path)

cp

public void cp(java.lang.String source,
      java.lang.String dest)

mv

public void mv(java.lang.String source,
      java.lang.String dest)

du

public void du(java.lang.String path,
      boolean summary)

expunge

public void expunge()

mkdir

public void mkdir(java.lang.String dir)

rm

public void rm(java.lang.String path,
      boolean skipTrash,
      boolean recursive)

setrep

public void setrep(java.lang.String path,
          int replica,
          boolean recursive,
          boolean waiting)

tail

public void tail(java.lang.String path,
        boolean file)

text

public void text(java.lang.String path)

touchz

public void touchz(java.lang.String path)