public class oadd.org.apache.drill.exec.util.Utilities extends java.lang.Object
{
public static final java.lang.String COL_NULL_ERROR;
public void <init>()
{
oadd.org.apache.drill.exec.util.Utilities v;
v := @this: oadd.org.apache.drill.exec.util.Utilities;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public static java.lang.String getFileNameForQueryFragment(oadd.org.apache.drill.exec.ops.FragmentContext, java.lang.String, java.lang.String)
{
java.lang.Object[] v;
oadd.org.apache.drill.exec.proto.ExecProtos$FragmentHandle v;
java.lang.Integer v, v;
oadd.org.apache.drill.exec.ops.FragmentContext v;
int v, v;
java.lang.String v, v, v, v;
oadd.org.apache.drill.exec.proto.UserBitShared$QueryId v;
v := @parameter: oadd.org.apache.drill.exec.ops.FragmentContext;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.ops.FragmentContext: oadd.org.apache.drill.exec.proto.ExecProtos$FragmentHandle getHandle()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.ExecProtos$FragmentHandle: oadd.org.apache.drill.exec.proto.UserBitShared$QueryId getQueryId()>();
v = staticinvoke <oadd.org.apache.drill.exec.proto.helper.QueryIdHelper: java.lang.String getQueryId(oadd.org.apache.drill.exec.proto.UserBitShared$QueryId)>(v);
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.ExecProtos$FragmentHandle: int getMajorFragmentId()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.ExecProtos$FragmentHandle: int getMinorFragmentId()>();
v = newarray (java.lang.Object)[5];
v[0] = v;
v[1] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[2] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[3] = v;
v[4] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("%s//%s_%s_%s_%s", v);
return v;
}
public static oadd.org.apache.drill.exec.proto.BitControl$QueryContextInformation createQueryContextInfo(java.lang.String, java.lang.String)
{
oadd.org.apache.drill.exec.proto.BitControl$QueryContextInformation$Builder v, v, v, v, v;
long v;
oadd.org.apache.drill.exec.proto.BitControl$QueryContextInformation v;
int v;
java.lang.String v, v, v;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = staticinvoke <java.lang.System: java.lang.String getProperty(java.lang.String)>("user.timezone");
v = staticinvoke <oadd.org.apache.drill.exec.expr.fn.impl.DateUtility: int getIndex(java.lang.String)>(v);
v = staticinvoke <oadd.org.apache.drill.exec.proto.BitControl$QueryContextInformation: oadd.org.apache.drill.exec.proto.BitControl$QueryContextInformation$Builder newBuilder()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.BitControl$QueryContextInformation$Builder: oadd.org.apache.drill.exec.proto.BitControl$QueryContextInformation$Builder setDefaultSchemaName(java.lang.String)>(v);
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.BitControl$QueryContextInformation$Builder: oadd.org.apache.drill.exec.proto.BitControl$QueryContextInformation$Builder setQueryStartTime(long)>(v);
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.BitControl$QueryContextInformation$Builder: oadd.org.apache.drill.exec.proto.BitControl$QueryContextInformation$Builder setTimeZone(int)>(v);
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.BitControl$QueryContextInformation$Builder: oadd.org.apache.drill.exec.proto.BitControl$QueryContextInformation$Builder setSessionId(java.lang.String)>(v);
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.BitControl$QueryContextInformation$Builder: oadd.org.apache.drill.exec.proto.BitControl$QueryContextInformation build()>();
return v;
}
public static java.lang.String getDrillVersion()
{
java.lang.Class v;
java.lang.String v;
java.lang.Package v;
v = class "Loadd/org/apache/drill/exec/util/Utilities;";
v = virtualinvoke v.<java.lang.Class: java.lang.Package getPackage()>();
v = virtualinvoke v.<java.lang.Package: java.lang.String getImplementationVersion()>();
return v;
}
public static boolean isStarQuery(java.util.Collection)
{
java.util.stream.Stream v;
java.util.function.Predicate v;
java.util.Collection v;
java.lang.Object v;
boolean v;
v := @parameter: java.util.Collection;
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object,java.lang.Object)>(v, "Columns cannot be null. Use star column to select all fields.");
v = interfaceinvoke v.<java.util.Collection: java.util.stream.Stream stream()>();
v = staticinvoke <oadd.org.apache.drill.exec.util.Utilities$isDynamicStar__594: java.util.function.Predicate bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: boolean anyMatch(java.util.function.Predicate)>(v);
return v;
}
public static boolean isStarQuery(oadd.org.apache.calcite.rel.type.RelDataType)
{
java.util.List v;
oadd.org.apache.calcite.rel.type.RelDataType v;
java.util.stream.Stream v;
java.util.function.Predicate v;
boolean v;
v := @parameter: oadd.org.apache.calcite.rel.type.RelDataType;
v = interfaceinvoke v.<oadd.org.apache.calcite.rel.type.RelDataType: java.util.List getFieldNames()>();
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = staticinvoke <oadd.org.apache.drill.exec.util.Utilities$equals__595: java.util.function.Predicate bootstrap$(java.lang.String)>("**");
v = interfaceinvoke v.<java.util.stream.Stream: boolean anyMatch(java.util.function.Predicate)>(v);
return v;
}
public static oadd.org.apache.drill.exec.planner.logical.DrillTable getDrillTable(oadd.org.apache.calcite.plan.RelOptTable)
{
oadd.org.apache.calcite.plan.RelOptTable v;
java.lang.Object v, v, v;
v := @parameter: oadd.org.apache.calcite.plan.RelOptTable;
v = interfaceinvoke v.<oadd.org.apache.calcite.plan.RelOptTable: java.lang.Object unwrap(java.lang.Class)>(class "Loadd/org/apache/drill/exec/planner/logical/DrillTable;");
if v != null goto label;
v = interfaceinvoke v.<oadd.org.apache.calcite.plan.RelOptTable: java.lang.Object unwrap(java.lang.Class)>(class "Loadd/org/apache/drill/exec/planner/logical/DrillTranslatableTable;");
if v == null goto label;
v = interfaceinvoke v.<oadd.org.apache.calcite.plan.RelOptTable: java.lang.Object unwrap(java.lang.Class)>(class "Loadd/org/apache/drill/exec/planner/logical/DrillTranslatableTable;");
v = virtualinvoke v.<oadd.org.apache.drill.exec.planner.logical.DrillTranslatableTable: oadd.org.apache.drill.exec.planner.logical.DrillTable getDrillTable()>();
label:
return v;
}
public static oadd.org.apache.drill.common.expression.PathSegment convertLiteral(oadd.org.apache.calcite.rex.RexLiteral)
{
oadd.org.apache.calcite.sql.type.SqlTypeName v;
oadd.org.apache.calcite.rel.type.RelDataType v;
oadd.org.apache.calcite.rex.RexLiteral v;
oadd.org.apache.drill.common.expression.PathSegment$NameSegment v;
int[] v;
int v, v, v;
oadd.org.apache.drill.common.expression.PathSegment$ArraySegment v;
java.lang.String v;
v := @parameter: oadd.org.apache.calcite.rex.RexLiteral;
v = <oadd.org.apache.drill.exec.util.Utilities$1: int[] $SwitchMap$org$apache$calcite$sql$type$SqlTypeName>;
v = virtualinvoke v.<oadd.org.apache.calcite.rex.RexLiteral: oadd.org.apache.calcite.rel.type.RelDataType getType()>();
v = interfaceinvoke v.<oadd.org.apache.calcite.rel.type.RelDataType: oadd.org.apache.calcite.sql.type.SqlTypeName getSqlTypeName()>();
v = virtualinvoke v.<oadd.org.apache.calcite.sql.type.SqlTypeName: int ordinal()>();
v = v[v];
lookupswitch(v)
{
case 1: goto label;
case 2: goto label;
default: goto label;
};
label:
v = new oadd.org.apache.drill.common.expression.PathSegment$NameSegment;
v = staticinvoke <oadd.org.apache.calcite.rex.RexLiteral: java.lang.String stringValue(oadd.org.apache.calcite.rex.RexNode)>(v);
specialinvoke v.<oadd.org.apache.drill.common.expression.PathSegment$NameSegment: void <init>(java.lang.CharSequence)>(v);
return v;
label:
v = new oadd.org.apache.drill.common.expression.PathSegment$ArraySegment;
v = staticinvoke <oadd.org.apache.calcite.rex.RexLiteral: int intValue(oadd.org.apache.calcite.rex.RexNode)>(v);
specialinvoke v.<oadd.org.apache.drill.common.expression.PathSegment$ArraySegment: void <init>(int)>(v);
return v;
label:
return null;
}
public static oadd.org.apache.calcite.rel.metadata.JaninoRelMetadataProvider registerJaninoRelMetadataProvider()
{
oadd.org.apache.calcite.rel.metadata.RelMetadataProvider v;
java.lang.ThreadLocal v;
oadd.org.apache.calcite.rel.metadata.JaninoRelMetadataProvider v;
v = <oadd.org.apache.drill.exec.planner.cost.DrillDefaultRelMetadataProvider: oadd.org.apache.calcite.rel.metadata.RelMetadataProvider INSTANCE>;
v = staticinvoke <oadd.org.apache.calcite.rel.metadata.JaninoRelMetadataProvider: oadd.org.apache.calcite.rel.metadata.JaninoRelMetadataProvider of(oadd.org.apache.calcite.rel.metadata.RelMetadataProvider)>(v);
v = <oadd.org.apache.calcite.rel.metadata.RelMetadataQuery: java.lang.ThreadLocal THREAD_PROVIDERS>;
virtualinvoke v.<java.lang.ThreadLocal: void set(java.lang.Object)>(v);
return v;
}
}