public abstract class oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter extends oadd.org.apache.drill.exec.vector.accessor.writer.BaseScalarWriter
{
protected int lastWriteIndex;
public void <init>()
{
oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter v;
v := @this: oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter;
specialinvoke v.<oadd.org.apache.drill.exec.vector.accessor.writer.BaseScalarWriter: void <init>()>();
return;
}
public void startWrite()
{
int v;
oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter v;
v := @this: oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter;
virtualinvoke v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: void setBuffer()>();
v = (int) -1;
v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: int lastWriteIndex> = v;
return;
}
public abstract int width();
protected final void setBuffer()
{
oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter v;
oadd.io.netty.buffer.DrillBuf v, v;
int v, v, v;
oadd.org.apache.drill.exec.vector.BaseDataValueVector v;
v := @this: oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter;
v = virtualinvoke v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: oadd.org.apache.drill.exec.vector.BaseDataValueVector vector()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.vector.BaseDataValueVector: oadd.io.netty.buffer.DrillBuf getBuffer()>();
v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: oadd.io.netty.buffer.DrillBuf drillBuf> = v;
v = v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: oadd.io.netty.buffer.DrillBuf drillBuf>;
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: int capacity()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: int width()>();
v = v / v;
v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: int capacity> = v;
return;
}
protected final void mandatoryResize(int)
{
oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter v;
int v, v, v, v, v, v, v;
v := @this: oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter;
v := @parameter: int;
v = v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: int capacity>;
if v >= v goto label;
return;
label:
v = v + 1;
v = virtualinvoke v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: int width()>();
v = v * v;
v = staticinvoke <java.lang.Math: int max(int,int)>(v, 256);
v = staticinvoke <oadd.org.apache.drill.exec.memory.BaseAllocator: int nextPowerOfTwo(int)>(v);
virtualinvoke v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: void realloc(int)>(v);
return;
}
protected final int resize(int)
{
oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter v;
oadd.org.apache.drill.exec.vector.accessor.ColumnWriterIndex v;
int v, v, v, v, v, v, v, v, v, v, v, v;
boolean v;
v := @this: oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter;
v := @parameter: int;
v = v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: int capacity>;
if v >= v goto label;
return v;
label:
v = virtualinvoke v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: int width()>();
v = v + 1;
v = v * v;
v = staticinvoke <java.lang.Math: int max(int,int)>(v, 256);
v = staticinvoke <oadd.org.apache.drill.exec.memory.BaseAllocator: int nextPowerOfTwo(int)>(v);
v = <oadd.org.apache.drill.exec.vector.ValueVector: int MAX_BUFFER_SIZE>;
if v > v goto label;
v = v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: int capacity>;
v = v * v;
v = v - v;
v = virtualinvoke v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: boolean canExpand(int)>(v);
if v == 0 goto label;
virtualinvoke v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: void realloc(int)>(v);
goto label;
label:
virtualinvoke v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: void overflowed()>();
label:
v = v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: oadd.org.apache.drill.exec.vector.accessor.ColumnWriterIndex vectorIndex>;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.vector.accessor.ColumnWriterIndex: int vectorIndex()>();
return v;
}
public int lastWriteIndex()
{
int v;
oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter v;
v := @this: oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter;
v = v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: int lastWriteIndex>;
return v;
}
public void setLastWriteIndex(int)
{
int v;
oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter v;
v := @this: oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter;
v := @parameter: int;
v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: int lastWriteIndex> = v;
return;
}
public void skipNulls()
{
oadd.org.apache.drill.exec.vector.accessor.ColumnWriterIndex v;
oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter v;
int v, v;
v := @this: oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter;
v = v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: oadd.org.apache.drill.exec.vector.accessor.ColumnWriterIndex vectorIndex>;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.vector.accessor.ColumnWriterIndex: int vectorIndex()>();
v = v - 1;
v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: int lastWriteIndex> = v;
return;
}
public void restartRow()
{
oadd.org.apache.drill.exec.vector.accessor.ColumnWriterIndex v;
oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter v;
int v, v, v, v;
v := @this: oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter;
v = v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: int lastWriteIndex>;
v = v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: oadd.org.apache.drill.exec.vector.accessor.ColumnWriterIndex vectorIndex>;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.vector.accessor.ColumnWriterIndex: int vectorIndex()>();
v = v - 1;
v = staticinvoke <java.lang.Math: int min(int,int)>(v, v);
v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: int lastWriteIndex> = v;
return;
}
public void preRollover()
{
int v;
oadd.org.apache.drill.exec.vector.accessor.ColumnWriterIndex v;
oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter v;
v := @this: oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter;
v = v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: oadd.org.apache.drill.exec.vector.accessor.ColumnWriterIndex vectorIndex>;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.vector.accessor.ColumnWriterIndex: int rowStartIndex()>();
virtualinvoke v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: void setValueCount(int)>(v);
return;
}
public void postRollover()
{
oadd.org.apache.drill.exec.vector.accessor.ColumnWriterIndex v;
oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter v;
int v, v, v, v, v;
v := @this: oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter;
v = v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: int lastWriteIndex>;
v = v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: oadd.org.apache.drill.exec.vector.accessor.ColumnWriterIndex vectorIndex>;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.vector.accessor.ColumnWriterIndex: int rowStartIndex()>();
v = v - v;
v = (int) -1;
v = staticinvoke <java.lang.Math: int max(int,int)>(v, v);
virtualinvoke v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: void startWrite()>();
v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: int lastWriteIndex> = v;
return;
}
public void endWrite()
{
int v;
oadd.org.apache.drill.exec.vector.accessor.ColumnWriterIndex v;
oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter v;
v := @this: oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter;
v = v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: oadd.org.apache.drill.exec.vector.accessor.ColumnWriterIndex vectorIndex>;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.vector.accessor.ColumnWriterIndex: int vectorIndex()>();
virtualinvoke v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: void setValueCount(int)>(v);
return;
}
protected abstract void fillEmpties(int);
public void setValueCount(int)
{
oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter v;
oadd.org.apache.drill.exec.vector.BaseDataValueVector v;
oadd.io.netty.buffer.DrillBuf v;
int v, v, v, v, v, v, v;
v := @this: oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter;
v := @parameter: int;
v = v - 1;
virtualinvoke v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: void mandatoryResize(int)>(v);
virtualinvoke v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: void fillEmpties(int)>(v);
v = virtualinvoke v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: oadd.org.apache.drill.exec.vector.BaseDataValueVector vector()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.vector.BaseDataValueVector: oadd.io.netty.buffer.DrillBuf getBuffer()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: int width()>();
v = v * v;
virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.ByteBuf writerIndex(int)>(v);
v = v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: int lastWriteIndex>;
v = v - 1;
v = staticinvoke <java.lang.Math: int max(int,int)>(v, v);
v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: int lastWriteIndex> = v;
return;
}
public void dump(oadd.org.apache.drill.exec.vector.accessor.impl.HierarchicalFormatter)
{
oadd.org.apache.drill.exec.vector.accessor.impl.HierarchicalFormatter v, v;
oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter v;
int v;
java.lang.Integer v;
v := @this: oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter;
v := @parameter: oadd.org.apache.drill.exec.vector.accessor.impl.HierarchicalFormatter;
interfaceinvoke v.<oadd.org.apache.drill.exec.vector.accessor.impl.HierarchicalFormatter: void extend()>();
specialinvoke v.<oadd.org.apache.drill.exec.vector.accessor.writer.BaseScalarWriter: void dump(oadd.org.apache.drill.exec.vector.accessor.impl.HierarchicalFormatter)>(v);
v = v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: int lastWriteIndex>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = interfaceinvoke v.<oadd.org.apache.drill.exec.vector.accessor.impl.HierarchicalFormatter: oadd.org.apache.drill.exec.vector.accessor.impl.HierarchicalFormatter attribute(java.lang.String,java.lang.Object)>("lastWriteIndex", v);
interfaceinvoke v.<oadd.org.apache.drill.exec.vector.accessor.impl.HierarchicalFormatter: oadd.org.apache.drill.exec.vector.accessor.impl.HierarchicalFormatter endObject()>();
return;
}
}