public class org.apache.drill.exec.store.googlesheets.TestGoogleSheetsQueries extends org.apache.drill.test.ClusterTest { private static final java.lang.String AUTH_URI; private static final java.lang.String TOKEN_URI; private static final java.util.List REDIRECT_URI; private static org.apache.drill.exec.store.StoragePluginRegistry pluginRegistry; private static java.lang.String accessToken; private static java.lang.String refreshToken; private static java.lang.String sheetID; private static java.lang.String clientID; private static java.lang.String clientSecret; public void () { org.apache.drill.exec.store.googlesheets.TestGoogleSheetsQueries v; v := @this: org.apache.drill.exec.store.googlesheets.TestGoogleSheetsQueries; specialinvoke v.()>(); return; } public static void init() throws java.lang.Exception { org.apache.drill.test.BaseDirTestWatcher v; org.apache.drill.shaded.guava.com.google.common.io.CharSource v; org.apache.drill.exec.store.googlesheets.GoogleSheetsStoragePluginConfig v; java.util.List v; org.apache.drill.test.ClusterFixtureBuilder v, v, v, v; org.apache.drill.exec.store.StoragePluginRegistry v, v; org.apache.drill.exec.server.Drillbit v; org.apache.drill.exec.server.DrillbitContext v; java.nio.charset.Charset v; java.lang.Boolean v, v, v, v, v, v; java.lang.String v, v, v; org.apache.drill.exec.store.googlesheets.GoogleSheetsStoragePluginConfig$GoogleSheetsStoragePluginConfigBuilder v, v, v, v, v, v, v, v; org.apache.drill.test.ClusterFixture v; com.fasterxml.jackson.databind.ObjectMapper v; java.io.File v; java.lang.Object v, v, v, v, v, v; v = staticinvoke ("/tokens/oauth_tokens.json"); v = ; v = staticinvoke (v, v); v = virtualinvoke v.(); v = new com.fasterxml.jackson.databind.ObjectMapper; specialinvoke v.()>(); v = virtualinvoke v.(v, class "Ljava/util/Map;"); v = interfaceinvoke v.("client_id"); = v; v = interfaceinvoke v.("client_secret"); = v; v = interfaceinvoke v.("access_token"); = v; v = interfaceinvoke v.("refresh_token"); = v; v = interfaceinvoke v.("sheet_id"); = v; v = new org.apache.drill.test.ClusterFixtureBuilder; v = ; specialinvoke v.(org.apache.drill.test.BaseDirTestWatcher)>(v); v = staticinvoke (1); v = virtualinvoke v.("drill.exec.http.enabled", v); v = staticinvoke (1); v = virtualinvoke v.("drill.exec.http.porthunt", v); v = staticinvoke (1); v = virtualinvoke v.("drill.exec.impersonation.enabled", v); staticinvoke (v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); = v; v = staticinvoke (); v = ; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.("https://accounts.google.com/o/oauth2/auth"); v = virtualinvoke v.("https://oauth.googleapis.com/token"); v = staticinvoke (0); v = virtualinvoke v.(v); v = staticinvoke (1); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (1); virtualinvoke v.(v); v = ; interfaceinvoke v.("googlesheets", v); return; } public void testStarQuery() throws java.lang.Exception { org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v, v; org.apache.drill.common.types.TypeProtos$MinorType v, v, v; org.apache.drill.test.rowSet.RowSetComparison v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v, v, v, v, v, v, v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; java.time.LocalDate v, v, v, v, v, v, v; java.lang.Throwable v; java.lang.Object[] v, v, v, v, v, v, v, v, v; java.lang.Double v, v, v, v, v, v, v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; java.lang.String v, v, v; org.apache.drill.test.ClientFixture v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; org.apache.drill.exec.store.googlesheets.TestGoogleSheetsQueries v; v := @this: org.apache.drill.exec.store.googlesheets.TestGoogleSheetsQueries; label: specialinvoke v.("googlesheets"); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); staticinvoke (v); label: v = newarray (java.lang.Object)[1]; v = ; v[0] = v; v = staticinvoke ("SELECT * FROM googlesheets.`%s`.`MixedSheet` WHERE `Col2` < 6.0", v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = virtualinvoke v.("Col1", v); v = ; v = virtualinvoke v.("Col2", v); v = ; v = virtualinvoke v.("Col3", v); v = virtualinvoke v.(); v = ; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[3]; v[0] = "Rosaline Thales"; v = staticinvoke (1.0); v[1] = v; v[2] = null; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[3]; v[0] = "Abdolhossein Detlev"; v = staticinvoke (2.0001); v[1] = v; v = staticinvoke ("2020-04-30"); v[2] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[3]; v[0] = null; v = staticinvoke (4.0); v[1] = v; v = staticinvoke ("2020-06-30"); v[2] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[3]; v[0] = "Yunus Elena"; v = staticinvoke (3.5); v[1] = v; v = staticinvoke ("2021-01-15"); v[2] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[3]; v[0] = "Swaran Ohiyesa"; v = staticinvoke (-63.8); v[1] = v; v = staticinvoke ("2021-04-08"); v[2] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[3]; v[0] = "Kalani Godabert"; v = staticinvoke (0.0); v[1] = v; v = staticinvoke ("2021-06-28"); v[2] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[3]; v[0] = "Caishen Origenes"; v = staticinvoke (5.0E-7); v[1] = v; v = staticinvoke ("2021-07-09"); v[2] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[3]; v[0] = "Toufik Gurgen"; v = staticinvoke (2.0); v[1] = v; v = staticinvoke ("2021-11-05"); v[2] = v; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = new org.apache.drill.test.rowSet.RowSetComparison; specialinvoke v.(org.apache.drill.exec.physical.rowSet.RowSet)>(v); virtualinvoke v.(v); return; catch org.apache.drill.exec.store.StoragePluginRegistry$PluginException from label to label with label; } public void testStarQueryWithTabs() throws java.lang.Exception { org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v, v; org.apache.drill.common.types.TypeProtos$MinorType v, v, v; org.apache.drill.test.rowSet.RowSetComparison v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v, v, v, v, v, v, v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; java.time.LocalDate v, v, v, v, v, v, v; java.lang.Throwable v; java.lang.Object[] v, v, v, v, v, v, v, v, v; java.lang.Double v, v, v, v, v, v, v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; java.lang.String v, v, v; org.apache.drill.test.ClientFixture v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; org.apache.drill.exec.store.googlesheets.TestGoogleSheetsQueries v; v := @this: org.apache.drill.exec.store.googlesheets.TestGoogleSheetsQueries; label: specialinvoke v.("googlesheets"); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); staticinvoke (v); label: v = newarray (java.lang.Object)[1]; v = ; v[0] = v; v = staticinvoke ("SELECT * FROM googlesheets.`%s`.`tab[1]` WHERE `Col2` < 6.0", v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = virtualinvoke v.("Col1", v); v = ; v = virtualinvoke v.("Col2", v); v = ; v = virtualinvoke v.("Col3", v); v = virtualinvoke v.(); v = ; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[3]; v[0] = "Rosaline Thales"; v = staticinvoke (1.0); v[1] = v; v[2] = null; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[3]; v[0] = "Abdolhossein Detlev"; v = staticinvoke (2.0001); v[1] = v; v = staticinvoke ("2020-04-30"); v[2] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[3]; v[0] = null; v = staticinvoke (4.0); v[1] = v; v = staticinvoke ("2020-06-30"); v[2] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[3]; v[0] = "Yunus Elena"; v = staticinvoke (3.5); v[1] = v; v = staticinvoke ("2021-01-15"); v[2] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[3]; v[0] = "Swaran Ohiyesa"; v = staticinvoke (-63.8); v[1] = v; v = staticinvoke ("2021-04-08"); v[2] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[3]; v[0] = "Kalani Godabert"; v = staticinvoke (0.0); v[1] = v; v = staticinvoke ("2021-06-28"); v[2] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[3]; v[0] = "Caishen Origenes"; v = staticinvoke (5.0E-7); v[1] = v; v = staticinvoke ("2021-07-09"); v[2] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[3]; v[0] = "Toufik Gurgen"; v = staticinvoke (2.0); v[1] = v; v = staticinvoke ("2021-11-05"); v[2] = v; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = new org.apache.drill.test.rowSet.RowSetComparison; specialinvoke v.(org.apache.drill.exec.physical.rowSet.RowSet)>(v); virtualinvoke v.(v); return; catch org.apache.drill.exec.store.StoragePluginRegistry$PluginException from label to label with label; } public void testSchemataInformationSchema() throws java.lang.Exception { java.lang.Throwable v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; int v; java.lang.String v; org.apache.drill.exec.store.googlesheets.TestGoogleSheetsQueries v; boolean v; v := @this: org.apache.drill.exec.store.googlesheets.TestGoogleSheetsQueries; label: specialinvoke v.("googlesheets"); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); staticinvoke (v); label: v = virtualinvoke v.(); v = virtualinvoke v.("SELECT * FROM `INFORMATION_SCHEMA`.`SCHEMATA` WHERE SCHEMA_NAME LIKE \'googlesheets.%\'"); v = virtualinvoke v.(); v = interfaceinvoke v.(); if v <= 1 goto label; v = 1; goto label; label: v = 0; label: staticinvoke (v); interfaceinvoke v.(); return; catch org.apache.drill.exec.store.StoragePluginRegistry$PluginException from label to label with label; } public void testTablesInfoSchema() throws java.lang.Exception { java.lang.Throwable v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.test.QueryBuilder v, v; int v; java.lang.String v; org.apache.drill.exec.store.googlesheets.TestGoogleSheetsQueries v; v := @this: org.apache.drill.exec.store.googlesheets.TestGoogleSheetsQueries; label: specialinvoke v.("googlesheets"); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); staticinvoke (v); label: v = virtualinvoke v.(); v = virtualinvoke v.("SELECT * FROM `INFORMATION_SCHEMA`.`TABLES` WHERE TABLE_SCHEMA LIKE \'googlesheets.%\'"); v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (0L, v); interfaceinvoke v.(); return; catch org.apache.drill.exec.store.StoragePluginRegistry$PluginException from label to label with label; } public void testImplicitFields() throws java.lang.Exception { java.lang.Throwable v; java.lang.Object[] v, v; java.lang.String[] v, v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v; org.apache.drill.common.types.TypeProtos$MinorType v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.test.rowSet.RowSetComparison v; java.lang.String v, v, v; org.apache.drill.test.ClientFixture 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; org.apache.drill.exec.record.metadata.TupleMetadata v; org.apache.drill.exec.store.googlesheets.TestGoogleSheetsQueries v; v := @this: org.apache.drill.exec.store.googlesheets.TestGoogleSheetsQueries; label: specialinvoke v.("googlesheets"); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); staticinvoke (v); label: v = newarray (java.lang.Object)[1]; v = ; v[0] = v; v = staticinvoke ("SELECT _sheets, _title FROM googlesheets.`%s`.`MixedSheet` LIMIT 1", v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = virtualinvoke v.("_sheets", v); v = ; v = virtualinvoke v.("_title", v); v = virtualinvoke v.(); v = ; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v = newarray (java.lang.String)[2]; v[0] = "TestSheet1"; v[1] = "MixedSheet"; v = staticinvoke (v); v[0] = v; v[1] = "Drill Test Data"; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = new org.apache.drill.test.rowSet.RowSetComparison; specialinvoke v.(org.apache.drill.exec.physical.rowSet.RowSet)>(v); virtualinvoke v.(v); return; catch org.apache.drill.exec.store.StoragePluginRegistry$PluginException from label to label with label; } public void testImplicitFieldsWithTabs() throws java.lang.Exception { java.lang.Throwable v; java.lang.Object[] v, v; java.lang.String[] v, v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v; org.apache.drill.common.types.TypeProtos$MinorType v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.test.rowSet.RowSetComparison v; java.lang.String v, v, v; org.apache.drill.test.ClientFixture 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; org.apache.drill.exec.record.metadata.TupleMetadata v; org.apache.drill.exec.store.googlesheets.TestGoogleSheetsQueries v; v := @this: org.apache.drill.exec.store.googlesheets.TestGoogleSheetsQueries; label: specialinvoke v.("googlesheets"); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); staticinvoke (v); label: v = newarray (java.lang.Object)[1]; v = ; v[0] = v; v = staticinvoke ("SELECT _sheets FROM googlesheets.`%s`.`tab[1]` LIMIT 1", v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = virtualinvoke v.("_sheets", v); v = virtualinvoke v.(); v = ; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[1]; v = newarray (java.lang.String)[2]; v[0] = "TestSheet1"; v[1] = "MixedSheet"; v = staticinvoke (v); v[0] = v; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = new org.apache.drill.test.rowSet.RowSetComparison; specialinvoke v.(org.apache.drill.exec.physical.rowSet.RowSet)>(v); virtualinvoke v.(v); return; catch org.apache.drill.exec.store.StoragePluginRegistry$PluginException from label to label with label; } public void testStarAndImplicitFields() throws java.lang.Exception { org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v, v, v; org.apache.drill.common.types.TypeProtos$MinorType v, v, v, v; org.apache.drill.test.rowSet.RowSetComparison v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; java.time.LocalDate v; java.lang.Throwable v; java.lang.Object[] v, v, v; java.lang.Double v, v; java.lang.String[] v, v, v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; java.lang.String v, v, v; org.apache.drill.test.ClientFixture v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; org.apache.drill.exec.store.googlesheets.TestGoogleSheetsQueries v; v := @this: org.apache.drill.exec.store.googlesheets.TestGoogleSheetsQueries; label: specialinvoke v.("googlesheets"); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); staticinvoke (v); label: v = newarray (java.lang.Object)[1]; v = ; v[0] = v; v = staticinvoke ("SELECT *, _sheets FROM googlesheets.`%s`.`MixedSheet` LIMIT 3", v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = virtualinvoke v.("Col1", v); v = ; v = virtualinvoke v.("Col2", v); v = ; v = virtualinvoke v.("Col3", v); v = ; v = virtualinvoke v.("_sheets", v); v = virtualinvoke v.(); v = ; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[4]; v[0] = "Rosaline Thales"; v = staticinvoke (1.0); v[1] = v; v[2] = null; v = newarray (java.lang.String)[2]; v[0] = "TestSheet1"; v[1] = "MixedSheet"; v = staticinvoke (v); v[3] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[4]; v[0] = "Abdolhossein Detlev"; v = staticinvoke (2.0001); v[1] = v; v = staticinvoke ("2020-04-30"); v[2] = v; v = newarray (java.lang.String)[2]; v[0] = "TestSheet1"; v[1] = "MixedSheet"; v = staticinvoke (v); v[3] = v; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = new org.apache.drill.test.rowSet.RowSetComparison; specialinvoke v.(org.apache.drill.exec.physical.rowSet.RowSet)>(v); virtualinvoke v.(v); return; catch org.apache.drill.exec.store.StoragePluginRegistry$PluginException from label to label with label; } public void testExplicitAndImplicitFields() throws java.lang.Exception { java.lang.Throwable v; java.lang.Object[] v, v, v; java.lang.String[] v, v, v, 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; java.lang.String v, v, v; org.apache.drill.test.ClientFixture 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; org.apache.drill.exec.record.metadata.TupleMetadata v; java.time.LocalDate v; org.apache.drill.exec.store.googlesheets.TestGoogleSheetsQueries v; v := @this: org.apache.drill.exec.store.googlesheets.TestGoogleSheetsQueries; label: specialinvoke v.("googlesheets"); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); staticinvoke (v); label: v = newarray (java.lang.Object)[1]; v = ; v[0] = v; v = staticinvoke ("SELECT Col, Col, _sheets FROM googlesheets.`%s`.`MixedSheet` LIMIT 3", v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = virtualinvoke v.("Col1", v); v = ; v = virtualinvoke v.("Col3", v); v = ; v = virtualinvoke v.("_sheets", v); v = virtualinvoke v.(); v = ; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[3]; v[0] = "Rosaline Thales"; v[1] = null; v = newarray (java.lang.String)[2]; v[0] = "TestSheet1"; v[1] = "MixedSheet"; v = staticinvoke (v); v[2] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[3]; v[0] = "Abdolhossein Detlev"; v = staticinvoke ("2020-04-30"); v[1] = v; v = newarray (java.lang.String)[2]; v[0] = "TestSheet1"; v[1] = "MixedSheet"; v = staticinvoke (v); v[2] = v; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = new org.apache.drill.test.rowSet.RowSetComparison; specialinvoke v.(org.apache.drill.exec.physical.rowSet.RowSet)>(v); virtualinvoke v.(v); return; catch org.apache.drill.exec.store.StoragePluginRegistry$PluginException from label to label with label; } public void testProjectPushdown() throws java.lang.Exception { java.lang.Throwable v; org.apache.drill.test.QueryBuilder v, v; java.lang.Object[] v; org.apache.drill.test.QueryBuilder$PlanMatcher v, v; java.lang.String[] v; java.lang.String v, v, v; org.apache.drill.exec.store.googlesheets.TestGoogleSheetsQueries v; v := @this: org.apache.drill.exec.store.googlesheets.TestGoogleSheetsQueries; label: specialinvoke v.("googlesheets"); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); staticinvoke (v); label: v = newarray (java.lang.Object)[1]; v = ; v[0] = v; v = staticinvoke ("SELECT Col, Col FROM googlesheets.`%s`.`MixedSheet` LIMIT 5", v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = newarray (java.lang.String)[4]; v[0] = "Project"; v[1] = "columns=\\[`Col1`, `Col3`\\]"; v[2] = "Limit"; v[3] = "maxRecords=5"; v = virtualinvoke v.(v); virtualinvoke v.(); return; catch org.apache.drill.exec.store.StoragePluginRegistry$PluginException from label to label with label; } public void testWithExplicitColumns() throws java.lang.Exception { org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v; org.apache.drill.common.types.TypeProtos$MinorType v, v; org.apache.drill.test.rowSet.RowSetComparison v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v, v, v, v, v, v, v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; java.time.LocalDate v, v, v, v, v, v, v; java.lang.Throwable v; java.lang.Object[] v, v, v, v, v, v, v, v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; java.lang.String v, v, v; org.apache.drill.test.ClientFixture v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; org.apache.drill.exec.store.googlesheets.TestGoogleSheetsQueries v; v := @this: org.apache.drill.exec.store.googlesheets.TestGoogleSheetsQueries; label: specialinvoke v.("googlesheets"); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); staticinvoke (v); label: v = newarray (java.lang.Object)[1]; v = ; v[0] = v; v = staticinvoke ("SELECT Col, Col FROM googlesheets.`%s`.`MixedSheet` WHERE `Col2` < 6.0", v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = virtualinvoke v.("Col1", v); v = ; v = virtualinvoke v.("Col3", v); v = virtualinvoke v.(); v = ; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v[0] = "Rosaline Thales"; v[1] = null; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v[0] = "Abdolhossein Detlev"; v = staticinvoke ("2020-04-30"); v[1] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v[0] = null; v = staticinvoke ("2020-06-30"); v[1] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v[0] = "Yunus Elena"; v = staticinvoke ("2021-01-15"); v[1] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v[0] = "Swaran Ohiyesa"; v = staticinvoke ("2021-04-08"); v[1] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v[0] = "Kalani Godabert"; v = staticinvoke ("2021-06-28"); v[1] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v[0] = "Caishen Origenes"; v = staticinvoke ("2021-07-09"); v[1] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v[0] = "Toufik Gurgen"; v = staticinvoke ("2021-11-05"); v[1] = v; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = new org.apache.drill.test.rowSet.RowSetComparison; specialinvoke v.(org.apache.drill.exec.physical.rowSet.RowSet)>(v); virtualinvoke v.(v); return; catch org.apache.drill.exec.store.StoragePluginRegistry$PluginException from label to label with label; } public void testInvalidTab() throws java.lang.Exception { java.lang.Throwable v; org.apache.drill.test.QueryBuilder v, v; java.lang.Object[] v; java.lang.Exception v; java.lang.String v, v, v, v; org.apache.drill.exec.store.googlesheets.TestGoogleSheetsQueries v; boolean v; v := @this: org.apache.drill.exec.store.googlesheets.TestGoogleSheetsQueries; label: specialinvoke v.("googlesheets"); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); staticinvoke (v); label: v = newarray (java.lang.Object)[1]; v = ; v[0] = v; v = staticinvoke ("SELECT * FROM googlesheets.`%s`.`tab[5]` WHERE `Col2` < 6.0", v); v = virtualinvoke v.(); v = virtualinvoke v.(v); virtualinvoke v.(); staticinvoke (); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = virtualinvoke v.("Tab not found at index 5"); staticinvoke (v); label: return; catch org.apache.drill.exec.store.StoragePluginRegistry$PluginException from label to label with label; catch java.lang.Exception from label to label with label; } public void testWithExplicitColumnsWithTab() throws java.lang.Exception { org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v; org.apache.drill.common.types.TypeProtos$MinorType v, v; org.apache.drill.test.rowSet.RowSetComparison v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v, v, v, v, v, v, v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; java.time.LocalDate v, v, v, v, v, v, v; java.lang.Throwable v; java.lang.Object[] v, v, v, v, v, v, v, v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; java.lang.String v, v, v; org.apache.drill.test.ClientFixture v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; org.apache.drill.exec.store.googlesheets.TestGoogleSheetsQueries v; v := @this: org.apache.drill.exec.store.googlesheets.TestGoogleSheetsQueries; label: specialinvoke v.("googlesheets"); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); staticinvoke (v); label: v = newarray (java.lang.Object)[1]; v = ; v[0] = v; v = staticinvoke ("SELECT Col, Col FROM googlesheets.`%s`.`tab[1]` WHERE `Col2` < 6.0", v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = virtualinvoke v.("Col1", v); v = ; v = virtualinvoke v.("Col3", v); v = virtualinvoke v.(); v = ; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v[0] = "Rosaline Thales"; v[1] = null; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v[0] = "Abdolhossein Detlev"; v = staticinvoke ("2020-04-30"); v[1] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v[0] = null; v = staticinvoke ("2020-06-30"); v[1] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v[0] = "Yunus Elena"; v = staticinvoke ("2021-01-15"); v[1] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v[0] = "Swaran Ohiyesa"; v = staticinvoke ("2021-04-08"); v[1] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v[0] = "Kalani Godabert"; v = staticinvoke ("2021-06-28"); v[1] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v[0] = "Caishen Origenes"; v = staticinvoke ("2021-07-09"); v[1] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v[0] = "Toufik Gurgen"; v = staticinvoke ("2021-11-05"); v[1] = v; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = new org.apache.drill.test.rowSet.RowSetComparison; specialinvoke v.(org.apache.drill.exec.physical.rowSet.RowSet)>(v); virtualinvoke v.(v); return; catch org.apache.drill.exec.store.StoragePluginRegistry$PluginException from label to label with label; } public void testWithExplicitColumnsInDifferentOrder() throws java.lang.Exception { org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v; org.apache.drill.common.types.TypeProtos$MinorType v, v; org.apache.drill.test.rowSet.RowSetComparison v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v, v, v, v, v, v, v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; java.time.LocalDate v, v, v, v, v, v, v; java.lang.Throwable v; java.lang.Object[] v, v, v, v, v, v, v, v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; java.lang.String v, v, v; org.apache.drill.test.ClientFixture v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; org.apache.drill.exec.store.googlesheets.TestGoogleSheetsQueries v; v := @this: org.apache.drill.exec.store.googlesheets.TestGoogleSheetsQueries; label: specialinvoke v.("googlesheets"); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); staticinvoke (v); label: v = newarray (java.lang.Object)[1]; v = ; v[0] = v; v = staticinvoke ("SELECT Col, Col FROM googlesheets.`%s`.`MixedSheet` WHERE `Col2` < 6.0", v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = virtualinvoke v.("Col3", v); v = ; v = virtualinvoke v.("Col1", v); v = virtualinvoke v.(); v = ; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v[0] = null; v[1] = "Rosaline Thales"; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v = staticinvoke ("2020-04-30"); v[0] = v; v[1] = "Abdolhossein Detlev"; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v = staticinvoke ("2020-06-30"); v[0] = v; v[1] = null; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v = staticinvoke ("2021-01-15"); v[0] = v; v[1] = "Yunus Elena"; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v = staticinvoke ("2021-04-08"); v[0] = v; v[1] = "Swaran Ohiyesa"; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v = staticinvoke ("2021-06-28"); v[0] = v; v[1] = "Kalani Godabert"; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v = staticinvoke ("2021-07-09"); v[0] = v; v[1] = "Caishen Origenes"; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v = staticinvoke ("2021-11-05"); v[0] = v; v[1] = "Toufik Gurgen"; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = new org.apache.drill.test.rowSet.RowSetComparison; specialinvoke v.(org.apache.drill.exec.physical.rowSet.RowSet)>(v); virtualinvoke v.(v); return; catch org.apache.drill.exec.store.StoragePluginRegistry$PluginException from label to label with label; } public void testAggregateQuery() throws java.lang.Exception { java.lang.Throwable v; org.apache.drill.test.QueryBuilder v, v; java.lang.Object[] v; java.util.Iterator v; java.util.List v; int v; java.lang.Object v; java.lang.String v, v, v; org.apache.drill.exec.store.googlesheets.TestGoogleSheetsQueries v; boolean v; v := @this: org.apache.drill.exec.store.googlesheets.TestGoogleSheetsQueries; label: specialinvoke v.("googlesheets"); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); staticinvoke (v); label: v = newarray (java.lang.Object)[1]; v = ; v[0] = v; v = staticinvoke ("SELECT EXTRACT(YEAR FROM Col) AS event_year, COUNT(*) AS event_count FROM googlesheets.`%s`.`MixedSheet` GROUP BY event_year", v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(); goto label; label: v = interfaceinvoke v.(); staticinvoke (4L, v); return; catch org.apache.drill.exec.store.StoragePluginRegistry$PluginException from label to label with label; } public void testSerDe() throws java.lang.Exception { java.lang.Throwable v; org.apache.drill.test.QueryBuilder v, v, v, v; java.lang.Object[] v; long v; java.lang.String v, v, v, v; org.apache.drill.exec.store.googlesheets.TestGoogleSheetsQueries v; v := @this: org.apache.drill.exec.store.googlesheets.TestGoogleSheetsQueries; label: specialinvoke v.("googlesheets"); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); staticinvoke (v); label: v = newarray (java.lang.Object)[1]; v = ; v[0] = v; v = staticinvoke ("SELECT COUNT(*) FROM googlesheets.`%s`.`MixedSheet`", v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.