public class org.finos.legend.engine.service.post.validation.runner.PostValidationAssertionStreamingOutput extends java.lang.Object implements javax.ws.rs.core.StreamingOutput
{
private final java.lang.String assertionId;
private final java.lang.String assertionMessage;
private final org.finos.legend.engine.plan.execution.result.StreamingResult result;
private final org.finos.legend.engine.plan.execution.result.serialization.SerializationFormat format;
private final byte[] b_id;
private final byte[] b_message;
private final byte[] b_violations;
private final byte[] b_endResult;
public void <init>(java.lang.String, java.lang.String, org.finos.legend.engine.plan.execution.result.StreamingResult, org.finos.legend.engine.plan.execution.result.serialization.SerializationFormat)
{
byte[] v, v, v, v;
org.finos.legend.engine.plan.execution.result.serialization.SerializationFormat v;
org.finos.legend.engine.plan.execution.result.StreamingResult v;
org.finos.legend.engine.service.post.validation.runner.PostValidationAssertionStreamingOutput v;
java.lang.String v, v, v, v, v, v;
v := @this: org.finos.legend.engine.service.post.validation.runner.PostValidationAssertionStreamingOutput;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: org.finos.legend.engine.plan.execution.result.StreamingResult;
v := @parameter: org.finos.legend.engine.plan.execution.result.serialization.SerializationFormat;
specialinvoke v.<java.lang.Object: void <init>()>();
v = "{\"id\": \"";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
v.<org.finos.legend.engine.service.post.validation.runner.PostValidationAssertionStreamingOutput: byte[] b_id> = v;
v = "\", \"message\": \"";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
v.<org.finos.legend.engine.service.post.validation.runner.PostValidationAssertionStreamingOutput: byte[] b_message> = v;
v = "\", \"violations\": ";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
v.<org.finos.legend.engine.service.post.validation.runner.PostValidationAssertionStreamingOutput: byte[] b_violations> = v;
v = "}";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
v.<org.finos.legend.engine.service.post.validation.runner.PostValidationAssertionStreamingOutput: byte[] b_endResult> = v;
v.<org.finos.legend.engine.service.post.validation.runner.PostValidationAssertionStreamingOutput: java.lang.String assertionId> = v;
v.<org.finos.legend.engine.service.post.validation.runner.PostValidationAssertionStreamingOutput: java.lang.String assertionMessage> = v;
v.<org.finos.legend.engine.service.post.validation.runner.PostValidationAssertionStreamingOutput: org.finos.legend.engine.plan.execution.result.StreamingResult result> = v;
v.<org.finos.legend.engine.service.post.validation.runner.PostValidationAssertionStreamingOutput: org.finos.legend.engine.plan.execution.result.serialization.SerializationFormat format> = v;
return;
}
public void write(java.io.OutputStream)
{
byte[] v, v, v, v, v, v;
org.finos.legend.engine.plan.execution.result.serialization.SerializationFormat v, v, v, v;
int[] v, v;
boolean v, v;
org.finos.legend.engine.plan.execution.result.StreamingResult v, v, v, v, v, v, v, v;
java.lang.Exception v;
org.finos.legend.engine.plan.execution.stores.relational.serialization.RelationalResultToPureTDSSerializer v;
java.lang.Throwable v;
org.finos.legend.engine.service.post.validation.runner.PostValidationAssertionStreamingOutput v;
org.finos.legend.engine.plan.execution.result.object.StreamingObjectResultJSONSerializer v;
int v, v, v, v;
org.finos.legend.engine.plan.execution.stores.relational.serialization.RelationalResultToJsonDefaultSerializer v;
java.lang.String v, v, v, v;
java.io.OutputStream v;
java.lang.RuntimeException v, v, v;
org.finos.legend.engine.plan.execution.stores.relational.serialization.RelationalResultToPureTDSToObjectSerializer v;
v := @this: org.finos.legend.engine.service.post.validation.runner.PostValidationAssertionStreamingOutput;
v := @parameter: java.io.OutputStream;
label:
v = v.<org.finos.legend.engine.service.post.validation.runner.PostValidationAssertionStreamingOutput: byte[] b_id>;
virtualinvoke v.<java.io.OutputStream: void write(byte[])>(v);
v = v.<org.finos.legend.engine.service.post.validation.runner.PostValidationAssertionStreamingOutput: java.lang.String assertionId>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
virtualinvoke v.<java.io.OutputStream: void write(byte[])>(v);
v = v.<org.finos.legend.engine.service.post.validation.runner.PostValidationAssertionStreamingOutput: byte[] b_message>;
virtualinvoke v.<java.io.OutputStream: void write(byte[])>(v);
v = v.<org.finos.legend.engine.service.post.validation.runner.PostValidationAssertionStreamingOutput: java.lang.String assertionMessage>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
virtualinvoke v.<java.io.OutputStream: void write(byte[])>(v);
v = v.<org.finos.legend.engine.service.post.validation.runner.PostValidationAssertionStreamingOutput: byte[] b_violations>;
virtualinvoke v.<java.io.OutputStream: void write(byte[])>(v);
v = v.<org.finos.legend.engine.service.post.validation.runner.PostValidationAssertionStreamingOutput: org.finos.legend.engine.plan.execution.result.StreamingResult result>;
v = v instanceof org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult;
if v == 0 goto label;
v = <org.finos.legend.engine.service.post.validation.runner.PostValidationAssertionStreamingOutput$1: int[] $SwitchMap$org$finos$legend$engine$plan$execution$result$serialization$SerializationFormat>;
v = v.<org.finos.legend.engine.service.post.validation.runner.PostValidationAssertionStreamingOutput: org.finos.legend.engine.plan.execution.result.serialization.SerializationFormat format>;
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.result.serialization.SerializationFormat: int ordinal()>();
v = v[v];
tableswitch(v)
{
case 1: goto label;
case 2: goto label;
case 3: goto label;
default: goto label;
};
label:
v = new org.finos.legend.engine.plan.execution.stores.relational.serialization.RelationalResultToPureTDSToObjectSerializer;
v = v.<org.finos.legend.engine.service.post.validation.runner.PostValidationAssertionStreamingOutput: org.finos.legend.engine.plan.execution.result.StreamingResult result>;
specialinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.serialization.RelationalResultToPureTDSToObjectSerializer: void <init>(org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult)>(v);
virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.serialization.RelationalResultToPureTDSToObjectSerializer: void stream(java.io.OutputStream)>(v);
goto label;
label:
v = new org.finos.legend.engine.plan.execution.stores.relational.serialization.RelationalResultToPureTDSSerializer;
v = v.<org.finos.legend.engine.service.post.validation.runner.PostValidationAssertionStreamingOutput: org.finos.legend.engine.plan.execution.result.StreamingResult result>;
specialinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.serialization.RelationalResultToPureTDSSerializer: void <init>(org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult)>(v);
virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.serialization.RelationalResultToPureTDSSerializer: void stream(java.io.OutputStream)>(v);
goto label;
label:
v = new org.finos.legend.engine.plan.execution.stores.relational.serialization.RelationalResultToJsonDefaultSerializer;
v = v.<org.finos.legend.engine.service.post.validation.runner.PostValidationAssertionStreamingOutput: org.finos.legend.engine.plan.execution.result.StreamingResult result>;
specialinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.serialization.RelationalResultToJsonDefaultSerializer: void <init>(org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult)>(v);
virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.serialization.RelationalResultToJsonDefaultSerializer: void stream(java.io.OutputStream)>(v);
goto label;
label:
v = new java.lang.RuntimeException;
v = v.<org.finos.legend.engine.service.post.validation.runner.PostValidationAssertionStreamingOutput: org.finos.legend.engine.plan.execution.result.serialization.SerializationFormat format>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.finos.legend.engine.plan.execution.result.serialization.SerializationFormat)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u format not currently supported for RelationalResult");
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.finos.legend.engine.service.post.validation.runner.PostValidationAssertionStreamingOutput: org.finos.legend.engine.plan.execution.result.StreamingResult result>;
v = v instanceof org.finos.legend.engine.plan.execution.result.object.StreamingObjectResult;
if v == 0 goto label;
v = <org.finos.legend.engine.service.post.validation.runner.PostValidationAssertionStreamingOutput$1: int[] $SwitchMap$org$finos$legend$engine$plan$execution$result$serialization$SerializationFormat>;
v = v.<org.finos.legend.engine.service.post.validation.runner.PostValidationAssertionStreamingOutput: org.finos.legend.engine.plan.execution.result.serialization.SerializationFormat format>;
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.result.serialization.SerializationFormat: int ordinal()>();
v = v[v];
lookupswitch(v)
{
case 3: goto label;
default: goto label;
};
label:
v = new org.finos.legend.engine.plan.execution.result.object.StreamingObjectResultJSONSerializer;
v = v.<org.finos.legend.engine.service.post.validation.runner.PostValidationAssertionStreamingOutput: org.finos.legend.engine.plan.execution.result.StreamingResult result>;
specialinvoke v.<org.finos.legend.engine.plan.execution.result.object.StreamingObjectResultJSONSerializer: void <init>(org.finos.legend.engine.plan.execution.result.object.StreamingObjectResult)>(v);
virtualinvoke v.<org.finos.legend.engine.plan.execution.result.object.StreamingObjectResultJSONSerializer: void stream(java.io.OutputStream)>(v);
goto label;
label:
v = new java.lang.RuntimeException;
v = v.<org.finos.legend.engine.service.post.validation.runner.PostValidationAssertionStreamingOutput: org.finos.legend.engine.plan.execution.result.serialization.SerializationFormat format>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.finos.legend.engine.plan.execution.result.serialization.SerializationFormat)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u format not currently supported for StreamingObjectResult");
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.finos.legend.engine.service.post.validation.runner.PostValidationAssertionStreamingOutput: byte[] b_endResult>;
virtualinvoke v.<java.io.OutputStream: void write(byte[])>(v);
label:
v = v.<org.finos.legend.engine.service.post.validation.runner.PostValidationAssertionStreamingOutput: org.finos.legend.engine.plan.execution.result.StreamingResult result>;
virtualinvoke v.<org.finos.legend.engine.plan.execution.result.StreamingResult: void close()>();
goto label;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v := @caughtexception;
v = v.<org.finos.legend.engine.service.post.validation.runner.PostValidationAssertionStreamingOutput: org.finos.legend.engine.plan.execution.result.StreamingResult result>;
virtualinvoke v.<org.finos.legend.engine.plan.execution.result.StreamingResult: void close()>();
throw v;
label:
return;
catch java.lang.Exception from label to label with label;
catch java.lang.Throwable from label to label with label;
}
}