public class oadd.org.apache.hadoop.fs.shell.Count extends oadd.org.apache.hadoop.fs.shell.FsCommand
{
private static final java.lang.String OPTION_QUOTA;
private static final java.lang.String OPTION_HUMAN;
private static final java.lang.String OPTION_HEADER;
private static final java.lang.String OPTION_TYPE;
private static final java.lang.String OPTION_EXCLUDE_SNAPSHOT;
private static final java.lang.String OPTION_QUOTA_AND_USAGE;
private static final java.lang.String OPTION_ECPOLICY;
public static final java.lang.String NAME;
public static final java.lang.String USAGE;
public static final java.lang.String DESCRIPTION;
private boolean showQuotas;
private boolean humanReadable;
private boolean showQuotabyType;
private java.util.List storageTypes;
private boolean showQuotasAndUsageOnly;
private boolean excludeSnapshots;
private boolean displayECPolicy;
public static void registerCommands(oadd.org.apache.hadoop.fs.shell.CommandFactory)
{
java.lang.String[] v;
oadd.org.apache.hadoop.fs.shell.CommandFactory v;
v := @parameter: oadd.org.apache.hadoop.fs.shell.CommandFactory;
v = newarray (java.lang.String)[1];
v[0] = "-count";
virtualinvoke v.<oadd.org.apache.hadoop.fs.shell.CommandFactory: void addClass(java.lang.Class,java.lang.String[])>(class "Loadd/org/apache/hadoop/fs/shell/Count;", v);
return;
}
public void <init>()
{
oadd.org.apache.hadoop.fs.shell.Count v;
v := @this: oadd.org.apache.hadoop.fs.shell.Count;
specialinvoke v.<oadd.org.apache.hadoop.fs.shell.FsCommand: void <init>()>();
v.<oadd.org.apache.hadoop.fs.shell.Count: java.util.List storageTypes> = null;
return;
}
public void <init>(java.lang.String[], int, oadd.org.apache.hadoop.conf.Configuration)
{
java.lang.Object[] v;
oadd.org.apache.hadoop.fs.shell.Count v;
int v, v;
java.lang.String[] v;
oadd.org.apache.hadoop.conf.Configuration v;
v := @this: oadd.org.apache.hadoop.fs.shell.Count;
v := @parameter: java.lang.String[];
v := @parameter: int;
v := @parameter: oadd.org.apache.hadoop.conf.Configuration;
specialinvoke v.<oadd.org.apache.hadoop.fs.shell.FsCommand: void <init>(oadd.org.apache.hadoop.conf.Configuration)>(v);
v.<oadd.org.apache.hadoop.fs.shell.Count: java.util.List storageTypes> = null;
v = lengthof v;
v = staticinvoke <java.util.Arrays: java.lang.Object[] copyOfRange(java.lang.Object[],int,int)>(v, v, v);
v.<oadd.org.apache.hadoop.fs.shell.Count: java.lang.String[] args> = v;
return;
}
protected void processOptions(java.util.LinkedList)
{
java.lang.String[] v;
java.lang.String v, v, v, v, v;
java.util.LinkedList v;
boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.io.PrintStream v, v;
oadd.org.apache.hadoop.fs.shell.CommandFormat v;
java.util.List v, v;
oadd.org.apache.hadoop.fs.shell.Count v;
java.lang.StringBuilder v;
v := @this: oadd.org.apache.hadoop.fs.shell.Count;
v := @parameter: java.util.LinkedList;
v = new oadd.org.apache.hadoop.fs.shell.CommandFormat;
v = newarray (java.lang.String)[6];
v[0] = "q";
v[1] = "h";
v[2] = "v";
v[3] = "u";
v[4] = "x";
v[5] = "e";
specialinvoke v.<oadd.org.apache.hadoop.fs.shell.CommandFormat: void <init>(int,int,java.lang.String[])>(1, 2147483647, v);
virtualinvoke v.<oadd.org.apache.hadoop.fs.shell.CommandFormat: void addOptionWithValue(java.lang.String)>("t");
virtualinvoke v.<oadd.org.apache.hadoop.fs.shell.CommandFormat: void parse(java.util.List)>(v);
v = virtualinvoke v.<java.util.LinkedList: boolean isEmpty()>();
if v == 0 goto label;
virtualinvoke v.<java.util.LinkedList: boolean add(java.lang.Object)>(".");
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.shell.CommandFormat: boolean getOpt(java.lang.String)>("q");
v.<oadd.org.apache.hadoop.fs.shell.Count: boolean showQuotas> = v;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.shell.CommandFormat: boolean getOpt(java.lang.String)>("h");
v.<oadd.org.apache.hadoop.fs.shell.Count: boolean humanReadable> = v;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.shell.CommandFormat: boolean getOpt(java.lang.String)>("u");
v.<oadd.org.apache.hadoop.fs.shell.Count: boolean showQuotasAndUsageOnly> = v;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.shell.CommandFormat: boolean getOpt(java.lang.String)>("x");
v.<oadd.org.apache.hadoop.fs.shell.Count: boolean excludeSnapshots> = v;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.shell.CommandFormat: boolean getOpt(java.lang.String)>("e");
v.<oadd.org.apache.hadoop.fs.shell.Count: boolean displayECPolicy> = v;
v = v.<oadd.org.apache.hadoop.fs.shell.Count: boolean showQuotas>;
if v != 0 goto label;
v = v.<oadd.org.apache.hadoop.fs.shell.Count: boolean showQuotasAndUsageOnly>;
if v == 0 goto label;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.shell.CommandFormat: java.lang.String getOptValue(java.lang.String)>("t");
if null == v goto label;
v.<oadd.org.apache.hadoop.fs.shell.Count: boolean showQuotabyType> = 1;
v = specialinvoke v.<oadd.org.apache.hadoop.fs.shell.Count: java.util.List getAndCheckStorageTypes(java.lang.String)>(v);
v.<oadd.org.apache.hadoop.fs.shell.Count: java.util.List storageTypes> = v;
goto label;
label:
v.<oadd.org.apache.hadoop.fs.shell.Count: boolean showQuotabyType> = 0;
label:
v = v.<oadd.org.apache.hadoop.fs.shell.Count: boolean excludeSnapshots>;
if v == 0 goto label;
v = v.<oadd.org.apache.hadoop.fs.shell.Count: java.io.PrintStream out>;
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>("q or u option is given, the -x option is ignored.");
v.<oadd.org.apache.hadoop.fs.shell.Count: boolean excludeSnapshots> = 0;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.shell.CommandFormat: boolean getOpt(java.lang.String)>("v");
if v == 0 goto label;
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
v = v.<oadd.org.apache.hadoop.fs.shell.Count: boolean showQuotabyType>;
if v == 0 goto label;
v = v.<oadd.org.apache.hadoop.fs.shell.Count: java.util.List storageTypes>;
v = staticinvoke <oadd.org.apache.hadoop.fs.QuotaUsage: java.lang.String getStorageTypeHeader(java.util.List)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
goto label;
label:
v = v.<oadd.org.apache.hadoop.fs.shell.Count: boolean showQuotasAndUsageOnly>;
if v == 0 goto label;
v = staticinvoke <oadd.org.apache.hadoop.fs.QuotaUsage: java.lang.String getHeader()>();
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
goto label;
label:
v = v.<oadd.org.apache.hadoop.fs.shell.Count: boolean showQuotas>;
v = staticinvoke <oadd.org.apache.hadoop.fs.ContentSummary: java.lang.String getHeader(boolean)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
label:
v = v.<oadd.org.apache.hadoop.fs.shell.Count: boolean displayECPolicy>;
if v == 0 goto label;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("ERASURECODING_POLICY ");
label:
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("PATHNAME");
v = v.<oadd.org.apache.hadoop.fs.shell.Count: java.io.PrintStream out>;
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
label:
return;
}
private java.util.List getAndCheckStorageTypes(java.lang.String)
{
java.lang.String[] v;
java.util.ArrayList v;
oadd.org.apache.hadoop.fs.StorageType v;
java.util.List v;
oadd.org.apache.hadoop.fs.shell.Count v;
int v, v;
java.lang.String v, v, v, v;
boolean v, v;
v := @this: oadd.org.apache.hadoop.fs.shell.Count;
v := @parameter: java.lang.String;
v = "";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = "all";
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>(v);
if v == 0 goto label;
label:
v = staticinvoke <oadd.org.apache.hadoop.fs.StorageType: java.util.List getTypesSupportingQuota()>();
return v;
label:
v = staticinvoke <oadd.org.apache.commons.lang.StringUtils: java.lang.String[] split(java.lang.String,char)>(v, 44);
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = staticinvoke <oadd.org.apache.hadoop.fs.StorageType: oadd.org.apache.hadoop.fs.StorageType parseStorageType(java.lang.String)>(v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
return v;
}
protected void processPath(oadd.org.apache.hadoop.fs.shell.PathData) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.shell.PathData v;
oadd.org.apache.hadoop.fs.QuotaUsage v;
java.lang.String v, v, v, v, v;
boolean v, v, v, v, v, v, v, v, v;
java.io.PrintStream v;
oadd.org.apache.hadoop.fs.ContentSummary v, v;
java.util.List v;
oadd.org.apache.hadoop.fs.shell.Count v;
java.lang.StringBuilder v;
oadd.org.apache.hadoop.fs.Path v, v, v;
oadd.org.apache.hadoop.fs.FileSystem v, v, v;
v := @this: oadd.org.apache.hadoop.fs.shell.Count;
v := @parameter: oadd.org.apache.hadoop.fs.shell.PathData;
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
v = v.<oadd.org.apache.hadoop.fs.shell.Count: boolean showQuotasAndUsageOnly>;
if v != 0 goto label;
v = v.<oadd.org.apache.hadoop.fs.shell.Count: boolean showQuotabyType>;
if v == 0 goto label;
label:
v = v.<oadd.org.apache.hadoop.fs.shell.PathData: oadd.org.apache.hadoop.fs.FileSystem fs>;
v = v.<oadd.org.apache.hadoop.fs.shell.PathData: oadd.org.apache.hadoop.fs.Path path>;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.QuotaUsage getQuotaUsage(oadd.org.apache.hadoop.fs.Path)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.shell.Count: boolean isHumanReadable()>();
v = v.<oadd.org.apache.hadoop.fs.shell.Count: boolean showQuotabyType>;
v = v.<oadd.org.apache.hadoop.fs.shell.Count: java.util.List storageTypes>;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.QuotaUsage: java.lang.String toString(boolean,boolean,java.util.List)>(v, v, v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
goto label;
label:
v = v.<oadd.org.apache.hadoop.fs.shell.PathData: oadd.org.apache.hadoop.fs.FileSystem fs>;
v = v.<oadd.org.apache.hadoop.fs.shell.PathData: oadd.org.apache.hadoop.fs.Path path>;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.ContentSummary getContentSummary(oadd.org.apache.hadoop.fs.Path)>(v);
v = v.<oadd.org.apache.hadoop.fs.shell.Count: boolean showQuotas>;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.shell.Count: boolean isHumanReadable()>();
v = v.<oadd.org.apache.hadoop.fs.shell.Count: boolean excludeSnapshots>;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.ContentSummary: java.lang.String toString(boolean,boolean,boolean)>(v, v, v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
label:
v = v.<oadd.org.apache.hadoop.fs.shell.Count: boolean displayECPolicy>;
if v == 0 goto label;
v = v.<oadd.org.apache.hadoop.fs.shell.PathData: oadd.org.apache.hadoop.fs.FileSystem fs>;
v = v.<oadd.org.apache.hadoop.fs.shell.PathData: oadd.org.apache.hadoop.fs.Path path>;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.ContentSummary getContentSummary(oadd.org.apache.hadoop.fs.Path)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.ContentSummary: java.lang.String getErasureCodingPolicy()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("Replicated");
if v != 0 goto label;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("EC:");
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.ContentSummary: java.lang.String getErasureCodingPolicy()>();
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(" ");
label:
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.Object)>(v);
v = v.<oadd.org.apache.hadoop.fs.shell.Count: java.io.PrintStream out>;
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
return;
}
boolean isShowQuotas()
{
oadd.org.apache.hadoop.fs.shell.Count v;
boolean v;
v := @this: oadd.org.apache.hadoop.fs.shell.Count;
v = v.<oadd.org.apache.hadoop.fs.shell.Count: boolean showQuotas>;
return v;
}
boolean isHumanReadable()
{
oadd.org.apache.hadoop.fs.shell.Count v;
boolean v;
v := @this: oadd.org.apache.hadoop.fs.shell.Count;
v = v.<oadd.org.apache.hadoop.fs.shell.Count: boolean humanReadable>;
return v;
}
boolean isShowQuotabyType()
{
oadd.org.apache.hadoop.fs.shell.Count v;
boolean v;
v := @this: oadd.org.apache.hadoop.fs.shell.Count;
v = v.<oadd.org.apache.hadoop.fs.shell.Count: boolean showQuotabyType>;
return v;
}
java.util.List getStorageTypes()
{
java.util.List v;
oadd.org.apache.hadoop.fs.shell.Count v;
v := @this: oadd.org.apache.hadoop.fs.shell.Count;
v = v.<oadd.org.apache.hadoop.fs.shell.Count: java.util.List storageTypes>;
return v;
}
static void <clinit>()
{
java.lang.String[] v, v, v;
java.lang.String v, v, v, v;
v = staticinvoke <oadd.org.apache.hadoop.fs.ContentSummary: java.lang.String[] getHeaderFields()>();
v = staticinvoke <oadd.org.apache.commons.lang.StringUtils: java.lang.String join(java.lang.Object[],char)>(v, 32);
v = staticinvoke <oadd.org.apache.hadoop.fs.ContentSummary: java.lang.String[] getQuotaHeaderFields()>();
v = staticinvoke <oadd.org.apache.commons.lang.StringUtils: java.lang.String join(java.lang.Object[],char)>(v, 32);
v = staticinvoke <oadd.org.apache.hadoop.fs.ContentSummary: java.lang.String[] getHeaderFields()>();
v = staticinvoke <oadd.org.apache.commons.lang.StringUtils: java.lang.String join(java.lang.Object[],char)>(v, 32);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String)>(v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Count the number of directories, files and bytes under the paths\nthat match the specified file pattern.  The output columns are:\n\u PATHNAME\nor, with the -q option:\n\u0001\n      \u PATHNAME\nThe -h option shows file sizes in human readable format.\nThe -v option displays a header line.\nThe -x option excludes snapshots from being calculated. \nThe -t option displays quota by storage types.\nIt should be used with -q or -u option, otherwise it will be ignored.\nIf a comma-separated list of storage types is given after the -t option, \nit displays the quota and usage for the specified types. \nOtherwise, it displays the quota and usage for all the storage \ntypes that support quota. The list of possible storage types(case insensitive):\nram_disk, ssd, disk and archive.\nIt can also pass the value \'\', \'all\' or \'ALL\' to specify all the storage types.\nThe -u option shows the quota and \nthe usage against the quota without the detailed content summary.The -e option shows the erasure coding policy.");
<oadd.org.apache.hadoop.fs.shell.Count: java.lang.String DESCRIPTION> = v;
return;
}
}