public abstract class org.apache.hive.hcatalog.templeton.JobCallable extends java.lang.Object implements java.util.concurrent.Callable
{
private static final org.slf4j.Logger LOG;
private org.apache.hive.hcatalog.templeton.JobCallable$JobState jobState;
public java.lang.Object returnResult;
public void <init>()
{
org.apache.hive.hcatalog.templeton.JobCallable$JobState v;
org.apache.hive.hcatalog.templeton.JobCallable v;
v := @this: org.apache.hive.hcatalog.templeton.JobCallable;
specialinvoke v.<java.lang.Object: void <init>()>();
v = <org.apache.hive.hcatalog.templeton.JobCallable$JobState: org.apache.hive.hcatalog.templeton.JobCallable$JobState STARTED>;
v.<org.apache.hive.hcatalog.templeton.JobCallable: org.apache.hive.hcatalog.templeton.JobCallable$JobState jobState> = v;
v.<org.apache.hive.hcatalog.templeton.JobCallable: java.lang.Object returnResult> = null;
return;
}
public boolean setJobStateFailed()
{
org.apache.hive.hcatalog.templeton.JobCallable$JobState v;
org.apache.hive.hcatalog.templeton.JobCallable v;
boolean v;
v := @this: org.apache.hive.hcatalog.templeton.JobCallable;
v = <org.apache.hive.hcatalog.templeton.JobCallable$JobState: org.apache.hive.hcatalog.templeton.JobCallable$JobState FAILED>;
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.JobCallable: boolean setStateAndResult(org.apache.hive.hcatalog.templeton.JobCallable$JobState,java.lang.Object)>(v, null);
return v;
}
public boolean setJobStateCompleted(java.lang.Object)
{
org.apache.hive.hcatalog.templeton.JobCallable v;
org.apache.hive.hcatalog.templeton.JobCallable$JobState v;
java.lang.Object v;
boolean v;
v := @this: org.apache.hive.hcatalog.templeton.JobCallable;
v := @parameter: java.lang.Object;
v = <org.apache.hive.hcatalog.templeton.JobCallable$JobState: org.apache.hive.hcatalog.templeton.JobCallable$JobState COMPLETED>;
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.JobCallable: boolean setStateAndResult(org.apache.hive.hcatalog.templeton.JobCallable$JobState,java.lang.Object)>(v, v);
return v;
}
private synchronized boolean setStateAndResult(org.apache.hive.hcatalog.templeton.JobCallable$JobState, java.lang.Object)
{
org.slf4j.Logger v;
org.apache.hive.hcatalog.templeton.JobCallable v;
org.apache.hive.hcatalog.templeton.JobCallable$JobState v, v, v, v, v;
java.lang.Object v;
java.lang.String v;
v := @this: org.apache.hive.hcatalog.templeton.JobCallable;
v := @parameter: org.apache.hive.hcatalog.templeton.JobCallable$JobState;
v := @parameter: java.lang.Object;
v = v.<org.apache.hive.hcatalog.templeton.JobCallable: org.apache.hive.hcatalog.templeton.JobCallable$JobState jobState>;
v = <org.apache.hive.hcatalog.templeton.JobCallable$JobState: org.apache.hive.hcatalog.templeton.JobCallable$JobState STARTED>;
if v != v goto label;
v.<org.apache.hive.hcatalog.templeton.JobCallable: org.apache.hive.hcatalog.templeton.JobCallable$JobState jobState> = v;
v.<org.apache.hive.hcatalog.templeton.JobCallable: java.lang.Object returnResult> = v;
return 1;
label:
v = <org.apache.hive.hcatalog.templeton.JobCallable: org.slf4j.Logger LOG>;
v = v.<org.apache.hive.hcatalog.templeton.JobCallable: org.apache.hive.hcatalog.templeton.JobCallable$JobState jobState>;
v = <org.apache.hive.hcatalog.templeton.JobCallable$JobState: org.apache.hive.hcatalog.templeton.JobCallable$JobState STARTED>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.hive.hcatalog.templeton.JobCallable$JobState,org.apache.hive.hcatalog.templeton.JobCallable$JobState,org.apache.hive.hcatalog.templeton.JobCallable$JobState)>(v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Failed to set job state to \u due to job state \u. Expected state is \u0001");
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
return 0;
}
public java.lang.Object call() throws java.lang.Exception
{
org.apache.hive.hcatalog.templeton.JobCallable v;
java.lang.Object v, v;
boolean v;
v := @this: org.apache.hive.hcatalog.templeton.JobCallable;
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.JobCallable: java.lang.Object execute()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.JobCallable: boolean setJobStateCompleted(java.lang.Object)>(v);
if v != 0 goto label;
virtualinvoke v.<org.apache.hive.hcatalog.templeton.JobCallable: void cleanup()>();
return null;
label:
v = v.<org.apache.hive.hcatalog.templeton.JobCallable: java.lang.Object returnResult>;
return v;
}
public abstract java.lang.Object execute() throws java.lang.Exception;
public void cleanup()
{
org.apache.hive.hcatalog.templeton.JobCallable v;
v := @this: org.apache.hive.hcatalog.templeton.JobCallable;
return;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/hive/hcatalog/templeton/JobCallable;");
<org.apache.hive.hcatalog.templeton.JobCallable: org.slf4j.Logger LOG> = v;
return;
}
}