Skip to content
Closed
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
add missing methods
  • Loading branch information
kiszk committed Aug 7, 2017
commit bb4729901338b16e5f79f1bf07100bfa367d5891
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,7 @@ public final class OnHeapCachedBatch extends ColumnVector implements java.io.Ser
private transient UnsafeRowWriter rowWriter;
private transient MutableUnsafeRow mutableRow;

// accesssor for a column
// accessor for a column
private transient ColumnAccessor columnAccessor;

// an accessor uses only column 0
Expand Down Expand Up @@ -170,6 +170,11 @@ public boolean getBoolean(int rowId) {
return unsafeRow.getBoolean(ORDINAL);
}

@Override
public boolean[] getBooleans(int rowId, int count) {
throw new UnsupportedOperationException();
}

//

//
Expand Down Expand Up @@ -197,6 +202,11 @@ public byte getByte(int rowId) {
return unsafeRow.getByte(ORDINAL);
}

@Override
public byte[] getBytes(int rowId, int count) {
throw new UnsupportedOperationException();
}

//
// APIs dealing with Shorts
//
Expand All @@ -222,6 +232,10 @@ public short getShort(int rowId) {
return unsafeRow.getShort(ORDINAL);
}

@Override
public short[] getShorts(int rowId, int count) {
throw new UnsupportedOperationException();
}

//
// APIs dealing with Ints
Expand Down Expand Up @@ -253,6 +267,11 @@ public int getInt(int rowId) {
return unsafeRow.getInt(ORDINAL);
}

@Override
public int[] getInts(int rowId, int count) {
throw new UnsupportedOperationException();
}

/**
* Returns the dictionary Id for rowId.
* This should only be called when the ColumnVector is dictionaryIds.
Expand Down Expand Up @@ -292,6 +311,11 @@ public long getLong(int rowId) {
return unsafeRow.getLong(ORDINAL);
}

@Override
public long[] getLongs(int rowId, int count) {
throw new UnsupportedOperationException();
}

//
// APIs dealing with floats
//
Expand Down Expand Up @@ -322,6 +346,11 @@ public float getFloat(int rowId) {
return unsafeRow.getFloat(ORDINAL);
}

@Override
public float[] getFloats(int rowId, int count) {
throw new UnsupportedOperationException();
}

//
// APIs dealing with doubles
//
Expand Down Expand Up @@ -352,6 +381,11 @@ public double getDouble(int rowId) {
return unsafeRow.getDouble(ORDINAL);
}

@Override
public double[] getDoubles(int rowId, int count) {
throw new UnsupportedOperationException();
}

//
// APIs dealing with Arrays
//
Expand Down