public class org.apache.drill.metastore.mongo.MongoBaseTest extends org.apache.drill.metastore.components.tables.AbstractBasicTablesRequestsTest
{
private static final org.slf4j.Logger logger;
private static final java.lang.String MONGO_IMAGE_NAME;
private static final int MONGO_PORT;
private static final java.lang.String CONFIG_SERVER_HOST;
private static final java.lang.String CONFIG_REPL_SET;
private static final java.lang.String SHARD_REPL_SET_0;
private static final java.lang.String SHARD_REPL_SET_1;
private static final java.util.List containers;
protected static boolean isShardMode;
public void <init>()
{
org.apache.drill.metastore.mongo.MongoBaseTest v;
v := @this: org.apache.drill.metastore.mongo.MongoBaseTest;
specialinvoke v.<org.apache.drill.metastore.components.tables.AbstractBasicTablesRequestsTest: void <init>()>();
return;
}
public static void init() throws java.io.IOException, java.lang.InterruptedException
{
org.apache.drill.common.config.DrillConfig v;
com.typesafe.config.Config v;
com.typesafe.config.ConfigValue v;
java.lang.String v;
boolean v;
v = <org.apache.drill.metastore.mongo.MongoBaseTest: boolean isShardMode>;
if v == 0 goto label;
v = staticinvoke <org.apache.drill.metastore.mongo.MongoBaseTest: java.lang.String initCluster()>();
goto label;
label:
v = staticinvoke <org.apache.drill.metastore.mongo.MongoBaseTest: java.lang.String initSingle()>();
label:
v = staticinvoke <org.apache.drill.common.config.DrillConfig: org.apache.drill.common.config.DrillConfig create()>();
v = staticinvoke <com.typesafe.config.ConfigValueFactory: com.typesafe.config.ConfigValue fromAnyRef(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.drill.common.config.DrillConfig: com.typesafe.config.Config withValue(java.lang.String,com.typesafe.config.ConfigValue)>("drill.metastore.mongo.connection", v);
staticinvoke <org.apache.drill.metastore.mongo.MongoBaseTest: void innerInit(com.typesafe.config.Config,java.lang.Class)>(v, class "Lorg/apache/drill/metastore/mongo/MongoMetastore;");
return;
}
private static java.lang.String initSingle()
{
java.util.List v;
java.lang.Object[] v;
java.lang.String v, v;
java.lang.Integer v;
org.testcontainers.containers.MongoDBContainer v;
v = new org.testcontainers.containers.MongoDBContainer;
specialinvoke v.<org.testcontainers.containers.MongoDBContainer: void <init>(java.lang.String)>("mongo:4.4.10");
virtualinvoke v.<org.testcontainers.containers.MongoDBContainer: void start()>();
v = <org.apache.drill.metastore.mongo.MongoBaseTest: java.util.List containers>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = newarray (java.lang.Object)[2];
v = virtualinvoke v.<org.testcontainers.containers.MongoDBContainer: java.lang.String getContainerIpAddress()>();
v[0] = v;
v = virtualinvoke v.<org.testcontainers.containers.MongoDBContainer: java.lang.Integer getFirstMappedPort()>();
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("mongodb://%s:%d", v);
return v;
}
private static java.lang.String initCluster() throws java.io.IOException, java.lang.InterruptedException
{
java.lang.String v;
org.testcontainers.containers.Network v;
v = staticinvoke <org.testcontainers.containers.Network: org.testcontainers.containers.Network newNetwork()>();
staticinvoke <org.apache.drill.metastore.mongo.MongoBaseTest: void initConfigServer(org.testcontainers.containers.Network)>(v);
staticinvoke <org.apache.drill.metastore.mongo.MongoBaseTest: void initShardServers(org.testcontainers.containers.Network)>(v);
v = staticinvoke <org.apache.drill.metastore.mongo.MongoBaseTest: java.lang.String initMongos(org.testcontainers.containers.Network)>(v);
staticinvoke <org.apache.drill.metastore.mongo.MongoBaseTest: void shardCollection()>();
return v;
}
private static void initConfigServer(org.testcontainers.containers.Network) throws java.io.IOException, java.lang.InterruptedException
{
java.lang.Object[] v;
org.slf4j.Logger v;
java.lang.String[] v;
java.lang.Integer v;
org.testcontainers.containers.Network v;
java.util.List v;
org.testcontainers.containers.Container$ExecResult v;
org.testcontainers.containers.GenericContainer v;
java.lang.String v, v;
v := @parameter: org.testcontainers.containers.Network;
v = staticinvoke <org.apache.drill.metastore.mongo.MongoBaseTest: org.testcontainers.containers.GenericContainer newContainer(org.testcontainers.containers.Network,java.lang.String,java.lang.String,java.lang.String)>(v, "configsvr", "conf", "m0");
virtualinvoke v.<org.testcontainers.containers.GenericContainer: void start()>();
v = newarray (java.lang.String)[3];
v[0] = "/bin/bash";
v[1] = "-c";
v = newarray (java.lang.Object)[3];
v[0] = "conf";
v[1] = "m0";
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(27017);
v[2] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("echo \'rs.initiate({_id: \"%s\", configsvr: true, members: [{ _id : 0, host : \"%s:%s\" }]})\' | mongo --port %3$s", v);
v[2] = v;
v = virtualinvoke v.<org.testcontainers.containers.GenericContainer: org.testcontainers.containers.Container$ExecResult execInContainer(java.lang.String[])>(v);
v = <org.apache.drill.metastore.mongo.MongoBaseTest: org.slf4j.Logger logger>;
v = virtualinvoke v.<org.testcontainers.containers.Container$ExecResult: java.lang.String toString()>();
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
v = <org.apache.drill.metastore.mongo.MongoBaseTest: java.util.List containers>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
return;
}
private static void initShardServers(org.testcontainers.containers.Network) throws java.io.IOException, java.lang.InterruptedException
{
java.lang.Integer v, v, v, v;
org.testcontainers.containers.Network v;
java.util.stream.Collector v, v;
java.util.List v;
java.util.stream.Stream v, v, v, v;
java.lang.Object[] v, v, v, v;
java.lang.String[] v, v, v, v, v, v;
java.util.function.Function v, v;
java.util.ArrayList v;
java.lang.String v, v, v, v, v, v, v, v;
org.slf4j.Logger v, v, v, v;
java.util.function.Consumer v;
org.testcontainers.containers.Container$ExecResult v, v, v, v;
java.lang.Object v, v, v, v, v, v;
v := @parameter: org.testcontainers.containers.Network;
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.collect.Lists: java.util.ArrayList newArrayList()>();
v = newarray (java.lang.String)[3];
v[0] = "m1";
v[1] = "m2";
v[2] = "m3";
v = staticinvoke <java.util.stream.Stream: java.util.stream.Stream of(java.lang.Object[])>(v);
v = staticinvoke <org.apache.drill.metastore.mongo.MongoBaseTest$lambda_initShardServers_0__1: java.util.function.Function bootstrap$(org.testcontainers.containers.Network)>(v);
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream map(java.util.function.Function)>(v);
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toList()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
interfaceinvoke v.<java.util.List: boolean addAll(java.util.Collection)>(v);
v = newarray (java.lang.String)[3];
v[0] = "m4";
v[1] = "m5";
v[2] = "m6";
v = staticinvoke <java.util.stream.Stream: java.util.stream.Stream of(java.lang.Object[])>(v);
v = staticinvoke <org.apache.drill.metastore.mongo.MongoBaseTest$lambda_initShardServers_1__2: java.util.function.Function bootstrap$(org.testcontainers.containers.Network)>(v);
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream map(java.util.function.Function)>(v);
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toList()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
interfaceinvoke v.<java.util.List: boolean addAll(java.util.Collection)>(v);
v = staticinvoke <org.apache.drill.metastore.mongo.MongoBaseTest$start__3: java.util.function.Consumer bootstrap$()>();
interfaceinvoke v.<java.util.List: void forEach(java.util.function.Consumer)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = newarray (java.lang.String)[3];
v[0] = "/bin/bash";
v[1] = "-c";
v = newarray (java.lang.Object)[2];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(27017);
v[0] = v;
v[1] = "shard0";
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("mongo --port %s --eval \'printjson(rs.initiate({_id:\"%s\",members:[{_id:0,host:\"m1:%1$s\"},{_id:1,host:\"m2:%1$s\"},{_id:2,host:\"m3:%1$s\"}]}))\' --quiet", v);
v[2] = v;
v = virtualinvoke v.<org.testcontainers.containers.GenericContainer: org.testcontainers.containers.Container$ExecResult execInContainer(java.lang.String[])>(v);
v = <org.apache.drill.metastore.mongo.MongoBaseTest: org.slf4j.Logger logger>;
v = virtualinvoke v.<org.testcontainers.containers.Container$ExecResult: java.lang.String toString()>();
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = newarray (java.lang.String)[3];
v[0] = "/bin/bash";
v[1] = "-c";
v = newarray (java.lang.Object)[1];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(27017);
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("until mongo --port %s --eval \"printjson(rs.isMaster())\" | grep ismaster | grep true > /dev/null 2>&1;do sleep 1;done", v);
v[2] = v;
v = virtualinvoke v.<org.testcontainers.containers.GenericContainer: org.testcontainers.containers.Container$ExecResult execInContainer(java.lang.String[])>(v);
v = <org.apache.drill.metastore.mongo.MongoBaseTest: org.slf4j.Logger logger>;
v = virtualinvoke v.<org.testcontainers.containers.Container$ExecResult: java.lang.String toString()>();
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(3);
v = newarray (java.lang.String)[3];
v[0] = "/bin/bash";
v[1] = "-c";
v = newarray (java.lang.Object)[2];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(27017);
v[0] = v;
v[1] = "shard1";
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("mongo --port %s --eval \'printjson(rs.initiate({_id:\"%s\",members:[{_id:0,host:\"m4:%1$s\"},{_id:1,host:\"m5:%1$s\"},{_id:2,host:\"m6:%1$s\"}]}))\' --quiet", v);
v[2] = v;
v = virtualinvoke v.<org.testcontainers.containers.GenericContainer: org.testcontainers.containers.Container$ExecResult execInContainer(java.lang.String[])>(v);
v = <org.apache.drill.metastore.mongo.MongoBaseTest: org.slf4j.Logger logger>;
v = virtualinvoke v.<org.testcontainers.containers.Container$ExecResult: java.lang.String toString()>();
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(3);
v = newarray (java.lang.String)[3];
v[0] = "/bin/bash";
v[1] = "-c";
v = newarray (java.lang.Object)[1];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(27017);
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("until mongo --port %s --eval \"printjson(rs.isMaster())\" | grep ismaster | grep true > /dev/null 2>&1;do sleep 1;done", v);
v[2] = v;
v = virtualinvoke v.<org.testcontainers.containers.GenericContainer: org.testcontainers.containers.Container$ExecResult execInContainer(java.lang.String[])>(v);
v = <org.apache.drill.metastore.mongo.MongoBaseTest: org.slf4j.Logger logger>;
v = virtualinvoke v.<org.testcontainers.containers.Container$ExecResult: java.lang.String toString()>();
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
v = <org.apache.drill.metastore.mongo.MongoBaseTest: java.util.List containers>;
interfaceinvoke v.<java.util.List: boolean addAll(java.util.Collection)>(v);
return;
}
private static java.lang.String initMongos(org.testcontainers.containers.Network) throws java.io.IOException, java.lang.InterruptedException
{
java.lang.Integer v, v, v, v, v;
org.testcontainers.containers.MongoDBContainer v;
org.testcontainers.containers.Network v;
java.util.List v;
java.lang.Integer[] v;
java.lang.Object[] v, v, v, v;
java.lang.String[] v, v, v, v;
org.testcontainers.containers.GenericContainer v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v;
org.slf4j.Logger v, v, v, v;
org.testcontainers.containers.Container$ExecResult v, v, v;
v := @parameter: org.testcontainers.containers.Network;
v = new org.testcontainers.containers.MongoDBContainer;
specialinvoke v.<org.testcontainers.containers.MongoDBContainer: void <init>(java.lang.String)>("mongo:4.4.10");
v = virtualinvoke v.<org.testcontainers.containers.MongoDBContainer: org.testcontainers.containers.GenericContainer withNetwork(org.testcontainers.containers.Network)>(v);
v = newarray (java.lang.String)[1];
v[0] = "m7";
v = virtualinvoke v.<org.testcontainers.containers.MongoDBContainer: org.testcontainers.containers.GenericContainer withNetworkAliases(java.lang.String[])>(v);
v = newarray (java.lang.Integer)[1];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(27017);
v[0] = v;
v = virtualinvoke v.<org.testcontainers.containers.MongoDBContainer: org.testcontainers.containers.GenericContainer withExposedPorts(java.lang.Integer[])>(v);
v = newarray (java.lang.Object)[4];
v[0] = "conf";
v[1] = "m0";
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(27017);
v[2] = v;
v[3] = "m7";
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("mongos --configdb %s/%s:%s --bind_ip localhost,%s --port %3$s", v);
v = virtualinvoke v.<org.testcontainers.containers.MongoDBContainer: org.testcontainers.containers.GenericContainer withCommand(java.lang.String)>(v);
virtualinvoke v.<org.testcontainers.containers.MongoDBContainer: void start()>();
v = newarray (java.lang.String)[3];
v[0] = "/bin/bash";
v[1] = "-c";
v = newarray (java.lang.Object)[2];
v[0] = "shard0";
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(27017);
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("echo \'sh.addShard(\"%s/m,m,m3\")\' | mongo --port %s", v);
v[2] = v;
v = virtualinvoke v.<org.testcontainers.containers.MongoDBContainer: org.testcontainers.containers.Container$ExecResult execInContainer(java.lang.String[])>(v);
v = <org.apache.drill.metastore.mongo.MongoBaseTest: org.slf4j.Logger logger>;
v = virtualinvoke v.<org.testcontainers.containers.Container$ExecResult: java.lang.String toString()>();
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
v = newarray (java.lang.String)[3];
v[0] = "/bin/bash";
v[1] = "-c";
v = newarray (java.lang.Object)[2];
v[0] = "shard1";
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(27017);
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("echo \'sh.addShard(\"%s/m,m,m6\")\' | mongo --port %s", v);
v[2] = v;
v = virtualinvoke v.<org.testcontainers.containers.MongoDBContainer: org.testcontainers.containers.Container$ExecResult execInContainer(java.lang.String[])>(v);
v = <org.apache.drill.metastore.mongo.MongoBaseTest: org.slf4j.Logger logger>;
v = virtualinvoke v.<org.testcontainers.containers.Container$ExecResult: java.lang.String toString()>();
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
v = <org.apache.drill.metastore.mongo.MongoBaseTest: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("Execute list shards.");
v = newarray (java.lang.String)[3];
v[0] = "/bin/bash";
v[1] = "-c";
v[2] = "mongo --eval \'db.adminCommand({ listShards: 1 })\' --port 27017";
v = virtualinvoke v.<org.testcontainers.containers.MongoDBContainer: org.testcontainers.containers.Container$ExecResult execInContainer(java.lang.String[])>(v);
v = <org.apache.drill.metastore.mongo.MongoBaseTest: org.slf4j.Logger logger>;
v = virtualinvoke v.<org.testcontainers.containers.Container$ExecResult: java.lang.String toString()>();
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
v = <org.apache.drill.metastore.mongo.MongoBaseTest: java.util.List containers>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = newarray (java.lang.Object)[2];
v = virtualinvoke v.<org.testcontainers.containers.MongoDBContainer: java.lang.String getContainerIpAddress()>();
v[0] = v;
v = virtualinvoke v.<org.testcontainers.containers.MongoDBContainer: java.lang.Integer getMappedPort(int)>(27017);
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("mongodb://%s:%s", v);
return v;
}
private static void shardCollection() throws java.io.IOException, java.lang.InterruptedException
{
java.lang.Object[] v, v;
java.lang.String[] v, v;
int v, v, v, v;
java.lang.String v, v, v, v;
org.slf4j.Logger v, v, v, v;
java.util.List v, v, v, v;
org.testcontainers.containers.Container$ExecResult v, v;
java.lang.Object v, v;
v = <org.apache.drill.metastore.mongo.MongoBaseTest: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Enabled sharding for database: {}", "meta");
v = <org.apache.drill.metastore.mongo.MongoBaseTest: java.util.List containers>;
v = <org.apache.drill.metastore.mongo.MongoBaseTest: java.util.List containers>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v - 1;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
v = newarray (java.lang.String)[3];
v[0] = "/bin/bash";
v[1] = "-c";
v = newarray (java.lang.Object)[1];
v[0] = "meta";
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("mongo --eval \'db.adminCommand({enableSharding:\"%s\"})\'", v);
v[2] = v;
v = virtualinvoke v.<org.testcontainers.containers.GenericContainer: org.testcontainers.containers.Container$ExecResult execInContainer(java.lang.String[])>(v);
v = <org.apache.drill.metastore.mongo.MongoBaseTest: org.slf4j.Logger logger>;
v = virtualinvoke v.<org.testcontainers.containers.Container$ExecResult: java.lang.String toString()>();
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
v = <org.apache.drill.metastore.mongo.MongoBaseTest: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("Shard the collection: {}.{}", "meta", "tables");
v = <org.apache.drill.metastore.mongo.MongoBaseTest: java.util.List containers>;
v = <org.apache.drill.metastore.mongo.MongoBaseTest: java.util.List containers>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v - 1;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
v = newarray (java.lang.String)[3];
v[0] = "/bin/bash";
v[1] = "-c";
v = newarray (java.lang.Object)[3];
v[0] = "meta";
v[1] = "tables";
v[2] = "_id";
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("echo \'sh.shardCollection(\"%s.%s\", {\"%s\" : \"hashed\"})\' | mongo ", v);
v[2] = v;
v = virtualinvoke v.<org.testcontainers.containers.GenericContainer: org.testcontainers.containers.Container$ExecResult execInContainer(java.lang.String[])>(v);
v = <org.apache.drill.metastore.mongo.MongoBaseTest: org.slf4j.Logger logger>;
v = virtualinvoke v.<org.testcontainers.containers.Container$ExecResult: java.lang.String toString()>();
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
return;
}
private static org.testcontainers.containers.GenericContainer newContainer(org.testcontainers.containers.Network, java.lang.String, java.lang.String, java.lang.String)
{
java.lang.Object[] v;
java.lang.String[] v;
java.lang.Integer v, v;
org.testcontainers.containers.Network v;
org.testcontainers.containers.GenericContainer v, v, v, v, v;
java.lang.String v, v, v, v;
java.lang.Integer[] v;
v := @parameter: org.testcontainers.containers.Network;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = new org.testcontainers.containers.GenericContainer;
specialinvoke v.<org.testcontainers.containers.GenericContainer: void <init>(java.lang.String)>("mongo:4.4.10");
v = virtualinvoke v.<org.testcontainers.containers.GenericContainer: org.testcontainers.containers.GenericContainer withNetwork(org.testcontainers.containers.Network)>(v);
v = newarray (java.lang.String)[1];
v[0] = v;
v = virtualinvoke v.<org.testcontainers.containers.GenericContainer: org.testcontainers.containers.GenericContainer withNetworkAliases(java.lang.String[])>(v);
v = newarray (java.lang.Integer)[1];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(27017);
v[0] = v;
v = virtualinvoke v.<org.testcontainers.containers.GenericContainer: org.testcontainers.containers.GenericContainer withExposedPorts(java.lang.Integer[])>(v);
v = newarray (java.lang.Object)[4];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(27017);
v[0] = v;
v[1] = v;
v[2] = v;
v[3] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("mongod --port %d --%s --replSet %s --bind_ip localhost,%s", v);
v = virtualinvoke v.<org.testcontainers.containers.GenericContainer: org.testcontainers.containers.GenericContainer withCommand(java.lang.String)>(v);
return v;
}
public static void tearDownCluster()
{
java.util.function.Consumer v;
java.util.List v;
v = <org.apache.drill.metastore.mongo.MongoBaseTest: java.util.List containers>;
v = staticinvoke <org.apache.drill.metastore.mongo.MongoBaseTest$stop__4: java.util.function.Consumer bootstrap$()>();
interfaceinvoke v.<java.util.List: void forEach(java.util.function.Consumer)>(v);
return;
}
static void <clinit>()
{
org.slf4j.Logger v;
java.lang.String v;
boolean v;
java.util.ArrayList v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/drill/metastore/mongo/MongoBaseTest;");
<org.apache.drill.metastore.mongo.MongoBaseTest: org.slf4j.Logger logger> = v;
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.collect.Lists: java.util.ArrayList newArrayList()>();
<org.apache.drill.metastore.mongo.MongoBaseTest: java.util.List containers> = v;
v = staticinvoke <java.lang.System: java.lang.String getProperty(java.lang.String,java.lang.String)>("drill.mongo.tests.shardMode", "false");
v = staticinvoke <java.lang.Boolean: boolean parseBoolean(java.lang.String)>(v);
<org.apache.drill.metastore.mongo.MongoBaseTest: boolean isShardMode> = v;
return;
}
}