public class oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl extends oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter implements oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriter
{
private static final int VALUE_WIDTH;
private final oadd.org.apache.drill.exec.vector.UInt4Vector vector;
private int rowStartOffset;
protected int nextOffset;
public void <init>(oadd.org.apache.drill.exec.vector.UInt4Vector)
{
oadd.org.apache.drill.exec.vector.UInt4Vector v;
oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl v;
v := @this: oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl;
v := @parameter: oadd.org.apache.drill.exec.vector.UInt4Vector;
specialinvoke v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: void <init>()>();
v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: oadd.org.apache.drill.exec.vector.UInt4Vector vector> = v;
return;
}
public oadd.org.apache.drill.exec.vector.BaseDataValueVector vector()
{
oadd.org.apache.drill.exec.vector.UInt4Vector v;
oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl v;
v := @this: oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl;
v = v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: oadd.org.apache.drill.exec.vector.UInt4Vector vector>;
return v;
}
public int width()
{
oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl v;
v := @this: oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl;
return 4;
}
protected void realloc(int)
{
int v;
oadd.org.apache.drill.exec.vector.UInt4Vector v;
oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl v;
v := @this: oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl;
v := @parameter: int;
v = v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: oadd.org.apache.drill.exec.vector.UInt4Vector vector>;
virtualinvoke v.<oadd.org.apache.drill.exec.vector.UInt4Vector: oadd.io.netty.buffer.DrillBuf reallocRaw(int)>(v);
virtualinvoke v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: void setBuffer()>();
return;
}
public oadd.org.apache.drill.exec.vector.accessor.ValueType valueType()
{
oadd.org.apache.drill.exec.vector.accessor.ValueType v;
oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl v;
v := @this: oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl;
v = <oadd.org.apache.drill.exec.vector.accessor.ValueType: oadd.org.apache.drill.exec.vector.accessor.ValueType INTEGER>;
return v;
}
public void startWrite()
{
oadd.io.netty.buffer.DrillBuf v;
int v, v;
oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl v;
v := @this: oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl;
specialinvoke v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: void startWrite()>();
v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: int nextOffset> = 0;
v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: int rowStartOffset> = 0;
v = v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: int capacity>;
v = v * 4;
if v >= 256 goto label;
virtualinvoke v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: void realloc(int)>(256);
label:
v = v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: oadd.io.netty.buffer.DrillBuf drillBuf>;
virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.ByteBuf setInt(int,int)>(0, 0);
return;
}
public int nextOffset()
{
int v;
oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl v;
v := @this: oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl;
v = v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: int nextOffset>;
return v;
}
public int rowStartOffset()
{
int v;
oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl v;
v := @this: oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl;
v = v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: int rowStartOffset>;
return v;
}
public void startRow()
{
int v;
oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl v;
v := @this: oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl;
v = v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: int nextOffset>;
v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: int rowStartOffset> = v;
return;
}
protected final int prepareWrite()
{
int v, v, v, v, v;
oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl v;
v := @this: oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl;
v = virtualinvoke v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: int prepareFill()>();
v = v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: int lastWriteIndex>;
v = v - v;
v = v - 1;
if v <= 0 goto label;
virtualinvoke v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: void fillEmpties(int)>(v);
label:
v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: int lastWriteIndex> = v;
v = v + 1;
return v;
}
public final int prepareFill()
{
oadd.org.apache.drill.exec.vector.accessor.ColumnWriterIndex v, v;
int v, v, v, v, v;
oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl v;
v := @this: oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl;
v = v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: 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 = v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: int capacity>;
if v >= v goto label;
return v;
label:
v = v + 1;
virtualinvoke v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: int resize(int)>(v);
v = v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: oadd.org.apache.drill.exec.vector.accessor.ColumnWriterIndex vectorIndex>;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.vector.accessor.ColumnWriterIndex: int vectorIndex()>();
return v;
}
protected final void fillEmpties(int)
{
int v, v, v;
oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl v;
v := @this: oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl;
v := @parameter: int;
v = 0;
label:
if v >= v goto label;
v = v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: int nextOffset>;
virtualinvoke v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: void fillOffset(int)>(v);
v = v + 1;
goto label;
label:
return;
}
public final void setNextOffset(int)
{
oadd.io.netty.buffer.DrillBuf v;
int v, v, v;
oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl v;
v := @this: oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl;
v := @parameter: int;
v = virtualinvoke v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: int prepareWrite()>();
v = v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: oadd.io.netty.buffer.DrillBuf drillBuf>;
v = v * 4;
virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.ByteBuf setInt(int,int)>(v, v);
v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: int nextOffset> = v;
return;
}
public final void reviseOffset(int)
{
oadd.org.apache.drill.exec.vector.accessor.ColumnWriterIndex v;
oadd.io.netty.buffer.DrillBuf v;
int v, v, v, v;
oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl v;
v := @this: oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl;
v := @parameter: int;
v = v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: 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 = v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: oadd.io.netty.buffer.DrillBuf drillBuf>;
v = v * 4;
virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.ByteBuf setInt(int,int)>(v, v);
v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: int nextOffset> = v;
return;
}
public final void fillOffset(int)
{
oadd.io.netty.buffer.DrillBuf v;
int v, v, v, v, v;
oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl v;
v := @this: oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl;
v := @parameter: int;
v = v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: oadd.io.netty.buffer.DrillBuf drillBuf>;
v = v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: int lastWriteIndex>;
v = v + 1;
v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: int lastWriteIndex> = v;
v = v + 1;
v = v * 4;
virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.ByteBuf setInt(int,int)>(v, v);
v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: int nextOffset> = v;
return;
}
public final void setValue(java.lang.Object)
{
oadd.org.apache.drill.exec.vector.accessor.InvalidConversionError v;
java.lang.Object v;
java.lang.String v;
oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl v;
v := @this: oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl;
v := @parameter: java.lang.Object;
v = new oadd.org.apache.drill.exec.vector.accessor.InvalidConversionError;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Object)>(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[])>("setValue() not supported for the offset vector writer: \u0001");
specialinvoke v.<oadd.org.apache.drill.exec.vector.accessor.InvalidConversionError: void <init>(java.lang.String)>(v);
throw v;
}
public void skipNulls()
{
oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl v;
v := @this: oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl;
return;
}
public void restartRow()
{
int v;
oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl v;
v := @this: oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl;
v = v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: int rowStartOffset>;
v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: int nextOffset> = v;
specialinvoke v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: void restartRow()>();
return;
}
public void preRollover()
{
int v;
oadd.org.apache.drill.exec.vector.accessor.ColumnWriterIndex v;
oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl v;
v := @this: oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl;
v = v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: 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.OffsetVectorWriterImpl: void setValueCount(int)>(v);
return;
}
public void postRollover()
{
int v, v, v;
oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl v;
v := @this: oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl;
v = v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: int nextOffset>;
v = v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: int rowStartOffset>;
v = v - v;
specialinvoke v.<oadd.org.apache.drill.exec.vector.accessor.writer.AbstractFixedWidthWriter: void postRollover()>();
v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: int nextOffset> = v;
return;
}
public void setValueCount(int)
{
oadd.org.apache.drill.exec.vector.BaseDataValueVector v, v;
oadd.io.netty.buffer.DrillBuf v, v;
int v, v, v, v, v, v;
oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl v;
v := @this: oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl;
v := @parameter: int;
if v != 0 goto label;
v = virtualinvoke v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: oadd.org.apache.drill.exec.vector.BaseDataValueVector vector()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.vector.BaseDataValueVector: oadd.io.netty.buffer.DrillBuf getBuffer()>();
virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.ByteBuf writerIndex(int)>(0);
goto label;
label:
v = v + 1;
virtualinvoke v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: void mandatoryResize(int)>(v);
v = v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: int lastWriteIndex>;
v = v - v;
v = v - 1;
virtualinvoke v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: void fillEmpties(int)>(v);
v = virtualinvoke v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: 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 = v * 4;
virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.ByteBuf writerIndex(int)>(v);
label:
return;
}
public void dump(oadd.org.apache.drill.exec.vector.accessor.impl.HierarchicalFormatter)
{
oadd.org.apache.drill.exec.vector.accessor.impl.HierarchicalFormatter v, v, v;
java.lang.Integer v, v;
int v, v;
oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl v;
v := @this: oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl;
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.AbstractFixedWidthWriter: void dump(oadd.org.apache.drill.exec.vector.accessor.impl.HierarchicalFormatter)>(v);
v = v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: 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);
v = v.<oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl: int nextOffset>;
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)>("nextOffset", v);
interfaceinvoke v.<oadd.org.apache.drill.exec.vector.accessor.impl.HierarchicalFormatter: oadd.org.apache.drill.exec.vector.accessor.impl.HierarchicalFormatter endObject()>();
return;
}
public void setDefaultValue(java.lang.Object)
{
java.lang.UnsupportedOperationException v;
java.lang.Object v;
oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl v;
v := @this: oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl;
v := @parameter: java.lang.Object;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>("Encoding not supported for offset vectors");
throw v;
}
public void copy(oadd.org.apache.drill.exec.vector.accessor.ColumnReader)
{
java.lang.UnsupportedOperationException v;
oadd.org.apache.drill.exec.vector.accessor.ColumnReader v;
oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl v;
v := @this: oadd.org.apache.drill.exec.vector.accessor.writer.OffsetVectorWriterImpl;
v := @parameter: oadd.org.apache.drill.exec.vector.accessor.ColumnReader;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>("Copying of offset vectors not supported");
throw v;
}
}