Skip to content

Commit

Permalink
Refactor the columnar related code (#1696)
Browse files Browse the repository at this point in the history
- Refactor ColumnarData and ColumnarDataBuilder.
- Remove redundant code.

Fixes #1698

Signed-off-by: vegetableysm <[email protected]>
  • Loading branch information
vegetableysm authored Dec 28, 2023
1 parent d4f820d commit 7575eee
Show file tree
Hide file tree
Showing 3 changed files with 306 additions and 1,012 deletions.
Original file line number Diff line number Diff line change
@@ -0,0 +1,61 @@
/** Copyright 2020-2023 Alibaba Group Holding Limited.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package io.v6d.modules.basic.columnar;

import org.apache.arrow.vector.FieldVector;

class ArrowFieldVectorAccessor {
public final FieldVector accessor;

ArrowFieldVectorAccessor(FieldVector vector) {
this.accessor = vector;
}

public final FieldVector getVector() {
return accessor;
}

final boolean isNullAt(int rowId) {
return accessor.isNull(rowId);
}

final int getNullCount() {
return accessor.getNullCount();
}

final int getValueCount() {
return accessor.getValueCount();
}

final void close() {
accessor.close();
}

Object getObject(int rowId) {
throw new UnsupportedOperationException();
}

void setSafe(int rowId, Object value) {
if (value == null) {
this.accessor.setNull(rowId);
} else {
this.setObject(rowId, value);
}
}

void setObject(int rowId, Object value) {
throw new UnsupportedOperationException();
}
}
Loading

0 comments on commit 7575eee

Please sign in to comment.