public class org.apache.drill.exec.store.jdbc.TestJdbcUserTranslation extends org.apache.drill.test.ClusterTest
{
private static final java.lang.String DOCKER_IMAGE_MYSQL;
private static final java.lang.String DOCKER_IMAGE_MARIADB;
private static org.testcontainers.containers.JdbcDatabaseContainer jdbcContainer;
private static final java.lang.String PLUGIN_NAME;
public void <init>()
{
org.apache.drill.exec.store.jdbc.TestJdbcUserTranslation v;
v := @this: org.apache.drill.exec.store.jdbc.TestJdbcUserTranslation;
specialinvoke v.<org.apache.drill.test.ClusterTest: void <init>()>();
return;
}
public static void initMysql() throws java.lang.Exception
{
org.apache.drill.test.BaseDirTestWatcher v;
org.testcontainers.utility.DockerImageName v, v;
java.lang.Integer v;
org.apache.drill.exec.store.jdbc.JdbcStorageConfig v;
boolean v, v, v;
org.apache.drill.common.logical.security.PlainCredentialsProvider v;
org.apache.drill.test.ClusterFixtureBuilder v, v, v, v, v;
java.lang.Integer[] v;
java.util.HashMap v;
org.testcontainers.jdbc.JdbcDatabaseDelegate v;
org.testcontainers.containers.JdbcDatabaseContainer v, v, v, v, v, v, v, v;
java.lang.Boolean v, v, v, v;
org.testcontainers.containers.GenericContainer v;
java.lang.String v, v, v, v, v, v, v;
org.apache.drill.test.ClusterFixture v;
org.testcontainers.containers.MySQLContainer v, v, v, v, v;
v = new org.apache.drill.test.ClusterFixtureBuilder;
v = <org.apache.drill.exec.store.jdbc.TestJdbcUserTranslation: org.apache.drill.test.BaseDirTestWatcher dirTestWatcher>;
specialinvoke v.<org.apache.drill.test.ClusterFixtureBuilder: void <init>(org.apache.drill.test.BaseDirTestWatcher)>(v);
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(1);
v = virtualinvoke v.<org.apache.drill.test.ClusterFixtureBuilder: org.apache.drill.test.ClusterFixtureBuilder configProperty(java.lang.String,java.lang.Object)>("drill.exec.http.enabled", v);
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(1);
v = virtualinvoke v.<org.apache.drill.test.ClusterFixtureBuilder: org.apache.drill.test.ClusterFixtureBuilder configProperty(java.lang.String,java.lang.Object)>("drill.exec.http.porthunt", v);
v = virtualinvoke v.<org.apache.drill.test.ClusterFixtureBuilder: org.apache.drill.test.ClusterFixtureBuilder configProperty(java.lang.String,java.lang.Object)>("drill.exec.security.user.auth.impl", "drillTestAuthenticator");
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(1);
v = virtualinvoke v.<org.apache.drill.test.ClusterFixtureBuilder: org.apache.drill.test.ClusterFixtureBuilder configProperty(java.lang.String,java.lang.Object)>("drill.exec.impersonation.enabled", v);
staticinvoke <org.apache.drill.exec.store.jdbc.TestJdbcUserTranslation: void startCluster(org.apache.drill.test.ClusterFixtureBuilder)>(v);
v = staticinvoke <java.lang.System: java.lang.String getProperty(java.lang.String)>("os.name");
v = virtualinvoke v.<java.lang.String: java.lang.String toLowerCase()>();
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("linux");
if v == 0 goto label;
v = "aarch64";
v = staticinvoke <java.lang.System: java.lang.String getProperty(java.lang.String)>("os.arch");
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = staticinvoke <org.testcontainers.utility.DockerImageName: org.testcontainers.utility.DockerImageName parse(java.lang.String)>("mariadb:10.6.0");
v = virtualinvoke v.<org.testcontainers.utility.DockerImageName: org.testcontainers.utility.DockerImageName asCompatibleSubstituteFor(java.lang.String)>("mysql");
goto label;
label:
v = staticinvoke <org.testcontainers.utility.DockerImageName: org.testcontainers.utility.DockerImageName parse(java.lang.String)>("mysql:5.7.27");
label:
v = new org.testcontainers.containers.MySQLContainer;
specialinvoke v.<org.testcontainers.containers.MySQLContainer: void <init>(org.testcontainers.utility.DockerImageName)>(v);
v = newarray (java.lang.Integer)[1];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(3306);
v[0] = v;
v = virtualinvoke v.<org.testcontainers.containers.MySQLContainer: org.testcontainers.containers.GenericContainer withExposedPorts(java.lang.Integer[])>(v);
v = virtualinvoke v.<org.testcontainers.containers.MySQLContainer: org.testcontainers.containers.MySQLContainer withConfigurationOverride(java.lang.String)>("mysql_config_override");
v = virtualinvoke v.<org.testcontainers.containers.MySQLContainer: org.testcontainers.containers.MySQLContainer withUsername(java.lang.String)>("mysqlUser");
v = virtualinvoke v.<org.testcontainers.containers.MySQLContainer: org.testcontainers.containers.MySQLContainer withPassword(java.lang.String)>("mysqlPass");
v = virtualinvoke v.<org.testcontainers.containers.MySQLContainer: org.testcontainers.containers.MySQLContainer withDatabaseName(java.lang.String)>("drill_mysql_test");
v = virtualinvoke v.<org.testcontainers.containers.MySQLContainer: org.testcontainers.containers.JdbcDatabaseContainer withUrlParam(java.lang.String,java.lang.String)>("serverTimezone", "UTC");
v = virtualinvoke v.<org.testcontainers.containers.MySQLContainer: org.testcontainers.containers.JdbcDatabaseContainer withUrlParam(java.lang.String,java.lang.String)>("useJDBCCompliantTimezoneShift", "true");
v = virtualinvoke v.<org.testcontainers.containers.MySQLContainer: org.testcontainers.containers.JdbcDatabaseContainer withInitScript(java.lang.String)>("mysql-test-data.sql");
<org.apache.drill.exec.store.jdbc.TestJdbcUserTranslation: org.testcontainers.containers.JdbcDatabaseContainer jdbcContainer> = v;
v = <org.apache.drill.exec.store.jdbc.TestJdbcUserTranslation: org.testcontainers.containers.JdbcDatabaseContainer jdbcContainer>;
virtualinvoke v.<org.testcontainers.containers.JdbcDatabaseContainer: void start()>();
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("linux");
if v == 0 goto label;
v = new org.testcontainers.jdbc.JdbcDatabaseDelegate;
v = <org.apache.drill.exec.store.jdbc.TestJdbcUserTranslation: org.testcontainers.containers.JdbcDatabaseContainer jdbcContainer>;
specialinvoke v.<org.testcontainers.jdbc.JdbcDatabaseDelegate: void <init>(org.testcontainers.containers.JdbcDatabaseContainer,java.lang.String)>(v, "");
staticinvoke <org.testcontainers.ext.ScriptUtils: void runInitScript(org.testcontainers.delegate.DatabaseDelegate,java.lang.String)>(v, "mysql-test-data-linux.sql");
label:
v = new org.apache.drill.common.logical.security.PlainCredentialsProvider;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
specialinvoke v.<org.apache.drill.common.logical.security.PlainCredentialsProvider: void <init>(java.util.Map)>(v);
v = <org.apache.drill.exec.store.jdbc.TestJdbcUserTranslation: org.testcontainers.containers.JdbcDatabaseContainer jdbcContainer>;
v = virtualinvoke v.<org.testcontainers.containers.JdbcDatabaseContainer: java.lang.String getJdbcUrl()>();
v = new org.apache.drill.exec.store.jdbc.JdbcStorageConfig;
v = <org.apache.drill.exec.store.jdbc.TestJdbcUserTranslation: org.testcontainers.containers.JdbcDatabaseContainer jdbcContainer>;
v = virtualinvoke v.<org.testcontainers.containers.JdbcDatabaseContainer: java.lang.String getUsername()>();
v = <org.apache.drill.exec.store.jdbc.TestJdbcUserTranslation: org.testcontainers.containers.JdbcDatabaseContainer jdbcContainer>;
v = virtualinvoke v.<org.testcontainers.containers.JdbcDatabaseContainer: java.lang.String getPassword()>();
specialinvoke v.<org.apache.drill.exec.store.jdbc.JdbcStorageConfig: void <init>(java.lang.String,java.lang.String,java.lang.String,java.lang.String,boolean,boolean,java.util.Map,org.apache.drill.common.logical.security.CredentialsProvider,java.lang.String,int)>("com.mysql.cj.jdbc.Driver", v, v, v, 0, 0, null, v, "user_translation", 10000);
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(1);
virtualinvoke v.<org.apache.drill.exec.store.jdbc.JdbcStorageConfig: void setEnabled(java.lang.Boolean)>(v);
v = <org.apache.drill.exec.store.jdbc.TestJdbcUserTranslation: org.apache.drill.test.ClusterFixture cluster>;
virtualinvoke v.<org.apache.drill.test.ClusterFixture: void defineStoragePlugin(java.lang.String,org.apache.drill.common.logical.StoragePluginConfig)>("mysql", v);
return;
}
public static void stopMysql()
{
org.testcontainers.containers.JdbcDatabaseContainer v, v;
v = <org.apache.drill.exec.store.jdbc.TestJdbcUserTranslation: org.testcontainers.containers.JdbcDatabaseContainer jdbcContainer>;
if v == null goto label;
v = <org.apache.drill.exec.store.jdbc.TestJdbcUserTranslation: org.testcontainers.containers.JdbcDatabaseContainer jdbcContainer>;
virtualinvoke v.<org.testcontainers.containers.JdbcDatabaseContainer: void stop()>();
label:
return;
}
public void testShowDatabasesWithUserWithNoCreds() throws java.lang.Exception
{
org.apache.drill.test.QueryBuilder v, v;
org.apache.drill.test.ClusterFixture v;
org.apache.drill.test.ClientFixture$ClientBuilder v, v, v;
long v;
org.apache.drill.test.QueryBuilder$QuerySummary v;
org.apache.drill.exec.store.jdbc.TestJdbcUserTranslation v;
org.apache.drill.test.ClientFixture v;
boolean v;
v := @this: org.apache.drill.exec.store.jdbc.TestJdbcUserTranslation;
v = <org.apache.drill.exec.store.jdbc.TestJdbcUserTranslation: org.apache.drill.test.ClusterFixture cluster>;
v = virtualinvoke v.<org.apache.drill.test.ClusterFixture: org.apache.drill.test.ClientFixture$ClientBuilder clientBuilder()>();
v = virtualinvoke v.<org.apache.drill.test.ClientFixture$ClientBuilder: org.apache.drill.test.ClientFixture$ClientBuilder property(java.lang.String,java.lang.Object)>("user", "testUser2");
v = virtualinvoke v.<org.apache.drill.test.ClientFixture$ClientBuilder: org.apache.drill.test.ClientFixture$ClientBuilder property(java.lang.String,java.lang.Object)>("password", "testUser2Password");
v = virtualinvoke v.<org.apache.drill.test.ClientFixture$ClientBuilder: org.apache.drill.test.ClientFixture build()>();
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)>("SHOW DATABASES");
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder: org.apache.drill.test.QueryBuilder$QuerySummary run()>();
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder$QuerySummary: boolean succeeded()>();
staticinvoke <org.junit.Assert: void assertTrue(boolean)>(v);
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder$QuerySummary: long recordCount()>();
staticinvoke <org.junit.Assert: void assertEquals(long,long)>(v, 7L);
return;
}
public void testShowDatabasesWithUserWithValidCreds() throws java.lang.Exception
{
org.apache.drill.exec.store.StoragePluginRegistry v;
org.apache.drill.test.ClientFixture$ClientBuilder v, v, v;
long v;
org.apache.drill.test.ClientFixture v;
boolean v;
org.apache.drill.test.QueryBuilder v, v;
org.apache.drill.common.logical.security.PlainCredentialsProvider v;
org.apache.drill.exec.store.StoragePlugin v;
org.apache.drill.test.ClusterFixture v, v;
org.apache.drill.common.logical.security.CredentialsProvider v;
org.apache.drill.test.QueryBuilder$QuerySummary v;
org.apache.drill.common.logical.StoragePluginConfig v;
org.apache.drill.exec.store.jdbc.TestJdbcUserTranslation v;
v := @this: org.apache.drill.exec.store.jdbc.TestJdbcUserTranslation;
v = <org.apache.drill.exec.store.jdbc.TestJdbcUserTranslation: org.apache.drill.test.ClusterFixture cluster>;
v = virtualinvoke v.<org.apache.drill.test.ClusterFixture: org.apache.drill.test.ClientFixture$ClientBuilder clientBuilder()>();
v = virtualinvoke v.<org.apache.drill.test.ClientFixture$ClientBuilder: org.apache.drill.test.ClientFixture$ClientBuilder property(java.lang.String,java.lang.Object)>("user", "testUser1");
v = virtualinvoke v.<org.apache.drill.test.ClientFixture$ClientBuilder: org.apache.drill.test.ClientFixture$ClientBuilder property(java.lang.String,java.lang.Object)>("password", "testUser1Password");
v = virtualinvoke v.<org.apache.drill.test.ClientFixture$ClientBuilder: org.apache.drill.test.ClientFixture build()>();
v = <org.apache.drill.exec.store.jdbc.TestJdbcUserTranslation: org.apache.drill.test.ClusterFixture cluster>;
v = virtualinvoke v.<org.apache.drill.test.ClusterFixture: org.apache.drill.exec.store.StoragePluginRegistry storageRegistry()>();
v = interfaceinvoke v.<org.apache.drill.exec.store.StoragePluginRegistry: org.apache.drill.exec.store.StoragePlugin getPlugin(java.lang.String)>("mysql");
v = interfaceinvoke v.<org.apache.drill.exec.store.StoragePlugin: org.apache.drill.common.logical.StoragePluginConfig getConfig()>();
v = virtualinvoke v.<org.apache.drill.exec.store.jdbc.JdbcStorageConfig: org.apache.drill.common.logical.security.CredentialsProvider getCredentialsProvider()>();
virtualinvoke v.<org.apache.drill.common.logical.security.PlainCredentialsProvider: void setUserCredentials(java.lang.String,java.lang.String,java.lang.String)>("mysqlUser", "mysqlPass", "testUser1");
virtualinvoke v.<org.apache.drill.exec.store.jdbc.JdbcStorageConfig: org.apache.drill.exec.store.jdbc.JdbcStorageConfig updateCredentialProvider(org.apache.drill.common.logical.security.CredentialsProvider)>(v);
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)>("SHOW DATABASES");
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder: org.apache.drill.test.QueryBuilder$QuerySummary run()>();
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder$QuerySummary: boolean succeeded()>();
staticinvoke <org.junit.Assert: void assertTrue(boolean)>(v);
v = virtualinvoke v.<org.apache.drill.test.QueryBuilder$QuerySummary: long recordCount()>();
staticinvoke <org.junit.Assert: void assertEquals(long,long)>(10L, v);
return;
}
public void testQueryWithInvalidCredentials()
{
org.apache.drill.test.QueryBuilder v, v;
org.apache.drill.test.ClusterFixture v;
org.apache.drill.test.ClientFixture$ClientBuilder v, v, v;
java.lang.Exception v;
org.hamcrest.Matcher v;
java.lang.String v;
org.apache.drill.exec.store.jdbc.TestJdbcUserTranslation v;
org.apache.drill.test.ClientFixture v;
v := @this: org.apache.drill.exec.store.jdbc.TestJdbcUserTranslation;
v = <org.apache.drill.exec.store.jdbc.TestJdbcUserTranslation: org.apache.drill.test.ClusterFixture cluster>;
v = virtualinvoke v.<org.apache.drill.test.ClusterFixture: org.apache.drill.test.ClientFixture$ClientBuilder clientBuilder()>();
v = virtualinvoke v.<org.apache.drill.test.ClientFixture$ClientBuilder: org.apache.drill.test.ClientFixture$ClientBuilder property(java.lang.String,java.lang.Object)>("user", "testUser2");
v = virtualinvoke v.<org.apache.drill.test.ClientFixture$ClientBuilder: org.apache.drill.test.ClientFixture$ClientBuilder property(java.lang.String,java.lang.Object)>("password", "testUser2Password");
v = virtualinvoke v.<org.apache.drill.test.ClientFixture$ClientBuilder: org.apache.drill.test.ClientFixture build()>();
label:
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 mysql.`drill_mysql_test`.person");
virtualinvoke v.<org.apache.drill.test.QueryBuilder: org.apache.drill.exec.physical.rowSet.DirectRowSet rowSet()>();
staticinvoke <org.junit.Assert: void fail()>();
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
v = staticinvoke <org.hamcrest.CoreMatchers: org.hamcrest.Matcher containsString(java.lang.String)>("Object \'mysql\' not found");
staticinvoke <org.hamcrest.MatcherAssert: void assertThat(java.lang.Object,org.hamcrest.Matcher)>(v, v);
label:
return;
catch java.lang.Exception from label to label with label;
}
public void testQueryWithValidCredentials() throws java.lang.Exception
{
org.apache.drill.exec.memory.BufferAllocator v;
org.apache.drill.test.ClientFixture$ClientBuilder v, v, v;
org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v;
org.apache.drill.common.types.TypeProtos$MinorType v, v;
org.apache.drill.common.logical.security.PlainCredentialsProvider v;
org.apache.drill.common.logical.security.CredentialsProvider v;
org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v, v, v, v;
org.apache.drill.exec.record.metadata.TupleMetadata v;
org.apache.drill.exec.store.StoragePluginRegistry v;
java.lang.Object[] v, v, v, v;
org.apache.drill.exec.physical.rowSet.DirectRowSet 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.StoragePlugin v;
org.apache.drill.test.ClusterFixture v, v;
org.apache.drill.common.logical.StoragePluginConfig v;
org.apache.drill.exec.store.jdbc.TestJdbcUserTranslation v;
v := @this: org.apache.drill.exec.store.jdbc.TestJdbcUserTranslation;
v = <org.apache.drill.exec.store.jdbc.TestJdbcUserTranslation: org.apache.drill.test.ClusterFixture cluster>;
v = virtualinvoke v.<org.apache.drill.test.ClusterFixture: org.apache.drill.test.ClientFixture$ClientBuilder clientBuilder()>();
v = virtualinvoke v.<org.apache.drill.test.ClientFixture$ClientBuilder: org.apache.drill.test.ClientFixture$ClientBuilder property(java.lang.String,java.lang.Object)>("user", "testUser1");
v = virtualinvoke v.<org.apache.drill.test.ClientFixture$ClientBuilder: org.apache.drill.test.ClientFixture$ClientBuilder property(java.lang.String,java.lang.Object)>("password", "testUser1Password");
v = virtualinvoke v.<org.apache.drill.test.ClientFixture$ClientBuilder: org.apache.drill.test.ClientFixture build()>();
v = <org.apache.drill.exec.store.jdbc.TestJdbcUserTranslation: org.apache.drill.test.ClusterFixture cluster>;
v = virtualinvoke v.<org.apache.drill.test.ClusterFixture: org.apache.drill.exec.store.StoragePluginRegistry storageRegistry()>();
v = interfaceinvoke v.<org.apache.drill.exec.store.StoragePluginRegistry: org.apache.drill.exec.store.StoragePlugin getPlugin(java.lang.String)>("mysql");
v = interfaceinvoke v.<org.apache.drill.exec.store.StoragePlugin: org.apache.drill.common.logical.StoragePluginConfig getConfig()>();
v = virtualinvoke v.<org.apache.drill.exec.store.jdbc.JdbcStorageConfig: org.apache.drill.common.logical.security.CredentialsProvider getCredentialsProvider()>();
virtualinvoke v.<org.apache.drill.common.logical.security.PlainCredentialsProvider: void setUserCredentials(java.lang.String,java.lang.String,java.lang.String)>("mysqlUser", "mysqlPass", "testUser1");
virtualinvoke v.<org.apache.drill.exec.store.jdbc.JdbcStorageConfig: org.apache.drill.exec.store.jdbc.JdbcStorageConfig updateCredentialProvider(org.apache.drill.common.logical.security.CredentialsProvider)>(v);
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 first_name, last_name FROM mysql.`drill_mysql_test`.person");
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 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,int)>("first_name", v, 38);
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,int)>("last_name", v, 38);
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 = 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)[2];
v[0] = "first_name_1";
v[1] = "last_name_1";
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)[2];
v[0] = "first_name_2";
v[1] = "last_name_2";
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)[2];
v[0] = "first_name_3";
v[1] = "last_name_3";
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)[2];
v[0] = null;
v[1] = null;
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()>();
staticinvoke <org.apache.drill.test.rowSet.RowSetUtilities: void verify(org.apache.drill.exec.physical.rowSet.RowSet,org.apache.drill.exec.physical.rowSet.RowSet)>(v, v);
return;
}
}