public class org.finos.legend.engine.plan.execution.stores.mongodb.result.MongoDBResult extends org.finos.legend.engine.plan.execution.result.Result
{
private final com.mongodb.client.MongoCursor mongoCursor;
private final com.mongodb.client.MongoClient mongoClient;
public void <init>(com.mongodb.client.MongoClient, com.mongodb.client.MongoCursor)
{
java.util.List v;
com.mongodb.client.MongoClient v;
com.mongodb.client.MongoCursor v;
org.finos.legend.engine.plan.execution.stores.mongodb.result.MongoDBResult v;
v := @this: org.finos.legend.engine.plan.execution.stores.mongodb.result.MongoDBResult;
v := @parameter: com.mongodb.client.MongoClient;
v := @parameter: com.mongodb.client.MongoCursor;
v = staticinvoke <java.util.Collections: java.util.List emptyList()>();
specialinvoke v.<org.finos.legend.engine.plan.execution.stores.mongodb.result.MongoDBResult: void <init>(com.mongodb.client.MongoClient,com.mongodb.client.MongoCursor,java.util.List)>(v, v, v);
return;
}
public void <init>(com.mongodb.client.MongoClient, com.mongodb.client.MongoCursor, java.util.List)
{
java.util.List v;
com.mongodb.client.MongoClient v;
com.mongodb.client.MongoCursor v;
org.finos.legend.engine.plan.execution.stores.mongodb.result.MongoDBResult v;
v := @this: org.finos.legend.engine.plan.execution.stores.mongodb.result.MongoDBResult;
v := @parameter: com.mongodb.client.MongoClient;
v := @parameter: com.mongodb.client.MongoCursor;
v := @parameter: java.util.List;
specialinvoke v.<org.finos.legend.engine.plan.execution.result.Result: void <init>(java.lang.String,java.util.List)>("success", v);
v.<org.finos.legend.engine.plan.execution.stores.mongodb.result.MongoDBResult: com.mongodb.client.MongoCursor mongoCursor> = v;
v.<org.finos.legend.engine.plan.execution.stores.mongodb.result.MongoDBResult: com.mongodb.client.MongoClient mongoClient> = v;
return;
}
public com.mongodb.client.MongoCursor getMongoCursor()
{
org.finos.legend.engine.plan.execution.stores.mongodb.result.MongoDBResult v;
com.mongodb.client.MongoCursor v;
v := @this: org.finos.legend.engine.plan.execution.stores.mongodb.result.MongoDBResult;
v = v.<org.finos.legend.engine.plan.execution.stores.mongodb.result.MongoDBResult: com.mongodb.client.MongoCursor mongoCursor>;
return v;
}
public org.finos.legend.engine.plan.execution.result.builder.Builder getResultBuilder()
{
org.finos.legend.engine.plan.execution.stores.mongodb.result.MongoDBResult v;
org.finos.legend.engine.plan.execution.result.builder.stream.StreamBuilder v;
v := @this: org.finos.legend.engine.plan.execution.stores.mongodb.result.MongoDBResult;
v = new org.finos.legend.engine.plan.execution.result.builder.stream.StreamBuilder;
specialinvoke v.<org.finos.legend.engine.plan.execution.result.builder.stream.StreamBuilder: void <init>()>();
return v;
}
public void close()
{
org.finos.legend.engine.plan.execution.stores.mongodb.result.MongoDBResult v;
com.mongodb.client.MongoClient v;
com.mongodb.client.MongoCursor v;
v := @this: org.finos.legend.engine.plan.execution.stores.mongodb.result.MongoDBResult;
v = v.<org.finos.legend.engine.plan.execution.stores.mongodb.result.MongoDBResult: com.mongodb.client.MongoCursor mongoCursor>;
interfaceinvoke v.<com.mongodb.client.MongoCursor: void close()>();
v = v.<org.finos.legend.engine.plan.execution.stores.mongodb.result.MongoDBResult: com.mongodb.client.MongoClient mongoClient>;
interfaceinvoke v.<com.mongodb.client.MongoClient: void close()>();
return;
}
public java.lang.Object accept(org.finos.legend.engine.plan.execution.result.ResultVisitor)
{
java.lang.UnsupportedOperationException v;
org.finos.legend.engine.plan.execution.result.ResultVisitor v;
org.finos.legend.engine.plan.execution.stores.mongodb.result.MongoDBResult v;
v := @this: org.finos.legend.engine.plan.execution.stores.mongodb.result.MongoDBResult;
v := @parameter: org.finos.legend.engine.plan.execution.result.ResultVisitor;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>("Streaming MongoDBResult result is not supported. Please raise a issue with dev team");
throw v;
}
}