public class org.apache.drill.exec.store.spss.TestSpssReader extends org.apache.drill.test.ClusterTest
{
public void <init>()
{
org.apache.drill.exec.store.spss.TestSpssReader v;
v := @this: org.apache.drill.exec.store.spss.TestSpssReader;
specialinvoke v.<org.apache.drill.test.ClusterTest: void <init>()>();
return;
}
public static void setup() throws java.lang.Exception
{
org.apache.drill.test.BaseDirTestWatcher v, v;
java.lang.String[] v;
org.apache.drill.test.ClusterFixtureBuilder v;
java.nio.file.Path v;
v = <org.apache.drill.exec.store.spss.TestSpssReader: 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.test.ClusterTest: void startCluster(org.apache.drill.test.ClusterFixtureBuilder)>(v);
v = <org.apache.drill.exec.store.spss.TestSpssReader: org.apache.drill.test.BaseDirTestWatcher dirTestWatcher>;
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("spss/", v);
virtualinvoke v.<org.apache.drill.test.BaseDirTestWatcher: java.io.File copyResourceToRoot(java.nio.file.Path)>(v);
return;
}
public void testStarQuery() throws java.lang.Exception
{
org.apache.drill.test.rowSet.RowSetComparison v;
org.apache.drill.exec.store.spss.TestSpssReader v;
java.lang.Object[] v, v, v;
org.apache.drill.test.ClientFixture v, v;
org.apache.drill.common.types.TypeProtos$MinorType 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.exec.record.metadata.TupleMetadata v;
int v;
org.apache.drill.test.QueryBuilder v, v;
org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v;
org.apache.drill.exec.memory.BufferAllocator v;
org.apache.drill.exec.record.metadata.SchemaBuilder 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;
java.lang.Double 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, 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.exec.physical.rowSet.RowSetBuilder v, v, v, v;
v := @this: org.apache.drill.exec.store.spss.TestSpssReader;
v = <org.apache.drill.exec.store.spss.TestSpssReader: org.apache.drill.test.ClientFixture client>;
v = virtualinvoke v.<org.apache.drill.test.ClientFixture: org.apache.drill.test.QueryBuilder queryBuilder()>();
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder: org.apache.drill.test.QueryBuilder sql(java.lang.String)>("SELECT * FROM dfs.`spss/testdata.sav` WHERE d16=4");
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 FLOAT8>;
v = virtualinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: org.apache.drill.exec.record.metadata.SchemaBuilder addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("ID", v);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType FLOAT8>;
v = virtualinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: org.apache.drill.exec.record.metadata.SchemaBuilder addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("Urban", 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 addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("Urban_value", v);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType FLOAT8>;
v = virtualinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: org.apache.drill.exec.record.metadata.SchemaBuilder addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("District", 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 addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("District_value", v);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType FLOAT8>;
v = virtualinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: org.apache.drill.exec.record.metadata.SchemaBuilder addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("Province", 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 addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("Province_value", v);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType FLOAT8>;
v = virtualinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: org.apache.drill.exec.record.metadata.SchemaBuilder addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("Interviewer", v);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType FLOAT8>;
v = virtualinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: org.apache.drill.exec.record.metadata.SchemaBuilder addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("Date", v);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType FLOAT8>;
v = virtualinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: org.apache.drill.exec.record.metadata.SchemaBuilder addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("d6_1", 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 addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("d6_1_Value", v);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType FLOAT8>;
v = virtualinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: org.apache.drill.exec.record.metadata.SchemaBuilder addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("d6_2", 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 addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("d6_2_Value", v);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType FLOAT8>;
v = virtualinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: org.apache.drill.exec.record.metadata.SchemaBuilder addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("d6_3", 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 addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("d6_3_Value", v);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType FLOAT8>;
v = virtualinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: org.apache.drill.exec.record.metadata.SchemaBuilder addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("d6_4", 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 addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("d6_4_Value", 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 addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("s_1", v);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType FLOAT8>;
v = virtualinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: org.apache.drill.exec.record.metadata.SchemaBuilder addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("d6_5", 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 addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("d6_5_Value", v);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType FLOAT8>;
v = virtualinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: org.apache.drill.exec.record.metadata.SchemaBuilder addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("d6_6", 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 addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("d6_6_Value", v);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType FLOAT8>;
v = virtualinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: org.apache.drill.exec.record.metadata.SchemaBuilder addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("d6_7", 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 addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("d6_7_Value", v);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType FLOAT8>;
v = virtualinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: org.apache.drill.exec.record.metadata.SchemaBuilder addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("q1", 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 addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("q1_Value", v);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType FLOAT8>;
v = virtualinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: org.apache.drill.exec.record.metadata.SchemaBuilder addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("q2", 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 addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("q2_Value", v);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType FLOAT8>;
v = virtualinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: org.apache.drill.exec.record.metadata.SchemaBuilder addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("d7a", 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 addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("d7a_Value", v);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType FLOAT8>;
v = virtualinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: org.apache.drill.exec.record.metadata.SchemaBuilder addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("d7b", 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 addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("d7b_Value", v);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType FLOAT8>;
v = virtualinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: org.apache.drill.exec.record.metadata.SchemaBuilder addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("d16", v);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType FLOAT8>;
v = virtualinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: org.apache.drill.exec.record.metadata.SchemaBuilder addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("Stratum", v);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType FLOAT8>;
v = virtualinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: org.apache.drill.exec.record.metadata.SchemaBuilder addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("S1_IP", v);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType FLOAT8>;
v = virtualinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: org.apache.drill.exec.record.metadata.SchemaBuilder addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("S2_IP", v);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType FLOAT8>;
v = virtualinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: org.apache.drill.exec.record.metadata.SchemaBuilder addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("Sample_Weight", v);
v = virtualinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: org.apache.drill.exec.record.metadata.TupleMetadata buildSchema()>();
v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder;
v = <org.apache.drill.exec.store.spss.TestSpssReader: 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)[37];
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(47.0);
v[0] = v;
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(1.0);
v[1] = v;
v[2] = "Urban";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(101.0);
v[3] = v;
v[4] = "Kabul";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(1.0);
v[5] = v;
v[6] = "Kabul";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(151.0);
v[7] = v;
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(1.34557632E10);
v[8] = v;
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(1.0);
v[9] = v;
v[10] = "Yes";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(2.0);
v[11] = v;
v[12] = "No";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(2.0);
v[13] = v;
v[14] = "No";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(2.0);
v[15] = v;
v[16] = "No";
v[17] = "";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(2.0);
v[18] = v;
v[19] = "No";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(2.0);
v[20] = v;
v[21] = "No";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(2.0);
v[22] = v;
v[23] = "No";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(1.0);
v[24] = v;
v[25] = "Good";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(2.0);
v[26] = v;
v[27] = "The same";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(5.0);
v[28] = v;
v[29] = "Housewife (not working outside of the home)";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(97.0);
v[30] = v;
v[31] = "Not Asked";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(4.0);
v[32] = v;
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(121.0);
v[33] = v;
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(0.007463305415042708);
v[34] = v;
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(0.006666666666666667);
v[35] = v;
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(20098.33333333333);
v[36] = v;
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)[37];
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(53.0);
v[0] = v;
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(1.0);
v[1] = v;
v[2] = "Urban";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(101.0);
v[3] = v;
v[4] = "Kabul";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(1.0);
v[5] = v;
v[6] = "Kabul";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(151.0);
v[7] = v;
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(1.34557632E10);
v[8] = v;
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(1.0);
v[9] = v;
v[10] = "Yes";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(2.0);
v[11] = v;
v[12] = "No";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(2.0);
v[13] = v;
v[14] = "No";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(2.0);
v[15] = v;
v[16] = "No";
v[17] = "";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(2.0);
v[18] = v;
v[19] = "No";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(2.0);
v[20] = v;
v[21] = "No";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(2.0);
v[22] = v;
v[23] = "No";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(1.0);
v[24] = v;
v[25] = "Good";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(2.0);
v[26] = v;
v[27] = "The same";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(5.0);
v[28] = v;
v[29] = "Housewife (not working outside of the home)";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(97.0);
v[30] = v;
v[31] = "Not Asked";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(4.0);
v[32] = v;
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(121.0);
v[33] = v;
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(0.007463305415042708);
v[34] = v;
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(0.006666666666666667);
v[35] = v;
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(20098.33333333333);
v[36] = v;
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)[37];
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(66.0);
v[0] = v;
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(1.0);
v[1] = v;
v[2] = "Urban";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(101.0);
v[3] = v;
v[4] = "Kabul";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(1.0);
v[5] = v;
v[6] = "Kabul";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(774.0);
v[7] = v;
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(1.34556768E10);
v[8] = v;
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(2.0);
v[9] = v;
v[10] = "No";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(1.0);
v[11] = v;
v[12] = "Yes";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(1.0);
v[13] = v;
v[14] = "Yes";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(2.0);
v[15] = v;
v[16] = "No";
v[17] = "";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(2.0);
v[18] = v;
v[19] = "No";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(2.0);
v[20] = v;
v[21] = "No";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(2.0);
v[22] = v;
v[23] = "No";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(1.0);
v[24] = v;
v[25] = "Good";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(1.0);
v[26] = v;
v[27] = "Better";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(1.0);
v[28] = v;
v[29] = "Working full time";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(13.0);
v[30] = v;
v[31] = "Private Business Sole Proprietor";
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(4.0);
v[32] = v;
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(111.0);
v[33] = v;
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(0.017389288198469743);
v[34] = v;
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(0.006666666666666667);
v[35] = v;
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(8626.0);
v[36] = v;
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 = interfaceinvoke v.<org.apache.drill.exec.physical.rowSet.RowSet: int rowCount()>();
staticinvoke <org.junit.Assert: void assertEquals(long,long)>(3L, v);
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 testExplicitQuery() throws java.lang.Exception
{
org.apache.drill.exec.store.spss.TestSpssReader v;
java.lang.Object[] v, v, v;
java.lang.Double v, v, v, v, v, v;
org.apache.drill.exec.memory.BufferAllocator v;
org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v, v;
org.apache.drill.common.types.TypeProtos$MinorType v, v, v;
org.apache.drill.exec.physical.rowSet.DirectRowSet v;
org.apache.drill.test.rowSet.RowSetComparison v;
int v;
org.apache.drill.test.ClientFixture v, v;
org.apache.drill.test.QueryBuilder v, v;
org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v;
org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v, v, v;
org.apache.drill.exec.record.metadata.TupleMetadata v;
v := @this: org.apache.drill.exec.store.spss.TestSpssReader;
v = <org.apache.drill.exec.store.spss.TestSpssReader: org.apache.drill.test.ClientFixture client>;
v = virtualinvoke v.<org.apache.drill.test.ClientFixture: org.apache.drill.test.QueryBuilder queryBuilder()>();
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder: org.apache.drill.test.QueryBuilder sql(java.lang.String)>("SELECT ID, Urban, Urban_value FROM dfs.`spss/testdata.sav` WHERE d16=4");
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 FLOAT8>;
v = virtualinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: org.apache.drill.exec.record.metadata.SchemaBuilder addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("ID", v);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType FLOAT8>;
v = virtualinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: org.apache.drill.exec.record.metadata.SchemaBuilder addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("Urban", 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 addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("Urban_value", v);
v = virtualinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: org.apache.drill.exec.record.metadata.TupleMetadata buildSchema()>();
v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder;
v = <org.apache.drill.exec.store.spss.TestSpssReader: 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.Double: java.lang.Double valueOf(double)>(47.0);
v[0] = v;
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(1.0);
v[1] = v;
v[2] = "Urban";
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.Double: java.lang.Double valueOf(double)>(53.0);
v[0] = v;
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(1.0);
v[1] = v;
v[2] = "Urban";
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.Double: java.lang.Double valueOf(double)>(66.0);
v[0] = v;
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(1.0);
v[1] = v;
v[2] = "Urban";
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 = interfaceinvoke v.<org.apache.drill.exec.physical.rowSet.RowSet: int rowCount()>();
staticinvoke <org.junit.Assert: void assertEquals(long,long)>(3L, v);
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 testSerDe() throws java.lang.Exception
{
org.apache.drill.exec.store.spss.TestSpssReader v;
org.apache.drill.test.QueryBuilder v, v, v, v;
long v;
java.lang.String v;
v := @this: org.apache.drill.exec.store.spss.TestSpssReader;
v = virtualinvoke v.<org.apache.drill.exec.store.spss.TestSpssReader: org.apache.drill.test.QueryBuilder queryBuilder()>();
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder: org.apache.drill.test.QueryBuilder sql(java.lang.String)>("SELECT COUNT(*) FROM dfs.`spss/testdata.sav`");
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder: java.lang.String explainJson()>();
v = virtualinvoke v.<org.apache.drill.exec.store.spss.TestSpssReader: 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: long singletonLong()>();
staticinvoke <org.junit.Assert: void assertEquals(java.lang.String,long,long)>("Counts should match", 25L, v);
return;
}
public void testExplicitQueryWithCompressedFile() throws java.lang.Exception
{
org.apache.drill.exec.store.spss.TestSpssReader v;
java.lang.Object[] v, v, v;
java.lang.Double v, v, v, v, v, v;
org.apache.drill.exec.memory.BufferAllocator v;
org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v, v;
org.apache.drill.common.types.TypeProtos$MinorType v, v, v;
org.apache.drill.exec.physical.rowSet.DirectRowSet v;
org.apache.drill.test.rowSet.RowSetComparison v;
int v;
org.apache.drill.test.ClientFixture v, v;
org.apache.drill.test.QueryBuilder v, v;
org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v;
org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v, v, v;
org.apache.drill.exec.record.metadata.TupleMetadata v;
v := @this: org.apache.drill.exec.store.spss.TestSpssReader;
staticinvoke <org.apache.drill.test.QueryTestUtil: void generateCompressedFile(java.lang.String,java.lang.String,java.lang.String)>("spss/testdata.sav", "zip", "spss/testdata.sav.zip");
v = <org.apache.drill.exec.store.spss.TestSpssReader: org.apache.drill.test.ClientFixture client>;
v = virtualinvoke v.<org.apache.drill.test.ClientFixture: org.apache.drill.test.QueryBuilder queryBuilder()>();
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder: org.apache.drill.test.QueryBuilder sql(java.lang.String)>("SELECT ID, Urban, Urban_value FROM dfs.`spss/testdata.sav.zip`  WHERE d16=4");
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 FLOAT8>;
v = virtualinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: org.apache.drill.exec.record.metadata.SchemaBuilder addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("ID", v);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType FLOAT8>;
v = virtualinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: org.apache.drill.exec.record.metadata.SchemaBuilder addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("Urban", 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 addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType)>("Urban_value", v);
v = virtualinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: org.apache.drill.exec.record.metadata.TupleMetadata buildSchema()>();
v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder;
v = <org.apache.drill.exec.store.spss.TestSpssReader: 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.Double: java.lang.Double valueOf(double)>(47.0);
v[0] = v;
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(1.0);
v[1] = v;
v[2] = "Urban";
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.Double: java.lang.Double valueOf(double)>(53.0);
v[0] = v;
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(1.0);
v[1] = v;
v[2] = "Urban";
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.Double: java.lang.Double valueOf(double)>(66.0);
v[0] = v;
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(1.0);
v[1] = v;
v[2] = "Urban";
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 = interfaceinvoke v.<org.apache.drill.exec.physical.rowSet.RowSet: int rowCount()>();
staticinvoke <org.junit.Assert: void assertEquals(long,long)>(3L, v);
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;
}
}