diff --git a/plugin/trino-mongodb/src/main/java/io/trino/plugin/mongodb/MongoIndex.java b/plugin/trino-mongodb/src/main/java/io/trino/plugin/mongodb/MongoIndex.java index b357bff4a75b..1f7bd5626a52 100644 --- a/plugin/trino-mongodb/src/main/java/io/trino/plugin/mongodb/MongoIndex.java +++ b/plugin/trino-mongodb/src/main/java/io/trino/plugin/mongodb/MongoIndex.java @@ -26,9 +26,7 @@ public class MongoIndex { - private final String name; private final List keys; - private final boolean unique; public static List parse(ListIndexesIterable indexes) { @@ -36,13 +34,11 @@ public static List parse(ListIndexesIterable indexes) for (Document index : indexes) { // TODO: v, ns, sparse fields Document key = (Document) index.get("key"); - String name = index.getString("name"); - boolean unique = index.getBoolean("unique", false); if (key.containsKey("_fts")) { // Full Text Search continue; } - builder.add(new MongoIndex(name, parseKey(key), unique)); + builder.add(new MongoIndex(parseKey(key))); } return builder.build(); @@ -70,16 +66,9 @@ else if (value instanceof String) { return builder.build(); } - public MongoIndex(String name, List keys, boolean unique) + public MongoIndex(List keys) { - this.name = name; this.keys = keys; - this.unique = unique; - } - - public String getName() - { - return name; } public List getKeys() @@ -87,11 +76,6 @@ public List getKeys() return keys; } - public boolean isUnique() - { - return unique; - } - public static class MongodbIndexKey { private final String name; diff --git a/plugin/trino-mongodb/src/main/java/io/trino/plugin/mongodb/MongoPageSource.java b/plugin/trino-mongodb/src/main/java/io/trino/plugin/mongodb/MongoPageSource.java index 8d621cdcd9b3..ca8b2217e0f6 100644 --- a/plugin/trino-mongodb/src/main/java/io/trino/plugin/mongodb/MongoPageSource.java +++ b/plugin/trino-mongodb/src/main/java/io/trino/plugin/mongodb/MongoPageSource.java @@ -13,14 +13,11 @@ */ package io.trino.plugin.mongodb; -import com.fasterxml.jackson.core.JsonFactory; -import com.fasterxml.jackson.core.JsonGenerator; import com.google.common.primitives.Shorts; import com.google.common.primitives.SignedBytes; import com.mongodb.DBRef; import com.mongodb.client.MongoCursor; import io.airlift.slice.Slice; -import io.airlift.slice.SliceOutput; import io.trino.spi.Page; import io.trino.spi.PageBuilder; import io.trino.spi.TrinoException; @@ -41,8 +38,6 @@ import org.bson.types.ObjectId; import org.joda.time.chrono.ISOChronology; -import java.io.IOException; -import java.io.OutputStream; import java.math.BigDecimal; import java.util.ArrayList; import java.util.Collection; @@ -275,12 +270,6 @@ else if (isJsonType(type)) { } } - public static JsonGenerator createJsonGenerator(JsonFactory factory, SliceOutput output) - throws IOException - { - return factory.createGenerator((OutputStream) output); - } - private void writeBlock(BlockBuilder output, Type type, Object value) { if (isArrayType(type)) { diff --git a/plugin/trino-mongodb/src/test/java/io/trino/plugin/mongodb/MongoQueryRunner.java b/plugin/trino-mongodb/src/test/java/io/trino/plugin/mongodb/MongoQueryRunner.java index 4ef0fb6d5da7..846ba23bf818 100644 --- a/plugin/trino-mongodb/src/test/java/io/trino/plugin/mongodb/MongoQueryRunner.java +++ b/plugin/trino-mongodb/src/test/java/io/trino/plugin/mongodb/MongoQueryRunner.java @@ -13,7 +13,6 @@ */ package io.trino.plugin.mongodb; -import com.google.common.collect.ImmutableList; import com.google.common.collect.ImmutableMap; import com.mongodb.client.MongoClient; import com.mongodb.client.MongoClients; @@ -39,12 +38,6 @@ public final class MongoQueryRunner private MongoQueryRunner() {} - public static DistributedQueryRunner createMongoQueryRunner(MongoServer server, TpchTable... tables) - throws Exception - { - return createMongoQueryRunner(server, ImmutableMap.of(), ImmutableList.copyOf(tables)); - } - public static DistributedQueryRunner createMongoQueryRunner(MongoServer server, Map extraProperties, Iterable> tables) throws Exception {