public abstract class oadd.org.apache.hadoop.fs.FileSystem extends oadd.org.apache.hadoop.conf.Configured implements java.io.Closeable, oadd.org.apache.hadoop.security.token.DelegationTokenIssuer, oadd.org.apache.hadoop.fs.PathCapabilities
{
public static final java.lang.String FS_DEFAULT_NAME_KEY;
public static final java.lang.String DEFAULT_FS;
public static final oadd.org.apache.commons.logging.Log LOG;
private static final org.slf4j.Logger LOGGER;
public static final int SHUTDOWN_HOOK_PRIORITY;
public static final java.lang.String TRASH_PREFIX;
public static final java.lang.String USER_HOME_PREFIX;
static final oadd.org.apache.hadoop.fs.FileSystem$Cache CACHE;
private oadd.org.apache.hadoop.fs.FileSystem$Cache$Key key;
private static final java.util.Map statisticsTable;
protected oadd.org.apache.hadoop.fs.FileSystem$Statistics statistics;
private final java.util.Set deleteOnExit;
boolean resolveSymlinks;
private static final oadd.org.apache.hadoop.fs.PathFilter DEFAULT_FILTER;
private static volatile boolean FILE_SYSTEMS_LOADED;
private static final java.util.Map SERVICE_FILE_SYSTEMS;
private static boolean symlinksEnabled;
static void addFileSystemForTesting(java.net.URI, oadd.org.apache.hadoop.conf.Configuration, oadd.org.apache.hadoop.fs.FileSystem) throws java.io.IOException
{
java.util.Map v;
oadd.org.apache.hadoop.fs.FileSystem$Cache$Key v;
oadd.org.apache.hadoop.conf.Configuration v;
java.net.URI v;
oadd.org.apache.hadoop.fs.FileSystem$Cache v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @parameter: java.net.URI;
v := @parameter: oadd.org.apache.hadoop.conf.Configuration;
v := @parameter: oadd.org.apache.hadoop.fs.FileSystem;
v = <oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileSystem$Cache CACHE>;
v = v.<oadd.org.apache.hadoop.fs.FileSystem$Cache: java.util.Map map>;
v = new oadd.org.apache.hadoop.fs.FileSystem$Cache$Key;
specialinvoke v.<oadd.org.apache.hadoop.fs.FileSystem$Cache$Key: void <init>(java.net.URI,oadd.org.apache.hadoop.conf.Configuration)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
return;
}
static int cacheSize()
{
int v;
oadd.org.apache.hadoop.fs.FileSystem$Cache v;
java.util.Map v;
v = <oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileSystem$Cache CACHE>;
v = v.<oadd.org.apache.hadoop.fs.FileSystem$Cache: java.util.Map map>;
v = interfaceinvoke v.<java.util.Map: int size()>();
return v;
}
public static oadd.org.apache.hadoop.fs.FileSystem get(java.net.URI, oadd.org.apache.hadoop.conf.Configuration, java.lang.String) throws java.io.IOException, java.lang.InterruptedException
{
oadd.org.apache.hadoop.security.UserGroupInformation v;
java.lang.Object v;
oadd.org.apache.hadoop.conf.Configuration v;
java.lang.String v, v;
java.net.URI v;
oadd.org.apache.hadoop.fs.FileSystem$1 v;
v := @parameter: java.net.URI;
v := @parameter: oadd.org.apache.hadoop.conf.Configuration;
v := @parameter: java.lang.String;
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: java.lang.String get(java.lang.String)>("hadoop.security.kerberos.ticket.cache.path");
v = staticinvoke <oadd.org.apache.hadoop.security.UserGroupInformation: oadd.org.apache.hadoop.security.UserGroupInformation getBestUGI(java.lang.String,java.lang.String)>(v, v);
v = new oadd.org.apache.hadoop.fs.FileSystem$1;
specialinvoke v.<oadd.org.apache.hadoop.fs.FileSystem$1: void <init>(java.net.URI,oadd.org.apache.hadoop.conf.Configuration)>(v, v);
v = virtualinvoke v.<oadd.org.apache.hadoop.security.UserGroupInformation: java.lang.Object doAs(java.security.PrivilegedExceptionAction)>(v);
return v;
}
public static oadd.org.apache.hadoop.fs.FileSystem get(oadd.org.apache.hadoop.conf.Configuration) throws java.io.IOException
{
oadd.org.apache.hadoop.conf.Configuration v;
java.net.URI v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @parameter: oadd.org.apache.hadoop.conf.Configuration;
v = staticinvoke <oadd.org.apache.hadoop.fs.FileSystem: java.net.URI getDefaultUri(oadd.org.apache.hadoop.conf.Configuration)>(v);
v = staticinvoke <oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileSystem get(java.net.URI,oadd.org.apache.hadoop.conf.Configuration)>(v, v);
return v;
}
public static java.net.URI getDefaultUri(oadd.org.apache.hadoop.conf.Configuration)
{
oadd.org.apache.hadoop.conf.Configuration v;
java.lang.String v, v, v, v;
java.net.URI v;
java.lang.IllegalArgumentException v;
v := @parameter: oadd.org.apache.hadoop.conf.Configuration;
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: java.lang.String get(java.lang.String,java.lang.String)>("fs.defaultFS", "file:///");
v = staticinvoke <oadd.org.apache.hadoop.fs.FileSystem: java.lang.String fixName(java.lang.String)>(v);
v = staticinvoke <java.net.URI: java.net.URI create(java.lang.String)>(v);
v = virtualinvoke v.<java.net.URI: java.lang.String getScheme()>();
if v != null goto label;
v = new java.lang.IllegalArgumentException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.net.URI)>(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[])>("No scheme in default FS: \u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
}
public static void setDefaultUri(oadd.org.apache.hadoop.conf.Configuration, java.net.URI)
{
oadd.org.apache.hadoop.conf.Configuration v;
java.lang.String v;
java.net.URI v;
v := @parameter: oadd.org.apache.hadoop.conf.Configuration;
v := @parameter: java.net.URI;
v = virtualinvoke v.<java.net.URI: java.lang.String toString()>();
virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: void set(java.lang.String,java.lang.String)>("fs.defaultFS", v);
return;
}
public static void setDefaultUri(oadd.org.apache.hadoop.conf.Configuration, java.lang.String)
{
oadd.org.apache.hadoop.conf.Configuration v;
java.lang.String v, v;
java.net.URI v;
v := @parameter: oadd.org.apache.hadoop.conf.Configuration;
v := @parameter: java.lang.String;
v = staticinvoke <oadd.org.apache.hadoop.fs.FileSystem: java.lang.String fixName(java.lang.String)>(v);
v = staticinvoke <java.net.URI: java.net.URI create(java.lang.String)>(v);
staticinvoke <oadd.org.apache.hadoop.fs.FileSystem: void setDefaultUri(oadd.org.apache.hadoop.conf.Configuration,java.net.URI)>(v, v);
return;
}
public void initialize(java.net.URI, oadd.org.apache.hadoop.conf.Configuration) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.FileSystem$Statistics v;
java.lang.Class v;
oadd.org.apache.hadoop.conf.Configuration v;
java.lang.String v, v, v;
java.net.URI v, v;
oadd.org.apache.hadoop.fs.FileSystem v;
boolean v, v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: java.net.URI;
v := @parameter: oadd.org.apache.hadoop.conf.Configuration;
v = virtualinvoke v.<java.net.URI: java.lang.String getScheme()>();
if v == null goto label;
v = virtualinvoke v.<java.net.URI: java.lang.String getScheme()>();
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v == 0 goto label;
label:
v = staticinvoke <oadd.org.apache.hadoop.fs.FileSystem: java.net.URI getDefaultUri(oadd.org.apache.hadoop.conf.Configuration)>(v);
v = virtualinvoke v.<java.net.URI: java.lang.String getScheme()>();
goto label;
label:
v = virtualinvoke v.<java.net.URI: java.lang.String getScheme()>();
label:
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = staticinvoke <oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileSystem$Statistics getStatistics(java.lang.String,java.lang.Class)>(v, v);
v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileSystem$Statistics statistics> = v;
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: boolean getBoolean(java.lang.String,boolean)>("fs.client.resolve.remote.symlinks", 1);
v.<oadd.org.apache.hadoop.fs.FileSystem: boolean resolveSymlinks> = v;
return;
}
public java.lang.String getScheme()
{
java.lang.UnsupportedOperationException v;
java.lang.Class v;
java.lang.String v, v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v = new java.lang.UnsupportedOperationException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("Not implemented by the \u FileSystem implementation");
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>(v);
throw v;
}
public abstract java.net.URI getUri();
protected java.net.URI getCanonicalUri()
{
java.net.URI v, v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: java.net.URI getUri()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: java.net.URI canonicalizeUri(java.net.URI)>(v);
return v;
}
protected java.net.URI canonicalizeUri(java.net.URI)
{
java.net.URISyntaxException v;
java.lang.AssertionError v;
int v, v, v, v;
java.lang.String v, v, v, v, v, v, v;
java.net.URI v, v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: java.net.URI;
v = virtualinvoke v.<java.net.URI: int getPort()>();
v = (int) -1;
if v != v goto label;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: int getDefaultPort()>();
if v <= 0 goto label;
label:
v = new java.net.URI;
v = virtualinvoke v.<java.net.URI: java.lang.String getScheme()>();
v = virtualinvoke v.<java.net.URI: java.lang.String getUserInfo()>();
v = virtualinvoke v.<java.net.URI: java.lang.String getHost()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: int getDefaultPort()>();
v = virtualinvoke v.<java.net.URI: java.lang.String getPath()>();
v = virtualinvoke v.<java.net.URI: java.lang.String getQuery()>();
v = virtualinvoke v.<java.net.URI: java.lang.String getFragment()>();
specialinvoke v.<java.net.URI: void <init>(java.lang.String,java.lang.String,java.lang.String,int,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v, v, v, v);
v = v;
label:
goto label;
label:
v := @caughtexception;
v = new java.lang.AssertionError;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.net.URI)>(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[])>("Valid URI became unparseable: \u0001");
specialinvoke v.<java.lang.AssertionError: void <init>(java.lang.Object)>(v);
throw v;
label:
return v;
catch java.net.URISyntaxException from label to label with label;
}
protected int getDefaultPort()
{
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
return 0;
}
protected static oadd.org.apache.hadoop.fs.FileSystem getFSofPath(oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.conf.Configuration) throws oadd.org.apache.hadoop.fs.UnsupportedFileSystemException, java.io.IOException
{
oadd.org.apache.hadoop.conf.Configuration v;
java.net.URI v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.conf.Configuration;
virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: void checkNotSchemeWithRelative()>();
virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: void checkNotRelative()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: java.net.URI toUri()>();
v = staticinvoke <oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileSystem get(java.net.URI,oadd.org.apache.hadoop.conf.Configuration)>(v, v);
return v;
}
public java.lang.String getCanonicalServiceName()
{
int v;
java.lang.String v;
java.net.URI v;
oadd.org.apache.hadoop.fs.FileSystem v;
oadd.org.apache.hadoop.fs.FileSystem[] v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileSystem[] getChildFileSystems()>();
if v != null goto label;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: java.net.URI getUri()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: int getDefaultPort()>();
v = staticinvoke <oadd.org.apache.hadoop.security.SecurityUtil: java.lang.String buildDTServiceName(java.net.URI,int)>(v, v);
goto label;
label:
v = null;
label:
return v;
}
public java.lang.String getName()
{
java.lang.String v;
java.net.URI v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: java.net.URI getUri()>();
v = virtualinvoke v.<java.net.URI: java.lang.String toString()>();
return v;
}
public static oadd.org.apache.hadoop.fs.FileSystem getNamed(java.lang.String, oadd.org.apache.hadoop.conf.Configuration) throws java.io.IOException
{
oadd.org.apache.hadoop.conf.Configuration v;
java.lang.String v, v;
java.net.URI v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @parameter: java.lang.String;
v := @parameter: oadd.org.apache.hadoop.conf.Configuration;
v = staticinvoke <oadd.org.apache.hadoop.fs.FileSystem: java.lang.String fixName(java.lang.String)>(v);
v = staticinvoke <java.net.URI: java.net.URI create(java.lang.String)>(v);
v = staticinvoke <oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileSystem get(java.net.URI,oadd.org.apache.hadoop.conf.Configuration)>(v, v);
return v;
}
private static java.lang.String fixName(java.lang.String)
{
org.slf4j.Logger v, v;
int v, v;
java.lang.String v, v;
boolean v;
v := @parameter: java.lang.String;
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("local");
if v == 0 goto label;
v = <oadd.org.apache.hadoop.fs.FileSystem: org.slf4j.Logger LOGGER>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>("\"local\" is a deprecated filesystem name. Use \"file:///\" instead.");
v = "file:///";
goto label;
label:
v = virtualinvoke v.<java.lang.String: int indexOf(int)>(47);
v = (int) -1;
if v != v goto label;
v = <oadd.org.apache.hadoop.fs.FileSystem: org.slf4j.Logger LOGGER>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(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[])>("\"\u0001\" is a deprecated filesystem name. Use \"hdfs://\u0001/\" instead.");
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("hdfs://\u0001");
label:
return v;
}
public static oadd.org.apache.hadoop.fs.LocalFileSystem getLocal(oadd.org.apache.hadoop.conf.Configuration) throws java.io.IOException
{
oadd.org.apache.hadoop.conf.Configuration v;
java.net.URI v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @parameter: oadd.org.apache.hadoop.conf.Configuration;
v = <oadd.org.apache.hadoop.fs.LocalFileSystem: java.net.URI NAME>;
v = staticinvoke <oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileSystem get(java.net.URI,oadd.org.apache.hadoop.conf.Configuration)>(v, v);
return v;
}
public static oadd.org.apache.hadoop.fs.FileSystem get(java.net.URI, oadd.org.apache.hadoop.conf.Configuration) throws java.io.IOException
{
java.lang.Object[] v;
oadd.org.apache.hadoop.conf.Configuration v;
java.lang.String v, v, v, v, v;
java.net.URI v, v;
oadd.org.apache.hadoop.fs.FileSystem$Cache v;
boolean v, v;
org.slf4j.Logger v;
oadd.org.apache.hadoop.fs.FileSystem v, v, v, v;
v := @parameter: java.net.URI;
v := @parameter: oadd.org.apache.hadoop.conf.Configuration;
v = virtualinvoke v.<java.net.URI: java.lang.String getScheme()>();
v = virtualinvoke v.<java.net.URI: java.lang.String getAuthority()>();
if v != null goto label;
if v != null goto label;
v = staticinvoke <oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileSystem get(oadd.org.apache.hadoop.conf.Configuration)>(v);
return v;
label:
if v == null goto label;
if v != null goto label;
v = staticinvoke <oadd.org.apache.hadoop.fs.FileSystem: java.net.URI getDefaultUri(oadd.org.apache.hadoop.conf.Configuration)>(v);
v = virtualinvoke v.<java.net.URI: java.lang.String getScheme()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = virtualinvoke v.<java.net.URI: java.lang.String getAuthority()>();
if v == null goto label;
v = staticinvoke <oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileSystem get(java.net.URI,oadd.org.apache.hadoop.conf.Configuration)>(v, v);
return v;
label:
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("fs.%s.impl.disable.cache", v);
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: boolean getBoolean(java.lang.String,boolean)>(v, 0);
if v == 0 goto label;
v = <oadd.org.apache.hadoop.fs.FileSystem: org.slf4j.Logger LOGGER>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Bypassing cache to create filesystem {}", v);
v = staticinvoke <oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileSystem createFileSystem(java.net.URI,oadd.org.apache.hadoop.conf.Configuration)>(v, v);
return v;
label:
v = <oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileSystem$Cache CACHE>;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem$Cache: oadd.org.apache.hadoop.fs.FileSystem get(java.net.URI,oadd.org.apache.hadoop.conf.Configuration)>(v, v);
return v;
}
public static oadd.org.apache.hadoop.fs.FileSystem newInstance(java.net.URI, oadd.org.apache.hadoop.conf.Configuration, java.lang.String) throws java.io.IOException, java.lang.InterruptedException
{
oadd.org.apache.hadoop.security.UserGroupInformation v;
java.lang.Object v;
oadd.org.apache.hadoop.conf.Configuration v;
java.lang.String v, v;
java.net.URI v;
oadd.org.apache.hadoop.fs.FileSystem$2 v;
v := @parameter: java.net.URI;
v := @parameter: oadd.org.apache.hadoop.conf.Configuration;
v := @parameter: java.lang.String;
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: java.lang.String get(java.lang.String)>("hadoop.security.kerberos.ticket.cache.path");
v = staticinvoke <oadd.org.apache.hadoop.security.UserGroupInformation: oadd.org.apache.hadoop.security.UserGroupInformation getBestUGI(java.lang.String,java.lang.String)>(v, v);
v = new oadd.org.apache.hadoop.fs.FileSystem$2;
specialinvoke v.<oadd.org.apache.hadoop.fs.FileSystem$2: void <init>(java.net.URI,oadd.org.apache.hadoop.conf.Configuration)>(v, v);
v = virtualinvoke v.<oadd.org.apache.hadoop.security.UserGroupInformation: java.lang.Object doAs(java.security.PrivilegedExceptionAction)>(v);
return v;
}
public static oadd.org.apache.hadoop.fs.FileSystem newInstance(java.net.URI, oadd.org.apache.hadoop.conf.Configuration) throws java.io.IOException
{
oadd.org.apache.hadoop.conf.Configuration v;
java.lang.String v, v, v, v;
java.net.URI v, v;
oadd.org.apache.hadoop.fs.FileSystem$Cache v;
oadd.org.apache.hadoop.fs.FileSystem v, v, v;
boolean v;
v := @parameter: java.net.URI;
v := @parameter: oadd.org.apache.hadoop.conf.Configuration;
v = virtualinvoke v.<java.net.URI: java.lang.String getScheme()>();
v = virtualinvoke v.<java.net.URI: java.lang.String getAuthority()>();
if v != null goto label;
v = staticinvoke <oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileSystem newInstance(oadd.org.apache.hadoop.conf.Configuration)>(v);
return v;
label:
if v != null goto label;
v = staticinvoke <oadd.org.apache.hadoop.fs.FileSystem: java.net.URI getDefaultUri(oadd.org.apache.hadoop.conf.Configuration)>(v);
v = virtualinvoke v.<java.net.URI: java.lang.String getScheme()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = virtualinvoke v.<java.net.URI: java.lang.String getAuthority()>();
if v == null goto label;
v = staticinvoke <oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileSystem newInstance(java.net.URI,oadd.org.apache.hadoop.conf.Configuration)>(v, v);
return v;
label:
v = <oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileSystem$Cache CACHE>;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem$Cache: oadd.org.apache.hadoop.fs.FileSystem getUnique(java.net.URI,oadd.org.apache.hadoop.conf.Configuration)>(v, v);
return v;
}
public static oadd.org.apache.hadoop.fs.FileSystem newInstance(oadd.org.apache.hadoop.conf.Configuration) throws java.io.IOException
{
oadd.org.apache.hadoop.conf.Configuration v;
java.net.URI v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @parameter: oadd.org.apache.hadoop.conf.Configuration;
v = staticinvoke <oadd.org.apache.hadoop.fs.FileSystem: java.net.URI getDefaultUri(oadd.org.apache.hadoop.conf.Configuration)>(v);
v = staticinvoke <oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileSystem newInstance(java.net.URI,oadd.org.apache.hadoop.conf.Configuration)>(v, v);
return v;
}
public static oadd.org.apache.hadoop.fs.LocalFileSystem newInstanceLocal(oadd.org.apache.hadoop.conf.Configuration) throws java.io.IOException
{
oadd.org.apache.hadoop.conf.Configuration v;
java.net.URI v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @parameter: oadd.org.apache.hadoop.conf.Configuration;
v = <oadd.org.apache.hadoop.fs.LocalFileSystem: java.net.URI NAME>;
v = staticinvoke <oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileSystem newInstance(java.net.URI,oadd.org.apache.hadoop.conf.Configuration)>(v, v);
return v;
}
public static void closeAll() throws java.io.IOException
{
oadd.org.apache.hadoop.fs.FileSystem$Cache v;
v = <oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileSystem$Cache CACHE>;
virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem$Cache: void closeAll()>();
return;
}
public static void closeAllForUGI(oadd.org.apache.hadoop.security.UserGroupInformation) throws java.io.IOException
{
oadd.org.apache.hadoop.security.UserGroupInformation v;
oadd.org.apache.hadoop.fs.FileSystem$Cache v;
v := @parameter: oadd.org.apache.hadoop.security.UserGroupInformation;
v = <oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileSystem$Cache CACHE>;
virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem$Cache: void closeAll(oadd.org.apache.hadoop.security.UserGroupInformation)>(v);
return;
}
public oadd.org.apache.hadoop.fs.Path makeQualified(oadd.org.apache.hadoop.fs.Path)
{
java.net.URI v;
oadd.org.apache.hadoop.fs.Path v, v, v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: void checkPath(oadd.org.apache.hadoop.fs.Path)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: java.net.URI getUri()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.Path getWorkingDirectory()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: oadd.org.apache.hadoop.fs.Path makeQualified(java.net.URI,oadd.org.apache.hadoop.fs.Path)>(v, v);
return v;
}
public oadd.org.apache.hadoop.security.token.Token getDelegationToken(java.lang.String) throws java.io.IOException
{
java.lang.String v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: java.lang.String;
return null;
}
public oadd.org.apache.hadoop.fs.FileSystem[] getChildFileSystems()
{
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
return null;
}
public oadd.org.apache.hadoop.security.token.DelegationTokenIssuer[] getAdditionalTokenIssuers() throws java.io.IOException
{
oadd.org.apache.hadoop.fs.FileSystem v;
oadd.org.apache.hadoop.fs.FileSystem[] v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileSystem[] getChildFileSystems()>();
return v;
}
public static oadd.org.apache.hadoop.fs.FSDataOutputStream create(oadd.org.apache.hadoop.fs.FileSystem, oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.permission.FsPermission) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.FSDataOutputStream v;
oadd.org.apache.hadoop.fs.permission.FsPermission v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @parameter: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.permission.FsPermission;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FSDataOutputStream create(oadd.org.apache.hadoop.fs.Path)>(v);
virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: void setPermission(oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.permission.FsPermission)>(v, v);
return v;
}
public static boolean mkdirs(oadd.org.apache.hadoop.fs.FileSystem, oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.permission.FsPermission) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.permission.FsPermission v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
boolean v;
v := @parameter: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.permission.FsPermission;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: boolean mkdirs(oadd.org.apache.hadoop.fs.Path)>(v);
virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: void setPermission(oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.permission.FsPermission)>(v, v);
return v;
}
protected void <init>()
{
java.util.TreeSet v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
specialinvoke v.<oadd.org.apache.hadoop.conf.Configured: void <init>(oadd.org.apache.hadoop.conf.Configuration)>(null);
v = new java.util.TreeSet;
specialinvoke v.<java.util.TreeSet: void <init>()>();
v.<oadd.org.apache.hadoop.fs.FileSystem: java.util.Set deleteOnExit> = v;
return;
}
protected void checkPath(oadd.org.apache.hadoop.fs.Path)
{
oadd.org.apache.hadoop.conf.Configuration v;
java.lang.String v, v, v, v, v, v, v;
java.net.URI v, v, v, v, v;
boolean v, v, v, v;
java.lang.IllegalArgumentException v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
if v == null goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <oadd.com.google.common.base.Preconditions: void checkArgument(boolean,java.lang.Object)>(v, "null path");
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: java.net.URI toUri()>();
v = virtualinvoke v.<java.net.URI: java.lang.String getScheme()>();
if v != null goto label;
return;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: java.net.URI getCanonicalUri()>();
v = virtualinvoke v.<java.net.URI: java.lang.String getScheme()>();
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>(v);
if v == 0 goto label;
v = virtualinvoke v.<java.net.URI: java.lang.String getAuthority()>();
v = virtualinvoke v.<java.net.URI: java.lang.String getAuthority()>();
if v != null goto label;
if v == null goto label;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.conf.Configuration getConf()>();
v = staticinvoke <oadd.org.apache.hadoop.fs.FileSystem: java.net.URI getDefaultUri(oadd.org.apache.hadoop.conf.Configuration)>(v);
v = virtualinvoke v.<java.net.URI: java.lang.String getScheme()>();
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>(v);
if v == 0 goto label;
v = v;
goto label;
label:
v = null;
label:
if v == null goto label;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: java.net.URI canonicalizeUri(java.net.URI)>(v);
v = virtualinvoke v.<java.net.URI: java.lang.String getAuthority()>();
if v == v goto label;
if v == null goto label;
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>(v);
if v == 0 goto label;
label:
return;
label:
v = new java.lang.IllegalArgumentException;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: java.net.URI getUri()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (oadd.org.apache.hadoop.fs.Path,java.net.URI)>(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[])>("Wrong FS: \u, expected: \u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
}
public oadd.org.apache.hadoop.fs.BlockLocation[] getFileBlockLocations(oadd.org.apache.hadoop.fs.FileStatus, long, long) throws java.io.IOException
{
java.lang.String[] v, v;
long v, v, v, v;
java.lang.IllegalArgumentException v;
oadd.org.apache.hadoop.fs.BlockLocation v;
byte v, v, v;
oadd.org.apache.hadoop.fs.FileStatus v;
oadd.org.apache.hadoop.fs.BlockLocation[] v, v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.FileStatus;
v := @parameter: long;
v := @parameter: long;
if v != null goto label;
return null;
label:
v = v cmp 0L;
if v < 0 goto label;
v = v cmp 0L;
if v >= 0 goto label;
label:
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Invalid start or len parameter");
throw v;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: long getLen()>();
v = v cmp v;
if v > 0 goto label;
v = newarray (oadd.org.apache.hadoop.fs.BlockLocation)[0];
return v;
label:
v = newarray (java.lang.String)[1];
v[0] = "localhost:9866";
v = newarray (java.lang.String)[1];
v[0] = "localhost";
v = newarray (oadd.org.apache.hadoop.fs.BlockLocation)[1];
v = new oadd.org.apache.hadoop.fs.BlockLocation;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: long getLen()>();
specialinvoke v.<oadd.org.apache.hadoop.fs.BlockLocation: void <init>(java.lang.String[],java.lang.String[],long,long)>(v, v, 0L, v);
v[0] = v;
return v;
}
public oadd.org.apache.hadoop.fs.BlockLocation[] getFileBlockLocations(oadd.org.apache.hadoop.fs.Path, long, long) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.FileStatus v;
long v, v;
oadd.org.apache.hadoop.fs.BlockLocation[] v;
oadd.org.apache.hadoop.fs.Path v;
java.lang.NullPointerException v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: long;
v := @parameter: long;
if v != null goto label;
v = new java.lang.NullPointerException;
specialinvoke v.<java.lang.NullPointerException: void <init>()>();
throw v;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileStatus getFileStatus(oadd.org.apache.hadoop.fs.Path)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.BlockLocation[] getFileBlockLocations(oadd.org.apache.hadoop.fs.FileStatus,long,long)>(v, v, v);
return v;
}
public oadd.org.apache.hadoop.fs.FsServerDefaults getServerDefaults() throws java.io.IOException
{
long v;
oadd.org.apache.hadoop.util.DataChecksum$Type v;
short v;
int v, v;
oadd.org.apache.hadoop.conf.Configuration v;
oadd.org.apache.hadoop.fs.FsServerDefaults v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.conf.Configuration getConf()>();
v = new oadd.org.apache.hadoop.fs.FsServerDefaults;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: long getDefaultBlockSize()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: int getInt(java.lang.String,int)>("oadd.io.bytes.per.checksum", 512);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: short getDefaultReplication()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: int getInt(java.lang.String,int)>("oadd.io.file.buffer.size", 4096);
v = <oadd.org.apache.hadoop.util.DataChecksum$Type: oadd.org.apache.hadoop.util.DataChecksum$Type CRC32>;
specialinvoke v.<oadd.org.apache.hadoop.fs.FsServerDefaults: void <init>(long,int,int,short,int,boolean,long,oadd.org.apache.hadoop.util.DataChecksum$Type,java.lang.String)>(v, v, 65536, v, v, 0, 0L, v, "");
return v;
}
public oadd.org.apache.hadoop.fs.FsServerDefaults getServerDefaults(oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.FsServerDefaults v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FsServerDefaults getServerDefaults()>();
return v;
}
public oadd.org.apache.hadoop.fs.Path resolvePath(oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.FileStatus v;
oadd.org.apache.hadoop.fs.Path v, v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: void checkPath(oadd.org.apache.hadoop.fs.Path)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileStatus getFileStatus(oadd.org.apache.hadoop.fs.Path)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: oadd.org.apache.hadoop.fs.Path getPath()>();
return v;
}
public abstract oadd.org.apache.hadoop.fs.FSDataInputStream open(oadd.org.apache.hadoop.fs.Path, int) throws java.io.IOException;
public oadd.org.apache.hadoop.fs.FSDataInputStream open(oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.FSDataInputStream v;
int v;
oadd.org.apache.hadoop.conf.Configuration v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.conf.Configuration getConf()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: int getInt(java.lang.String,int)>("oadd.io.file.buffer.size", 4096);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FSDataInputStream open(oadd.org.apache.hadoop.fs.Path,int)>(v, v);
return v;
}
public oadd.org.apache.hadoop.fs.FSDataInputStream open(oadd.org.apache.hadoop.fs.PathHandle) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.FSDataInputStream v;
int v;
oadd.org.apache.hadoop.conf.Configuration v;
oadd.org.apache.hadoop.fs.FileSystem v;
oadd.org.apache.hadoop.fs.PathHandle v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.PathHandle;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.conf.Configuration getConf()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: int getInt(java.lang.String,int)>("oadd.io.file.buffer.size", 4096);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FSDataInputStream open(oadd.org.apache.hadoop.fs.PathHandle,int)>(v, v);
return v;
}
public oadd.org.apache.hadoop.fs.FSDataInputStream open(oadd.org.apache.hadoop.fs.PathHandle, int) throws java.io.IOException
{
java.lang.UnsupportedOperationException v;
int v;
oadd.org.apache.hadoop.fs.FileSystem v;
oadd.org.apache.hadoop.fs.PathHandle v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.PathHandle;
v := @parameter: int;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>()>();
throw v;
}
public final transient oadd.org.apache.hadoop.fs.PathHandle getPathHandle(oadd.org.apache.hadoop.fs.FileStatus, oadd.org.apache.hadoop.fs.Options$HandleOpt[])
{
oadd.org.apache.hadoop.fs.FileStatus v;
oadd.org.apache.hadoop.fs.Options$HandleOpt[] v, v;
int v;
oadd.org.apache.hadoop.fs.FileSystem v;
oadd.org.apache.hadoop.fs.PathHandle v, v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.FileStatus;
v := @parameter: oadd.org.apache.hadoop.fs.Options$HandleOpt[];
if null == v goto label;
v = lengthof v;
if 0 != v goto label;
label:
v = staticinvoke <oadd.org.apache.hadoop.fs.Options$HandleOpt: oadd.org.apache.hadoop.fs.Options$HandleOpt[] path()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.PathHandle createPathHandle(oadd.org.apache.hadoop.fs.FileStatus,oadd.org.apache.hadoop.fs.Options$HandleOpt[])>(v, v);
return v;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.PathHandle createPathHandle(oadd.org.apache.hadoop.fs.FileStatus,oadd.org.apache.hadoop.fs.Options$HandleOpt[])>(v, v);
return v;
}
protected transient oadd.org.apache.hadoop.fs.PathHandle createPathHandle(oadd.org.apache.hadoop.fs.FileStatus, oadd.org.apache.hadoop.fs.Options$HandleOpt[])
{
java.lang.UnsupportedOperationException v;
oadd.org.apache.hadoop.fs.FileStatus v;
oadd.org.apache.hadoop.fs.Options$HandleOpt[] v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.FileStatus;
v := @parameter: oadd.org.apache.hadoop.fs.Options$HandleOpt[];
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>()>();
throw v;
}
public oadd.org.apache.hadoop.fs.FSDataOutputStream create(oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FSDataOutputStream v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FSDataOutputStream create(oadd.org.apache.hadoop.fs.Path,boolean)>(v, 1);
return v;
}
public oadd.org.apache.hadoop.fs.FSDataOutputStream create(oadd.org.apache.hadoop.fs.Path, boolean) throws java.io.IOException
{
long v;
short v;
oadd.org.apache.hadoop.fs.FSDataOutputStream v;
int v;
oadd.org.apache.hadoop.conf.Configuration v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
boolean v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: boolean;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.conf.Configuration getConf()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: int getInt(java.lang.String,int)>("oadd.io.file.buffer.size", 4096);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: short getDefaultReplication(oadd.org.apache.hadoop.fs.Path)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: long getDefaultBlockSize(oadd.org.apache.hadoop.fs.Path)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FSDataOutputStream create(oadd.org.apache.hadoop.fs.Path,boolean,int,short,long)>(v, v, v, v, v);
return v;
}
public oadd.org.apache.hadoop.fs.FSDataOutputStream create(oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.util.Progressable) throws java.io.IOException
{
oadd.org.apache.hadoop.util.Progressable v;
long v;
short v;
oadd.org.apache.hadoop.fs.FSDataOutputStream v;
int v;
oadd.org.apache.hadoop.conf.Configuration v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.util.Progressable;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.conf.Configuration getConf()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: int getInt(java.lang.String,int)>("oadd.io.file.buffer.size", 4096);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: short getDefaultReplication(oadd.org.apache.hadoop.fs.Path)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: long getDefaultBlockSize(oadd.org.apache.hadoop.fs.Path)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FSDataOutputStream create(oadd.org.apache.hadoop.fs.Path,boolean,int,short,long,oadd.org.apache.hadoop.util.Progressable)>(v, 1, v, v, v, v);
return v;
}
public oadd.org.apache.hadoop.fs.FSDataOutputStream create(oadd.org.apache.hadoop.fs.Path, short) throws java.io.IOException
{
short v;
oadd.org.apache.hadoop.fs.FSDataOutputStream v;
int v;
long v;
oadd.org.apache.hadoop.conf.Configuration v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: short;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.conf.Configuration getConf()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: int getInt(java.lang.String,int)>("oadd.io.file.buffer.size", 4096);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: long getDefaultBlockSize(oadd.org.apache.hadoop.fs.Path)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FSDataOutputStream create(oadd.org.apache.hadoop.fs.Path,boolean,int,short,long)>(v, 1, v, v, v);
return v;
}
public oadd.org.apache.hadoop.fs.FSDataOutputStream create(oadd.org.apache.hadoop.fs.Path, short, oadd.org.apache.hadoop.util.Progressable) throws java.io.IOException
{
oadd.org.apache.hadoop.util.Progressable v;
long v;
short v;
oadd.org.apache.hadoop.fs.FSDataOutputStream v;
int v;
oadd.org.apache.hadoop.conf.Configuration v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: short;
v := @parameter: oadd.org.apache.hadoop.util.Progressable;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.conf.Configuration getConf()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: int getInt(java.lang.String,int)>("oadd.io.file.buffer.size", 4096);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: long getDefaultBlockSize(oadd.org.apache.hadoop.fs.Path)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FSDataOutputStream create(oadd.org.apache.hadoop.fs.Path,boolean,int,short,long,oadd.org.apache.hadoop.util.Progressable)>(v, 1, v, v, v, v);
return v;
}
public oadd.org.apache.hadoop.fs.FSDataOutputStream create(oadd.org.apache.hadoop.fs.Path, boolean, int) throws java.io.IOException
{
short v;
oadd.org.apache.hadoop.fs.FSDataOutputStream v;
int v;
long v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
boolean v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: boolean;
v := @parameter: int;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: short getDefaultReplication(oadd.org.apache.hadoop.fs.Path)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: long getDefaultBlockSize(oadd.org.apache.hadoop.fs.Path)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FSDataOutputStream create(oadd.org.apache.hadoop.fs.Path,boolean,int,short,long)>(v, v, v, v, v);
return v;
}
public oadd.org.apache.hadoop.fs.FSDataOutputStream create(oadd.org.apache.hadoop.fs.Path, boolean, int, oadd.org.apache.hadoop.util.Progressable) throws java.io.IOException
{
oadd.org.apache.hadoop.util.Progressable v;
long v;
short v;
oadd.org.apache.hadoop.fs.FSDataOutputStream v;
int v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
boolean v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: boolean;
v := @parameter: int;
v := @parameter: oadd.org.apache.hadoop.util.Progressable;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: short getDefaultReplication(oadd.org.apache.hadoop.fs.Path)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: long getDefaultBlockSize(oadd.org.apache.hadoop.fs.Path)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FSDataOutputStream create(oadd.org.apache.hadoop.fs.Path,boolean,int,short,long,oadd.org.apache.hadoop.util.Progressable)>(v, v, v, v, v, v);
return v;
}
public oadd.org.apache.hadoop.fs.FSDataOutputStream create(oadd.org.apache.hadoop.fs.Path, boolean, int, short, long) throws java.io.IOException
{
short v;
oadd.org.apache.hadoop.fs.FSDataOutputStream v;
int v;
long v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
boolean v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: boolean;
v := @parameter: int;
v := @parameter: short;
v := @parameter: long;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FSDataOutputStream create(oadd.org.apache.hadoop.fs.Path,boolean,int,short,long,oadd.org.apache.hadoop.util.Progressable)>(v, v, v, v, v, null);
return v;
}
public oadd.org.apache.hadoop.fs.FSDataOutputStream create(oadd.org.apache.hadoop.fs.Path, boolean, int, short, long, oadd.org.apache.hadoop.util.Progressable) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.permission.FsPermission v, v, v;
oadd.org.apache.hadoop.util.Progressable v;
long v;
short v;
oadd.org.apache.hadoop.fs.FSDataOutputStream v;
int v;
oadd.org.apache.hadoop.conf.Configuration v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
boolean v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: boolean;
v := @parameter: int;
v := @parameter: short;
v := @parameter: long;
v := @parameter: oadd.org.apache.hadoop.util.Progressable;
v = staticinvoke <oadd.org.apache.hadoop.fs.permission.FsPermission: oadd.org.apache.hadoop.fs.permission.FsPermission getFileDefault()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.conf.Configuration getConf()>();
v = staticinvoke <oadd.org.apache.hadoop.fs.permission.FsPermission: oadd.org.apache.hadoop.fs.permission.FsPermission getUMask(oadd.org.apache.hadoop.conf.Configuration)>(v);
v = staticinvoke <oadd.org.apache.hadoop.fs.permission.FsCreateModes: oadd.org.apache.hadoop.fs.permission.FsPermission applyUMask(oadd.org.apache.hadoop.fs.permission.FsPermission,oadd.org.apache.hadoop.fs.permission.FsPermission)>(v, v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FSDataOutputStream create(oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.permission.FsPermission,boolean,int,short,long,oadd.org.apache.hadoop.util.Progressable)>(v, v, v, v, v, v, v);
return v;
}
public abstract oadd.org.apache.hadoop.fs.FSDataOutputStream create(oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.permission.FsPermission, boolean, int, short, long, oadd.org.apache.hadoop.util.Progressable) throws java.io.IOException;
public oadd.org.apache.hadoop.fs.FSDataOutputStream create(oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.permission.FsPermission, java.util.EnumSet, int, short, long, oadd.org.apache.hadoop.util.Progressable) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.permission.FsPermission v;
oadd.org.apache.hadoop.util.Progressable v;
long v;
short v;
oadd.org.apache.hadoop.fs.FSDataOutputStream v;
int v;
oadd.org.apache.hadoop.fs.Path v;
java.util.EnumSet v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.permission.FsPermission;
v := @parameter: java.util.EnumSet;
v := @parameter: int;
v := @parameter: short;
v := @parameter: long;
v := @parameter: oadd.org.apache.hadoop.util.Progressable;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FSDataOutputStream create(oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.permission.FsPermission,java.util.EnumSet,int,short,long,oadd.org.apache.hadoop.util.Progressable,oadd.org.apache.hadoop.fs.Options$ChecksumOpt)>(v, v, v, v, v, v, v, null);
return v;
}
public oadd.org.apache.hadoop.fs.FSDataOutputStream create(oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.permission.FsPermission, java.util.EnumSet, int, short, long, oadd.org.apache.hadoop.util.Progressable, oadd.org.apache.hadoop.fs.Options$ChecksumOpt) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.permission.FsPermission v;
oadd.org.apache.hadoop.util.Progressable v;
long v;
oadd.org.apache.hadoop.fs.Options$ChecksumOpt v;
short v;
oadd.org.apache.hadoop.fs.CreateFlag v;
oadd.org.apache.hadoop.fs.FSDataOutputStream v;
int v;
oadd.org.apache.hadoop.fs.Path v;
java.util.EnumSet v;
oadd.org.apache.hadoop.fs.FileSystem v;
boolean v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.permission.FsPermission;
v := @parameter: java.util.EnumSet;
v := @parameter: int;
v := @parameter: short;
v := @parameter: long;
v := @parameter: oadd.org.apache.hadoop.util.Progressable;
v := @parameter: oadd.org.apache.hadoop.fs.Options$ChecksumOpt;
v = <oadd.org.apache.hadoop.fs.CreateFlag: oadd.org.apache.hadoop.fs.CreateFlag OVERWRITE>;
v = virtualinvoke v.<java.util.EnumSet: boolean contains(java.lang.Object)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FSDataOutputStream create(oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.permission.FsPermission,boolean,int,short,long,oadd.org.apache.hadoop.util.Progressable)>(v, v, v, v, v, v, v);
return v;
}
protected oadd.org.apache.hadoop.fs.FSDataOutputStream primitiveCreate(oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.permission.FsPermission, java.util.EnumSet, int, short, long, oadd.org.apache.hadoop.util.Progressable, oadd.org.apache.hadoop.fs.Options$ChecksumOpt) throws java.io.IOException
{
long v;
oadd.org.apache.hadoop.fs.Options$ChecksumOpt v;
short v;
oadd.org.apache.hadoop.fs.CreateFlag v, v;
int v;
java.util.EnumSet v;
boolean v, v, v;
oadd.org.apache.hadoop.fs.permission.FsPermission v;
oadd.org.apache.hadoop.util.Progressable v;
oadd.org.apache.hadoop.fs.FSDataOutputStream v, v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.permission.FsPermission;
v := @parameter: java.util.EnumSet;
v := @parameter: int;
v := @parameter: short;
v := @parameter: long;
v := @parameter: oadd.org.apache.hadoop.util.Progressable;
v := @parameter: oadd.org.apache.hadoop.fs.Options$ChecksumOpt;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: boolean exists(oadd.org.apache.hadoop.fs.Path)>(v);
staticinvoke <oadd.org.apache.hadoop.fs.CreateFlag: void validate(java.lang.Object,boolean,java.util.EnumSet)>(v, v, v);
if v == 0 goto label;
v = <oadd.org.apache.hadoop.fs.CreateFlag: oadd.org.apache.hadoop.fs.CreateFlag APPEND>;
v = virtualinvoke v.<java.util.EnumSet: boolean contains(java.lang.Object)>(v);
if v == 0 goto label;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FSDataOutputStream append(oadd.org.apache.hadoop.fs.Path,int,oadd.org.apache.hadoop.util.Progressable)>(v, v, v);
return v;
label:
v = <oadd.org.apache.hadoop.fs.CreateFlag: oadd.org.apache.hadoop.fs.CreateFlag OVERWRITE>;
v = virtualinvoke v.<java.util.EnumSet: boolean contains(java.lang.Object)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FSDataOutputStream create(oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.permission.FsPermission,boolean,int,short,long,oadd.org.apache.hadoop.util.Progressable)>(v, v, v, v, v, v, v);
return v;
}
protected boolean primitiveMkdir(oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.permission.FsPermission) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.permission.FsPermission v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
boolean v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.permission.FsPermission;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: boolean mkdirs(oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.permission.FsPermission)>(v, v);
return v;
}
protected void primitiveMkdir(oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.permission.FsPermission, boolean) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.permission.FsPermission v;
java.io.IOException v;
java.io.FileNotFoundException v;
oadd.org.apache.hadoop.fs.FileStatus v;
java.lang.String v, v;
oadd.org.apache.hadoop.fs.Path v, v;
oadd.org.apache.hadoop.fs.ParentNotDirectoryException v;
oadd.org.apache.hadoop.fs.FileSystem v;
boolean v, v, v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.permission.FsPermission;
v := @parameter: boolean;
if v != 0 goto label;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: oadd.org.apache.hadoop.fs.Path getParent()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileStatus getFileStatus(oadd.org.apache.hadoop.fs.Path)>(v);
if v != null goto label;
v = new java.io.FileNotFoundException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (oadd.org.apache.hadoop.fs.Path)>(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[])>("Missing parent:\u0001");
specialinvoke v.<java.io.FileNotFoundException: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: boolean isDirectory()>();
if v != 0 goto label;
v = new oadd.org.apache.hadoop.fs.ParentNotDirectoryException;
specialinvoke v.<oadd.org.apache.hadoop.fs.ParentNotDirectoryException: void <init>(java.lang.String)>("parent is not a dir");
throw v;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: boolean mkdirs(oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.permission.FsPermission)>(v, v);
if v != 0 goto label;
v = new java.io.IOException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (oadd.org.apache.hadoop.fs.Path)>(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[])>("mkdir of \u failed");
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
public oadd.org.apache.hadoop.fs.FSDataOutputStream createNonRecursive(oadd.org.apache.hadoop.fs.Path, boolean, int, short, long, oadd.org.apache.hadoop.util.Progressable) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.permission.FsPermission v;
oadd.org.apache.hadoop.util.Progressable v;
long v;
short v;
oadd.org.apache.hadoop.fs.FSDataOutputStream v;
int v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
boolean v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: boolean;
v := @parameter: int;
v := @parameter: short;
v := @parameter: long;
v := @parameter: oadd.org.apache.hadoop.util.Progressable;
v = staticinvoke <oadd.org.apache.hadoop.fs.permission.FsPermission: oadd.org.apache.hadoop.fs.permission.FsPermission getFileDefault()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FSDataOutputStream createNonRecursive(oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.permission.FsPermission,boolean,int,short,long,oadd.org.apache.hadoop.util.Progressable)>(v, v, v, v, v, v, v);
return v;
}
public oadd.org.apache.hadoop.fs.FSDataOutputStream createNonRecursive(oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.permission.FsPermission, boolean, int, short, long, oadd.org.apache.hadoop.util.Progressable) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.permission.FsPermission v;
oadd.org.apache.hadoop.util.Progressable v;
long v;
short v;
oadd.org.apache.hadoop.fs.CreateFlag v, v, v;
oadd.org.apache.hadoop.fs.FSDataOutputStream v;
int v;
oadd.org.apache.hadoop.fs.Path v;
java.util.EnumSet v;
oadd.org.apache.hadoop.fs.FileSystem v;
boolean v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.permission.FsPermission;
v := @parameter: boolean;
v := @parameter: int;
v := @parameter: short;
v := @parameter: long;
v := @parameter: oadd.org.apache.hadoop.util.Progressable;
if v == 0 goto label;
v = <oadd.org.apache.hadoop.fs.CreateFlag: oadd.org.apache.hadoop.fs.CreateFlag CREATE>;
v = <oadd.org.apache.hadoop.fs.CreateFlag: oadd.org.apache.hadoop.fs.CreateFlag OVERWRITE>;
v = staticinvoke <java.util.EnumSet: java.util.EnumSet of(java.lang.Enum,java.lang.Enum)>(v, v);
goto label;
label:
v = <oadd.org.apache.hadoop.fs.CreateFlag: oadd.org.apache.hadoop.fs.CreateFlag CREATE>;
v = staticinvoke <java.util.EnumSet: java.util.EnumSet of(java.lang.Enum)>(v);
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FSDataOutputStream createNonRecursive(oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.permission.FsPermission,java.util.EnumSet,int,short,long,oadd.org.apache.hadoop.util.Progressable)>(v, v, v, v, v, v, v);
return v;
}
public oadd.org.apache.hadoop.fs.FSDataOutputStream createNonRecursive(oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.permission.FsPermission, java.util.EnumSet, int, short, long, oadd.org.apache.hadoop.util.Progressable) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.permission.FsPermission v;
oadd.org.apache.hadoop.util.Progressable v;
java.io.IOException v;
long v;
short v;
int v;
java.lang.Class v;
java.lang.String v;
oadd.org.apache.hadoop.fs.Path v;
java.util.EnumSet v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.permission.FsPermission;
v := @parameter: java.util.EnumSet;
v := @parameter: int;
v := @parameter: short;
v := @parameter: long;
v := @parameter: oadd.org.apache.hadoop.util.Progressable;
v = new java.io.IOException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Class)>(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[])>("createNonRecursive unsupported for this filesystem \u0001");
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>(v);
throw v;
}
public boolean createNewFile(oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.FSDataOutputStream v;
int v;
oadd.org.apache.hadoop.conf.Configuration v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
boolean v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: boolean exists(oadd.org.apache.hadoop.fs.Path)>(v);
if v == 0 goto label;
return 0;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.conf.Configuration getConf()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: int getInt(java.lang.String,int)>("oadd.io.file.buffer.size", 4096);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FSDataOutputStream create(oadd.org.apache.hadoop.fs.Path,boolean,int)>(v, 0, v);
virtualinvoke v.<oadd.org.apache.hadoop.fs.FSDataOutputStream: void close()>();
return 1;
}
public oadd.org.apache.hadoop.fs.FSDataOutputStream append(oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.FSDataOutputStream v;
int v;
oadd.org.apache.hadoop.conf.Configuration v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.conf.Configuration getConf()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: int getInt(java.lang.String,int)>("oadd.io.file.buffer.size", 4096);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FSDataOutputStream append(oadd.org.apache.hadoop.fs.Path,int,oadd.org.apache.hadoop.util.Progressable)>(v, v, null);
return v;
}
public oadd.org.apache.hadoop.fs.FSDataOutputStream append(oadd.org.apache.hadoop.fs.Path, int) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.FSDataOutputStream v;
int v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: int;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FSDataOutputStream append(oadd.org.apache.hadoop.fs.Path,int,oadd.org.apache.hadoop.util.Progressable)>(v, v, null);
return v;
}
public abstract oadd.org.apache.hadoop.fs.FSDataOutputStream append(oadd.org.apache.hadoop.fs.Path, int, oadd.org.apache.hadoop.util.Progressable) throws java.io.IOException;
public void concat(oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.Path[]) throws java.io.IOException
{
java.lang.UnsupportedOperationException v;
oadd.org.apache.hadoop.fs.Path[] v;
java.lang.Class v;
java.lang.String v, v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.Path[];
v = new java.lang.UnsupportedOperationException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("Not implemented by the \u FileSystem implementation");
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>(v);
throw v;
}
public short getReplication(oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
short v;
oadd.org.apache.hadoop.fs.FileStatus v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileStatus getFileStatus(oadd.org.apache.hadoop.fs.Path)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: short getReplication()>();
return v;
}
public boolean setReplication(oadd.org.apache.hadoop.fs.Path, short) throws java.io.IOException
{
short v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: short;
return 1;
}
public abstract boolean rename(oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.Path) throws java.io.IOException;
protected transient void rename(oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.Options$Rename[]) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.Options$Rename v, v;
oadd.org.apache.hadoop.fs.ParentNotDirectoryException v;
boolean v, v, v, v, v, v;
oadd.org.apache.hadoop.fs.FileStatus[] v;
java.io.FileNotFoundException v, v;
oadd.org.apache.hadoop.fs.Options$Rename[] v;
oadd.org.apache.hadoop.fs.FileStatus v, v, v;
oadd.org.apache.hadoop.fs.FileSystem v;
int v, v, v;
java.lang.String v, v, v, v, v, v, v;
oadd.org.apache.hadoop.fs.FileAlreadyExistsException v;
java.io.IOException v, v, v, v;
oadd.org.apache.hadoop.fs.Path v, v, v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.Options$Rename[];
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileStatus getFileLinkStatus(oadd.org.apache.hadoop.fs.Path)>(v);
if v != null goto label;
v = new java.io.FileNotFoundException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (oadd.org.apache.hadoop.fs.Path)>(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[])>("rename source \u not found.");
specialinvoke v.<java.io.FileNotFoundException: void <init>(java.lang.String)>(v);
throw v;
label:
v = 0;
if null == v goto label;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = <oadd.org.apache.hadoop.fs.Options$Rename: oadd.org.apache.hadoop.fs.Options$Rename OVERWRITE>;
if v != v goto label;
v = 1;
label:
v = v + 1;
goto label;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileStatus getFileLinkStatus(oadd.org.apache.hadoop.fs.Path)>(v);
label:
goto label;
label:
v := @caughtexception;
v = null;
label:
if v == null goto label;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: boolean isDirectory()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: boolean isDirectory()>();
if v == v goto label;
v = new java.io.IOException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.Path)>(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[])>("Source \u Destination \u both should be either file or directory");
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>(v);
throw v;
label:
if v != 0 goto label;
v = new oadd.org.apache.hadoop.fs.FileAlreadyExistsException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (oadd.org.apache.hadoop.fs.Path)>(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[])>("rename destination \u already exists.");
specialinvoke v.<oadd.org.apache.hadoop.fs.FileAlreadyExistsException: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: boolean isDirectory()>();
if v == 0 goto label;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileStatus[] listStatus(oadd.org.apache.hadoop.fs.Path)>(v);
if v == null goto label;
v = lengthof v;
if v == 0 goto label;
v = new java.io.IOException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (oadd.org.apache.hadoop.fs.Path)>(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[])>("rename cannot overwrite non empty destination directory \u0001");
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>(v);
throw v;
label:
virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: boolean delete(oadd.org.apache.hadoop.fs.Path,boolean)>(v, 0);
goto label;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: oadd.org.apache.hadoop.fs.Path getParent()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileStatus getFileStatus(oadd.org.apache.hadoop.fs.Path)>(v);
if v != null goto label;
v = new java.io.FileNotFoundException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (oadd.org.apache.hadoop.fs.Path)>(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[])>("rename destination parent \u not found.");
specialinvoke v.<java.io.FileNotFoundException: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: boolean isDirectory()>();
if v != 0 goto label;
v = new oadd.org.apache.hadoop.fs.ParentNotDirectoryException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (oadd.org.apache.hadoop.fs.Path)>(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[])>("rename destination parent \u is a file.");
specialinvoke v.<oadd.org.apache.hadoop.fs.ParentNotDirectoryException: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: boolean rename(oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.Path)>(v, v);
if v != 0 goto label;
v = new java.io.IOException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.Path)>(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[])>("rename from \u to \u failed.");
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
catch java.io.IOException from label to label with label;
}
public boolean truncate(oadd.org.apache.hadoop.fs.Path, long) throws java.io.IOException
{
java.lang.UnsupportedOperationException v;
java.lang.Class v;
long v;
java.lang.String v, v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: long;
v = new java.lang.UnsupportedOperationException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("Not implemented by the \u FileSystem implementation");
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>(v);
throw v;
}
public boolean delete(oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
boolean v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: boolean delete(oadd.org.apache.hadoop.fs.Path,boolean)>(v, 1);
return v;
}
public abstract boolean delete(oadd.org.apache.hadoop.fs.Path, boolean) throws java.io.IOException;
public boolean deleteOnExit(oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
java.lang.Throwable v;
java.util.Set v, v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
boolean v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: boolean exists(oadd.org.apache.hadoop.fs.Path)>(v);
if v != 0 goto label;
return 0;
label:
v = v.<oadd.org.apache.hadoop.fs.FileSystem: java.util.Set deleteOnExit>;
entermonitor v;
label:
v = v.<oadd.org.apache.hadoop.fs.FileSystem: java.util.Set deleteOnExit>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return 1;
catch java.lang.Throwable from label to label with label;
}
public boolean cancelDeleteOnExit(oadd.org.apache.hadoop.fs.Path)
{
java.lang.Throwable v;
java.util.Set v, v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
boolean v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = v.<oadd.org.apache.hadoop.fs.FileSystem: java.util.Set deleteOnExit>;
entermonitor v;
label:
v = v.<oadd.org.apache.hadoop.fs.FileSystem: java.util.Set deleteOnExit>;
v = interfaceinvoke v.<java.util.Set: boolean remove(java.lang.Object)>(v);
exitmonitor v;
label:
return v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
protected void processDeleteOnExit()
{
java.lang.Throwable v;
org.slf4j.Logger v;
java.util.Iterator v;
java.util.Set v, v;
java.io.IOException v;
java.lang.Object v;
oadd.org.apache.hadoop.fs.FileSystem v;
boolean v, v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v = v.<oadd.org.apache.hadoop.fs.FileSystem: java.util.Set deleteOnExit>;
entermonitor v;
label:
v = v.<oadd.org.apache.hadoop.fs.FileSystem: java.util.Set deleteOnExit>;
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: boolean exists(oadd.org.apache.hadoop.fs.Path)>(v);
if v == 0 goto label;
virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: boolean delete(oadd.org.apache.hadoop.fs.Path,boolean)>(v, 1);
label:
goto label;
label:
v := @caughtexception;
v = <oadd.org.apache.hadoop.fs.FileSystem: org.slf4j.Logger LOGGER>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("Ignoring failure to deleteOnExit for path {}", v);
label:
interfaceinvoke v.<java.util.Iterator: void remove()>();
goto label;
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return;
catch java.io.IOException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public boolean exists(oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.FileStatus v;
oadd.org.apache.hadoop.fs.Path v;
java.io.FileNotFoundException v;
oadd.org.apache.hadoop.fs.FileSystem v;
boolean v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileStatus getFileStatus(oadd.org.apache.hadoop.fs.Path)>(v);
if v == null goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
label:
v := @caughtexception;
return 0;
catch java.io.FileNotFoundException from label to label with label;
}
public boolean isDirectory(oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.FileStatus v;
oadd.org.apache.hadoop.fs.Path v;
java.io.FileNotFoundException v;
oadd.org.apache.hadoop.fs.FileSystem v;
boolean v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileStatus getFileStatus(oadd.org.apache.hadoop.fs.Path)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: boolean isDirectory()>();
label:
return v;
label:
v := @caughtexception;
return 0;
catch java.io.FileNotFoundException from label to label with label;
}
public boolean isFile(oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.FileStatus v;
oadd.org.apache.hadoop.fs.Path v;
java.io.FileNotFoundException v;
oadd.org.apache.hadoop.fs.FileSystem v;
boolean v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileStatus getFileStatus(oadd.org.apache.hadoop.fs.Path)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: boolean isFile()>();
label:
return v;
label:
v := @caughtexception;
return 0;
catch java.io.FileNotFoundException from label to label with label;
}
public long getLength(oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.FileStatus v;
long v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileStatus getFileStatus(oadd.org.apache.hadoop.fs.Path)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: long getLen()>();
return v;
}
public oadd.org.apache.hadoop.fs.ContentSummary getContentSummary(oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
boolean v, v;
oadd.org.apache.hadoop.fs.ContentSummary v, v, v;
oadd.org.apache.hadoop.fs.FileStatus[] v;
oadd.org.apache.hadoop.fs.FileStatus v, v;
oadd.org.apache.hadoop.fs.ContentSummary$Builder v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
oadd.org.apache.hadoop.fs.FileSystem v;
long v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
long[] v;
int v, v;
oadd.org.apache.hadoop.fs.Path v, v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileStatus getFileStatus(oadd.org.apache.hadoop.fs.Path)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: boolean isFile()>();
if v == 0 goto label;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: long getLen()>();
v = new oadd.org.apache.hadoop.fs.ContentSummary$Builder;
specialinvoke v.<oadd.org.apache.hadoop.fs.ContentSummary$Builder: void <init>()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.ContentSummary$Builder: oadd.org.apache.hadoop.fs.ContentSummary$Builder length(long)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.ContentSummary$Builder: oadd.org.apache.hadoop.fs.ContentSummary$Builder fileCount(long)>(1L);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.ContentSummary$Builder: oadd.org.apache.hadoop.fs.ContentSummary$Builder directoryCount(long)>(0L);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.ContentSummary$Builder: oadd.org.apache.hadoop.fs.ContentSummary$Builder spaceConsumed(long)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.ContentSummary$Builder: oadd.org.apache.hadoop.fs.ContentSummary build()>();
return v;
label:
v = newarray (long)[3];
v[0] = 0L;
v[1] = 0L;
v[2] = 1L;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileStatus[] listStatus(oadd.org.apache.hadoop.fs.Path)>(v);
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: long getLen()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: boolean isDirectory()>();
if v == 0 goto label;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: oadd.org.apache.hadoop.fs.Path getPath()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.ContentSummary getContentSummary(oadd.org.apache.hadoop.fs.Path)>(v);
goto label;
label:
v = new oadd.org.apache.hadoop.fs.ContentSummary$Builder;
specialinvoke v.<oadd.org.apache.hadoop.fs.ContentSummary$Builder: void <init>()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.ContentSummary$Builder: oadd.org.apache.hadoop.fs.ContentSummary$Builder length(long)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.ContentSummary$Builder: oadd.org.apache.hadoop.fs.ContentSummary$Builder fileCount(long)>(1L);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.ContentSummary$Builder: oadd.org.apache.hadoop.fs.ContentSummary$Builder directoryCount(long)>(0L);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.ContentSummary$Builder: oadd.org.apache.hadoop.fs.ContentSummary$Builder spaceConsumed(long)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.ContentSummary$Builder: oadd.org.apache.hadoop.fs.ContentSummary build()>();
label:
v = v[0];
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.ContentSummary: long getLength()>();
v = v + v;
v[0] = v;
v = v[1];
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.ContentSummary: long getFileCount()>();
v = v + v;
v[1] = v;
v = v[2];
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.ContentSummary: long getDirectoryCount()>();
v = v + v;
v[2] = v;
v = v + 1;
goto label;
label:
v = new oadd.org.apache.hadoop.fs.ContentSummary$Builder;
specialinvoke v.<oadd.org.apache.hadoop.fs.ContentSummary$Builder: void <init>()>();
v = v[0];
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.ContentSummary$Builder: oadd.org.apache.hadoop.fs.ContentSummary$Builder length(long)>(v);
v = v[1];
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.ContentSummary$Builder: oadd.org.apache.hadoop.fs.ContentSummary$Builder fileCount(long)>(v);
v = v[2];
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.ContentSummary$Builder: oadd.org.apache.hadoop.fs.ContentSummary$Builder directoryCount(long)>(v);
v = v[0];
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.ContentSummary$Builder: oadd.org.apache.hadoop.fs.ContentSummary$Builder spaceConsumed(long)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.ContentSummary$Builder: oadd.org.apache.hadoop.fs.ContentSummary build()>();
return v;
}
public oadd.org.apache.hadoop.fs.QuotaUsage getQuotaUsage(oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.ContentSummary v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.ContentSummary getContentSummary(oadd.org.apache.hadoop.fs.Path)>(v);
return v;
}
public void setQuota(oadd.org.apache.hadoop.fs.Path, long, long) throws java.io.IOException
{
long v, v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: long;
v := @parameter: long;
specialinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: void methodNotSupported()>();
return;
}
public void setQuotaByStorageType(oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.StorageType, long) throws java.io.IOException
{
long v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
oadd.org.apache.hadoop.fs.StorageType v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.StorageType;
v := @parameter: long;
specialinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: void methodNotSupported()>();
return;
}
public abstract oadd.org.apache.hadoop.fs.FileStatus[] listStatus(oadd.org.apache.hadoop.fs.Path) throws java.io.FileNotFoundException, java.io.IOException;
protected oadd.org.apache.hadoop.fs.FileSystem$DirectoryEntries listStatusBatch(oadd.org.apache.hadoop.fs.Path, byte[]) throws java.io.FileNotFoundException, java.io.IOException
{
byte[] v;
oadd.org.apache.hadoop.fs.FileStatus[] v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
oadd.org.apache.hadoop.fs.FileSystem$DirectoryEntries v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: byte[];
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileStatus[] listStatus(oadd.org.apache.hadoop.fs.Path)>(v);
v = new oadd.org.apache.hadoop.fs.FileSystem$DirectoryEntries;
specialinvoke v.<oadd.org.apache.hadoop.fs.FileSystem$DirectoryEntries: void <init>(oadd.org.apache.hadoop.fs.FileStatus[],byte[],boolean)>(v, null, 0);
return v;
}
private void listStatus(java.util.ArrayList, oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.PathFilter) throws java.io.FileNotFoundException, java.io.IOException
{
oadd.org.apache.hadoop.fs.FileStatus[] v;
oadd.org.apache.hadoop.fs.PathFilter v;
java.util.ArrayList v;
oadd.org.apache.hadoop.fs.FileStatus v, v;
int v, v;
oadd.org.apache.hadoop.fs.Path v, v;
oadd.org.apache.hadoop.fs.FileSystem v;
boolean v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: java.util.ArrayList;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.PathFilter;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileStatus[] listStatus(oadd.org.apache.hadoop.fs.Path)>(v);
staticinvoke <oadd.com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object,java.lang.Object)>(v, "listStatus should not return NULL");
v = 0;
label:
v = lengthof v;
if v >= v goto label;
v = v[v];
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: oadd.org.apache.hadoop.fs.Path getPath()>();
v = interfaceinvoke v.<oadd.org.apache.hadoop.fs.PathFilter: boolean accept(oadd.org.apache.hadoop.fs.Path)>(v);
if v == 0 goto label;
v = v[v];
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
label:
v = v + 1;
goto label;
label:
return;
}
public oadd.org.apache.hadoop.fs.RemoteIterator listCorruptFileBlocks(oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
java.lang.UnsupportedOperationException v;
java.lang.Class v;
java.lang.String v, v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = new java.lang.UnsupportedOperationException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getCanonicalName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u does not support listCorruptFileBlocks");
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>(v);
throw v;
}
public oadd.org.apache.hadoop.fs.FileStatus[] listStatus(oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.PathFilter) throws java.io.FileNotFoundException, java.io.IOException
{
java.lang.Object[] v;
oadd.org.apache.hadoop.fs.FileStatus[] v;
int v;
oadd.org.apache.hadoop.fs.PathFilter v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
java.util.ArrayList v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.PathFilter;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
specialinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: void listStatus(java.util.ArrayList,oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.PathFilter)>(v, v, v);
v = virtualinvoke v.<java.util.ArrayList: int size()>();
v = newarray (oadd.org.apache.hadoop.fs.FileStatus)[v];
v = virtualinvoke v.<java.util.ArrayList: java.lang.Object[] toArray(java.lang.Object[])>(v);
return v;
}
public oadd.org.apache.hadoop.fs.FileStatus[] listStatus(oadd.org.apache.hadoop.fs.Path[]) throws java.io.FileNotFoundException, java.io.IOException
{
oadd.org.apache.hadoop.fs.Path[] v;
oadd.org.apache.hadoop.fs.FileStatus[] v;
oadd.org.apache.hadoop.fs.PathFilter v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path[];
v = <oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.PathFilter DEFAULT_FILTER>;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileStatus[] listStatus(oadd.org.apache.hadoop.fs.Path[],oadd.org.apache.hadoop.fs.PathFilter)>(v, v);
return v;
}
public oadd.org.apache.hadoop.fs.FileStatus[] listStatus(oadd.org.apache.hadoop.fs.Path[], oadd.org.apache.hadoop.fs.PathFilter) throws java.io.FileNotFoundException, java.io.IOException
{
oadd.org.apache.hadoop.fs.Path[] v;
java.lang.Object[] v;
oadd.org.apache.hadoop.fs.FileStatus[] v;
oadd.org.apache.hadoop.fs.PathFilter v;
java.util.ArrayList v;
int v, v, v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path[];
v := @parameter: oadd.org.apache.hadoop.fs.PathFilter;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = 0;
label:
v = lengthof v;
if v >= v goto label;
v = v[v];
specialinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: void listStatus(java.util.ArrayList,oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.PathFilter)>(v, v, v);
v = v + 1;
goto label;
label:
v = virtualinvoke v.<java.util.ArrayList: int size()>();
v = newarray (oadd.org.apache.hadoop.fs.FileStatus)[v];
v = virtualinvoke v.<java.util.ArrayList: java.lang.Object[] toArray(java.lang.Object[])>(v);
return v;
}
public oadd.org.apache.hadoop.fs.FileStatus[] globStatus(oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.FileStatus[] v;
oadd.org.apache.hadoop.fs.Globber v;
oadd.org.apache.hadoop.fs.PathFilter v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = new oadd.org.apache.hadoop.fs.Globber;
v = <oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.PathFilter DEFAULT_FILTER>;
specialinvoke v.<oadd.org.apache.hadoop.fs.Globber: void <init>(oadd.org.apache.hadoop.fs.FileSystem,oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.PathFilter)>(v, v, v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Globber: oadd.org.apache.hadoop.fs.FileStatus[] glob()>();
return v;
}
public oadd.org.apache.hadoop.fs.FileStatus[] globStatus(oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.PathFilter) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.FileStatus[] v;
oadd.org.apache.hadoop.fs.Globber v;
oadd.org.apache.hadoop.fs.PathFilter v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.PathFilter;
v = new oadd.org.apache.hadoop.fs.Globber;
specialinvoke v.<oadd.org.apache.hadoop.fs.Globber: void <init>(oadd.org.apache.hadoop.fs.FileSystem,oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.PathFilter)>(v, v, v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Globber: oadd.org.apache.hadoop.fs.FileStatus[] glob()>();
return v;
}
public oadd.org.apache.hadoop.fs.RemoteIterator listLocatedStatus(oadd.org.apache.hadoop.fs.Path) throws java.io.FileNotFoundException, java.io.IOException
{
oadd.org.apache.hadoop.fs.PathFilter v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
oadd.org.apache.hadoop.fs.RemoteIterator v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = <oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.PathFilter DEFAULT_FILTER>;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.RemoteIterator listLocatedStatus(oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.PathFilter)>(v, v);
return v;
}
protected oadd.org.apache.hadoop.fs.RemoteIterator listLocatedStatus(oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.PathFilter) throws java.io.FileNotFoundException, java.io.IOException
{
oadd.org.apache.hadoop.fs.FileSystem$4 v;
oadd.org.apache.hadoop.fs.PathFilter v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.PathFilter;
v = new oadd.org.apache.hadoop.fs.FileSystem$4;
specialinvoke v.<oadd.org.apache.hadoop.fs.FileSystem$4: void <init>(oadd.org.apache.hadoop.fs.FileSystem,oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.PathFilter)>(v, v, v);
return v;
}
public oadd.org.apache.hadoop.fs.RemoteIterator listStatusIterator(oadd.org.apache.hadoop.fs.Path) throws java.io.FileNotFoundException, java.io.IOException
{
oadd.org.apache.hadoop.fs.FileSystem$DirListingIterator v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = new oadd.org.apache.hadoop.fs.FileSystem$DirListingIterator;
specialinvoke v.<oadd.org.apache.hadoop.fs.FileSystem$DirListingIterator: void <init>(oadd.org.apache.hadoop.fs.FileSystem,oadd.org.apache.hadoop.fs.Path)>(v, v);
return v;
}
public oadd.org.apache.hadoop.fs.RemoteIterator listFiles(oadd.org.apache.hadoop.fs.Path, boolean) throws java.io.FileNotFoundException, java.io.IOException
{
oadd.org.apache.hadoop.fs.FileSystem$5 v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
boolean v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: boolean;
v = new oadd.org.apache.hadoop.fs.FileSystem$5;
specialinvoke v.<oadd.org.apache.hadoop.fs.FileSystem$5: void <init>(oadd.org.apache.hadoop.fs.FileSystem,oadd.org.apache.hadoop.fs.Path,boolean)>(v, v, v);
return v;
}
public oadd.org.apache.hadoop.fs.Path getHomeDirectory()
{
java.lang.String v, v;
oadd.org.apache.hadoop.fs.Path v, v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v = new oadd.org.apache.hadoop.fs.Path;
v = staticinvoke <java.lang.System: java.lang.String getProperty(java.lang.String)>("user.name");
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("/user/\u0001");
specialinvoke v.<oadd.org.apache.hadoop.fs.Path: void <init>(java.lang.String)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.Path makeQualified(oadd.org.apache.hadoop.fs.Path)>(v);
return v;
}
public abstract void setWorkingDirectory(oadd.org.apache.hadoop.fs.Path);
public abstract oadd.org.apache.hadoop.fs.Path getWorkingDirectory();
protected oadd.org.apache.hadoop.fs.Path getInitialWorkingDirectory()
{
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
return null;
}
public boolean mkdirs(oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.permission.FsPermission v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
boolean v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = staticinvoke <oadd.org.apache.hadoop.fs.permission.FsPermission: oadd.org.apache.hadoop.fs.permission.FsPermission getDirDefault()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: boolean mkdirs(oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.permission.FsPermission)>(v, v);
return v;
}
public abstract boolean mkdirs(oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.permission.FsPermission) throws java.io.IOException;
public void copyFromLocalFile(oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.Path v, v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: void copyFromLocalFile(boolean,oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.Path)>(0, v, v);
return;
}
public void moveFromLocalFile(oadd.org.apache.hadoop.fs.Path[], oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.Path[] v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path[];
v := @parameter: oadd.org.apache.hadoop.fs.Path;
virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: void copyFromLocalFile(boolean,boolean,oadd.org.apache.hadoop.fs.Path[],oadd.org.apache.hadoop.fs.Path)>(1, 1, v, v);
return;
}
public void moveFromLocalFile(oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.Path v, v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: void copyFromLocalFile(boolean,oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.Path)>(1, v, v);
return;
}
public void copyFromLocalFile(boolean, oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.Path v, v;
oadd.org.apache.hadoop.fs.FileSystem v;
boolean v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: boolean;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: void copyFromLocalFile(boolean,boolean,oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.Path)>(v, 1, v, v);
return;
}
public void copyFromLocalFile(boolean, boolean, oadd.org.apache.hadoop.fs.Path[], oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.Path[] v;
oadd.org.apache.hadoop.conf.Configuration v;
oadd.org.apache.hadoop.fs.LocalFileSystem v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
boolean v, v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: boolean;
v := @parameter: boolean;
v := @parameter: oadd.org.apache.hadoop.fs.Path[];
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.conf.Configuration getConf()>();
v = staticinvoke <oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.LocalFileSystem getLocal(oadd.org.apache.hadoop.conf.Configuration)>(v);
staticinvoke <oadd.org.apache.hadoop.fs.FileUtil: boolean copy(oadd.org.apache.hadoop.fs.FileSystem,oadd.org.apache.hadoop.fs.Path[],oadd.org.apache.hadoop.fs.FileSystem,oadd.org.apache.hadoop.fs.Path,boolean,boolean,oadd.org.apache.hadoop.conf.Configuration)>(v, v, v, v, v, v, v);
return;
}
public void copyFromLocalFile(boolean, boolean, oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
oadd.org.apache.hadoop.conf.Configuration v;
oadd.org.apache.hadoop.fs.LocalFileSystem v;
oadd.org.apache.hadoop.fs.Path v, v;
oadd.org.apache.hadoop.fs.FileSystem v;
boolean v, v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: boolean;
v := @parameter: boolean;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.conf.Configuration getConf()>();
v = staticinvoke <oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.LocalFileSystem getLocal(oadd.org.apache.hadoop.conf.Configuration)>(v);
staticinvoke <oadd.org.apache.hadoop.fs.FileUtil: boolean copy(oadd.org.apache.hadoop.fs.FileSystem,oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.FileSystem,oadd.org.apache.hadoop.fs.Path,boolean,boolean,oadd.org.apache.hadoop.conf.Configuration)>(v, v, v, v, v, v, v);
return;
}
public void copyToLocalFile(oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.Path v, v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: void copyToLocalFile(boolean,oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.Path)>(0, v, v);
return;
}
public void moveToLocalFile(oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.Path v, v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: void copyToLocalFile(boolean,oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.Path)>(1, v, v);
return;
}
public void copyToLocalFile(boolean, oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.Path v, v;
oadd.org.apache.hadoop.fs.FileSystem v;
boolean v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: boolean;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: void copyToLocalFile(boolean,oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.Path,boolean)>(v, v, v, 0);
return;
}
public void copyToLocalFile(boolean, oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.Path, boolean) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.LocalFileSystem v;
oadd.org.apache.hadoop.conf.Configuration v;
oadd.org.apache.hadoop.fs.Path v, v;
oadd.org.apache.hadoop.fs.FileSystem v, v;
boolean v, v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: boolean;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: boolean;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.conf.Configuration getConf()>();
if v == 0 goto label;
v = staticinvoke <oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.LocalFileSystem getLocal(oadd.org.apache.hadoop.conf.Configuration)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.LocalFileSystem: oadd.org.apache.hadoop.fs.FileSystem getRawFileSystem()>();
goto label;
label:
v = staticinvoke <oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.LocalFileSystem getLocal(oadd.org.apache.hadoop.conf.Configuration)>(v);
label:
staticinvoke <oadd.org.apache.hadoop.fs.FileUtil: boolean copy(oadd.org.apache.hadoop.fs.FileSystem,oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.FileSystem,oadd.org.apache.hadoop.fs.Path,boolean,oadd.org.apache.hadoop.conf.Configuration)>(v, v, v, v, v, v);
return;
}
public oadd.org.apache.hadoop.fs.Path startLocalOutput(oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.Path v, v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
return v;
}
public void completeLocalOutput(oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.Path v, v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: void moveFromLocalFile(oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.Path)>(v, v);
return;
}
public void close() throws java.io.IOException
{
oadd.org.apache.hadoop.fs.FileSystem$Cache$Key v;
oadd.org.apache.hadoop.fs.FileSystem$Cache v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: void processDeleteOnExit()>();
v = <oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileSystem$Cache CACHE>;
v = v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileSystem$Cache$Key key>;
virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem$Cache: void remove(oadd.org.apache.hadoop.fs.FileSystem$Cache$Key,oadd.org.apache.hadoop.fs.FileSystem)>(v, v);
return;
}
public long getUsed() throws java.io.IOException
{
long v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v = new oadd.org.apache.hadoop.fs.Path;
specialinvoke v.<oadd.org.apache.hadoop.fs.Path: void <init>(java.lang.String)>("/");
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: long getUsed(oadd.org.apache.hadoop.fs.Path)>(v);
return v;
}
public long getUsed(oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.ContentSummary v;
long v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.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: long getLength()>();
return v;
}
public long getBlockSize(oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.FileStatus v;
long v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileStatus getFileStatus(oadd.org.apache.hadoop.fs.Path)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: long getBlockSize()>();
return v;
}
public long getDefaultBlockSize()
{
long v;
oadd.org.apache.hadoop.conf.Configuration v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.conf.Configuration getConf()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: long getLong(java.lang.String,long)>("fs.local.block.size", 33554432L);
return v;
}
public long getDefaultBlockSize(oadd.org.apache.hadoop.fs.Path)
{
long v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: long getDefaultBlockSize()>();
return v;
}
public short getDefaultReplication()
{
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
return 1;
}
public short getDefaultReplication(oadd.org.apache.hadoop.fs.Path)
{
short v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: short getDefaultReplication()>();
return v;
}
public abstract oadd.org.apache.hadoop.fs.FileStatus getFileStatus(oadd.org.apache.hadoop.fs.Path) throws java.io.IOException;
public void msync() throws java.io.IOException, java.lang.UnsupportedOperationException
{
java.lang.UnsupportedOperationException v;
java.lang.Class v;
java.lang.String v, v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v = new java.lang.UnsupportedOperationException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getCanonicalName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u does not support method msync");
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>(v);
throw v;
}
public void access(oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.permission.FsAction) throws oadd.org.apache.hadoop.security.AccessControlException, java.io.FileNotFoundException, java.io.IOException
{
oadd.org.apache.hadoop.fs.permission.FsAction v;
oadd.org.apache.hadoop.fs.FileStatus v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.permission.FsAction;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileStatus getFileStatus(oadd.org.apache.hadoop.fs.Path)>(v);
staticinvoke <oadd.org.apache.hadoop.fs.FileSystem: void checkAccessPermissions(oadd.org.apache.hadoop.fs.FileStatus,oadd.org.apache.hadoop.fs.permission.FsAction)>(v, v);
return;
}
static void checkAccessPermissions(oadd.org.apache.hadoop.fs.FileStatus, oadd.org.apache.hadoop.fs.permission.FsAction) throws oadd.org.apache.hadoop.security.AccessControlException, java.io.IOException
{
java.lang.Object[] v;
java.lang.String v, v, v, v, v, v, v;
boolean v, v, v, v, v, v;
oadd.org.apache.hadoop.security.UserGroupInformation v;
oadd.org.apache.hadoop.fs.permission.FsPermission v;
java.util.List v;
oadd.org.apache.hadoop.fs.permission.FsAction v, v, v, v;
oadd.org.apache.hadoop.fs.FileStatus v;
oadd.org.apache.hadoop.security.AccessControlException v;
oadd.org.apache.hadoop.fs.Path v;
v := @parameter: oadd.org.apache.hadoop.fs.FileStatus;
v := @parameter: oadd.org.apache.hadoop.fs.permission.FsAction;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: oadd.org.apache.hadoop.fs.permission.FsPermission getPermission()>();
v = staticinvoke <oadd.org.apache.hadoop.security.UserGroupInformation: oadd.org.apache.hadoop.security.UserGroupInformation getCurrentUser()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.security.UserGroupInformation: java.lang.String getShortUserName()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: java.lang.String getOwner()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.permission.FsPermission: oadd.org.apache.hadoop.fs.permission.FsAction getUserAction()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.permission.FsAction: boolean implies(oadd.org.apache.hadoop.fs.permission.FsAction)>(v);
if v == 0 goto label;
return;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.security.UserGroupInformation: java.util.List getGroups()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: java.lang.String getGroup()>();
v = interfaceinvoke v.<java.util.List: boolean contains(java.lang.Object)>(v);
if v == 0 goto label;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.permission.FsPermission: oadd.org.apache.hadoop.fs.permission.FsAction getGroupAction()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.permission.FsAction: boolean implies(oadd.org.apache.hadoop.fs.permission.FsAction)>(v);
if v == 0 goto label;
return;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.permission.FsPermission: oadd.org.apache.hadoop.fs.permission.FsAction getOtherAction()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.permission.FsAction: boolean implies(oadd.org.apache.hadoop.fs.permission.FsAction)>(v);
if v == 0 goto label;
return;
label:
v = new oadd.org.apache.hadoop.security.AccessControlException;
v = newarray (java.lang.Object)[6];
v[0] = v;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: oadd.org.apache.hadoop.fs.Path getPath()>();
v[1] = v;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: java.lang.String getOwner()>();
v[2] = v;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: java.lang.String getGroup()>();
v[3] = v;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: boolean isDirectory()>();
if v == 0 goto label;
v = "d";
goto label;
label:
v = "-";
label:
v[4] = v;
v[5] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Permission denied: user=%s, path=\"%s\":%s:%s:%s%s", v);
specialinvoke v.<oadd.org.apache.hadoop.security.AccessControlException: void <init>(java.lang.String)>(v);
throw v;
}
protected oadd.org.apache.hadoop.fs.Path fixRelativePart(oadd.org.apache.hadoop.fs.Path)
{
oadd.org.apache.hadoop.fs.Path v, v, v;
oadd.org.apache.hadoop.fs.FileSystem v;
boolean v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: boolean isUriPathAbsolute()>();
if v == 0 goto label;
return v;
label:
v = new oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.Path getWorkingDirectory()>();
specialinvoke v.<oadd.org.apache.hadoop.fs.Path: void <init>(oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.Path)>(v, v);
return v;
}
public void createSymlink(oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.Path, boolean) throws oadd.org.apache.hadoop.security.AccessControlException, oadd.org.apache.hadoop.fs.FileAlreadyExistsException, java.io.FileNotFoundException, oadd.org.apache.hadoop.fs.ParentNotDirectoryException, oadd.org.apache.hadoop.fs.UnsupportedFileSystemException, java.io.IOException
{
java.lang.UnsupportedOperationException v;
oadd.org.apache.hadoop.fs.Path v, v;
oadd.org.apache.hadoop.fs.FileSystem v;
boolean v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: boolean;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>("Filesystem does not support symlinks!");
throw v;
}
public oadd.org.apache.hadoop.fs.FileStatus getFileLinkStatus(oadd.org.apache.hadoop.fs.Path) throws oadd.org.apache.hadoop.security.AccessControlException, java.io.FileNotFoundException, oadd.org.apache.hadoop.fs.UnsupportedFileSystemException, java.io.IOException
{
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileStatus v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileStatus getFileStatus(oadd.org.apache.hadoop.fs.Path)>(v);
return v;
}
public boolean supportsSymlinks()
{
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
return 0;
}
public oadd.org.apache.hadoop.fs.Path getLinkTarget(oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
java.lang.UnsupportedOperationException v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>("Filesystem does not support symlinks!");
throw v;
}
protected oadd.org.apache.hadoop.fs.Path resolveLink(oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
java.lang.UnsupportedOperationException v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>("Filesystem does not support symlinks!");
throw v;
}
public oadd.org.apache.hadoop.fs.FileChecksum getFileChecksum(oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
oadd.org.apache.hadoop.fs.FileChecksum v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileChecksum getFileChecksum(oadd.org.apache.hadoop.fs.Path,long)>(v, 9223372036854775807L);
return v;
}
public oadd.org.apache.hadoop.fs.FileChecksum getFileChecksum(oadd.org.apache.hadoop.fs.Path, long) throws java.io.IOException
{
long v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: long;
return null;
}
public void setVerifyChecksum(boolean)
{
oadd.org.apache.hadoop.fs.FileSystem v;
boolean v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: boolean;
return;
}
public void setWriteChecksum(boolean)
{
oadd.org.apache.hadoop.fs.FileSystem v;
boolean v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: boolean;
return;
}
public oadd.org.apache.hadoop.fs.FsStatus getStatus() throws java.io.IOException
{
oadd.org.apache.hadoop.fs.FsStatus v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FsStatus getStatus(oadd.org.apache.hadoop.fs.Path)>(null);
return v;
}
public oadd.org.apache.hadoop.fs.FsStatus getStatus(oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.FsStatus v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = new oadd.org.apache.hadoop.fs.FsStatus;
specialinvoke v.<oadd.org.apache.hadoop.fs.FsStatus: void <init>(long,long,long)>(9223372036854775807L, 0L, 9223372036854775807L);
return v;
}
public void setPermission(oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.permission.FsPermission) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.permission.FsPermission v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.permission.FsPermission;
return;
}
public void setOwner(oadd.org.apache.hadoop.fs.Path, java.lang.String, java.lang.String) throws java.io.IOException
{
java.lang.String v, v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
return;
}
public void setTimes(oadd.org.apache.hadoop.fs.Path, long, long) throws java.io.IOException
{
long v, v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: long;
v := @parameter: long;
return;
}
public final oadd.org.apache.hadoop.fs.Path createSnapshot(oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.Path v, v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.Path createSnapshot(oadd.org.apache.hadoop.fs.Path,java.lang.String)>(v, null);
return v;
}
public oadd.org.apache.hadoop.fs.Path createSnapshot(oadd.org.apache.hadoop.fs.Path, java.lang.String) throws java.io.IOException
{
java.lang.UnsupportedOperationException v;
java.lang.Class v;
java.lang.String v, v, v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: java.lang.String;
v = new java.lang.UnsupportedOperationException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u doesn\'t support createSnapshot");
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>(v);
throw v;
}
public void renameSnapshot(oadd.org.apache.hadoop.fs.Path, java.lang.String, java.lang.String) throws java.io.IOException
{
java.lang.UnsupportedOperationException v;
java.lang.Class v;
java.lang.String v, v, v, v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = new java.lang.UnsupportedOperationException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u doesn\'t support renameSnapshot");
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>(v);
throw v;
}
public void deleteSnapshot(oadd.org.apache.hadoop.fs.Path, java.lang.String) throws java.io.IOException
{
java.lang.UnsupportedOperationException v;
java.lang.Class v;
java.lang.String v, v, v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: java.lang.String;
v = new java.lang.UnsupportedOperationException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u doesn\'t support deleteSnapshot");
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>(v);
throw v;
}
public void modifyAclEntries(oadd.org.apache.hadoop.fs.Path, java.util.List) throws java.io.IOException
{
java.lang.UnsupportedOperationException v;
java.util.List v;
java.lang.Class v;
java.lang.String v, v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: java.util.List;
v = new java.lang.UnsupportedOperationException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u doesn\'t support modifyAclEntries");
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>(v);
throw v;
}
public void removeAclEntries(oadd.org.apache.hadoop.fs.Path, java.util.List) throws java.io.IOException
{
java.lang.UnsupportedOperationException v;
java.util.List v;
java.lang.Class v;
java.lang.String v, v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: java.util.List;
v = new java.lang.UnsupportedOperationException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u doesn\'t support removeAclEntries");
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>(v);
throw v;
}
public void removeDefaultAcl(oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
java.lang.UnsupportedOperationException v;
java.lang.Class v;
java.lang.String v, v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = new java.lang.UnsupportedOperationException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u doesn\'t support removeDefaultAcl");
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>(v);
throw v;
}
public void removeAcl(oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
java.lang.UnsupportedOperationException v;
java.lang.Class v;
java.lang.String v, v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = new java.lang.UnsupportedOperationException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u doesn\'t support removeAcl");
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>(v);
throw v;
}
public void setAcl(oadd.org.apache.hadoop.fs.Path, java.util.List) throws java.io.IOException
{
java.lang.UnsupportedOperationException v;
java.util.List v;
java.lang.Class v;
java.lang.String v, v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: java.util.List;
v = new java.lang.UnsupportedOperationException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u doesn\'t support setAcl");
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>(v);
throw v;
}
public oadd.org.apache.hadoop.fs.permission.AclStatus getAclStatus(oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
java.lang.UnsupportedOperationException v;
java.lang.Class v;
java.lang.String v, v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = new java.lang.UnsupportedOperationException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u doesn\'t support getAclStatus");
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>(v);
throw v;
}
public void setXAttr(oadd.org.apache.hadoop.fs.Path, java.lang.String, byte[]) throws java.io.IOException
{
byte[] v;
java.lang.String v;
oadd.org.apache.hadoop.fs.Path v;
java.util.EnumSet v;
oadd.org.apache.hadoop.fs.FileSystem v;
oadd.org.apache.hadoop.fs.XAttrSetFlag v, v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: java.lang.String;
v := @parameter: byte[];
v = <oadd.org.apache.hadoop.fs.XAttrSetFlag: oadd.org.apache.hadoop.fs.XAttrSetFlag CREATE>;
v = <oadd.org.apache.hadoop.fs.XAttrSetFlag: oadd.org.apache.hadoop.fs.XAttrSetFlag REPLACE>;
v = staticinvoke <java.util.EnumSet: java.util.EnumSet of(java.lang.Enum,java.lang.Enum)>(v, v);
virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: void setXAttr(oadd.org.apache.hadoop.fs.Path,java.lang.String,byte[],java.util.EnumSet)>(v, v, v, v);
return;
}
public void setXAttr(oadd.org.apache.hadoop.fs.Path, java.lang.String, byte[], java.util.EnumSet) throws java.io.IOException
{
byte[] v;
java.lang.UnsupportedOperationException v;
java.lang.Class v;
java.lang.String v, v, v;
oadd.org.apache.hadoop.fs.Path v;
java.util.EnumSet v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: java.lang.String;
v := @parameter: byte[];
v := @parameter: java.util.EnumSet;
v = new java.lang.UnsupportedOperationException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u doesn\'t support setXAttr");
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>(v);
throw v;
}
public byte[] getXAttr(oadd.org.apache.hadoop.fs.Path, java.lang.String) throws java.io.IOException
{
java.lang.UnsupportedOperationException v;
java.lang.Class v;
java.lang.String v, v, v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: java.lang.String;
v = new java.lang.UnsupportedOperationException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u doesn\'t support getXAttr");
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>(v);
throw v;
}
public java.util.Map getXAttrs(oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
java.lang.UnsupportedOperationException v;
java.lang.Class v;
java.lang.String v, v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = new java.lang.UnsupportedOperationException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u doesn\'t support getXAttrs");
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>(v);
throw v;
}
public java.util.Map getXAttrs(oadd.org.apache.hadoop.fs.Path, java.util.List) throws java.io.IOException
{
java.lang.UnsupportedOperationException v;
java.util.List v;
java.lang.Class v;
java.lang.String v, v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: java.util.List;
v = new java.lang.UnsupportedOperationException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u doesn\'t support getXAttrs");
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>(v);
throw v;
}
public java.util.List listXAttrs(oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
java.lang.UnsupportedOperationException v;
java.lang.Class v;
java.lang.String v, v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = new java.lang.UnsupportedOperationException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u doesn\'t support listXAttrs");
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>(v);
throw v;
}
public void removeXAttr(oadd.org.apache.hadoop.fs.Path, java.lang.String) throws java.io.IOException
{
java.lang.UnsupportedOperationException v;
java.lang.Class v;
java.lang.String v, v, v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: java.lang.String;
v = new java.lang.UnsupportedOperationException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u doesn\'t support removeXAttr");
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>(v);
throw v;
}
public void satisfyStoragePolicy(oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
java.lang.UnsupportedOperationException v;
java.lang.Class v;
java.lang.String v, v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = new java.lang.UnsupportedOperationException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u doesn\'t support setStoragePolicy");
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>(v);
throw v;
}
public void setStoragePolicy(oadd.org.apache.hadoop.fs.Path, java.lang.String) throws java.io.IOException
{
java.lang.UnsupportedOperationException v;
java.lang.Class v;
java.lang.String v, v, v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: java.lang.String;
v = new java.lang.UnsupportedOperationException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u doesn\'t support setStoragePolicy");
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>(v);
throw v;
}
public void unsetStoragePolicy(oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
java.lang.UnsupportedOperationException v;
java.lang.Class v;
java.lang.String v, v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = new java.lang.UnsupportedOperationException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u doesn\'t support unsetStoragePolicy");
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>(v);
throw v;
}
public oadd.org.apache.hadoop.fs.BlockStoragePolicySpi getStoragePolicy(oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
java.lang.UnsupportedOperationException v;
java.lang.Class v;
java.lang.String v, v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = new java.lang.UnsupportedOperationException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u doesn\'t support getStoragePolicy");
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>(v);
throw v;
}
public java.util.Collection getAllStoragePolicies() throws java.io.IOException
{
java.lang.UnsupportedOperationException v;
java.lang.Class v;
java.lang.String v, v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v = new java.lang.UnsupportedOperationException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u doesn\'t support getAllStoragePolicies");
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>(v);
throw v;
}
public oadd.org.apache.hadoop.fs.Path getTrashRoot(oadd.org.apache.hadoop.fs.Path)
{
java.lang.String v;
java.net.URI v;
oadd.org.apache.hadoop.fs.Path v, v, v, v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = new oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.Path getHomeDirectory()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: java.net.URI toUri()>();
v = virtualinvoke v.<java.net.URI: java.lang.String getPath()>();
specialinvoke v.<oadd.org.apache.hadoop.fs.Path: void <init>(java.lang.String,java.lang.String)>(v, ".Trash");
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.Path makeQualified(oadd.org.apache.hadoop.fs.Path)>(v);
return v;
}
public java.util.Collection getTrashRoots(boolean)
{
java.util.ArrayList v;
int v, v;
java.lang.String v;
java.net.URI v;
boolean v, v, v, v;
oadd.org.apache.hadoop.fs.FileStatus[] v;
org.slf4j.Logger v;
java.io.IOException v;
oadd.org.apache.hadoop.fs.FileStatus v, v;
oadd.org.apache.hadoop.fs.Path v, v, v, v, v, v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: boolean;
v = new oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.Path getHomeDirectory()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: java.net.URI toUri()>();
v = virtualinvoke v.<java.net.URI: java.lang.String getPath()>();
specialinvoke v.<oadd.org.apache.hadoop.fs.Path: void <init>(java.lang.String)>(v);
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
label:
if v != 0 goto label;
v = new oadd.org.apache.hadoop.fs.Path;
specialinvoke v.<oadd.org.apache.hadoop.fs.Path: void <init>(oadd.org.apache.hadoop.fs.Path,java.lang.String)>(v, ".Trash");
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: boolean exists(oadd.org.apache.hadoop.fs.Path)>(v);
if v == 0 goto label;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileStatus getFileStatus(oadd.org.apache.hadoop.fs.Path)>(v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: oadd.org.apache.hadoop.fs.Path getParent()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: boolean exists(oadd.org.apache.hadoop.fs.Path)>(v);
if v == 0 goto label;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileStatus[] listStatus(oadd.org.apache.hadoop.fs.Path)>(v);
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = new oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: oadd.org.apache.hadoop.fs.Path getPath()>();
specialinvoke v.<oadd.org.apache.hadoop.fs.Path: void <init>(oadd.org.apache.hadoop.fs.Path,java.lang.String)>(v, ".Trash");
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: boolean exists(oadd.org.apache.hadoop.fs.Path)>(v);
if v == 0 goto label;
virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: void setPath(oadd.org.apache.hadoop.fs.Path)>(v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
v = v + 1;
goto label;
label:
v := @caughtexception;
v = <oadd.org.apache.hadoop.fs.FileSystem: org.slf4j.Logger LOGGER>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Throwable)>("Cannot get all trash roots", v);
label:
return v;
catch java.io.IOException from label to label with label;
}
public boolean hasPathCapability(oadd.org.apache.hadoop.fs.Path, java.lang.String) throws java.io.IOException
{
byte v;
int v;
java.lang.String v, v;
oadd.org.apache.hadoop.fs.Path v, v;
oadd.org.apache.hadoop.fs.FileSystem v;
boolean v, v, v, v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: java.lang.String;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.Path makeQualified(oadd.org.apache.hadoop.fs.Path)>(v);
v = staticinvoke <oadd.org.apache.hadoop.fs.impl.PathCapabilitiesSupport: java.lang.String validatePathCapabilityArgs(oadd.org.apache.hadoop.fs.Path,java.lang.String)>(v, v);
v = -1;
v = virtualinvoke v.<java.lang.String: int hashCode()>();
lookupswitch(v)
{
case -1881327609: goto label;
default: goto label;
};
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("fs.capability.paths.symlinks");
if v == 0 goto label;
v = 0;
label:
lookupswitch(v)
{
case 0: goto label;
default: goto label;
};
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: boolean supportsSymlinks()>();
if v == 0 goto label;
v = staticinvoke <oadd.org.apache.hadoop.fs.FileSystem: boolean areSymlinksEnabled()>();
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
label:
return 0;
}
private static void loadFileSystems()
{
java.lang.Throwable v, v;
java.lang.Object[] v;
java.util.Map v;
java.util.ServiceConfigurationError v;
java.lang.String v, v, v, v, v, v;
boolean v, v, v;
org.slf4j.Logger v, v, v, v, v;
java.util.Iterator v;
java.util.ServiceLoader v;
java.lang.Exception v;
oadd.org.apache.commons.logging.Log v, v, v;
java.lang.Class v, v, v, v;
java.lang.Object v;
v = <oadd.org.apache.hadoop.fs.FileSystem: org.slf4j.Logger LOGGER>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("Loading filesystems");
entermonitor class "Loadd/org/apache/hadoop/fs/FileSystem;";
label:
v = <oadd.org.apache.hadoop.fs.FileSystem: boolean FILE_SYSTEMS_LOADED>;
if v != 0 goto label;
v = staticinvoke <java.util.ServiceLoader: java.util.ServiceLoader load(java.lang.Class)>(class "Loadd/org/apache/hadoop/fs/FileSystem;");
v = virtualinvoke v.<java.util.ServiceLoader: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
label:
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
label:
v = <oadd.org.apache.hadoop.fs.FileSystem: java.util.Map SERVICE_FILE_SYSTEMS>;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: java.lang.String getScheme()>();
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = <oadd.org.apache.hadoop.fs.FileSystem: org.slf4j.Logger LOGGER>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <oadd.org.apache.hadoop.fs.FileSystem: org.slf4j.Logger LOGGER>;
v = newarray (java.lang.Object)[3];
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: java.lang.String getScheme()>();
v[0] = v;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v[1] = v;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = staticinvoke <oadd.org.apache.hadoop.util.ClassUtil: java.lang.String findContainingJar(java.lang.Class)>(v);
v[2] = v;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object[])>("{}:// = {} from {}", v);
label:
goto label;
label:
v := @caughtexception;
v = <oadd.org.apache.hadoop.fs.FileSystem: org.slf4j.Logger LOGGER>;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = staticinvoke <oadd.org.apache.hadoop.util.ClassUtil: java.lang.String findContainingJar(java.lang.Class)>(v);
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Object,java.lang.Object)>("Cannot load: {} from {}", v, v);
v = <oadd.org.apache.hadoop.fs.FileSystem: org.slf4j.Logger LOGGER>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object,java.lang.Object)>("Full exception loading: {}", v, v);
label:
goto label;
label:
v := @caughtexception;
v = <oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.commons.logging.Log LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.util.ServiceConfigurationError)>(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[])>("Cannot load filesystem: \u0001");
interfaceinvoke v.<oadd.org.apache.commons.logging.Log: void warn(java.lang.Object)>(v);
v = virtualinvoke v.<java.util.ServiceConfigurationError: java.lang.Throwable getCause()>();
label:
if v == null goto label;
v = <oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.commons.logging.Log LOG>;
v = virtualinvoke v.<java.lang.Throwable: java.lang.String toString()>();
interfaceinvoke v.<oadd.org.apache.commons.logging.Log: void warn(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.Throwable: java.lang.Throwable getCause()>();
goto label;
label:
v = <oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.commons.logging.Log LOG>;
interfaceinvoke v.<oadd.org.apache.commons.logging.Log: void debug(java.lang.Object,java.lang.Throwable)>("Stack Trace", v);
goto label;
label:
<oadd.org.apache.hadoop.fs.FileSystem: boolean FILE_SYSTEMS_LOADED> = 1;
label:
exitmonitor class "Loadd/org/apache/hadoop/fs/FileSystem;";
label:
goto label;
label:
v := @caughtexception;
exitmonitor class "Loadd/org/apache/hadoop/fs/FileSystem;";
throw v;
label:
return;
catch java.lang.Exception from label to label with label;
catch java.util.ServiceConfigurationError from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public static java.lang.Class getFileSystemClass(java.lang.String, oadd.org.apache.hadoop.conf.Configuration) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.UnsupportedFileSystemException v;
org.slf4j.Logger v, v, v, v, v, v;
java.util.Map v;
java.lang.Class v;
java.lang.Object v;
oadd.org.apache.hadoop.conf.Configuration v;
java.lang.String v, v, v;
boolean v;
v := @parameter: java.lang.String;
v := @parameter: oadd.org.apache.hadoop.conf.Configuration;
v = <oadd.org.apache.hadoop.fs.FileSystem: boolean FILE_SYSTEMS_LOADED>;
if v != 0 goto label;
staticinvoke <oadd.org.apache.hadoop.fs.FileSystem: void loadFileSystems()>();
label:
v = <oadd.org.apache.hadoop.fs.FileSystem: org.slf4j.Logger LOGGER>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Looking for FS supporting {}", v);
v = null;
if v == null goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("fs.\u.impl");
v = <oadd.org.apache.hadoop.fs.FileSystem: org.slf4j.Logger LOGGER>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("looking for configuration option {}", v);
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: java.lang.Class getClass(java.lang.String,java.lang.Class)>(v, null);
goto label;
label:
v = <oadd.org.apache.hadoop.fs.FileSystem: org.slf4j.Logger LOGGER>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("No configuration: skipping check for fs.{}.impl", v);
label:
if v != null goto label;
v = <oadd.org.apache.hadoop.fs.FileSystem: org.slf4j.Logger LOGGER>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("Looking in service filesystems for implementation class");
v = <oadd.org.apache.hadoop.fs.FileSystem: java.util.Map SERVICE_FILE_SYSTEMS>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
goto label;
label:
v = <oadd.org.apache.hadoop.fs.FileSystem: org.slf4j.Logger LOGGER>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Filesystem {} defined in configuration option", v);
label:
if v != null goto label;
v = new oadd.org.apache.hadoop.fs.UnsupportedFileSystemException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("No FileSystem for scheme \"\u0001\"");
specialinvoke v.<oadd.org.apache.hadoop.fs.UnsupportedFileSystemException: void <init>(java.lang.String)>(v);
throw v;
label:
v = <oadd.org.apache.hadoop.fs.FileSystem: org.slf4j.Logger LOGGER>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("FS for {} is {}", v, v);
return v;
}
private static oadd.org.apache.hadoop.fs.FileSystem createFileSystem(java.net.URI, oadd.org.apache.hadoop.conf.Configuration) throws java.io.IOException
{
java.lang.Throwable v;
org.apache.htrace.core.TraceScope v;
org.apache.htrace.core.Tracer v;
java.lang.Class v;
java.lang.Object v;
oadd.org.apache.hadoop.conf.Configuration v;
java.lang.String v, v;
java.net.URI v;
v := @parameter: java.net.URI;
v := @parameter: oadd.org.apache.hadoop.conf.Configuration;
v = staticinvoke <oadd.org.apache.hadoop.fs.FsTracer: org.apache.htrace.core.Tracer get(oadd.org.apache.hadoop.conf.Configuration)>(v);
v = virtualinvoke v.<org.apache.htrace.core.Tracer: org.apache.htrace.core.TraceScope newScope(java.lang.String)>("FileSystem#createFileSystem");
label:
v = virtualinvoke v.<java.net.URI: java.lang.String getScheme()>();
virtualinvoke v.<org.apache.htrace.core.TraceScope: void addKVAnnotation(java.lang.String,java.lang.String)>("scheme", v);
v = virtualinvoke v.<java.net.URI: java.lang.String getScheme()>();
v = staticinvoke <oadd.org.apache.hadoop.fs.FileSystem: java.lang.Class getFileSystemClass(java.lang.String,oadd.org.apache.hadoop.conf.Configuration)>(v, v);
v = staticinvoke <oadd.org.apache.hadoop.util.ReflectionUtils: java.lang.Object newInstance(java.lang.Class,oadd.org.apache.hadoop.conf.Configuration)>(v, v);
virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: void initialize(java.net.URI,oadd.org.apache.hadoop.conf.Configuration)>(v, v);
label:
virtualinvoke v.<org.apache.htrace.core.TraceScope: void close()>();
return v;
label:
v := @caughtexception;
throw v;
catch java.lang.Throwable from label to label with label;
}
public static synchronized java.util.Map getStatistics()
{
java.util.Iterator v;
java.util.Collection v;
java.util.Map v;
java.lang.Object v;
java.util.HashMap v;
java.lang.String v;
boolean v;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = <oadd.org.apache.hadoop.fs.FileSystem: java.util.Map statisticsTable>;
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem$Statistics: java.lang.String getScheme()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
return v;
}
public static synchronized java.util.List getAllStatistics()
{
java.util.ArrayList v;
java.util.Collection v;
java.util.Map v;
v = new java.util.ArrayList;
v = <oadd.org.apache.hadoop.fs.FileSystem: java.util.Map statisticsTable>;
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
specialinvoke v.<java.util.ArrayList: void <init>(java.util.Collection)>(v);
return v;
}
public static synchronized oadd.org.apache.hadoop.fs.FileSystem$Statistics getStatistics(java.lang.String, java.lang.Class)
{
oadd.org.apache.hadoop.fs.FileSystem$Statistics v;
java.util.Map v, v;
oadd.org.apache.hadoop.fs.GlobalStorageStatistics v;
java.lang.Class v;
java.lang.Object v;
java.lang.String v;
oadd.org.apache.hadoop.fs.FileSystem$6 v;
boolean v;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Class;
if v == null goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <oadd.com.google.common.base.Preconditions: void checkArgument(boolean,java.lang.Object)>(v, "No statistics is allowed for a file system with null scheme!");
v = <oadd.org.apache.hadoop.fs.FileSystem: java.util.Map statisticsTable>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = new oadd.org.apache.hadoop.fs.FileSystem$Statistics;
specialinvoke v.<oadd.org.apache.hadoop.fs.FileSystem$Statistics: void <init>(java.lang.String)>(v);
v = <oadd.org.apache.hadoop.fs.FileSystem: java.util.Map statisticsTable>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v;
v = <oadd.org.apache.hadoop.fs.GlobalStorageStatistics: oadd.org.apache.hadoop.fs.GlobalStorageStatistics INSTANCE>;
v = new oadd.org.apache.hadoop.fs.FileSystem$6;
specialinvoke v.<oadd.org.apache.hadoop.fs.FileSystem$6: void <init>(java.lang.String,oadd.org.apache.hadoop.fs.FileSystem$Statistics)>(v, v);
virtualinvoke v.<oadd.org.apache.hadoop.fs.GlobalStorageStatistics: oadd.org.apache.hadoop.fs.StorageStatistics put(java.lang.String,oadd.org.apache.hadoop.fs.GlobalStorageStatistics$StorageStatisticsProvider)>(v, v);
label:
return v;
}
public static synchronized void clearStatistics()
{
oadd.org.apache.hadoop.fs.GlobalStorageStatistics v;
v = <oadd.org.apache.hadoop.fs.GlobalStorageStatistics: oadd.org.apache.hadoop.fs.GlobalStorageStatistics INSTANCE>;
virtualinvoke v.<oadd.org.apache.hadoop.fs.GlobalStorageStatistics: void reset()>();
return;
}
public static synchronized void printStatistics() throws java.io.IOException
{
java.io.PrintStream v;
java.util.Iterator v;
java.util.Set v;
java.util.Map v;
java.lang.Object v, v, v;
java.lang.String v, v;
boolean v;
v = <oadd.org.apache.hadoop.fs.FileSystem: java.util.Map statisticsTable>;
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = <java.lang.System: java.io.PrintStream out>;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.Object)>(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[])>("  FileSystem \u0001: \u0001");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
goto label;
label:
return;
}
public static boolean areSymlinksEnabled()
{
boolean v;
v = <oadd.org.apache.hadoop.fs.FileSystem: boolean symlinksEnabled>;
return v;
}
public static void enableSymlinks()
{
<oadd.org.apache.hadoop.fs.FileSystem: boolean symlinksEnabled> = 1;
return;
}
public oadd.org.apache.hadoop.fs.StorageStatistics getStorageStatistics()
{
oadd.org.apache.hadoop.fs.EmptyStorageStatistics v;
java.lang.String v;
java.net.URI v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v = new oadd.org.apache.hadoop.fs.EmptyStorageStatistics;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: java.net.URI getUri()>();
v = virtualinvoke v.<java.net.URI: java.lang.String toString()>();
specialinvoke v.<oadd.org.apache.hadoop.fs.EmptyStorageStatistics: void <init>(java.lang.String)>(v);
return v;
}
public static oadd.org.apache.hadoop.fs.GlobalStorageStatistics getGlobalStorageStatistics()
{
oadd.org.apache.hadoop.fs.GlobalStorageStatistics v;
v = <oadd.org.apache.hadoop.fs.GlobalStorageStatistics: oadd.org.apache.hadoop.fs.GlobalStorageStatistics INSTANCE>;
return v;
}
public oadd.org.apache.hadoop.fs.FSDataOutputStreamBuilder createFile(oadd.org.apache.hadoop.fs.Path)
{
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FSDataOutputStreamBuilder v, v;
oadd.org.apache.hadoop.fs.FileSystem v;
oadd.org.apache.hadoop.fs.FileSystem$FileSystemDataOutputStreamBuilder v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = new oadd.org.apache.hadoop.fs.FileSystem$FileSystemDataOutputStreamBuilder;
specialinvoke v.<oadd.org.apache.hadoop.fs.FileSystem$FileSystemDataOutputStreamBuilder: void <init>(oadd.org.apache.hadoop.fs.FileSystem,oadd.org.apache.hadoop.fs.Path)>(v, v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem$FileSystemDataOutputStreamBuilder: oadd.org.apache.hadoop.fs.FSDataOutputStreamBuilder create()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem$FileSystemDataOutputStreamBuilder: oadd.org.apache.hadoop.fs.FSDataOutputStreamBuilder overwrite(boolean)>(1);
return v;
}
private void methodNotSupported()
{
java.lang.UnsupportedOperationException v;
java.lang.StackTraceElement[] v;
java.lang.Thread v;
java.lang.Class v;
java.lang.StackTraceElement v;
java.lang.String v, v, v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
v = virtualinvoke v.<java.lang.Thread: java.lang.StackTraceElement[] getStackTrace()>();
v = v[2];
v = virtualinvoke v.<java.lang.StackTraceElement: java.lang.String getMethodName()>();
v = new java.lang.UnsupportedOperationException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getCanonicalName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(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[])>("\u does not support method \u0001");
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>(v);
throw v;
}
public oadd.org.apache.hadoop.fs.FSDataOutputStreamBuilder appendFile(oadd.org.apache.hadoop.fs.Path)
{
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FSDataOutputStreamBuilder v;
oadd.org.apache.hadoop.fs.FileSystem v;
oadd.org.apache.hadoop.fs.FileSystem$FileSystemDataOutputStreamBuilder v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = new oadd.org.apache.hadoop.fs.FileSystem$FileSystemDataOutputStreamBuilder;
specialinvoke v.<oadd.org.apache.hadoop.fs.FileSystem$FileSystemDataOutputStreamBuilder: void <init>(oadd.org.apache.hadoop.fs.FileSystem,oadd.org.apache.hadoop.fs.Path)>(v, v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem$FileSystemDataOutputStreamBuilder: oadd.org.apache.hadoop.fs.FSDataOutputStreamBuilder append()>();
return v;
}
static void <clinit>()
{
java.util.IdentityHashMap v;
org.slf4j.Logger v;
oadd.org.apache.hadoop.fs.FileSystem$3 v;
java.util.HashMap v;
oadd.org.apache.hadoop.fs.FileSystem$Cache v;
oadd.org.apache.commons.logging.Log v;
v = staticinvoke <oadd.org.apache.commons.logging.LogFactory: oadd.org.apache.commons.logging.Log getLog(java.lang.Class)>(class "Loadd/org/apache/hadoop/fs/FileSystem;");
<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.commons.logging.Log LOG> = v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Loadd/org/apache/hadoop/fs/FileSystem;");
<oadd.org.apache.hadoop.fs.FileSystem: org.slf4j.Logger LOGGER> = v;
v = new oadd.org.apache.hadoop.fs.FileSystem$Cache;
specialinvoke v.<oadd.org.apache.hadoop.fs.FileSystem$Cache: void <init>()>();
<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileSystem$Cache CACHE> = v;
v = new java.util.IdentityHashMap;
specialinvoke v.<java.util.IdentityHashMap: void <init>()>();
<oadd.org.apache.hadoop.fs.FileSystem: java.util.Map statisticsTable> = v;
v = new oadd.org.apache.hadoop.fs.FileSystem$3;
specialinvoke v.<oadd.org.apache.hadoop.fs.FileSystem$3: void <init>()>();
<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.PathFilter DEFAULT_FILTER> = v;
<oadd.org.apache.hadoop.fs.FileSystem: boolean FILE_SYSTEMS_LOADED> = 0;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
<oadd.org.apache.hadoop.fs.FileSystem: java.util.Map SERVICE_FILE_SYSTEMS> = v;
<oadd.org.apache.hadoop.fs.FileSystem: boolean symlinksEnabled> = 0;
return;
}
}