Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
wg1026688210 committed Jun 7, 2024
1 parent b9f89c5 commit ecf7809
Show file tree
Hide file tree
Showing 3 changed files with 14 additions and 13 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -209,7 +209,7 @@ static ValueSetter createValueSetter(DataType elementType) {
}
}

static ValueSetter createValueSetter(DataType elementType,Serializer<?> serializer) {
static ValueSetter createValueSetter(DataType elementType, Serializer<?> serializer) {
// ordered by type root definition
switch (elementType.getTypeRoot()) {
case CHAR:
Expand Down Expand Up @@ -246,9 +246,7 @@ static ValueSetter createValueSetter(DataType elementType,Serializer<?> serializ
case ARRAY:
return (writer, pos, value) ->
writer.writeArray(
pos,
(InternalArray) value,
(InternalArraySerializer) serializer);
pos, (InternalArray) value, (InternalArraySerializer) serializer);
case MULTISET:
case MAP:
return (writer, pos, value) ->
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -73,7 +73,7 @@ public InternalRowSerializer(DataType[] types, Serializer<?>[] fieldSerializers)
for (int i = 0; i < types.length; i++) {
DataType type = types[i];
fieldGetters[i] = InternalRow.createFieldGetter(type, i);
valueSetters[i] = BinaryWriter.createValueSetter(type,this);
valueSetters[i] = BinaryWriter.createValueSetter(type, this);
}
}

Expand Down
Loading

0 comments on commit ecf7809

Please sign in to comment.