Skip to content

Commit

Permalink
More PR comments
Browse files Browse the repository at this point in the history
  • Loading branch information
jon-wei committed Dec 11, 2023
1 parent 998898e commit b169246
Showing 1 changed file with 0 additions and 23 deletions.
23 changes: 0 additions & 23 deletions server/src/main/java/org/apache/druid/catalog/model/Columns.java
Original file line number Diff line number Diff line change
Expand Up @@ -20,16 +20,13 @@
package org.apache.druid.catalog.model;

import com.google.common.collect.ImmutableMap;
import com.google.common.collect.ImmutableSet;
import org.apache.druid.java.util.common.IAE;
import org.apache.druid.java.util.common.StringUtils;
import org.apache.druid.segment.column.ColumnType;
import org.apache.druid.segment.column.RowSignature;
import org.apache.druid.segment.column.ValueType;

import java.util.List;
import java.util.Map;
import java.util.Set;

public class Columns
{
Expand All @@ -50,11 +47,6 @@ public class Columns
public static final String SQL_DOUBLE_ARRAY = "DOUBLE ARRAY";
public static final String SQL_TIMESTAMP = "TIMESTAMP";

public static final Set<String> NUMERIC_TYPES =
ImmutableSet.of(LONG, FLOAT, DOUBLE);
public static final Set<String> SCALAR_TYPES =
ImmutableSet.of(STRING, LONG, FLOAT, DOUBLE);

public static final Map<String, ColumnType> SQL_TO_DRUID_TYPES =
new ImmutableMap.Builder<String, ColumnType>()
.put(SQL_TIMESTAMP, ColumnType.LONG)
Expand Down Expand Up @@ -84,11 +76,6 @@ private Columns()
{
}

public static boolean isScalar(String type)
{
return SCALAR_TYPES.contains(StringUtils.toUpperCase(type.trim()));
}

public static ColumnType druidType(ColumnSpec spec)
{
if (isTimeColumn(spec.name())) {
Expand Down Expand Up @@ -118,16 +105,6 @@ public static String sqlType(ColumnSpec spec)
return sqlType == null ? druidType.asTypeString() : sqlType;
}

public static void validateScalarColumn(String name, String type)
{
if (type == null) {
return;
}
if (!Columns.isScalar(type)) {
throw new IAE("Not a supported Druid type: " + type);
}
}

public static boolean isTimeColumn(String name)
{
return TIME_COLUMN.equals(name);
Expand Down

0 comments on commit b169246

Please sign in to comment.