Skip to content

Commit

Permalink
lint
Browse files Browse the repository at this point in the history
  • Loading branch information
cashmand committed Nov 7, 2024
1 parent af8e8ce commit cae6dbc
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -50,7 +50,7 @@ public String toString() {
}
}

public static abstract class ScalarType {
public abstract static class ScalarType {
}

public static final class StringType extends ScalarType {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -18,13 +18,8 @@
package org.apache.spark.types.variant;

import java.math.BigDecimal;
import java.math.BigInteger;
import java.math.RoundingMode;
import java.util.ArrayList;
import java.util.List;
import java.util.HashSet;
import java.util.Map;
import java.util.Set;

/**
* Class to implement shredding a Variant value.
Expand Down Expand Up @@ -96,13 +91,15 @@ public static ShreddedResult castShredded(
Integer fieldIdx = schema.objectSchemaMap.get(field.key);
if (fieldIdx != null) {
// The field exists in the shredding schema. Recursively shred, and write the result.
ShreddedResult shreddedField = castShredded(field.value, objectSchema[fieldIdx].schema, builder);
ShreddedResult shreddedField = castShredded(
field.value, objectSchema[fieldIdx].schema, builder);
shreddedValues[fieldIdx] = shreddedField;
numFieldsMatched++;
} else {
// The field is not shredded. Put it in the untyped_value column.
int id = v.getDictionaryIdAtIndex(i);
fieldEntries.add(new VariantBuilder.FieldEntry(field.key, id, variantBuilder.getWritePos() - start));
fieldEntries.add(new VariantBuilder.FieldEntry(
field.key, id, variantBuilder.getWritePos() - start));
variantBuilder.appendVariant(field.value);
}
}
Expand Down

0 comments on commit cae6dbc

Please sign in to comment.