public class oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable extends oadd.org.apache.drill.exec.cache.AbstractStreamSerializable
{
static final oadd.com.codahale.metrics.MetricRegistry metrics;
static final java.lang.String WRITER_TIMER;
private oadd.org.apache.drill.exec.record.VectorContainer va;
private oadd.org.apache.drill.exec.record.WritableBatch batch;
private final oadd.org.apache.drill.exec.memory.BufferAllocator allocator;
private int recordCount;
private oadd.org.apache.drill.exec.record.BatchSchema$SelectionVectorMode svMode;
private oadd.org.apache.drill.exec.record.selection.SelectionVector sv;
private long timeNs;
private boolean retain;
public void <init>(oadd.org.apache.drill.exec.memory.BufferAllocator)
{
oadd.org.apache.drill.exec.record.BatchSchema$SelectionVectorMode v;
int v;
oadd.org.apache.drill.exec.memory.BufferAllocator v;
oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable v;
oadd.org.apache.drill.exec.record.VectorContainer v;
v := @this: oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable;
v := @parameter: oadd.org.apache.drill.exec.memory.BufferAllocator;
specialinvoke v.<oadd.org.apache.drill.exec.cache.AbstractStreamSerializable: void <init>()>();
v = (int) -1;
v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: int recordCount> = v;
v = <oadd.org.apache.drill.exec.record.BatchSchema$SelectionVectorMode: oadd.org.apache.drill.exec.record.BatchSchema$SelectionVectorMode NONE>;
v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.record.BatchSchema$SelectionVectorMode svMode> = v;
v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: boolean retain> = 0;
v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.memory.BufferAllocator allocator> = v;
v = new oadd.org.apache.drill.exec.record.VectorContainer;
specialinvoke v.<oadd.org.apache.drill.exec.record.VectorContainer: void <init>()>();
v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.record.VectorContainer va> = v;
return;
}
public void <init>(oadd.org.apache.drill.exec.record.WritableBatch, oadd.org.apache.drill.exec.memory.BufferAllocator)
{
oadd.org.apache.drill.exec.memory.BufferAllocator v;
oadd.org.apache.drill.exec.record.WritableBatch v;
oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable v;
v := @this: oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable;
v := @parameter: oadd.org.apache.drill.exec.record.WritableBatch;
v := @parameter: oadd.org.apache.drill.exec.memory.BufferAllocator;
specialinvoke v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: void <init>(oadd.org.apache.drill.exec.record.WritableBatch,oadd.org.apache.drill.exec.record.selection.SelectionVector,oadd.org.apache.drill.exec.memory.BufferAllocator)>(v, null, v);
return;
}
public void <init>(oadd.org.apache.drill.exec.record.WritableBatch, oadd.org.apache.drill.exec.record.selection.SelectionVector, oadd.org.apache.drill.exec.memory.BufferAllocator)
{
oadd.org.apache.drill.exec.record.BatchSchema$SelectionVectorMode v, v;
oadd.org.apache.drill.exec.record.selection.SelectionVector v;
int v;
oadd.org.apache.drill.exec.memory.BufferAllocator v;
oadd.org.apache.drill.exec.record.WritableBatch v;
oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable v;
v := @this: oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable;
v := @parameter: oadd.org.apache.drill.exec.record.WritableBatch;
v := @parameter: oadd.org.apache.drill.exec.record.selection.SelectionVector;
v := @parameter: oadd.org.apache.drill.exec.memory.BufferAllocator;
specialinvoke v.<oadd.org.apache.drill.exec.cache.AbstractStreamSerializable: void <init>()>();
v = (int) -1;
v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: int recordCount> = v;
v = <oadd.org.apache.drill.exec.record.BatchSchema$SelectionVectorMode: oadd.org.apache.drill.exec.record.BatchSchema$SelectionVectorMode NONE>;
v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.record.BatchSchema$SelectionVectorMode svMode> = v;
v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: boolean retain> = 0;
v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.memory.BufferAllocator allocator> = v;
v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.record.WritableBatch batch> = v;
if v == null goto label;
v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.record.selection.SelectionVector sv2> = v;
v = <oadd.org.apache.drill.exec.record.BatchSchema$SelectionVectorMode: oadd.org.apache.drill.exec.record.BatchSchema$SelectionVectorMode TWO_BYTE>;
v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.record.BatchSchema$SelectionVectorMode svMode> = v;
label:
return;
}
public void readFromStream(java.io.InputStream) throws java.io.IOException
{
int v;
oadd.org.apache.drill.exec.proto.UserBitShared$RecordBatchDef v;
oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable v;
boolean v, v;
java.io.InputStream v;
v := @this: oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable;
v := @parameter: java.io.InputStream;
v = staticinvoke <oadd.org.apache.drill.exec.proto.UserBitShared$RecordBatchDef: oadd.org.apache.drill.exec.proto.UserBitShared$RecordBatchDef parseDelimitedFrom(java.io.InputStream)>(v);
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserBitShared$RecordBatchDef: int getRecordCount()>();
v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: int recordCount> = v;
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserBitShared$RecordBatchDef: boolean hasCarriesTwoByteSelectionVector()>();
if v == 0 goto label;
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserBitShared$RecordBatchDef: boolean getCarriesTwoByteSelectionVector()>();
if v == 0 goto label;
specialinvoke v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: void readSv2(java.io.InputStream)>(v);
label:
specialinvoke v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: void readVectors(java.io.InputStream,oadd.org.apache.drill.exec.proto.UserBitShared$RecordBatchDef)>(v, v);
return;
}
private void readSv2(java.io.InputStream) throws java.io.IOException
{
oadd.org.apache.drill.exec.record.selection.SelectionVector v, v, v;
oadd.io.netty.buffer.DrillBuf v;
oadd.org.apache.drill.exec.record.BatchSchema$SelectionVectorMode v;
int v, v, v;
oadd.org.apache.drill.exec.memory.BufferAllocator v, v;
oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable v;
java.io.InputStream v;
v := @this: oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable;
v := @parameter: java.io.InputStream;
v = v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.record.selection.SelectionVector sv2>;
if v == null goto label;
v = v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.record.selection.SelectionVector sv2>;
virtualinvoke v.<oadd.org.apache.drill.exec.record.selection.SelectionVector2: void clear()>();
label:
v = v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: int recordCount>;
v = v * 2;
v = <oadd.org.apache.drill.exec.record.BatchSchema$SelectionVectorMode: oadd.org.apache.drill.exec.record.BatchSchema$SelectionVectorMode TWO_BYTE>;
v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.record.BatchSchema$SelectionVectorMode svMode> = v;
v = v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.memory.BufferAllocator allocator>;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.memory.BufferAllocator: oadd.io.netty.buffer.DrillBuf read(int,java.io.InputStream)>(v, v);
v = new oadd.org.apache.drill.exec.record.selection.SelectionVector;
v = v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.memory.BufferAllocator allocator>;
v = v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: int recordCount>;
specialinvoke v.<oadd.org.apache.drill.exec.record.selection.SelectionVector2: void <init>(oadd.org.apache.drill.exec.memory.BufferAllocator,oadd.io.netty.buffer.DrillBuf,int)>(v, v, v);
v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.record.selection.SelectionVector sv2> = v;
virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: boolean release()>();
return;
}
private void readVectors(java.io.InputStream, oadd.org.apache.drill.exec.proto.UserBitShared$RecordBatchDef) throws java.io.IOException
{
java.util.ArrayList v;
int v, v;
oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable v;
oadd.org.apache.drill.exec.vector.ValueVector v;
boolean v;
java.util.Iterator v;
oadd.org.apache.drill.exec.record.VectorContainer v;
java.util.List v;
oadd.io.netty.buffer.DrillBuf v;
oadd.org.apache.drill.exec.record.BatchSchema$SelectionVectorMode v;
oadd.org.apache.drill.exec.memory.BufferAllocator v, v;
java.lang.Object v;
oadd.org.apache.drill.exec.proto.UserBitShared$RecordBatchDef v;
oadd.org.apache.drill.exec.record.MaterializedField v;
java.io.InputStream v;
v := @this: oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable;
v := @parameter: java.io.InputStream;
v := @parameter: oadd.org.apache.drill.exec.proto.UserBitShared$RecordBatchDef;
v = new oadd.org.apache.drill.exec.record.VectorContainer;
specialinvoke v.<oadd.org.apache.drill.exec.record.VectorContainer: void <init>()>();
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.collect.Lists: java.util.ArrayList newArrayList()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserBitShared$RecordBatchDef: java.util.List getFieldList()>();
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserBitShared$SerializedField: int getBufferLength()>();
v = staticinvoke <oadd.org.apache.drill.exec.record.MaterializedField: oadd.org.apache.drill.exec.record.MaterializedField create(oadd.org.apache.drill.exec.proto.UserBitShared$SerializedField)>(v);
v = v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.memory.BufferAllocator allocator>;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.memory.BufferAllocator: oadd.io.netty.buffer.DrillBuf read(int,java.io.InputStream)>(v, v);
v = v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.memory.BufferAllocator allocator>;
v = staticinvoke <oadd.org.apache.drill.exec.expr.TypeHelper: oadd.org.apache.drill.exec.vector.ValueVector getNewVector(oadd.org.apache.drill.exec.record.MaterializedField,oadd.org.apache.drill.exec.memory.BufferAllocator)>(v, v);
interfaceinvoke v.<oadd.org.apache.drill.exec.vector.ValueVector: void load(oadd.org.apache.drill.exec.proto.UserBitShared$SerializedField,oadd.io.netty.buffer.DrillBuf)>(v, v);
virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: boolean release()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
virtualinvoke v.<oadd.org.apache.drill.exec.record.VectorContainer: void addCollection(java.lang.Iterable)>(v);
v = v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.record.BatchSchema$SelectionVectorMode svMode>;
virtualinvoke v.<oadd.org.apache.drill.exec.record.VectorContainer: void buildSchema(oadd.org.apache.drill.exec.record.BatchSchema$SelectionVectorMode)>(v);
v = v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: int recordCount>;
virtualinvoke v.<oadd.org.apache.drill.exec.record.VectorContainer: void setRecordCount(int)>(v);
v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.record.VectorContainer va> = v;
return;
}
public void readFromStreamWithContainer(oadd.org.apache.drill.exec.record.VectorContainer, java.io.InputStream) throws java.io.IOException
{
oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable v;
boolean v, v, v;
oadd.org.apache.drill.exec.record.selection.SelectionVector v, v, v, v;
java.util.List v;
oadd.io.netty.buffer.DrillBuf v, v;
oadd.org.apache.drill.exec.memory.BufferAllocator v, v, v;
oadd.org.apache.drill.exec.proto.UserBitShared$RecordBatchDef v;
java.lang.Throwable v;
java.util.ArrayList v;
int v, v, v, v, v, v, v, v;
oadd.org.apache.drill.exec.vector.ValueVector v;
java.util.Iterator v;
oadd.org.apache.drill.exec.record.VectorContainer v, v;
oadd.org.apache.drill.exec.record.BatchSchema$SelectionVectorMode v, v;
java.lang.Object v;
oadd.org.apache.drill.exec.record.MaterializedField v;
java.io.InputStream v;
v := @this: oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable;
v := @parameter: oadd.org.apache.drill.exec.record.VectorContainer;
v := @parameter: java.io.InputStream;
v = new oadd.org.apache.drill.exec.record.VectorContainer;
specialinvoke v.<oadd.org.apache.drill.exec.record.VectorContainer: void <init>()>();
v = staticinvoke <oadd.org.apache.drill.exec.proto.UserBitShared$RecordBatchDef: oadd.org.apache.drill.exec.proto.UserBitShared$RecordBatchDef parseDelimitedFrom(java.io.InputStream)>(v);
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserBitShared$RecordBatchDef: int getRecordCount()>();
v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: int recordCount> = v;
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserBitShared$RecordBatchDef: boolean hasCarriesTwoByteSelectionVector()>();
if v == 0 goto label;
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserBitShared$RecordBatchDef: boolean getCarriesTwoByteSelectionVector()>();
if v == 0 goto label;
v = v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.record.selection.SelectionVector sv2>;
if v != null goto label;
v = new oadd.org.apache.drill.exec.record.selection.SelectionVector;
v = v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.memory.BufferAllocator allocator>;
specialinvoke v.<oadd.org.apache.drill.exec.record.selection.SelectionVector2: void <init>(oadd.org.apache.drill.exec.memory.BufferAllocator)>(v);
v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.record.selection.SelectionVector sv2> = v;
label:
v = v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.record.selection.SelectionVector sv2>;
v = v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: int recordCount>;
v = v * 2;
virtualinvoke v.<oadd.org.apache.drill.exec.record.selection.SelectionVector2: void allocateNew(int)>(v);
v = v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.record.selection.SelectionVector sv2>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.record.selection.SelectionVector2: oadd.io.netty.buffer.DrillBuf getBuffer()>();
v = v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: int recordCount>;
v = v * 2;
virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: int setBytes(int,java.io.InputStream,int)>(0, v, v);
v = <oadd.org.apache.drill.exec.record.BatchSchema$SelectionVectorMode: oadd.org.apache.drill.exec.record.BatchSchema$SelectionVectorMode TWO_BYTE>;
v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.record.BatchSchema$SelectionVectorMode svMode> = v;
label:
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.collect.Lists: java.util.ArrayList newArrayList()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserBitShared$RecordBatchDef: java.util.List getFieldList()>();
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserBitShared$SerializedField: int getBufferLength()>();
v = staticinvoke <oadd.org.apache.drill.exec.record.MaterializedField: oadd.org.apache.drill.exec.record.MaterializedField create(oadd.org.apache.drill.exec.proto.UserBitShared$SerializedField)>(v);
v = v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.memory.BufferAllocator allocator>;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.memory.BufferAllocator: oadd.io.netty.buffer.DrillBuf buffer(int)>(v);
label:
virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: int writeBytes(java.io.InputStream,int)>(v, v);
v = v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.memory.BufferAllocator allocator>;
v = staticinvoke <oadd.org.apache.drill.exec.expr.TypeHelper: oadd.org.apache.drill.exec.vector.ValueVector getNewVector(oadd.org.apache.drill.exec.record.MaterializedField,oadd.org.apache.drill.exec.memory.BufferAllocator)>(v, v);
interfaceinvoke v.<oadd.org.apache.drill.exec.vector.ValueVector: void load(oadd.org.apache.drill.exec.proto.UserBitShared$SerializedField,oadd.io.netty.buffer.DrillBuf)>(v, v);
label:
virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: boolean release()>();
goto label;
label:
v := @caughtexception;
virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: boolean release()>();
throw v;
label:
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
virtualinvoke v.<oadd.org.apache.drill.exec.record.VectorContainer: void addCollection(java.lang.Iterable)>(v);
v = v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: int recordCount>;
virtualinvoke v.<oadd.org.apache.drill.exec.record.VectorContainer: void setRecordCount(int)>(v);
virtualinvoke v.<oadd.org.apache.drill.exec.record.VectorContainer: void transferIn(oadd.org.apache.drill.exec.record.VectorContainer)>(v);
v = v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.record.BatchSchema$SelectionVectorMode svMode>;
virtualinvoke v.<oadd.org.apache.drill.exec.record.VectorContainer: void buildSchema(oadd.org.apache.drill.exec.record.BatchSchema$SelectionVectorMode)>(v);
v = v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: int recordCount>;
virtualinvoke v.<oadd.org.apache.drill.exec.record.VectorContainer: void setRecordCount(int)>(v);
v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.record.VectorContainer va> = v;
return;
catch java.lang.Throwable from label to label with label;
}
public void writeToStreamAndRetain(java.io.OutputStream) throws java.io.IOException
{
java.io.OutputStream v;
oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable v;
v := @this: oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable;
v := @parameter: java.io.OutputStream;
v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: boolean retain> = 1;
virtualinvoke v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: void writeToStream(java.io.OutputStream)>(v);
return;
}
public void writeToStream(java.io.OutputStream) throws java.io.IOException
{
java.lang.Throwable v;
oadd.com.codahale.metrics.MetricRegistry v;
oadd.com.codahale.metrics.Timer v;
long v, v, v;
oadd.org.apache.drill.exec.record.WritableBatch v, v;
oadd.com.codahale.metrics.Timer$Context v;
int v, v, v, v, v;
java.lang.String v;
oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable v;
java.io.OutputStream v;
oadd.io.netty.buffer.DrillBuf[] v;
oadd.org.apache.drill.exec.record.selection.SelectionVector v, v;
java.io.IOException v;
java.lang.RuntimeException v;
oadd.io.netty.buffer.DrillBuf v, v;
oadd.org.apache.drill.exec.record.BatchSchema$SelectionVectorMode v, v;
oadd.org.apache.drill.exec.memory.BufferAllocator v, v;
oadd.org.apache.drill.exec.proto.UserBitShared$RecordBatchDef v;
v := @this: oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable;
v := @parameter: java.io.OutputStream;
staticinvoke <org.apache.drill.shaded.guava.com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object)>(v);
v = <oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.com.codahale.metrics.MetricRegistry metrics>;
v = <oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: java.lang.String WRITER_TIMER>;
v = virtualinvoke v.<oadd.com.codahale.metrics.MetricRegistry: oadd.com.codahale.metrics.Timer timer(java.lang.String)>(v);
v = virtualinvoke v.<oadd.com.codahale.metrics.Timer: oadd.com.codahale.metrics.Timer$Context time()>();
v = v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.record.WritableBatch batch>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.record.WritableBatch: oadd.io.netty.buffer.DrillBuf[] getBuffers()>();
v = v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.record.WritableBatch batch>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.record.WritableBatch: oadd.org.apache.drill.exec.proto.UserBitShared$RecordBatchDef getDef()>();
label:
virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserBitShared$RecordBatchDef: void writeDelimitedTo(java.io.OutputStream)>(v);
v = v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.record.BatchSchema$SelectionVectorMode svMode>;
v = <oadd.org.apache.drill.exec.record.BatchSchema$SelectionVectorMode: oadd.org.apache.drill.exec.record.BatchSchema$SelectionVectorMode TWO_BYTE>;
if v != v goto label;
v = v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.record.selection.SelectionVector sv2>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.record.selection.SelectionVector2: int getCount()>();
v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: int recordCount> = v;
v = v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: int recordCount>;
v = v * 2;
v = v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.memory.BufferAllocator allocator>;
v = v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.record.selection.SelectionVector sv2>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.record.selection.SelectionVector2: oadd.io.netty.buffer.DrillBuf getBuffer(boolean)>(0);
interfaceinvoke v.<oadd.org.apache.drill.exec.memory.BufferAllocator: void write(oadd.io.netty.buffer.DrillBuf,int,java.io.OutputStream)>(v, v, v);
label:
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.memory.BufferAllocator allocator>;
interfaceinvoke v.<oadd.org.apache.drill.exec.memory.BufferAllocator: void write(oadd.io.netty.buffer.DrillBuf,java.io.OutputStream)>(v, v);
v = v + 1;
goto label;
label:
v = v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: long timeNs>;
v = virtualinvoke v.<oadd.com.codahale.metrics.Timer$Context: long stop()>();
v = v + v;
v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: long timeNs> = v;
label:
virtualinvoke v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: void clear()>();
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;
virtualinvoke v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: void clear()>();
throw v;
label:
return;
catch java.io.IOException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public void clear()
{
oadd.org.apache.drill.exec.record.selection.SelectionVector v, v;
oadd.org.apache.drill.exec.record.WritableBatch v;
oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable v;
boolean v;
v := @this: oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable;
v = v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: boolean retain>;
if v != 0 goto label;
v = v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.record.WritableBatch batch>;
virtualinvoke v.<oadd.org.apache.drill.exec.record.WritableBatch: void clear()>();
v = v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.record.selection.SelectionVector sv2>;
if v == null goto label;
v = v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.record.selection.SelectionVector sv2>;
virtualinvoke v.<oadd.org.apache.drill.exec.record.selection.SelectionVector2: void clear()>();
label:
return;
}
public oadd.org.apache.drill.exec.record.VectorContainer get()
{
oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable v;
oadd.org.apache.drill.exec.record.VectorContainer v;
v := @this: oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable;
v = v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.record.VectorContainer va>;
return v;
}
public oadd.org.apache.drill.exec.record.selection.SelectionVector getSv2()
{
oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable v;
oadd.org.apache.drill.exec.record.selection.SelectionVector v;
v := @this: oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable;
v = v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.org.apache.drill.exec.record.selection.SelectionVector sv2>;
return v;
}
public long getTimeNs()
{
long v;
oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable v;
v := @this: oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable;
v = v.<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: long timeNs>;
return v;
}
static void <clinit>()
{
java.lang.String[] v;
java.lang.String v;
oadd.com.codahale.metrics.MetricRegistry v;
v = staticinvoke <oadd.org.apache.drill.exec.metrics.DrillMetrics: oadd.com.codahale.metrics.MetricRegistry getRegistry()>();
<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: oadd.com.codahale.metrics.MetricRegistry metrics> = v;
v = newarray (java.lang.String)[1];
v[0] = "writerTime";
v = staticinvoke <oadd.com.codahale.metrics.MetricRegistry: java.lang.String name(java.lang.Class,java.lang.String[])>(class "Loadd/org/apache/drill/exec/cache/VectorAccessibleSerializable;", v);
<oadd.org.apache.drill.exec.cache.VectorAccessibleSerializable: java.lang.String WRITER_TIMER> = v;
return;
}
}