diff --git a/hetu-carbondata/pom.xml b/hetu-carbondata/pom.xml index 32eab6502..841dd8be4 100755 --- a/hetu-carbondata/pom.xml +++ b/hetu-carbondata/pom.xml @@ -717,12 +717,40 @@ hadoop-yarn-api ${hadoop.version} runtime + + + javax.xml.bind + jaxb-api + + + com.google.protobuf + protobuf-java + + + commons-logging + commons-logging + + org.apache.hadoop hadoop-yarn-client ${hadoop.version} runtime + + + log4j + log4j + + + commons-logging + commons-logging + + + commons-cli + commons-cli + + org.apache.hadoop @@ -734,6 +762,78 @@ jetty-util org.eclipse.jetty + + zookeeper + org.apache.zookeeper + + + * + org.apache.kerby + + + json-smart + net.minidev + + + * + com.sun.jersey + + + jersey-guice + com.sun.jersey.contribs + + + slf4j-log4j12 + org.slf4j + + + * + com.fasterxml.jackson.module + + + * + com.fasterxml.jackson.jaxrs + + + * + com.fasterxml.jackson.core + + + jaxb-api + javax.xml.bind + + + javax.servlet-api + javax.servlet + + + log4j + log4j + + + nimbus-jose-jwt + com.nimbusds + + + okhttp + com.squareup.okhttp + + + protobuf-java + com.google.protobuf + + + guice-servlet + com.google.inject.extensions + + + commons-logging + commons-logging + + + commons-cli + commons-cli + diff --git a/hetu-hazelcast/pom.xml b/hetu-hazelcast/pom.xml index d99b1c613..42cbedf53 100644 --- a/hetu-hazelcast/pom.xml +++ b/hetu-hazelcast/pom.xml @@ -17,7 +17,7 @@ ${project.parent.basedir} 4.0.3 1.9.4 - 5.2.0.RELEASE + 5.2.5.RELEASE 1.1.1 1.38 diff --git a/hetu-heuristic-index/pom.xml b/hetu-heuristic-index/pom.xml index ff125efe3..ac197f91f 100644 --- a/hetu-heuristic-index/pom.xml +++ b/hetu-heuristic-index/pom.xml @@ -39,7 +39,7 @@ org.apache.druid druid-core - 0.16.0-incubating + 0.19.0 netty-resolver @@ -137,12 +137,36 @@ async-http-client-netty-utils org.asynchttpclient + + jackson-core + com.fasterxml.jackson.core + + + jackson-annotations + com.fasterxml.jackson.core + + + jackson-datatype-guava + com.fasterxml.jackson.datatype + + + jackson-datatype-joda + com.fasterxml.jackson.datatype + + + jackson-dataformat-smile + com.fasterxml.jackson.dataformat + + + org.hibernate + hibernate-validator + org.apache.druid druid-processing - 0.16.0-incubating + 0.19.0 joda-time @@ -156,6 +180,30 @@ com.fasterxml.jackson.core jackson-databind + + jackson-core + com.fasterxml.jackson.core + + + jackson-annotations + com.fasterxml.jackson.core + + + jackson-datatype-guava + com.fasterxml.jackson.datatype + + + jackson-datatype-joda + com.fasterxml.jackson.datatype + + + jackson-dataformat-smile + com.fasterxml.jackson.dataformat + + + netty-common + io.netty + diff --git a/hetu-heuristic-index/src/main/java/io/hetu/core/plugin/heuristicindex/index/bitmap/BitMapIndex.java b/hetu-heuristic-index/src/main/java/io/hetu/core/plugin/heuristicindex/index/bitmap/BitMapIndex.java index 1137e7f77..04cc0b95b 100644 --- a/hetu-heuristic-index/src/main/java/io/hetu/core/plugin/heuristicindex/index/bitmap/BitMapIndex.java +++ b/hetu-heuristic-index/src/main/java/io/hetu/core/plugin/heuristicindex/index/bitmap/BitMapIndex.java @@ -27,6 +27,7 @@ import io.prestosql.spi.predicate.SortedRangeSet; import org.apache.commons.io.FileUtils; import org.apache.commons.io.IOUtils; import org.apache.druid.collections.bitmap.ImmutableBitmap; +import org.apache.druid.common.config.NullHandling; import org.apache.druid.data.input.MapBasedInputRow; import org.apache.druid.data.input.impl.DimensionsSpec; import org.apache.druid.data.input.impl.StringDimensionSchema; @@ -75,6 +76,7 @@ import java.nio.charset.StandardCharsets; import java.util.ArrayList; import java.util.Collections; import java.util.HashMap; +import java.util.HashSet; import java.util.Iterator; import java.util.LinkedHashMap; import java.util.List; @@ -101,6 +103,11 @@ import static java.util.stream.Collectors.toMap; public class BitMapIndex implements Index { + static + { + NullHandling.initializeForTests(); + } + static final int DEFAULT_EXPECTED_NUM_OF_SIZE = 200000; private static final Logger LOG = LoggerFactory.getLogger(BitMapIndex.class); private static final String COLUMN_NAME = "column"; @@ -449,10 +456,10 @@ public class BitMapIndex BitmapResultFactory bitmapResultFactory = new DefaultBitmapResultFactory(bitmapIndexSelector.getBitmapFactory()); if (filters.size() == 0) { - filters.add(new TrueFilter()); + filters.add(TrueFilter.instance()); } - ImmutableBitmap bm = AndFilter.getBitmapIndex(bitmapIndexSelector, bitmapResultFactory, filters); + ImmutableBitmap bm = AndFilter.getBitmapIndex(bitmapIndexSelector, bitmapResultFactory, new HashSet(filters)); if (lastBm == null) { lastBm = bm; diff --git a/hetu-hive-functions/pom.xml b/hetu-hive-functions/pom.xml index e8fd54e0b..649effc8e 100644 --- a/hetu-hive-functions/pom.xml +++ b/hetu-hive-functions/pom.xml @@ -118,6 +118,12 @@ io.prestosql.hive hive-apache + + + org.apache.thrift + libthrift + + io.prestosql.hadoop