public class org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest extends org.apache.drill.test.ClusterTest
{
private static final java.lang.String TABLE_NAME;
private static org.apache.drill.test.ClusterFixture drill;
private static org.apache.drill.test.ClientFixture drillClient;
public void <init>()
{
org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest v;
v := @this: org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest;
specialinvoke v.<org.apache.drill.test.ClusterTest: void <init>()>();
return;
}
public static void setUpBeforeClass() throws java.lang.Exception
{
staticinvoke <org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest: void initPlugin()>();
return;
}
public static void shutdown() throws java.lang.Exception
{
java.lang.Object[] v;
org.apache.drill.test.ClientFixture v;
org.apache.drill.test.ClusterFixture v;
v = newarray (java.lang.AutoCloseable)[2];
v = <org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest: org.apache.drill.test.ClusterFixture drill>;
v[0] = v;
v = <org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest: org.apache.drill.test.ClientFixture drillClient>;
v[1] = v;
staticinvoke <org.apache.drill.common.AutoCloseables: void close(java.lang.AutoCloseable[])>(v);
return;
}
private static void initPlugin() throws java.lang.Exception
{
org.apache.drill.test.BaseDirTestWatcher v, v;
java.lang.Object[] v;
org.apache.drill.exec.server.Drillbit v;
int v;
java.lang.Boolean v;
java.lang.String v;
org.apache.drill.test.ClientFixture v, v;
org.apache.drill.test.QueryBuilder v, v;
java.util.Properties v;
org.apache.drill.test.ClusterFixture v, v, v, v, v;
org.apache.drill.exec.store.drill.plugin.DrillStoragePluginConfig v;
org.apache.drill.test.ClusterFixtureBuilder v, v;
v = <org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest: org.apache.drill.test.BaseDirTestWatcher dirTestWatcher>;
v = staticinvoke <org.apache.drill.test.ClusterFixture: org.apache.drill.test.ClusterFixtureBuilder builder(org.apache.drill.test.BaseDirTestWatcher)>(v);
staticinvoke <org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest: void startCluster(org.apache.drill.test.ClusterFixtureBuilder)>(v);
v = <org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest: org.apache.drill.test.BaseDirTestWatcher dirTestWatcher>;
v = staticinvoke <org.apache.drill.test.ClusterFixture: org.apache.drill.test.ClusterFixtureBuilder builder(org.apache.drill.test.BaseDirTestWatcher)>(v);
v = virtualinvoke v.<org.apache.drill.test.ClusterFixtureBuilder: org.apache.drill.test.ClusterFixture build()>();
<org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest: org.apache.drill.test.ClusterFixture drill> = v;
v = new org.apache.drill.exec.store.drill.plugin.DrillStoragePluginConfig;
v = <org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest: org.apache.drill.test.ClusterFixture drill>;
v = virtualinvoke v.<org.apache.drill.test.ClusterFixture: org.apache.drill.exec.server.Drillbit drillbit()>();
v = virtualinvoke v.<org.apache.drill.exec.server.Drillbit: int getUserPort()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(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[])>("jdbc:drill:drillbit=localhost:\u0001");
v = new java.util.Properties;
specialinvoke v.<java.util.Properties: void <init>()>();
specialinvoke v.<org.apache.drill.exec.store.drill.plugin.DrillStoragePluginConfig: void <init>(java.lang.String,java.util.Properties,org.apache.drill.common.logical.security.CredentialsProvider,java.lang.String)>(v, v, null, null);
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(1);
virtualinvoke v.<org.apache.drill.exec.store.drill.plugin.DrillStoragePluginConfig: void setEnabled(java.lang.Boolean)>(v);
v = <org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest: org.apache.drill.test.ClusterFixture cluster>;
virtualinvoke v.<org.apache.drill.test.ClusterFixture: void defineStoragePlugin(java.lang.String,org.apache.drill.common.logical.StoragePluginConfig)>("drill", v);
v = <org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest: org.apache.drill.test.ClusterFixture cluster>;
virtualinvoke v.<org.apache.drill.test.ClusterFixture: void defineStoragePlugin(java.lang.String,org.apache.drill.common.logical.StoragePluginConfig)>("drill2", v);
v = <org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest: org.apache.drill.test.ClusterFixture drill>;
v = virtualinvoke v.<org.apache.drill.test.ClusterFixture: org.apache.drill.test.ClientFixture clientFixture()>();
<org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest: org.apache.drill.test.ClientFixture drillClient> = v;
v = <org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest: org.apache.drill.test.ClientFixture drillClient>;
v = virtualinvoke v.<org.apache.drill.test.ClientFixture: org.apache.drill.test.QueryBuilder queryBuilder()>();
v = newarray (java.lang.Object)[1];
v[0] = "dfs.tmp.test_table";
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder: org.apache.drill.test.QueryBuilder sql(java.lang.String,java.lang.Object[])>("create table %s as select * from cp.`tpch/nation.parquet`", v);
virtualinvoke v.<org.apache.drill.test.QueryBuilder: org.apache.drill.test.QueryBuilder$QuerySummary run()>();
return;
}
public void testSerDe() throws java.lang.Exception
{
org.apache.drill.test.QueryBuilder v, v, v, v;
java.lang.Object[] v;
long v;
org.apache.drill.test.QueryBuilder$QuerySummary v;
org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest v;
java.lang.String v;
v := @this: org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest;
v = virtualinvoke v.<org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest: org.apache.drill.test.QueryBuilder queryBuilder()>();
v = newarray (java.lang.Object)[1];
v[0] = "dfs.tmp.test_table";
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder: org.apache.drill.test.QueryBuilder sql(java.lang.String,java.lang.Object[])>("select * from drill.%s", v);
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder: java.lang.String explainJson()>();
v = virtualinvoke v.<org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest: org.apache.drill.test.QueryBuilder queryBuilder()>();
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder: org.apache.drill.test.QueryBuilder physical(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder: org.apache.drill.test.QueryBuilder$QuerySummary run()>();
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder$QuerySummary: long recordCount()>();
staticinvoke <org.junit.Assert: void assertEquals(long,long)>(25L, v);
return;
}
public void testShowDatabases() throws java.lang.Exception
{
java.lang.Object[] v;
java.lang.String[] v;
org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest v;
org.apache.drill.test.TestBuilder v, v, v, v, v;
v := @this: org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest;
v = virtualinvoke v.<org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest: org.apache.drill.test.TestBuilder testBuilder()>();
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder sqlQuery(java.lang.String)>("show databases where SCHEMA_NAME=\'drill.dfs.tmp\'");
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder unOrdered()>();
v = newarray (java.lang.String)[1];
v[0] = "SCHEMA_NAME";
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder baselineColumns(java.lang.String[])>(v);
v = newarray (java.lang.Object)[1];
v[0] = "drill.dfs.tmp";
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder baselineValues(java.lang.Object[])>(v);
virtualinvoke v.<org.apache.drill.test.TestBuilder: void go()>();
return;
}
public void testShowTables() throws java.lang.Exception
{
java.lang.Object[] v, v, v, v, v, v, v;
java.lang.String[] v;
org.apache.drill.test.TestBuilder v, v, v, v, v, v, v, v, v, v, v;
org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest v;
v := @this: org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest;
v = virtualinvoke v.<org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest: org.apache.drill.test.TestBuilder testBuilder()>();
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder sqlQuery(java.lang.String)>("show tables IN drill.INFORMATION_SCHEMA");
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder unOrdered()>();
v = newarray (java.lang.String)[2];
v[0] = "TABLE_SCHEMA";
v[1] = "TABLE_NAME";
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder baselineColumns(java.lang.String[])>(v);
v = newarray (java.lang.Object)[2];
v[0] = "drill.information_schema";
v[1] = "VIEWS";
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder baselineValues(java.lang.Object[])>(v);
v = newarray (java.lang.Object)[2];
v[0] = "drill.information_schema";
v[1] = "CATALOGS";
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder baselineValues(java.lang.Object[])>(v);
v = newarray (java.lang.Object)[2];
v[0] = "drill.information_schema";
v[1] = "COLUMNS";
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder baselineValues(java.lang.Object[])>(v);
v = newarray (java.lang.Object)[2];
v[0] = "drill.information_schema";
v[1] = "PARTITIONS";
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder baselineValues(java.lang.Object[])>(v);
v = newarray (java.lang.Object)[2];
v[0] = "drill.information_schema";
v[1] = "FILES";
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder baselineValues(java.lang.Object[])>(v);
v = newarray (java.lang.Object)[2];
v[0] = "drill.information_schema";
v[1] = "SCHEMATA";
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder baselineValues(java.lang.Object[])>(v);
v = newarray (java.lang.Object)[2];
v[0] = "drill.information_schema";
v[1] = "TABLES";
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder baselineValues(java.lang.Object[])>(v);
virtualinvoke v.<org.apache.drill.test.TestBuilder: void go()>();
return;
}
public void testProjectPushDown() throws java.lang.Exception
{
org.apache.drill.exec.memory.BufferAllocator v;
org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v, v;
java.lang.Integer v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.drill.test.rowSet.RowSetComparison v;
org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest v;
java.lang.Object[] v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.drill.exec.physical.rowSet.DirectRowSet v;
org.apache.drill.test.ClientFixture v;
org.apache.drill.test.QueryBuilder$PlanMatcher v, v, v;
org.apache.drill.common.types.TypeProtos$MinorType v, v, v;
org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.drill.exec.record.metadata.TupleMetadata v;
java.lang.String[] v, v;
org.apache.drill.test.QueryBuilder v, v, v, v;
org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v;
v := @this: org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest;
v = virtualinvoke v.<org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest: org.apache.drill.test.QueryBuilder queryBuilder()>();
v = newarray (java.lang.Object)[1];
v[0] = "dfs.tmp.test_table";
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder: org.apache.drill.test.QueryBuilder sql(java.lang.String,java.lang.Object[])>("select n_nationkey, n_regionkey, n_name from drill.%s", v);
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder: org.apache.drill.test.QueryBuilder$PlanMatcher planMatcher()>();
v = newarray (java.lang.String)[1];
v[0] = "query=\"SELECT `n_nationkey`, `n_regionkey`, `n_name`";
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder$PlanMatcher: org.apache.drill.test.QueryBuilder$PlanMatcher include(java.lang.String[])>(v);
v = newarray (java.lang.String)[1];
v[0] = "\\*";
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder$PlanMatcher: org.apache.drill.test.QueryBuilder$PlanMatcher exclude(java.lang.String[])>(v);
virtualinvoke v.<org.apache.drill.test.QueryBuilder$PlanMatcher: void match()>();
v = virtualinvoke v.<org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest: org.apache.drill.test.QueryBuilder queryBuilder()>();
v = newarray (java.lang.Object)[1];
v[0] = "dfs.tmp.test_table";
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder: org.apache.drill.test.QueryBuilder sql(java.lang.String,java.lang.Object[])>("select n_nationkey, n_regionkey, n_name from drill.%s", v);
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder: org.apache.drill.exec.physical.rowSet.DirectRowSet rowSet()>();
v = new org.apache.drill.exec.record.metadata.SchemaBuilder;
specialinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: void <init>()>();
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType INT>;
v = virtualinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: org.apache.drill.exec.record.metadata.SchemaBuilder add(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("n_nationkey", v);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType INT>;
v = virtualinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: org.apache.drill.exec.record.metadata.SchemaBuilder add(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("n_regionkey", v);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType VARCHAR>;
v = virtualinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: org.apache.drill.exec.record.metadata.SchemaBuilder add(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("n_name", v);
v = virtualinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: org.apache.drill.exec.record.metadata.TupleMetadata build()>();
v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder;
v = <org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest: org.apache.drill.test.ClientFixture client>;
v = virtualinvoke v.<org.apache.drill.test.ClientFixture: org.apache.drill.exec.memory.BufferAllocator allocator()>();
specialinvoke v.<org.apache.drill.exec.physical.rowSet.RowSetBuilder: void <init>(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v);
v = newarray (java.lang.Object)[3];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v[1] = v;
v[2] = "ALGERIA";
v = virtualinvoke v.<org.apache.drill.exec.physical.rowSet.RowSetBuilder: org.apache.drill.exec.physical.rowSet.RowSetBuilder addRow(java.lang.Object[])>(v);
v = newarray (java.lang.Object)[3];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(1);
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(1);
v[1] = v;
v[2] = "ARGENTINA";
v = virtualinvoke v.<org.apache.drill.exec.physical.rowSet.RowSetBuilder: org.apache.drill.exec.physical.rowSet.RowSetBuilder addRow(java.lang.Object[])>(v);
v = newarray (java.lang.Object)[3];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(2);
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(1);
v[1] = v;
v[2] = "BRAZIL";
v = virtualinvoke v.<org.apache.drill.exec.physical.rowSet.RowSetBuilder: org.apache.drill.exec.physical.rowSet.RowSetBuilder addRow(java.lang.Object[])>(v);
v = newarray (java.lang.Object)[3];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(3);
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(1);
v[1] = v;
v[2] = "CANADA";
v = virtualinvoke v.<org.apache.drill.exec.physical.rowSet.RowSetBuilder: org.apache.drill.exec.physical.rowSet.RowSetBuilder addRow(java.lang.Object[])>(v);
v = newarray (java.lang.Object)[3];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(4);
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(4);
v[1] = v;
v[2] = "EGYPT";
v = virtualinvoke v.<org.apache.drill.exec.physical.rowSet.RowSetBuilder: org.apache.drill.exec.physical.rowSet.RowSetBuilder addRow(java.lang.Object[])>(v);
v = newarray (java.lang.Object)[3];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(5);
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v[1] = v;
v[2] = "ETHIOPIA";
v = virtualinvoke v.<org.apache.drill.exec.physical.rowSet.RowSetBuilder: org.apache.drill.exec.physical.rowSet.RowSetBuilder addRow(java.lang.Object[])>(v);
v = newarray (java.lang.Object)[3];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(6);
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(3);
v[1] = v;
v[2] = "FRANCE";
v = virtualinvoke v.<org.apache.drill.exec.physical.rowSet.RowSetBuilder: org.apache.drill.exec.physical.rowSet.RowSetBuilder addRow(java.lang.Object[])>(v);
v = newarray (java.lang.Object)[3];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(7);
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(3);
v[1] = v;
v[2] = "GERMANY";
v = virtualinvoke v.<org.apache.drill.exec.physical.rowSet.RowSetBuilder: org.apache.drill.exec.physical.rowSet.RowSetBuilder addRow(java.lang.Object[])>(v);
v = newarray (java.lang.Object)[3];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(8);
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(2);
v[1] = v;
v[2] = "INDIA";
v = virtualinvoke v.<org.apache.drill.exec.physical.rowSet.RowSetBuilder: org.apache.drill.exec.physical.rowSet.RowSetBuilder addRow(java.lang.Object[])>(v);
v = newarray (java.lang.Object)[3];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(9);
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(2);
v[1] = v;
v[2] = "INDONESIA";
v = virtualinvoke v.<org.apache.drill.exec.physical.rowSet.RowSetBuilder: org.apache.drill.exec.physical.rowSet.RowSetBuilder addRow(java.lang.Object[])>(v);
v = newarray (java.lang.Object)[3];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(10);
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(4);
v[1] = v;
v[2] = "IRAN";
v = virtualinvoke v.<org.apache.drill.exec.physical.rowSet.RowSetBuilder: org.apache.drill.exec.physical.rowSet.RowSetBuilder addRow(java.lang.Object[])>(v);
v = newarray (java.lang.Object)[3];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(11);
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(4);
v[1] = v;
v[2] = "IRAQ";
v = virtualinvoke v.<org.apache.drill.exec.physical.rowSet.RowSetBuilder: org.apache.drill.exec.physical.rowSet.RowSetBuilder addRow(java.lang.Object[])>(v);
v = newarray (java.lang.Object)[3];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(12);
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(2);
v[1] = v;
v[2] = "JAPAN";
v = virtualinvoke v.<org.apache.drill.exec.physical.rowSet.RowSetBuilder: org.apache.drill.exec.physical.rowSet.RowSetBuilder addRow(java.lang.Object[])>(v);
v = newarray (java.lang.Object)[3];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(13);
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(4);
v[1] = v;
v[2] = "JORDAN";
v = virtualinvoke v.<org.apache.drill.exec.physical.rowSet.RowSetBuilder: org.apache.drill.exec.physical.rowSet.RowSetBuilder addRow(java.lang.Object[])>(v);
v = newarray (java.lang.Object)[3];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(14);
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v[1] = v;
v[2] = "KENYA";
v = virtualinvoke v.<org.apache.drill.exec.physical.rowSet.RowSetBuilder: org.apache.drill.exec.physical.rowSet.RowSetBuilder addRow(java.lang.Object[])>(v);
v = newarray (java.lang.Object)[3];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(15);
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v[1] = v;
v[2] = "MOROCCO";
v = virtualinvoke v.<org.apache.drill.exec.physical.rowSet.RowSetBuilder: org.apache.drill.exec.physical.rowSet.RowSetBuilder addRow(java.lang.Object[])>(v);
v = newarray (java.lang.Object)[3];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(16);
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v[1] = v;
v[2] = "MOZAMBIQUE";
v = virtualinvoke v.<org.apache.drill.exec.physical.rowSet.RowSetBuilder: org.apache.drill.exec.physical.rowSet.RowSetBuilder addRow(java.lang.Object[])>(v);
v = newarray (java.lang.Object)[3];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(17);
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(1);
v[1] = v;
v[2] = "PERU";
v = virtualinvoke v.<org.apache.drill.exec.physical.rowSet.RowSetBuilder: org.apache.drill.exec.physical.rowSet.RowSetBuilder addRow(java.lang.Object[])>(v);
v = newarray (java.lang.Object)[3];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(18);
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(2);
v[1] = v;
v[2] = "CHINA";
v = virtualinvoke v.<org.apache.drill.exec.physical.rowSet.RowSetBuilder: org.apache.drill.exec.physical.rowSet.RowSetBuilder addRow(java.lang.Object[])>(v);
v = newarray (java.lang.Object)[3];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(19);
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(3);
v[1] = v;
v[2] = "ROMANIA";
v = virtualinvoke v.<org.apache.drill.exec.physical.rowSet.RowSetBuilder: org.apache.drill.exec.physical.rowSet.RowSetBuilder addRow(java.lang.Object[])>(v);
v = newarray (java.lang.Object)[3];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(20);
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(4);
v[1] = v;
v[2] = "SAUDI ARABIA";
v = virtualinvoke v.<org.apache.drill.exec.physical.rowSet.RowSetBuilder: org.apache.drill.exec.physical.rowSet.RowSetBuilder addRow(java.lang.Object[])>(v);
v = newarray (java.lang.Object)[3];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(21);
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(2);
v[1] = v;
v[2] = "VIETNAM";
v = virtualinvoke v.<org.apache.drill.exec.physical.rowSet.RowSetBuilder: org.apache.drill.exec.physical.rowSet.RowSetBuilder addRow(java.lang.Object[])>(v);
v = newarray (java.lang.Object)[3];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(22);
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(3);
v[1] = v;
v[2] = "RUSSIA";
v = virtualinvoke v.<org.apache.drill.exec.physical.rowSet.RowSetBuilder: org.apache.drill.exec.physical.rowSet.RowSetBuilder addRow(java.lang.Object[])>(v);
v = newarray (java.lang.Object)[3];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(23);
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(3);
v[1] = v;
v[2] = "UNITED KINGDOM";
v = virtualinvoke v.<org.apache.drill.exec.physical.rowSet.RowSetBuilder: org.apache.drill.exec.physical.rowSet.RowSetBuilder addRow(java.lang.Object[])>(v);
v = newarray (java.lang.Object)[3];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(24);
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(1);
v[1] = v;
v[2] = "UNITED STATES";
v = virtualinvoke v.<org.apache.drill.exec.physical.rowSet.RowSetBuilder: org.apache.drill.exec.physical.rowSet.RowSetBuilder addRow(java.lang.Object[])>(v);
v = virtualinvoke v.<org.apache.drill.exec.physical.rowSet.RowSetBuilder: org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet build()>();
v = new org.apache.drill.test.rowSet.RowSetComparison;
specialinvoke v.<org.apache.drill.test.rowSet.RowSetComparison: void <init>(org.apache.drill.exec.physical.rowSet.RowSet)>(v);
virtualinvoke v.<org.apache.drill.test.rowSet.RowSetComparison: void verifyAndClearAll(org.apache.drill.exec.physical.rowSet.RowSet)>(v);
return;
}
public void testFilterPushDown() throws java.lang.Exception
{
java.lang.Object[] v, v, v;
org.apache.drill.test.QueryBuilder$PlanMatcher v, v, v;
java.lang.String[] v, v, v;
java.lang.Integer v;
org.apache.drill.test.TestBuilder v, v, v, v, v;
org.apache.drill.test.QueryBuilder v, v;
org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest v;
v := @this: org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest;
v = virtualinvoke v.<org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest: org.apache.drill.test.QueryBuilder queryBuilder()>();
v = newarray (java.lang.Object)[1];
v[0] = "dfs.tmp.test_table";
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder: org.apache.drill.test.QueryBuilder sql(java.lang.String,java.lang.Object[])>("select n_name, n_nationkey from drill.%s where n_nationkey = 0", v);
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder: org.apache.drill.test.QueryBuilder$PlanMatcher planMatcher()>();
v = newarray (java.lang.String)[1];
v[0] = "WHERE";
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder$PlanMatcher: org.apache.drill.test.QueryBuilder$PlanMatcher include(java.lang.String[])>(v);
v = newarray (java.lang.String)[1];
v[0] = "Filter";
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder$PlanMatcher: org.apache.drill.test.QueryBuilder$PlanMatcher exclude(java.lang.String[])>(v);
virtualinvoke v.<org.apache.drill.test.QueryBuilder$PlanMatcher: void match()>();
v = virtualinvoke v.<org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest: org.apache.drill.test.TestBuilder testBuilder()>();
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder unOrdered()>();
v = newarray (java.lang.Object)[1];
v[0] = "dfs.tmp.test_table";
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder sqlQuery(java.lang.String,java.lang.Object[])>("select n_name, n_nationkey from drill.%s where n_nationkey = 0", v);
v = newarray (java.lang.String)[2];
v[0] = "n_name";
v[1] = "n_nationkey";
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder baselineColumns(java.lang.String[])>(v);
v = newarray (java.lang.Object)[2];
v[0] = "ALGERIA";
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v[1] = v;
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder baselineValues(java.lang.Object[])>(v);
virtualinvoke v.<org.apache.drill.test.TestBuilder: void go()>();
return;
}
public void testFilterPushDownWithJoin() throws java.lang.Exception
{
java.lang.Object[] v, v, v;
org.apache.drill.test.QueryBuilder$PlanMatcher v, v;
java.lang.String[] v, v;
java.lang.Integer v, v, v, v;
org.apache.drill.test.TestBuilder v, v, v, v, v;
org.apache.drill.test.QueryBuilder v, v;
org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest v;
v := @this: org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest;
v = virtualinvoke v.<org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest: org.apache.drill.test.QueryBuilder queryBuilder()>();
v = newarray (java.lang.Object)[2];
v[0] = "dfs.tmp.test_table";
v[1] = "dfs.tmp.test_table";
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder: org.apache.drill.test.QueryBuilder sql(java.lang.String,java.lang.Object[])>("select * from drill.%s e\njoin drill.%s s on e.n_nationkey = s.n_nationkey where e.n_name = \'BRAZIL\'", v);
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder: org.apache.drill.test.QueryBuilder$PlanMatcher planMatcher()>();
v = newarray (java.lang.String)[1];
v[0] = "INNER JOIN";
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder$PlanMatcher: org.apache.drill.test.QueryBuilder$PlanMatcher include(java.lang.String[])>(v);
virtualinvoke v.<org.apache.drill.test.QueryBuilder$PlanMatcher: void match()>();
v = virtualinvoke v.<org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest: org.apache.drill.test.TestBuilder testBuilder()>();
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder ordered()>();
v = newarray (java.lang.Object)[2];
v[0] = "dfs.tmp.test_table";
v[1] = "dfs.tmp.test_table";
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder sqlQuery(java.lang.String,java.lang.Object[])>("select * from drill.%s e\njoin drill.%s s on e.n_nationkey = s.n_nationkey where e.n_name = \'BRAZIL\'", v);
v = newarray (java.lang.String)[8];
v[0] = "n_nationkey";
v[1] = "n_name";
v[2] = "n_regionkey";
v[3] = "n_comment";
v[4] = "n_nationkey0";
v[5] = "n_name0";
v[6] = "n_regionkey0";
v[7] = "n_comment0";
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder baselineColumns(java.lang.String[])>(v);
v = newarray (java.lang.Object)[8];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(2);
v[0] = v;
v[1] = "BRAZIL";
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(1);
v[2] = v;
v[3] = "y alongside of the pending deposits. carefully special packages are about the ironic forges. slyly special ";
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(2);
v[4] = v;
v[5] = "BRAZIL";
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(1);
v[6] = v;
v[7] = "y alongside of the pending deposits. carefully special packages are about the ironic forges. slyly special ";
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder baselineValues(java.lang.Object[])>(v);
virtualinvoke v.<org.apache.drill.test.TestBuilder: void go()>();
return;
}
public void testJoinDifferentDrillPlugins() throws java.lang.Exception
{
java.lang.Object[] v, v, v;
org.apache.drill.test.QueryBuilder$PlanMatcher v, v, v;
java.lang.String[] v, v, v;
java.lang.Integer v, v, v, v;
org.apache.drill.test.TestBuilder v, v, v, v, v;
org.apache.drill.test.QueryBuilder v, v;
org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest v;
v := @this: org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest;
v = virtualinvoke v.<org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest: org.apache.drill.test.QueryBuilder queryBuilder()>();
v = newarray (java.lang.Object)[2];
v[0] = "dfs.tmp.test_table";
v[1] = "dfs.tmp.test_table";
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder: org.apache.drill.test.QueryBuilder sql(java.lang.String,java.lang.Object[])>("select * from drill.%s e\njoin drill.cp.`tpch/nation.parquet` s on e.n_nationkey = s.n_nationkey where e.n_name = \'BRAZIL\'", v);
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder: org.apache.drill.test.QueryBuilder$PlanMatcher planMatcher()>();
v = newarray (java.lang.String)[1];
v[0] = "HashJoin";
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder$PlanMatcher: org.apache.drill.test.QueryBuilder$PlanMatcher include(java.lang.String[])>(v);
v = newarray (java.lang.String)[1];
v[0] = "INNER JOIN";
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder$PlanMatcher: org.apache.drill.test.QueryBuilder$PlanMatcher exclude(java.lang.String[])>(v);
virtualinvoke v.<org.apache.drill.test.QueryBuilder$PlanMatcher: void match()>();
v = virtualinvoke v.<org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest: org.apache.drill.test.TestBuilder testBuilder()>();
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder unOrdered()>();
v = newarray (java.lang.Object)[2];
v[0] = "dfs.tmp.test_table";
v[1] = "dfs.tmp.test_table";
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder sqlQuery(java.lang.String,java.lang.Object[])>("select * from drill.%s e\njoin drill.cp.`tpch/nation.parquet` s on e.n_nationkey = s.n_nationkey where e.n_name = \'BRAZIL\'", v);
v = newarray (java.lang.String)[8];
v[0] = "n_nationkey";
v[1] = "n_name";
v[2] = "n_regionkey";
v[3] = "n_comment";
v[4] = "n_nationkey0";
v[5] = "n_name0";
v[6] = "n_regionkey0";
v[7] = "n_comment0";
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder baselineColumns(java.lang.String[])>(v);
v = newarray (java.lang.Object)[8];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(2);
v[0] = v;
v[1] = "BRAZIL";
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(1);
v[2] = v;
v[3] = "y alongside of the pending deposits. carefully special packages are about the ironic forges. slyly special ";
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(2);
v[4] = v;
v[5] = "BRAZIL";
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(1);
v[6] = v;
v[7] = "y alongside of the pending deposits. carefully special packages are about the ironic forges. slyly special ";
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder baselineValues(java.lang.Object[])>(v);
virtualinvoke v.<org.apache.drill.test.TestBuilder: void go()>();
return;
}
public void testAggregationPushDown() throws java.lang.Exception
{
java.lang.Object[] v, v, v;
org.apache.drill.test.QueryBuilder$PlanMatcher v, v;
java.lang.String[] v, v;
org.apache.drill.test.TestBuilder v, v, v, v, v;
java.lang.Long v;
org.apache.drill.test.QueryBuilder v, v;
org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest v;
v := @this: org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest;
v = virtualinvoke v.<org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest: org.apache.drill.test.QueryBuilder queryBuilder()>();
v = newarray (java.lang.Object)[1];
v[0] = "dfs.tmp.test_table";
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder: org.apache.drill.test.QueryBuilder sql(java.lang.String,java.lang.Object[])>("select count(*) c from drill.%s", v);
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder: org.apache.drill.test.QueryBuilder$PlanMatcher planMatcher()>();
v = newarray (java.lang.String)[1];
v[0] = "query=\"SELECT COUNT\\(\\*\\)";
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder$PlanMatcher: org.apache.drill.test.QueryBuilder$PlanMatcher include(java.lang.String[])>(v);
virtualinvoke v.<org.apache.drill.test.QueryBuilder$PlanMatcher: void match()>();
v = virtualinvoke v.<org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest: org.apache.drill.test.TestBuilder testBuilder()>();
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder unOrdered()>();
v = newarray (java.lang.Object)[1];
v[0] = "dfs.tmp.test_table";
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder sqlQuery(java.lang.String,java.lang.Object[])>("select count(*) c from drill.%s", v);
v = newarray (java.lang.String)[1];
v[0] = "c";
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder baselineColumns(java.lang.String[])>(v);
v = newarray (java.lang.Object)[1];
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(25L);
v[0] = v;
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder baselineValues(java.lang.Object[])>(v);
virtualinvoke v.<org.apache.drill.test.TestBuilder: void go()>();
return;
}
public void testLimitPushDown() throws java.lang.Exception
{
org.apache.drill.test.QueryBuilder v, v;
java.lang.Object[] v, v, v;
org.apache.drill.test.QueryBuilder$PlanMatcher v, v;
java.lang.String[] v, v;
org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest v;
org.apache.drill.test.TestBuilder v, v, v, v, v;
v := @this: org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest;
v = virtualinvoke v.<org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest: org.apache.drill.test.QueryBuilder queryBuilder()>();
v = newarray (java.lang.Object)[1];
v[0] = "dfs.tmp.test_table";
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder: org.apache.drill.test.QueryBuilder sql(java.lang.String,java.lang.Object[])>("select n_name from drill.%s FETCH NEXT 1 ROWS ONLY", v);
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder: org.apache.drill.test.QueryBuilder$PlanMatcher planMatcher()>();
v = newarray (java.lang.String)[1];
v[0] = "FETCH NEXT 1 ROWS ONLY";
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder$PlanMatcher: org.apache.drill.test.QueryBuilder$PlanMatcher include(java.lang.String[])>(v);
virtualinvoke v.<org.apache.drill.test.QueryBuilder$PlanMatcher: void match()>();
v = virtualinvoke v.<org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest: org.apache.drill.test.TestBuilder testBuilder()>();
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder unOrdered()>();
v = newarray (java.lang.Object)[1];
v[0] = "dfs.tmp.test_table";
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder sqlQuery(java.lang.String,java.lang.Object[])>("select n_name from drill.%s FETCH NEXT 1 ROWS ONLY", v);
v = newarray (java.lang.String)[1];
v[0] = "n_name";
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder baselineColumns(java.lang.String[])>(v);
v = newarray (java.lang.Object)[1];
v[0] = "ALGERIA";
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder baselineValues(java.lang.Object[])>(v);
virtualinvoke v.<org.apache.drill.test.TestBuilder: void go()>();
return;
}
public void testLimitWithSortPushDown() throws java.lang.Exception
{
java.lang.Object[] v, v, v, v, v;
org.apache.drill.test.QueryBuilder$PlanMatcher v, v;
java.lang.String[] v, v;
java.lang.Integer v, v, v;
org.apache.drill.test.TestBuilder v, v, v, v, v, v, v;
org.apache.drill.test.QueryBuilder v, v;
org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest v;
v := @this: org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest;
v = virtualinvoke v.<org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest: org.apache.drill.test.QueryBuilder queryBuilder()>();
v = newarray (java.lang.Object)[1];
v[0] = "dfs.tmp.test_table";
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder: org.apache.drill.test.QueryBuilder sql(java.lang.String,java.lang.Object[])>("select n_nationkey from drill.%s order by n_name limit 3", v);
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder: org.apache.drill.test.QueryBuilder$PlanMatcher planMatcher()>();
v = newarray (java.lang.String)[2];
v[0] = "ORDER BY `n_name`";
v[1] = "FETCH NEXT 3 ROWS ONLY";
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder$PlanMatcher: org.apache.drill.test.QueryBuilder$PlanMatcher include(java.lang.String[])>(v);
virtualinvoke v.<org.apache.drill.test.QueryBuilder$PlanMatcher: void match()>();
v = virtualinvoke v.<org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest: org.apache.drill.test.TestBuilder testBuilder()>();
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder unOrdered()>();
v = newarray (java.lang.Object)[1];
v[0] = "dfs.tmp.test_table";
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder sqlQuery(java.lang.String,java.lang.Object[])>("select n_nationkey from drill.%s order by n_name limit 3", v);
v = newarray (java.lang.String)[1];
v[0] = "n_nationkey";
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder baselineColumns(java.lang.String[])>(v);
v = newarray (java.lang.Object)[1];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v[0] = v;
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder baselineValues(java.lang.Object[])>(v);
v = newarray (java.lang.Object)[1];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(1);
v[0] = v;
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder baselineValues(java.lang.Object[])>(v);
v = newarray (java.lang.Object)[1];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(2);
v[0] = v;
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder baselineValues(java.lang.Object[])>(v);
virtualinvoke v.<org.apache.drill.test.TestBuilder: void go()>();
return;
}
public void testAggregationWithGroupByPushDown() throws java.lang.Exception
{
java.lang.Object[] v, v, v, v, v, v, v;
org.apache.drill.test.QueryBuilder$PlanMatcher v, v;
java.lang.String[] v, v;
org.apache.drill.test.TestBuilder v, v, v, v, v, v, v, v, v;
java.lang.Long v, v, v, v, v;
org.apache.drill.test.QueryBuilder v, v;
org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest v;
v := @this: org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest;
v = virtualinvoke v.<org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest: org.apache.drill.test.QueryBuilder queryBuilder()>();
v = newarray (java.lang.Object)[1];
v[0] = "dfs.tmp.test_table";
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder: org.apache.drill.test.QueryBuilder sql(java.lang.String,java.lang.Object[])>("select sum(n_nationkey) s from drill.%s group by n_regionkey", v);
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder: org.apache.drill.test.QueryBuilder$PlanMatcher planMatcher()>();
v = newarray (java.lang.String)[2];
v[0] = "query=\"SELECT SUM\\(`n_nationkey`\\)";
v[1] = "GROUP BY `n_regionkey`";
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder$PlanMatcher: org.apache.drill.test.QueryBuilder$PlanMatcher include(java.lang.String[])>(v);
virtualinvoke v.<org.apache.drill.test.QueryBuilder$PlanMatcher: void match()>();
v = virtualinvoke v.<org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest: org.apache.drill.test.TestBuilder testBuilder()>();
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder unOrdered()>();
v = newarray (java.lang.Object)[1];
v[0] = "dfs.tmp.test_table";
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder sqlQuery(java.lang.String,java.lang.Object[])>("select sum(n_nationkey) s from drill.%s group by n_regionkey", v);
v = newarray (java.lang.String)[1];
v[0] = "s";
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder baselineColumns(java.lang.String[])>(v);
v = newarray (java.lang.Object)[1];
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(47L);
v[0] = v;
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder baselineValues(java.lang.Object[])>(v);
v = newarray (java.lang.Object)[1];
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(50L);
v[0] = v;
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder baselineValues(java.lang.Object[])>(v);
v = newarray (java.lang.Object)[1];
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(58L);
v[0] = v;
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder baselineValues(java.lang.Object[])>(v);
v = newarray (java.lang.Object)[1];
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(68L);
v[0] = v;
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder baselineValues(java.lang.Object[])>(v);
v = newarray (java.lang.Object)[1];
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(77L);
v[0] = v;
v = virtualinvoke v.<org.apache.drill.test.TestBuilder: org.apache.drill.test.TestBuilder baselineValues(java.lang.Object[])>(v);
virtualinvoke v.<org.apache.drill.test.TestBuilder: void go()>();
return;
}
public void testUnionAllPushDown() throws java.lang.Exception
{
org.apache.drill.test.QueryBuilder v, v, v, v;
java.lang.Object[] v, v;
org.apache.drill.test.QueryBuilder$PlanMatcher v, v;
java.lang.String[] v;
long v;
org.apache.drill.test.QueryBuilder$QuerySummary v;
org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest v;
v := @this: org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest;
v = virtualinvoke v.<org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest: org.apache.drill.test.QueryBuilder queryBuilder()>();
v = newarray (java.lang.Object)[2];
v[0] = "dfs.tmp.test_table";
v[1] = "dfs.tmp.test_table";
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder: org.apache.drill.test.QueryBuilder sql(java.lang.String,java.lang.Object[])>("select col, col from drill.%s union all select col, col from drill.%s", v);
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder: org.apache.drill.test.QueryBuilder$PlanMatcher planMatcher()>();
v = newarray (java.lang.String)[1];
v[0] = "UNION ALL";
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder$PlanMatcher: org.apache.drill.test.QueryBuilder$PlanMatcher include(java.lang.String[])>(v);
virtualinvoke v.<org.apache.drill.test.QueryBuilder$PlanMatcher: void match()>();
v = virtualinvoke v.<org.apache.drill.exec.store.drill.plugin.DrillPluginQueriesTest: org.apache.drill.test.QueryBuilder queryBuilder()>();
v = newarray (java.lang.Object)[2];
v[0] = "dfs.tmp.test_table";
v[1] = "dfs.tmp.test_table";
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder: org.apache.drill.test.QueryBuilder sql(java.lang.String,java.lang.Object[])>("select col, col from drill.%s union all select col, col from drill.%s", v);
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder: org.apache.drill.test.QueryBuilder$QuerySummary run()>();
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder$QuerySummary: long recordCount()>();
staticinvoke <org.junit.Assert: void assertEquals(long,long)>(50L, v);
return;
}
}