@Component public class FsShellCommands extends ConfigurationAware implements org.springframework.shell.core.ExecutionProcessor
LOG
コンストラクターと説明 |
---|
FsShellCommands() |
修飾子と型 | メソッドと説明 |
---|---|
org.springframework.shell.event.ParseResult | beforeInvocation(org.springframework.shell.event.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() 構成が変更された場合にコマンドを呼び出す前に呼び出されます。 |
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) |
afterReturningInvocation, afterThrowingInvocation, getHadoopConfiguration, logUpdateError, onApplicationEvent
@PostConstruct public void init()
protected java.lang.String failedComponentName()
ConfigurationAware
の failedComponentName
protected boolean configurationChanged()
ConfigurationAware
ConfigurationAware.failedComponentName()
を通じて名前を適宜更新することが推奨されます。ConfigurationAware
の configurationChanged
ConfigurationAware.failedComponentName()
, ConfigurationAware.logUpdateError(Exception)
public org.springframework.shell.event.ParseResult beforeInvocation(org.springframework.shell.event.ParseResult invocationContext)
org.springframework.shell.core.ExecutionProcessor
の beforeInvocation
ConfigurationAware
の beforeInvocation
@CliCommand(value="hadoop fs ls", help="List files in the directory") public void ls(@CliOption(key={"","dir"},mandatory=false,unspecifiedDefaultValue=".",help="directory to be listed") java.lang.String path, @CliOption(key="recursive",mandatory=false,specifiedDefaultValue="true",unspecifiedDefaultValue="false",help="whether with recursion") boolean recursive)
@CliCommand(value="hadoop fs cat", help="Copy source paths to stdout") public void cat(@CliOption(key={"","path"},mandatory=true,unspecifiedDefaultValue=".",help="file name to be shown") java.lang.String path)
@CliCommand(value="hadoop fs chgrp", help="Change group association of files") public void chgrp(@CliOption(key="recursive",mandatory=false,specifiedDefaultValue="true",unspecifiedDefaultValue="false",help="whether with recursion") boolean recursive, @CliOption(key="group",mandatory=true,help="group name") java.lang.String group, @CliOption(key={"","path"},mandatory=true,help="path of the file whose group will be changed") java.lang.String path)
@CliCommand(value="hadoop fs chown", help="Change the owner of files") public void chown(@CliOption(key="recursive",mandatory=false,specifiedDefaultValue="true",unspecifiedDefaultValue="false",help="whether with recursion") boolean recursive, @CliOption(key="owner",mandatory=true,help="owner name") java.lang.String owner, @CliOption(key={"","path"},mandatory=true,help="path of the file whose ownership will be changed") java.lang.String path)
@CliCommand(value="hadoop fs chmod", help="Change the permissions of files") public void chmod(@CliOption(key="recursive",mandatory=false,specifiedDefaultValue="true",unspecifiedDefaultValue="false",help="whether with recursion") boolean recursive, @CliOption(key="mode",mandatory=true,help="permission mode") java.lang.String mode, @CliOption(key={"","path"},mandatory=true,help="path of the file whose permissions will be changed") java.lang.String path)
@CliCommand(value="hadoop fs copyFromLocal", help="Copy single src, or multiple srcs from local file system to the destination file system. Same as put") public void copyFromLocal(@CliOption(key="from",mandatory=true,help="source file names") java.lang.String source, @CliOption(key="to",mandatory=true,help="destination path name") java.lang.String dest)
@CliCommand(value="hadoop fs put", help="Copy single src, or multiple srcs from local file system to the destination file system") public void put(@CliOption(key="from",mandatory=true,help="source file names") java.lang.String source, @CliOption(key="to",mandatory=true,help="destination path name") java.lang.String dest)
@CliCommand(value="hadoop fs moveFromLocal", help="Similar to put command, except that the source localsrc is deleted after it\'s copied") public void moveFromLocal(@CliOption(key="from",mandatory=true,help="source file names") java.lang.String source, @CliOption(key="to",mandatory=true,help="destination path name") java.lang.String dest)
@CliCommand(value="hadoop fs copyToLocal", help="Copy files to the local file system. Same as get") public void copyToLocal(@CliOption(key="from",mandatory=true,help="source file names") java.lang.String source, @CliOption(key="to",mandatory=true,help="destination path name") java.lang.String dest, @CliOption(key="ignoreCrc",mandatory=false,specifiedDefaultValue="true",unspecifiedDefaultValue="false",help="whether ignore CRC") boolean ignoreCrc, @CliOption(key="crc",mandatory=false,specifiedDefaultValue="true",unspecifiedDefaultValue="false",help="whether copy CRC") boolean crc)
@CliCommand(value="hadoop fs copyMergeToLocal", help="Takes a source directory and a destination file as input and concatenates files in src into the destination local file") public void copyMergeToLocal(@CliOption(key="from",mandatory=true,help="source file names") java.lang.String source, @CliOption(key="to",mandatory=true,help="destination path name") java.lang.String dest, @CliOption(key="endline",mandatory=false,specifiedDefaultValue="true",unspecifiedDefaultValue="false",help="whether add a newline character at the end of each file") boolean endline)
@CliCommand(value="hadoop fs get", help="Copy files to the local file system") public void get(@CliOption(key="from",mandatory=true,help="source file names") java.lang.String source, @CliOption(key="to",mandatory=true,help="destination path name") java.lang.String dest, @CliOption(key="ignoreCrc",mandatory=false,specifiedDefaultValue="true",unspecifiedDefaultValue="false",help="whether ignore CRC") boolean ignoreCrc, @CliOption(key="crc",mandatory=false,specifiedDefaultValue="true",unspecifiedDefaultValue="false",help="whether copy CRC") boolean crc)
@CliCommand(value="hadoop fs count", help="Count the number of directories, files, bytes, quota, and remaining quota") public void count(@CliOption(key="quota",mandatory=false,specifiedDefaultValue="true",unspecifiedDefaultValue="false",help="whether with quta information") boolean quota, @CliOption(key="path",mandatory=true,help="path name") java.lang.String path)
@CliCommand(value="hadoop fs cp", help="Copy files from source to destination. This command allows multiple sources as well in which case the destination must be a directory") public void cp(@CliOption(key="from",mandatory=true,help="source file names") java.lang.String source, @CliOption(key="to",mandatory=true,help="destination path name") java.lang.String dest)
@CliCommand(value="hadoop fs mv", help="Move source files to destination in the HDFS") public void mv(@CliOption(key="from",mandatory=true,help="source file names") java.lang.String source, @CliOption(key="to",mandatory=true,help="destination path name") java.lang.String dest)
@CliCommand(value="hadoop fs du", help="Displays sizes of files and directories contained in the given directory or the length of a file in case its just a file") public void du(@CliOption(key={"","dir"},mandatory=false,unspecifiedDefaultValue=".",help="directory to be listed") java.lang.String path, @CliOption(key="summary",mandatory=false,specifiedDefaultValue="true",unspecifiedDefaultValue="false",help="whether with summary") boolean summary)
@CliCommand(value="hadoop fs expunge", help="Empty the trash") public void expunge()
@CliCommand(value="hadoop fs mkdir", help="Create a new directory") public void mkdir(@CliOption(key={"","dir"},mandatory=true,help="directory name") java.lang.String dir)
@CliCommand(value="hadoop fs rm", help="Remove files in the HDFS") public void rm(@CliOption(key={"","path"},mandatory=false,unspecifiedDefaultValue=".",help="path to be deleted") java.lang.String path, @CliOption(key="skipTrash",mandatory=false,specifiedDefaultValue="true",unspecifiedDefaultValue="false",help="whether to skip trash") boolean skipTrash, @CliOption(key="recursive",mandatory=false,specifiedDefaultValue="true",unspecifiedDefaultValue="false",help="whether to recurse") boolean recursive)
@CliCommand(value="hadoop fs setrep", help="Change the replication factor of a file") public void setrep(@CliOption(key="path",mandatory=true,help="path name") java.lang.String path, @CliOption(key="replica",mandatory=true,help="source file names") int replica, @CliOption(key="recursive",mandatory=false,specifiedDefaultValue="true",unspecifiedDefaultValue="false",help="whether with recursion") boolean recursive, @CliOption(key="waiting",mandatory=false,specifiedDefaultValue="true",unspecifiedDefaultValue="false",help="whether wait for the replic number is eqal to the number") boolean waiting)
@CliCommand(value="hadoop fs tail", help="Display last kilobyte of the file to stdout") public void tail(@CliOption(key={"","file"},mandatory=true,help="file to be tailed") java.lang.String path, @CliOption(key="follow",mandatory=false,specifiedDefaultValue="true",unspecifiedDefaultValue="false",help="whether show content while file grow") boolean file)
@CliCommand(value="hadoop fs text", help="Take a source file and output the file in text format") public void text(@CliOption(key={"","file"},mandatory=true,help="file to be shown") java.lang.String path)
@CliCommand(value="hadoop fs touchz", help="Create a file of zero length") public void touchz(@CliOption(key={"","file"},mandatory=true,help="file to be touched") java.lang.String path)