Skip to content

Commit 2145574

Browse files
author
Julien Ruaux
committed
Removed unused class
1 parent 3f475fc commit 2145574

File tree

2 files changed

+2
-31
lines changed

2 files changed

+2
-31
lines changed

subprojects/trino-redisearch/src/main/java/com/redis/trino/RediSearchPageSourceResultWriter.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
11
package com.redis.trino;
22

3-
import static com.redis.trino.TypeUtils.isJsonType;
43
import static io.airlift.slice.Slices.utf8Slice;
54
import static io.trino.plugin.base.util.JsonTypeUtil.jsonParse;
65
import static io.trino.spi.StandardErrorCode.GENERIC_INTERNAL_ERROR;
@@ -13,6 +12,7 @@
1312
import static io.trino.spi.type.IntegerType.INTEGER;
1413
import static io.trino.spi.type.RealType.REAL;
1514
import static io.trino.spi.type.SmallintType.SMALLINT;
15+
import static io.trino.spi.type.StandardTypes.JSON;
1616
import static io.trino.spi.type.TimeZoneKey.UTC_KEY;
1717
import static io.trino.spi.type.TimestampType.TIMESTAMP_MILLIS;
1818
import static io.trino.spi.type.TimestampWithTimeZoneType.TIMESTAMP_TZ_MILLIS;
@@ -91,7 +91,7 @@ private void writeSlice(BlockBuilder output, Type type, String value) {
9191
type.writeSlice(output, truncateToLengthAndTrimSpaces(utf8Slice(value), ((CharType) type)));
9292
} else if (type instanceof DecimalType) {
9393
type.writeObject(output, encodeScaledValue(new BigDecimal(value), ((DecimalType) type).getScale()));
94-
} else if (isJsonType(type)) {
94+
} else if (type.getBaseName().equals(JSON)) {
9595
type.writeSlice(output, jsonParse(utf8Slice(value)));
9696
} else {
9797
throw new TrinoException(GENERIC_INTERNAL_ERROR, "Unhandled type for Slice: " + type.getTypeSignature());

subprojects/trino-redisearch/src/main/java/com/redis/trino/TypeUtils.java

Lines changed: 0 additions & 29 deletions
This file was deleted.

0 commit comments

Comments
 (0)