diff --git a/itests/custom-serde/src/main/java/org/apache/hadoop/hive/serde2/CustomNonSettableUnionObjectInspector1.java b/itests/custom-serde/src/main/java/org/apache/hadoop/hive/serde2/CustomNonSettableUnionObjectInspector1.java index 61179ba294..3818003765 100644 --- a/itests/custom-serde/src/main/java/org/apache/hadoop/hive/serde2/CustomNonSettableUnionObjectInspector1.java +++ b/itests/custom-serde/src/main/java/org/apache/hadoop/hive/serde2/CustomNonSettableUnionObjectInspector1.java @@ -50,7 +50,7 @@ public Object getObject() { } @Override - public byte getTag() { + public int getTag() { return tag; } @@ -63,7 +63,7 @@ public String toString() { /** * Return the tag of the object. */ - public byte getTag(Object o) { + public int getTag(Object o) { if (o == null) { return -1; } diff --git a/itests/src/test/resources/testconfiguration.properties b/itests/src/test/resources/testconfiguration.properties index d6339f3ea7..d539654c3b 100644 --- a/itests/src/test/resources/testconfiguration.properties +++ b/itests/src/test/resources/testconfiguration.properties @@ -583,6 +583,7 @@ minillaplocal.query.files=\ csv_llap.q,\ default_constraint.q,\ disable_merge_for_bucketing.q,\ + count_dist_gt128.q,\ cross_prod_1.q,\ cross_prod_3.q,\ cross_prod_4.q,\ diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/ReduceSinkOperator.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/ReduceSinkOperator.java index 964c98dac2..b372170621 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/ReduceSinkOperator.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/ReduceSinkOperator.java @@ -413,13 +413,13 @@ private void populateCachedDistributionKeys(Object row) throws HiveException { private void populateCachedDistinctKeys(Object row, int index) throws HiveException { StandardUnion union; cachedKeys[index][numDistributionKeys] = union = new StandardUnion( - (byte)index, new Object[distinctColIndices.get(index).size()]); + index, new Object[distinctColIndices.get(index).size()]); Object[] distinctParameters = (Object[]) union.getObject(); for (int distinctParamI = 0; distinctParamI < distinctParameters.length; distinctParamI++) { distinctParameters[distinctParamI] = keyEval[distinctColIndices.get(index).get(distinctParamI)].evaluate(row); } - union.setTag((byte) index); + union.setTag(index); } protected final int computeMurmurHash(HiveKey firstKey) { diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorAssignRow.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorAssignRow.java index 19a3eedcb5..cce1e1dadc 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorAssignRow.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorAssignRow.java @@ -620,7 +620,7 @@ private void assignRowColumn( final UnionColumnVector unionColumnVector = (UnionColumnVector) columnVector; final UnionTypeInfo unionTypeInfo = (UnionTypeInfo) targetTypeInfo; final List objectTypeInfos = unionTypeInfo.getAllUnionObjectTypeInfos(); - final byte tag = union.getTag(); + final int tag = union.getTag(); unionColumnVector.tags[batchIndex] = tag; assignRowColumn(unionColumnVector.fields[tag], batchIndex, objectTypeInfos.get(tag), union.getObject()); } diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorDeserializeRow.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorDeserializeRow.java index 97166ec4db..423f70ff90 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorDeserializeRow.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorDeserializeRow.java @@ -1329,8 +1329,8 @@ private Object convertUnionRowColumn( final Object union = unionOI.create(); final int tag = deserializeRead.currentInt; - unionOI.setFieldAndTag(union, new StandardUnion((byte) tag, - convertComplexFieldRowColumn(unionColumnVector.fields[tag], batchIndex, fields[tag])), (byte) tag); + unionOI.setFieldAndTag(union, new StandardUnion(tag, + convertComplexFieldRowColumn(unionColumnVector.fields[tag], batchIndex, fields[tag])), tag); deserializeRead.finishComplexVariableFieldsType(); return union; } diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorExtractRow.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorExtractRow.java index e1482e077d..e188eacbe8 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorExtractRow.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorExtractRow.java @@ -454,7 +454,7 @@ public Object extractRowColumn( final UnionObjectInspector unionInspector = (UnionObjectInspector) objectInspector; final List unionInspectors = unionInspector.getObjectInspectors(); final UnionColumnVector unionColumnVector = (UnionColumnVector) colVector; - final byte tag = (byte) unionColumnVector.tags[adjustedIndex]; + final int tag = unionColumnVector.tags[adjustedIndex]; final Object object = extractRowColumn( unionColumnVector.fields[tag], objectTypeInfos.get(tag), diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/VectorExpressionWriterFactory.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/VectorExpressionWriterFactory.java index 163347febe..edd6fdb4f4 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/VectorExpressionWriterFactory.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/VectorExpressionWriterFactory.java @@ -1689,7 +1689,7 @@ public Object writeValue(ColumnVector column, int row) return null; } - unionOI.setFieldAndTag(obj, value, (byte) tag); + unionOI.setFieldAndTag(obj, value, tag); return obj; } @@ -1713,7 +1713,7 @@ public Object setValue(Object union, ColumnVector column, int row) return null; } - unionOI.setFieldAndTag(union, value, (byte) tag); + unionOI.setFieldAndTag(union, value, tag); return union; } }.init(fieldObjInspector); diff --git a/ql/src/java/org/apache/hadoop/hive/ql/io/BatchToRowReader.java b/ql/src/java/org/apache/hadoop/hive/ql/io/BatchToRowReader.java index 9d1d2608de..fd3e26669e 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/io/BatchToRowReader.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/io/BatchToRowReader.java @@ -124,7 +124,7 @@ public BatchToRowReader(RecordReader vrbReader protected abstract Object getStructCol(StructType structObj, int i); protected abstract int getStructLength(StructType structObj); protected abstract UnionType createUnionObject(List childrenTypes, Object previous); - protected abstract void setUnion(UnionType unionObj, byte tag, Object object); + protected abstract void setUnion(UnionType unionObj, int tag, Object object); protected abstract Object getUnionField(UnionType unionObj); protected abstract void populateRecordIdentifier(StructType o); @@ -519,7 +519,7 @@ private UnionType nextUnion( List childrenTypes = schema.getAllUnionObjectTypeInfos(); UnionType result = createUnionObject(childrenTypes, previous); UnionColumnVector union = (UnionColumnVector) vector; - byte tag = (byte) union.tags[row]; + int tag = union.tags[row]; setUnion(result, tag, nextValue(union.fields[tag], row, childrenTypes.get(tag), getUnionField(result))); return result; diff --git a/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcOiBatchToRowReader.java b/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcOiBatchToRowReader.java index bfd6eaeba1..2d1d6729fa 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcOiBatchToRowReader.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcOiBatchToRowReader.java @@ -83,7 +83,7 @@ protected Object getUnionField(OrcUnion unionObj) { } @Override - protected void setUnion(OrcUnion unionObj, byte tag, Object object) { + protected void setUnion(OrcUnion unionObj, int tag, Object object) { unionObj.set(tag, object); } diff --git a/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcUnion.java b/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcUnion.java index b87e00d007..a0fb42299c 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcUnion.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcUnion.java @@ -31,16 +31,16 @@ * An in-memory representation of a union type. */ final class OrcUnion implements UnionObject { - private byte tag; + private int tag; private Object object; - void set(byte tag, Object object) { + void set(int tag, Object object) { this.tag = tag; this.object = object; } @Override - public byte getTag() { + public int getTag() { return tag; } @@ -108,7 +108,7 @@ protected OrcUnionObjectInspector() { } @Override - public byte getTag(Object obj) { + public int getTag(Object obj) { return ((OrcUnion) obj).tag; } diff --git a/ql/src/java/org/apache/hadoop/hive/ql/io/orc/RecordReaderImpl.java b/ql/src/java/org/apache/hadoop/hive/ql/io/orc/RecordReaderImpl.java index d0a6c6e25a..0356d0663e 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/io/orc/RecordReaderImpl.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/io/orc/RecordReaderImpl.java @@ -507,7 +507,7 @@ static OrcUnion nextUnion(ColumnVector vector, result = (OrcUnion) previous; } UnionColumnVector union = (UnionColumnVector) vector; - byte tag = (byte) union.tags[row]; + int tag = union.tags[row]; result.set(tag, nextValue(union.fields[tag], row, childrenTypes.get(tag), result.getObject())); return result; diff --git a/ql/src/java/org/apache/hadoop/hive/ql/optimizer/calcite/rules/HiveExpandDistinctAggregatesRule.java b/ql/src/java/org/apache/hadoop/hive/ql/optimizer/calcite/rules/HiveExpandDistinctAggregatesRule.java index e8b2c37089..69681e96e0 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/optimizer/calcite/rules/HiveExpandDistinctAggregatesRule.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/optimizer/calcite/rules/HiveExpandDistinctAggregatesRule.java @@ -139,6 +139,10 @@ public void onMatch(RelOptRuleCall call) { Preconditions.checkArgument(argListSets.size() > 0, "containsDistinctCall lied"); if (numCountDistinct > 1 && numCountDistinct == aggregate.getAggCallList().size()) { + if (newGroupSet.cardinality() > Long.SIZE) { + // Currently grouping sets size cannot be greater than 64 + return; + } LOG.debug("Trigger countDistinct rewrite. numCountDistinct is " + numCountDistinct); // now positions contains all the distinct positions, i.e., $5, $4, $6 // we need to first sort them as group by set diff --git a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDFExtractUnion.java b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDFExtractUnion.java index 4783c5baba..dafa8d714d 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDFExtractUnion.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDFExtractUnion.java @@ -255,7 +255,7 @@ private Object convertStruct(Object struct, ObjectInspector inspector) { private Object convertUnion(Object union, ObjectInspector inspector) { UnionObjectInspector unionOI = (UnionObjectInspector) inspector; List childOIs = unionOI.getObjectInspectors(); - byte tag = unionOI.getTag(union); + int tag = unionOI.getTag(union); Object value = unionOI.getField(union); List result = new ArrayList<>(childOIs.size()); for (int i = 0; i < childOIs.size(); i++) { diff --git a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDFUnion.java b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDFUnion.java index 552887ee76..988ed63d29 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDFUnion.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDFUnion.java @@ -49,7 +49,7 @@ public ObjectInspector initialize(ObjectInspector[] arguments) @Override public Object evaluate(DeferredObject[] arguments) throws HiveException { - byte tag = (byte)((IntObjectInspector)tagOI).get(arguments[0].get()); + int tag = ((IntObjectInspector)tagOI).get(arguments[0].get()); return new StandardUnion(tag, arguments[tag + 1].get()); } diff --git a/ql/src/test/org/apache/hadoop/hive/ql/exec/vector/VectorRandomRowSource.java b/ql/src/test/org/apache/hadoop/hive/ql/exec/vector/VectorRandomRowSource.java index 1b6dbe48d8..84e53809b0 100644 --- a/ql/src/test/org/apache/hadoop/hive/ql/exec/vector/VectorRandomRowSource.java +++ b/ql/src/test/org/apache/hadoop/hive/ql/exec/vector/VectorRandomRowSource.java @@ -1644,7 +1644,7 @@ public static Object randomWritable(Random random, TypeInfo typeInfo, (StandardUnionObjectInspector) objectInspector; final List objectInspectorList = unionObjectInspector.getObjectInspectors(); final int unionCount = objectInspectorList.size(); - final byte tag = (byte) random.nextInt(unionCount); + final int tag = random.nextInt(unionCount); final ObjectInspector fieldObjectInspector = objectInspectorList.get(tag); final TypeInfo fieldTypeInfo = diff --git a/ql/src/test/org/apache/hadoop/hive/ql/exec/vector/VectorVerifyFast.java b/ql/src/test/org/apache/hadoop/hive/ql/exec/vector/VectorVerifyFast.java index a0ba0e1346..744e722b0d 100644 --- a/ql/src/test/org/apache/hadoop/hive/ql/exec/vector/VectorVerifyFast.java +++ b/ql/src/test/org/apache/hadoop/hive/ql/exec/vector/VectorVerifyFast.java @@ -501,7 +501,7 @@ public static void serializeWrite(SerializeWrite serializeWrite, List fieldTypeInfos = unionTypeInfo.getAllUnionObjectTypeInfos(); final int size = fieldTypeInfos.size(); StandardUnionObjectInspector.StandardUnion standardUnion = (StandardUnionObjectInspector.StandardUnion) object; - byte tag = standardUnion.getTag(); + int tag = standardUnion.getTag(); serializeWrite.beginUnion(tag); serializeWrite(serializeWrite, fieldTypeInfos.get(tag), standardUnion.getObject()); serializeWrite.finishUnion(); @@ -685,7 +685,7 @@ private static Object getComplexField(DeserializeRead deserializeRead, unionObj = null; } else { // Get the union value. - unionObj = new StandardUnionObjectInspector.StandardUnion((byte) tag, getComplexField(deserializeRead, unionTypeInfos.get(tag))); + unionObj = new StandardUnionObjectInspector.StandardUnion(tag, getComplexField(deserializeRead, unionTypeInfos.get(tag))); } } diff --git a/ql/src/test/org/apache/hadoop/hive/ql/exec/vector/mapjoin/fast/VerifyFastRow.java b/ql/src/test/org/apache/hadoop/hive/ql/exec/vector/mapjoin/fast/VerifyFastRow.java index 9615bf30ae..bb00162cc9 100644 --- a/ql/src/test/org/apache/hadoop/hive/ql/exec/vector/mapjoin/fast/VerifyFastRow.java +++ b/ql/src/test/org/apache/hadoop/hive/ql/exec/vector/mapjoin/fast/VerifyFastRow.java @@ -505,7 +505,7 @@ public static void serializeWrite(SerializeWrite serializeWrite, List fieldTypeInfos = unionTypeInfo.getAllUnionObjectTypeInfos(); final int size = fieldTypeInfos.size(); StandardUnionObjectInspector.StandardUnion standardUnion = (StandardUnionObjectInspector.StandardUnion) object; - byte tag = standardUnion.getTag(); + int tag = standardUnion.getTag(); serializeWrite.beginUnion(tag); serializeWrite(serializeWrite, fieldTypeInfos.get(tag), standardUnion.getObject()); serializeWrite.finishUnion(); @@ -689,7 +689,7 @@ private static Object getComplexField(DeserializeRead deserializeRead, unionObj = null; } else { // Get the union value. - unionObj = new StandardUnionObjectInspector.StandardUnion((byte) tag, getComplexField(deserializeRead, unionTypeInfos.get(tag))); + unionObj = new StandardUnionObjectInspector.StandardUnion(tag, getComplexField(deserializeRead, unionTypeInfos.get(tag))); } } diff --git a/ql/src/test/org/apache/hadoop/hive/ql/udf/generic/TestGenericUDFExtractUnion.java b/ql/src/test/org/apache/hadoop/hive/ql/udf/generic/TestGenericUDFExtractUnion.java index 0fcb341a3f..4269310850 100644 --- a/ql/src/test/org/apache/hadoop/hive/ql/udf/generic/TestGenericUDFExtractUnion.java +++ b/ql/src/test/org/apache/hadoop/hive/ql/udf/generic/TestGenericUDFExtractUnion.java @@ -86,7 +86,7 @@ public void evaluate_UnionAndTagArguments_MatchesTag() throws HiveException { PrimitiveObjectInspectorFactory.writableLongObjectInspector)); when(tagOI.getWritableConstantValue()).thenReturn(new IntWritable(0)); when(deferredObject.get()).thenReturn(value); - when(unionOI.getTag(value)).thenReturn((byte) 0); + when(unionOI.getTag(value)).thenReturn(0); when(unionOI.getField(value)).thenReturn("foo"); underTest.initialize(new ObjectInspector[] { unionOI, tagOI }); @@ -103,7 +103,7 @@ public void evaluate_UnionAndTagArguments_NotMatchesTag() throws HiveException { PrimitiveObjectInspectorFactory.writableLongObjectInspector)); when(tagOI.getWritableConstantValue()).thenReturn(new IntWritable(0)); when(deferredObject.get()).thenReturn(value); - when(unionOI.getTag(value)).thenReturn((byte) 1); + when(unionOI.getTag(value)).thenReturn(1); underTest.initialize(new ObjectInspector[] { unionOI, tagOI }); Object result = underTest.evaluate(new DeferredObject[] { deferredObject }); diff --git a/ql/src/test/org/apache/hadoop/hive/ql/udf/generic/TestGenericUDFExtractUnionValueConverter.java b/ql/src/test/org/apache/hadoop/hive/ql/udf/generic/TestGenericUDFExtractUnionValueConverter.java index 4189485dd0..5a1fe54a2f 100644 --- a/ql/src/test/org/apache/hadoop/hive/ql/udf/generic/TestGenericUDFExtractUnionValueConverter.java +++ b/ql/src/test/org/apache/hadoop/hive/ql/udf/generic/TestGenericUDFExtractUnionValueConverter.java @@ -43,7 +43,7 @@ PrimitiveObjectInspectorFactory.javaStringObjectInspector, PrimitiveObjectInspectorFactory.javaIntObjectInspector)); - private final Object union = new StandardUnion((byte) 0, "foo"); + private final Object union = new StandardUnion(0, "foo"); private final ValueConverter underTest = new ValueConverter(); diff --git a/ql/src/test/queries/clientpositive/count_dist_gt128.q b/ql/src/test/queries/clientpositive/count_dist_gt128.q new file mode 100644 index 0000000000..78525f9dc9 --- /dev/null +++ b/ql/src/test/queries/clientpositive/count_dist_gt128.q @@ -0,0 +1,609 @@ +CREATE TABLE `cdist_gt128_01`( + c1 int, + c2 int, + c3 int, + c4 int, + c5 int, + c6 int, + c7 int, + c8 int, + c9 int, + c10 int, + c11 int, + c12 int, + c13 int, + c14 int, + c15 int, + c16 int, + c17 int, + c18 int, + c19 int, + c20 int, + c21 int, + c22 int, + c23 int, + c24 int, + c25 int, + c26 int, + c27 int, + c28 int, + c29 int, + c30 int, + c31 int, + c32 int, + c33 int, + c34 int, + c35 int, + c36 int, + c37 int, + c38 int, + c39 int, + c40 int, + c41 int, + c42 int, + c43 int, + c44 int, + c45 int, + c46 int, + c47 int, + c48 int, + c49 int, + c50 int, + c51 int, + c52 int, + c53 int, + c54 int, + c55 int, + c56 int, + c57 int, + c58 int, + c59 int, + c60 int, + c61 int, + c62 int, + c63 int, + c64 int, + c65 int, + c66 int, + c67 int, + c68 int, + c69 int, + c70 int, + c71 int, + c72 int, + c73 int, + c74 int, + c75 int, + c76 int, + c77 int, + c78 int, + c79 int, + c80 int, + c81 int, + c82 int, + c83 int, + c84 int, + c85 int, + c86 int, + c87 int, + c88 int, + c89 int, + c90 int, + c91 int, + c92 int, + c93 int, + c94 int, + c95 int, + c96 int, + c97 int, + c98 int, + c99 int, + c100 int, + c101 int, + c102 int, + c103 int, + c104 int, + c105 int, + c106 int, + c107 int, + c108 int, + c109 int, + c110 int, + c111 int, + c112 int, + c113 int, + c114 int, + c115 int, + c116 int, + c117 int, + c118 int, + c119 int, + c120 int, + c121 int, + c122 int, + c123 int, + c124 int, + c125 int, + c126 int, + c127 int, + c128 int, + c129 int, + c130 int, + c131 int, + c132 int, + c133 int, + c134 int, + c135 int, + c136 int, + c137 int, + c138 int, + c139 int, + c140 int, + c141 int, + c142 int, + c143 int, + c144 int, + c145 int, + c146 int, + c147 int, + c148 int, + c149 int, + c150 int, + c151 int, + c152 int, + c153 int, + c154 int, + c155 int, + c156 int, + c157 int, + c158 int, + c159 int, + c160 int, + c161 int, + c162 int, + c163 int, + c164 int, + c165 int, + c166 int, + c167 int, + c168 int, + c169 int, + c170 int, + c171 int, + c172 int, + c173 int, + c174 int, + c175 int, + c176 int, + c177 int, + c178 int, + c179 int, + c180 int, + c181 int, + c182 int, + c183 int, + c184 int, + c185 int, + c186 int, + c187 int, + c188 int, + c189 int, + c190 int, + c191 int, + c192 int, + c193 int, + c194 int, + c195 int, + c196 int, + c197 int, + c198 int, + c199 int, + c200 int) +stored as parquet; + +INSERT INTO `cdist_gt128_01` VALUES ( + 1, + 2, + 3, + 4, + 5, + 6, + 7, + 8, + 9, + 10, + 11, + 12, + 13, + 14, + 15, + 16, + 17, + 18, + 19, + 20, + 21, + 22, + 23, + 24, + 25, + 26, + 27, + 28, + 29, + 30, + 31, + 32, + 33, + 34, + 35, + 36, + 37, + 38, + 39, + 40, + 41, + 42, + 43, + 44, + 45, + 46, + 47, + 48, + 49, + 50, + 51, + 52, + 53, + 54, + 55, + 56, + 57, + 58, + 59, + 60, + 61, + 62, + 63, + 64, + 65, + 66, + 67, + 68, + 69, + 70, + 71, + 72, + 73, + 74, + 75, + 76, + 77, + 78, + 79, + 80, + 81, + 82, + 83, + 84, + 85, + 86, + 87, + 88, + 89, + 90, + 91, + 92, + 93, + 94, + 95, + 96, + 97, + 98, + 99, + 100, + 101, + 102, + 103, + 104, + 105, + 106, + 107, + 108, + 109, + 110, + 111, + 112, + 113, + 114, + 115, + 116, + 117, + 118, + 119, + 120, + 121, + 122, + 123, + 124, + 125, + 126, + 127, + 128, + 129, + 130, + 131, + 132, + 133, + 134, + 135, + 136, + 137, + 138, + 139, + 140, + 141, + 142, + 143, + 144, + 145, + 146, + 147, + 148, + 149, + 150, + 151, + 152, + 153, + 154, + 155, + 156, + 157, + 158, + 159, + 160, + 161, + 162, + 163, + 164, + 165, + 166, + 167, + 168, + 169, + 170, + 171, + 172, + 173, + 174, + 175, + 176, + 177, + 178, + 179, + 180, + 181, + 182, + 183, + 184, + 185, + 186, + 187, + 188, + 189, + 190, + 191, + 192, + 193, + 194, + 195, + 196, + 197, + 198, + 199, + 200); + +SELECT + COUNT(DISTINCT c1), + COUNT(DISTINCT c2), + COUNT(DISTINCT c3), + COUNT(DISTINCT c4), + COUNT(DISTINCT c5), + COUNT(DISTINCT c6), + COUNT(DISTINCT c7), + COUNT(DISTINCT c8), + COUNT(DISTINCT c9), + COUNT(DISTINCT c10), + COUNT(DISTINCT c11), + COUNT(DISTINCT c12), + COUNT(DISTINCT c13), + COUNT(DISTINCT c14), + COUNT(DISTINCT c15), + COUNT(DISTINCT c16), + COUNT(DISTINCT c17), + COUNT(DISTINCT c18), + COUNT(DISTINCT c19), + COUNT(DISTINCT c20), + COUNT(DISTINCT c21), + COUNT(DISTINCT c22), + COUNT(DISTINCT c23), + COUNT(DISTINCT c24), + COUNT(DISTINCT c25), + COUNT(DISTINCT c26), + COUNT(DISTINCT c27), + COUNT(DISTINCT c28), + COUNT(DISTINCT c29), + COUNT(DISTINCT c30), + COUNT(DISTINCT c31), + COUNT(DISTINCT c32), + COUNT(DISTINCT c33), + COUNT(DISTINCT c34), + COUNT(DISTINCT c35), + COUNT(DISTINCT c36), + COUNT(DISTINCT c37), + COUNT(DISTINCT c38), + COUNT(DISTINCT c39), + COUNT(DISTINCT c40), + COUNT(DISTINCT c41), + COUNT(DISTINCT c42), + COUNT(DISTINCT c43), + COUNT(DISTINCT c44), + COUNT(DISTINCT c45), + COUNT(DISTINCT c46), + COUNT(DISTINCT c47), + COUNT(DISTINCT c48), + COUNT(DISTINCT c49), + COUNT(DISTINCT c50), + COUNT(DISTINCT c51), + COUNT(DISTINCT c52), + COUNT(DISTINCT c53), + COUNT(DISTINCT c54), + COUNT(DISTINCT c55), + COUNT(DISTINCT c56), + COUNT(DISTINCT c57), + COUNT(DISTINCT c58), + COUNT(DISTINCT c59), + COUNT(DISTINCT c60), + COUNT(DISTINCT c61), + COUNT(DISTINCT c62), + COUNT(DISTINCT c63), + COUNT(DISTINCT c64), + COUNT(DISTINCT c65), + COUNT(DISTINCT c66), + COUNT(DISTINCT c67), + COUNT(DISTINCT c68), + COUNT(DISTINCT c69), + COUNT(DISTINCT c70), + COUNT(DISTINCT c71), + COUNT(DISTINCT c72), + COUNT(DISTINCT c73), + COUNT(DISTINCT c74), + COUNT(DISTINCT c75), + COUNT(DISTINCT c76), + COUNT(DISTINCT c77), + COUNT(DISTINCT c78), + COUNT(DISTINCT c79), + COUNT(DISTINCT c80), + COUNT(DISTINCT c81), + COUNT(DISTINCT c82), + COUNT(DISTINCT c83), + COUNT(DISTINCT c84), + COUNT(DISTINCT c85), + COUNT(DISTINCT c86), + COUNT(DISTINCT c87), + COUNT(DISTINCT c88), + COUNT(DISTINCT c89), + COUNT(DISTINCT c90), + COUNT(DISTINCT c91), + COUNT(DISTINCT c92), + COUNT(DISTINCT c93), + COUNT(DISTINCT c94), + COUNT(DISTINCT c95), + COUNT(DISTINCT c96), + COUNT(DISTINCT c97), + COUNT(DISTINCT c98), + COUNT(DISTINCT c99), + COUNT(DISTINCT c100), + COUNT(DISTINCT c101), + COUNT(DISTINCT c102), + COUNT(DISTINCT c103), + COUNT(DISTINCT c104), + COUNT(DISTINCT c105), + COUNT(DISTINCT c106), + COUNT(DISTINCT c107), + COUNT(DISTINCT c108), + COUNT(DISTINCT c109), + COUNT(DISTINCT c110), + COUNT(DISTINCT c111), + COUNT(DISTINCT c112), + COUNT(DISTINCT c113), + COUNT(DISTINCT c114), + COUNT(DISTINCT c115), + COUNT(DISTINCT c116), + COUNT(DISTINCT c117), + COUNT(DISTINCT c118), + COUNT(DISTINCT c119), + COUNT(DISTINCT c120), + COUNT(DISTINCT c121), + COUNT(DISTINCT c122), + COUNT(DISTINCT c123), + COUNT(DISTINCT c124), + COUNT(DISTINCT c125), + COUNT(DISTINCT c126), + COUNT(DISTINCT c127), + COUNT(DISTINCT c128), + COUNT(DISTINCT c129), + COUNT(DISTINCT c130), + COUNT(DISTINCT c131), + COUNT(DISTINCT c132), + COUNT(DISTINCT c133), + COUNT(DISTINCT c134), + COUNT(DISTINCT c135), + COUNT(DISTINCT c136), + COUNT(DISTINCT c137), + COUNT(DISTINCT c138), + COUNT(DISTINCT c139), + COUNT(DISTINCT c140), + COUNT(DISTINCT c141), + COUNT(DISTINCT c142), + COUNT(DISTINCT c143), + COUNT(DISTINCT c144), + COUNT(DISTINCT c145), + COUNT(DISTINCT c146), + COUNT(DISTINCT c147), + COUNT(DISTINCT c148), + COUNT(DISTINCT c149), + COUNT(DISTINCT c150), + COUNT(DISTINCT c151), + COUNT(DISTINCT c152), + COUNT(DISTINCT c153), + COUNT(DISTINCT c154), + COUNT(DISTINCT c155), + COUNT(DISTINCT c156), + COUNT(DISTINCT c157), + COUNT(DISTINCT c158), + COUNT(DISTINCT c159), + COUNT(DISTINCT c160), + COUNT(DISTINCT c161), + COUNT(DISTINCT c162), + COUNT(DISTINCT c163), + COUNT(DISTINCT c164), + COUNT(DISTINCT c165), + COUNT(DISTINCT c166), + COUNT(DISTINCT c167), + COUNT(DISTINCT c168), + COUNT(DISTINCT c169), + COUNT(DISTINCT c170), + COUNT(DISTINCT c171), + COUNT(DISTINCT c172), + COUNT(DISTINCT c173), + COUNT(DISTINCT c174), + COUNT(DISTINCT c175), + COUNT(DISTINCT c176), + COUNT(DISTINCT c177), + COUNT(DISTINCT c178), + COUNT(DISTINCT c179), + COUNT(DISTINCT c180), + COUNT(DISTINCT c181), + COUNT(DISTINCT c182), + COUNT(DISTINCT c183), + COUNT(DISTINCT c184), + COUNT(DISTINCT c185), + COUNT(DISTINCT c186), + COUNT(DISTINCT c187), + COUNT(DISTINCT c188), + COUNT(DISTINCT c189), + COUNT(DISTINCT c190), + COUNT(DISTINCT c191), + COUNT(DISTINCT c192), + COUNT(DISTINCT c193), + COUNT(DISTINCT c194), + COUNT(DISTINCT c195), + COUNT(DISTINCT c196), + COUNT(DISTINCT c197), + COUNT(DISTINCT c198), + COUNT(DISTINCT c199), + COUNT(DISTINCT c200) +FROM `cdist_gt128_01`; + +DROP TABLE `cdist_gt128_01`; diff --git a/ql/src/test/results/clientpositive/llap/count_dist_gt128.q.out b/ql/src/test/results/clientpositive/llap/count_dist_gt128.q.out new file mode 100644 index 0000000000..fb828b19db --- /dev/null +++ b/ql/src/test/results/clientpositive/llap/count_dist_gt128.q.out @@ -0,0 +1,1437 @@ +PREHOOK: query: CREATE TABLE `cdist_gt128_01`( + c1 int, + c2 int, + c3 int, + c4 int, + c5 int, + c6 int, + c7 int, + c8 int, + c9 int, + c10 int, + c11 int, + c12 int, + c13 int, + c14 int, + c15 int, + c16 int, + c17 int, + c18 int, + c19 int, + c20 int, + c21 int, + c22 int, + c23 int, + c24 int, + c25 int, + c26 int, + c27 int, + c28 int, + c29 int, + c30 int, + c31 int, + c32 int, + c33 int, + c34 int, + c35 int, + c36 int, + c37 int, + c38 int, + c39 int, + c40 int, + c41 int, + c42 int, + c43 int, + c44 int, + c45 int, + c46 int, + c47 int, + c48 int, + c49 int, + c50 int, + c51 int, + c52 int, + c53 int, + c54 int, + c55 int, + c56 int, + c57 int, + c58 int, + c59 int, + c60 int, + c61 int, + c62 int, + c63 int, + c64 int, + c65 int, + c66 int, + c67 int, + c68 int, + c69 int, + c70 int, + c71 int, + c72 int, + c73 int, + c74 int, + c75 int, + c76 int, + c77 int, + c78 int, + c79 int, + c80 int, + c81 int, + c82 int, + c83 int, + c84 int, + c85 int, + c86 int, + c87 int, + c88 int, + c89 int, + c90 int, + c91 int, + c92 int, + c93 int, + c94 int, + c95 int, + c96 int, + c97 int, + c98 int, + c99 int, + c100 int, + c101 int, + c102 int, + c103 int, + c104 int, + c105 int, + c106 int, + c107 int, + c108 int, + c109 int, + c110 int, + c111 int, + c112 int, + c113 int, + c114 int, + c115 int, + c116 int, + c117 int, + c118 int, + c119 int, + c120 int, + c121 int, + c122 int, + c123 int, + c124 int, + c125 int, + c126 int, + c127 int, + c128 int, + c129 int, + c130 int, + c131 int, + c132 int, + c133 int, + c134 int, + c135 int, + c136 int, + c137 int, + c138 int, + c139 int, + c140 int, + c141 int, + c142 int, + c143 int, + c144 int, + c145 int, + c146 int, + c147 int, + c148 int, + c149 int, + c150 int, + c151 int, + c152 int, + c153 int, + c154 int, + c155 int, + c156 int, + c157 int, + c158 int, + c159 int, + c160 int, + c161 int, + c162 int, + c163 int, + c164 int, + c165 int, + c166 int, + c167 int, + c168 int, + c169 int, + c170 int, + c171 int, + c172 int, + c173 int, + c174 int, + c175 int, + c176 int, + c177 int, + c178 int, + c179 int, + c180 int, + c181 int, + c182 int, + c183 int, + c184 int, + c185 int, + c186 int, + c187 int, + c188 int, + c189 int, + c190 int, + c191 int, + c192 int, + c193 int, + c194 int, + c195 int, + c196 int, + c197 int, + c198 int, + c199 int, + c200 int) +stored as parquet +PREHOOK: type: CREATETABLE +PREHOOK: Output: database:default +PREHOOK: Output: default@cdist_gt128_01 +POSTHOOK: query: CREATE TABLE `cdist_gt128_01`( + c1 int, + c2 int, + c3 int, + c4 int, + c5 int, + c6 int, + c7 int, + c8 int, + c9 int, + c10 int, + c11 int, + c12 int, + c13 int, + c14 int, + c15 int, + c16 int, + c17 int, + c18 int, + c19 int, + c20 int, + c21 int, + c22 int, + c23 int, + c24 int, + c25 int, + c26 int, + c27 int, + c28 int, + c29 int, + c30 int, + c31 int, + c32 int, + c33 int, + c34 int, + c35 int, + c36 int, + c37 int, + c38 int, + c39 int, + c40 int, + c41 int, + c42 int, + c43 int, + c44 int, + c45 int, + c46 int, + c47 int, + c48 int, + c49 int, + c50 int, + c51 int, + c52 int, + c53 int, + c54 int, + c55 int, + c56 int, + c57 int, + c58 int, + c59 int, + c60 int, + c61 int, + c62 int, + c63 int, + c64 int, + c65 int, + c66 int, + c67 int, + c68 int, + c69 int, + c70 int, + c71 int, + c72 int, + c73 int, + c74 int, + c75 int, + c76 int, + c77 int, + c78 int, + c79 int, + c80 int, + c81 int, + c82 int, + c83 int, + c84 int, + c85 int, + c86 int, + c87 int, + c88 int, + c89 int, + c90 int, + c91 int, + c92 int, + c93 int, + c94 int, + c95 int, + c96 int, + c97 int, + c98 int, + c99 int, + c100 int, + c101 int, + c102 int, + c103 int, + c104 int, + c105 int, + c106 int, + c107 int, + c108 int, + c109 int, + c110 int, + c111 int, + c112 int, + c113 int, + c114 int, + c115 int, + c116 int, + c117 int, + c118 int, + c119 int, + c120 int, + c121 int, + c122 int, + c123 int, + c124 int, + c125 int, + c126 int, + c127 int, + c128 int, + c129 int, + c130 int, + c131 int, + c132 int, + c133 int, + c134 int, + c135 int, + c136 int, + c137 int, + c138 int, + c139 int, + c140 int, + c141 int, + c142 int, + c143 int, + c144 int, + c145 int, + c146 int, + c147 int, + c148 int, + c149 int, + c150 int, + c151 int, + c152 int, + c153 int, + c154 int, + c155 int, + c156 int, + c157 int, + c158 int, + c159 int, + c160 int, + c161 int, + c162 int, + c163 int, + c164 int, + c165 int, + c166 int, + c167 int, + c168 int, + c169 int, + c170 int, + c171 int, + c172 int, + c173 int, + c174 int, + c175 int, + c176 int, + c177 int, + c178 int, + c179 int, + c180 int, + c181 int, + c182 int, + c183 int, + c184 int, + c185 int, + c186 int, + c187 int, + c188 int, + c189 int, + c190 int, + c191 int, + c192 int, + c193 int, + c194 int, + c195 int, + c196 int, + c197 int, + c198 int, + c199 int, + c200 int) +stored as parquet +POSTHOOK: type: CREATETABLE +POSTHOOK: Output: database:default +POSTHOOK: Output: default@cdist_gt128_01 +PREHOOK: query: INSERT INTO `cdist_gt128_01` VALUES ( + 1, + 2, + 3, + 4, + 5, + 6, + 7, + 8, + 9, + 10, + 11, + 12, + 13, + 14, + 15, + 16, + 17, + 18, + 19, + 20, + 21, + 22, + 23, + 24, + 25, + 26, + 27, + 28, + 29, + 30, + 31, + 32, + 33, + 34, + 35, + 36, + 37, + 38, + 39, + 40, + 41, + 42, + 43, + 44, + 45, + 46, + 47, + 48, + 49, + 50, + 51, + 52, + 53, + 54, + 55, + 56, + 57, + 58, + 59, + 60, + 61, + 62, + 63, + 64, + 65, + 66, + 67, + 68, + 69, + 70, + 71, + 72, + 73, + 74, + 75, + 76, + 77, + 78, + 79, + 80, + 81, + 82, + 83, + 84, + 85, + 86, + 87, + 88, + 89, + 90, + 91, + 92, + 93, + 94, + 95, + 96, + 97, + 98, + 99, + 100, + 101, + 102, + 103, + 104, + 105, + 106, + 107, + 108, + 109, + 110, + 111, + 112, + 113, + 114, + 115, + 116, + 117, + 118, + 119, + 120, + 121, + 122, + 123, + 124, + 125, + 126, + 127, + 128, + 129, + 130, + 131, + 132, + 133, + 134, + 135, + 136, + 137, + 138, + 139, + 140, + 141, + 142, + 143, + 144, + 145, + 146, + 147, + 148, + 149, + 150, + 151, + 152, + 153, + 154, + 155, + 156, + 157, + 158, + 159, + 160, + 161, + 162, + 163, + 164, + 165, + 166, + 167, + 168, + 169, + 170, + 171, + 172, + 173, + 174, + 175, + 176, + 177, + 178, + 179, + 180, + 181, + 182, + 183, + 184, + 185, + 186, + 187, + 188, + 189, + 190, + 191, + 192, + 193, + 194, + 195, + 196, + 197, + 198, + 199, + 200) +PREHOOK: type: QUERY +PREHOOK: Input: _dummy_database@_dummy_table +PREHOOK: Output: default@cdist_gt128_01 +POSTHOOK: query: INSERT INTO `cdist_gt128_01` VALUES ( + 1, + 2, + 3, + 4, + 5, + 6, + 7, + 8, + 9, + 10, + 11, + 12, + 13, + 14, + 15, + 16, + 17, + 18, + 19, + 20, + 21, + 22, + 23, + 24, + 25, + 26, + 27, + 28, + 29, + 30, + 31, + 32, + 33, + 34, + 35, + 36, + 37, + 38, + 39, + 40, + 41, + 42, + 43, + 44, + 45, + 46, + 47, + 48, + 49, + 50, + 51, + 52, + 53, + 54, + 55, + 56, + 57, + 58, + 59, + 60, + 61, + 62, + 63, + 64, + 65, + 66, + 67, + 68, + 69, + 70, + 71, + 72, + 73, + 74, + 75, + 76, + 77, + 78, + 79, + 80, + 81, + 82, + 83, + 84, + 85, + 86, + 87, + 88, + 89, + 90, + 91, + 92, + 93, + 94, + 95, + 96, + 97, + 98, + 99, + 100, + 101, + 102, + 103, + 104, + 105, + 106, + 107, + 108, + 109, + 110, + 111, + 112, + 113, + 114, + 115, + 116, + 117, + 118, + 119, + 120, + 121, + 122, + 123, + 124, + 125, + 126, + 127, + 128, + 129, + 130, + 131, + 132, + 133, + 134, + 135, + 136, + 137, + 138, + 139, + 140, + 141, + 142, + 143, + 144, + 145, + 146, + 147, + 148, + 149, + 150, + 151, + 152, + 153, + 154, + 155, + 156, + 157, + 158, + 159, + 160, + 161, + 162, + 163, + 164, + 165, + 166, + 167, + 168, + 169, + 170, + 171, + 172, + 173, + 174, + 175, + 176, + 177, + 178, + 179, + 180, + 181, + 182, + 183, + 184, + 185, + 186, + 187, + 188, + 189, + 190, + 191, + 192, + 193, + 194, + 195, + 196, + 197, + 198, + 199, + 200) +POSTHOOK: type: QUERY +POSTHOOK: Input: _dummy_database@_dummy_table +POSTHOOK: Output: default@cdist_gt128_01 +POSTHOOK: Lineage: cdist_gt128_01.c1 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c10 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c100 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c101 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c102 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c103 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c104 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c105 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c106 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c107 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c108 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c109 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c11 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c110 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c111 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c112 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c113 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c114 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c115 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c116 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c117 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c118 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c119 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c12 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c120 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c121 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c122 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c123 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c124 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c125 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c126 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c127 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c128 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c129 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c13 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c130 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c131 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c132 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c133 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c134 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c135 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c136 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c137 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c138 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c139 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c14 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c140 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c141 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c142 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c143 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c144 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c145 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c146 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c147 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c148 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c149 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c15 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c150 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c151 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c152 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c153 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c154 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c155 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c156 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c157 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c158 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c159 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c16 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c160 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c161 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c162 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c163 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c164 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c165 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c166 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c167 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c168 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c169 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c17 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c170 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c171 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c172 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c173 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c174 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c175 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c176 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c177 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c178 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c179 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c18 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c180 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c181 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c182 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c183 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c184 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c185 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c186 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c187 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c188 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c189 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c19 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c190 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c191 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c192 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c193 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c194 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c195 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c196 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c197 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c198 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c199 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c2 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c20 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c200 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c21 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c22 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c23 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c24 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c25 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c26 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c27 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c28 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c29 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c3 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c30 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c31 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c32 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c33 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c34 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c35 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c36 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c37 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c38 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c39 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c4 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c40 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c41 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c42 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c43 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c44 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c45 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c46 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c47 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c48 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c49 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c5 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c50 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c51 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c52 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c53 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c54 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c55 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c56 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c57 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c58 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c59 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c6 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c60 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c61 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c62 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c63 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c64 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c65 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c66 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c67 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c68 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c69 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c7 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c70 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c71 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c72 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c73 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c74 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c75 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c76 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c77 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c78 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c79 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c8 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c80 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c81 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c82 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c83 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c84 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c85 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c86 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c87 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c88 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c89 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c9 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c90 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c91 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c92 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c93 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c94 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c95 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c96 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c97 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c98 SCRIPT [] +POSTHOOK: Lineage: cdist_gt128_01.c99 SCRIPT [] +PREHOOK: query: SELECT + COUNT(DISTINCT c1), + COUNT(DISTINCT c2), + COUNT(DISTINCT c3), + COUNT(DISTINCT c4), + COUNT(DISTINCT c5), + COUNT(DISTINCT c6), + COUNT(DISTINCT c7), + COUNT(DISTINCT c8), + COUNT(DISTINCT c9), + COUNT(DISTINCT c10), + COUNT(DISTINCT c11), + COUNT(DISTINCT c12), + COUNT(DISTINCT c13), + COUNT(DISTINCT c14), + COUNT(DISTINCT c15), + COUNT(DISTINCT c16), + COUNT(DISTINCT c17), + COUNT(DISTINCT c18), + COUNT(DISTINCT c19), + COUNT(DISTINCT c20), + COUNT(DISTINCT c21), + COUNT(DISTINCT c22), + COUNT(DISTINCT c23), + COUNT(DISTINCT c24), + COUNT(DISTINCT c25), + COUNT(DISTINCT c26), + COUNT(DISTINCT c27), + COUNT(DISTINCT c28), + COUNT(DISTINCT c29), + COUNT(DISTINCT c30), + COUNT(DISTINCT c31), + COUNT(DISTINCT c32), + COUNT(DISTINCT c33), + COUNT(DISTINCT c34), + COUNT(DISTINCT c35), + COUNT(DISTINCT c36), + COUNT(DISTINCT c37), + COUNT(DISTINCT c38), + COUNT(DISTINCT c39), + COUNT(DISTINCT c40), + COUNT(DISTINCT c41), + COUNT(DISTINCT c42), + COUNT(DISTINCT c43), + COUNT(DISTINCT c44), + COUNT(DISTINCT c45), + COUNT(DISTINCT c46), + COUNT(DISTINCT c47), + COUNT(DISTINCT c48), + COUNT(DISTINCT c49), + COUNT(DISTINCT c50), + COUNT(DISTINCT c51), + COUNT(DISTINCT c52), + COUNT(DISTINCT c53), + COUNT(DISTINCT c54), + COUNT(DISTINCT c55), + COUNT(DISTINCT c56), + COUNT(DISTINCT c57), + COUNT(DISTINCT c58), + COUNT(DISTINCT c59), + COUNT(DISTINCT c60), + COUNT(DISTINCT c61), + COUNT(DISTINCT c62), + COUNT(DISTINCT c63), + COUNT(DISTINCT c64), + COUNT(DISTINCT c65), + COUNT(DISTINCT c66), + COUNT(DISTINCT c67), + COUNT(DISTINCT c68), + COUNT(DISTINCT c69), + COUNT(DISTINCT c70), + COUNT(DISTINCT c71), + COUNT(DISTINCT c72), + COUNT(DISTINCT c73), + COUNT(DISTINCT c74), + COUNT(DISTINCT c75), + COUNT(DISTINCT c76), + COUNT(DISTINCT c77), + COUNT(DISTINCT c78), + COUNT(DISTINCT c79), + COUNT(DISTINCT c80), + COUNT(DISTINCT c81), + COUNT(DISTINCT c82), + COUNT(DISTINCT c83), + COUNT(DISTINCT c84), + COUNT(DISTINCT c85), + COUNT(DISTINCT c86), + COUNT(DISTINCT c87), + COUNT(DISTINCT c88), + COUNT(DISTINCT c89), + COUNT(DISTINCT c90), + COUNT(DISTINCT c91), + COUNT(DISTINCT c92), + COUNT(DISTINCT c93), + COUNT(DISTINCT c94), + COUNT(DISTINCT c95), + COUNT(DISTINCT c96), + COUNT(DISTINCT c97), + COUNT(DISTINCT c98), + COUNT(DISTINCT c99), + COUNT(DISTINCT c100), + COUNT(DISTINCT c101), + COUNT(DISTINCT c102), + COUNT(DISTINCT c103), + COUNT(DISTINCT c104), + COUNT(DISTINCT c105), + COUNT(DISTINCT c106), + COUNT(DISTINCT c107), + COUNT(DISTINCT c108), + COUNT(DISTINCT c109), + COUNT(DISTINCT c110), + COUNT(DISTINCT c111), + COUNT(DISTINCT c112), + COUNT(DISTINCT c113), + COUNT(DISTINCT c114), + COUNT(DISTINCT c115), + COUNT(DISTINCT c116), + COUNT(DISTINCT c117), + COUNT(DISTINCT c118), + COUNT(DISTINCT c119), + COUNT(DISTINCT c120), + COUNT(DISTINCT c121), + COUNT(DISTINCT c122), + COUNT(DISTINCT c123), + COUNT(DISTINCT c124), + COUNT(DISTINCT c125), + COUNT(DISTINCT c126), + COUNT(DISTINCT c127), + COUNT(DISTINCT c128), + COUNT(DISTINCT c129), + COUNT(DISTINCT c130), + COUNT(DISTINCT c131), + COUNT(DISTINCT c132), + COUNT(DISTINCT c133), + COUNT(DISTINCT c134), + COUNT(DISTINCT c135), + COUNT(DISTINCT c136), + COUNT(DISTINCT c137), + COUNT(DISTINCT c138), + COUNT(DISTINCT c139), + COUNT(DISTINCT c140), + COUNT(DISTINCT c141), + COUNT(DISTINCT c142), + COUNT(DISTINCT c143), + COUNT(DISTINCT c144), + COUNT(DISTINCT c145), + COUNT(DISTINCT c146), + COUNT(DISTINCT c147), + COUNT(DISTINCT c148), + COUNT(DISTINCT c149), + COUNT(DISTINCT c150), + COUNT(DISTINCT c151), + COUNT(DISTINCT c152), + COUNT(DISTINCT c153), + COUNT(DISTINCT c154), + COUNT(DISTINCT c155), + COUNT(DISTINCT c156), + COUNT(DISTINCT c157), + COUNT(DISTINCT c158), + COUNT(DISTINCT c159), + COUNT(DISTINCT c160), + COUNT(DISTINCT c161), + COUNT(DISTINCT c162), + COUNT(DISTINCT c163), + COUNT(DISTINCT c164), + COUNT(DISTINCT c165), + COUNT(DISTINCT c166), + COUNT(DISTINCT c167), + COUNT(DISTINCT c168), + COUNT(DISTINCT c169), + COUNT(DISTINCT c170), + COUNT(DISTINCT c171), + COUNT(DISTINCT c172), + COUNT(DISTINCT c173), + COUNT(DISTINCT c174), + COUNT(DISTINCT c175), + COUNT(DISTINCT c176), + COUNT(DISTINCT c177), + COUNT(DISTINCT c178), + COUNT(DISTINCT c179), + COUNT(DISTINCT c180), + COUNT(DISTINCT c181), + COUNT(DISTINCT c182), + COUNT(DISTINCT c183), + COUNT(DISTINCT c184), + COUNT(DISTINCT c185), + COUNT(DISTINCT c186), + COUNT(DISTINCT c187), + COUNT(DISTINCT c188), + COUNT(DISTINCT c189), + COUNT(DISTINCT c190), + COUNT(DISTINCT c191), + COUNT(DISTINCT c192), + COUNT(DISTINCT c193), + COUNT(DISTINCT c194), + COUNT(DISTINCT c195), + COUNT(DISTINCT c196), + COUNT(DISTINCT c197), + COUNT(DISTINCT c198), + COUNT(DISTINCT c199), + COUNT(DISTINCT c200) +FROM `cdist_gt128_01` +PREHOOK: type: QUERY +PREHOOK: Input: default@cdist_gt128_01 +#### A masked pattern was here #### +POSTHOOK: query: SELECT + COUNT(DISTINCT c1), + COUNT(DISTINCT c2), + COUNT(DISTINCT c3), + COUNT(DISTINCT c4), + COUNT(DISTINCT c5), + COUNT(DISTINCT c6), + COUNT(DISTINCT c7), + COUNT(DISTINCT c8), + COUNT(DISTINCT c9), + COUNT(DISTINCT c10), + COUNT(DISTINCT c11), + COUNT(DISTINCT c12), + COUNT(DISTINCT c13), + COUNT(DISTINCT c14), + COUNT(DISTINCT c15), + COUNT(DISTINCT c16), + COUNT(DISTINCT c17), + COUNT(DISTINCT c18), + COUNT(DISTINCT c19), + COUNT(DISTINCT c20), + COUNT(DISTINCT c21), + COUNT(DISTINCT c22), + COUNT(DISTINCT c23), + COUNT(DISTINCT c24), + COUNT(DISTINCT c25), + COUNT(DISTINCT c26), + COUNT(DISTINCT c27), + COUNT(DISTINCT c28), + COUNT(DISTINCT c29), + COUNT(DISTINCT c30), + COUNT(DISTINCT c31), + COUNT(DISTINCT c32), + COUNT(DISTINCT c33), + COUNT(DISTINCT c34), + COUNT(DISTINCT c35), + COUNT(DISTINCT c36), + COUNT(DISTINCT c37), + COUNT(DISTINCT c38), + COUNT(DISTINCT c39), + COUNT(DISTINCT c40), + COUNT(DISTINCT c41), + COUNT(DISTINCT c42), + COUNT(DISTINCT c43), + COUNT(DISTINCT c44), + COUNT(DISTINCT c45), + COUNT(DISTINCT c46), + COUNT(DISTINCT c47), + COUNT(DISTINCT c48), + COUNT(DISTINCT c49), + COUNT(DISTINCT c50), + COUNT(DISTINCT c51), + COUNT(DISTINCT c52), + COUNT(DISTINCT c53), + COUNT(DISTINCT c54), + COUNT(DISTINCT c55), + COUNT(DISTINCT c56), + COUNT(DISTINCT c57), + COUNT(DISTINCT c58), + COUNT(DISTINCT c59), + COUNT(DISTINCT c60), + COUNT(DISTINCT c61), + COUNT(DISTINCT c62), + COUNT(DISTINCT c63), + COUNT(DISTINCT c64), + COUNT(DISTINCT c65), + COUNT(DISTINCT c66), + COUNT(DISTINCT c67), + COUNT(DISTINCT c68), + COUNT(DISTINCT c69), + COUNT(DISTINCT c70), + COUNT(DISTINCT c71), + COUNT(DISTINCT c72), + COUNT(DISTINCT c73), + COUNT(DISTINCT c74), + COUNT(DISTINCT c75), + COUNT(DISTINCT c76), + COUNT(DISTINCT c77), + COUNT(DISTINCT c78), + COUNT(DISTINCT c79), + COUNT(DISTINCT c80), + COUNT(DISTINCT c81), + COUNT(DISTINCT c82), + COUNT(DISTINCT c83), + COUNT(DISTINCT c84), + COUNT(DISTINCT c85), + COUNT(DISTINCT c86), + COUNT(DISTINCT c87), + COUNT(DISTINCT c88), + COUNT(DISTINCT c89), + COUNT(DISTINCT c90), + COUNT(DISTINCT c91), + COUNT(DISTINCT c92), + COUNT(DISTINCT c93), + COUNT(DISTINCT c94), + COUNT(DISTINCT c95), + COUNT(DISTINCT c96), + COUNT(DISTINCT c97), + COUNT(DISTINCT c98), + COUNT(DISTINCT c99), + COUNT(DISTINCT c100), + COUNT(DISTINCT c101), + COUNT(DISTINCT c102), + COUNT(DISTINCT c103), + COUNT(DISTINCT c104), + COUNT(DISTINCT c105), + COUNT(DISTINCT c106), + COUNT(DISTINCT c107), + COUNT(DISTINCT c108), + COUNT(DISTINCT c109), + COUNT(DISTINCT c110), + COUNT(DISTINCT c111), + COUNT(DISTINCT c112), + COUNT(DISTINCT c113), + COUNT(DISTINCT c114), + COUNT(DISTINCT c115), + COUNT(DISTINCT c116), + COUNT(DISTINCT c117), + COUNT(DISTINCT c118), + COUNT(DISTINCT c119), + COUNT(DISTINCT c120), + COUNT(DISTINCT c121), + COUNT(DISTINCT c122), + COUNT(DISTINCT c123), + COUNT(DISTINCT c124), + COUNT(DISTINCT c125), + COUNT(DISTINCT c126), + COUNT(DISTINCT c127), + COUNT(DISTINCT c128), + COUNT(DISTINCT c129), + COUNT(DISTINCT c130), + COUNT(DISTINCT c131), + COUNT(DISTINCT c132), + COUNT(DISTINCT c133), + COUNT(DISTINCT c134), + COUNT(DISTINCT c135), + COUNT(DISTINCT c136), + COUNT(DISTINCT c137), + COUNT(DISTINCT c138), + COUNT(DISTINCT c139), + COUNT(DISTINCT c140), + COUNT(DISTINCT c141), + COUNT(DISTINCT c142), + COUNT(DISTINCT c143), + COUNT(DISTINCT c144), + COUNT(DISTINCT c145), + COUNT(DISTINCT c146), + COUNT(DISTINCT c147), + COUNT(DISTINCT c148), + COUNT(DISTINCT c149), + COUNT(DISTINCT c150), + COUNT(DISTINCT c151), + COUNT(DISTINCT c152), + COUNT(DISTINCT c153), + COUNT(DISTINCT c154), + COUNT(DISTINCT c155), + COUNT(DISTINCT c156), + COUNT(DISTINCT c157), + COUNT(DISTINCT c158), + COUNT(DISTINCT c159), + COUNT(DISTINCT c160), + COUNT(DISTINCT c161), + COUNT(DISTINCT c162), + COUNT(DISTINCT c163), + COUNT(DISTINCT c164), + COUNT(DISTINCT c165), + COUNT(DISTINCT c166), + COUNT(DISTINCT c167), + COUNT(DISTINCT c168), + COUNT(DISTINCT c169), + COUNT(DISTINCT c170), + COUNT(DISTINCT c171), + COUNT(DISTINCT c172), + COUNT(DISTINCT c173), + COUNT(DISTINCT c174), + COUNT(DISTINCT c175), + COUNT(DISTINCT c176), + COUNT(DISTINCT c177), + COUNT(DISTINCT c178), + COUNT(DISTINCT c179), + COUNT(DISTINCT c180), + COUNT(DISTINCT c181), + COUNT(DISTINCT c182), + COUNT(DISTINCT c183), + COUNT(DISTINCT c184), + COUNT(DISTINCT c185), + COUNT(DISTINCT c186), + COUNT(DISTINCT c187), + COUNT(DISTINCT c188), + COUNT(DISTINCT c189), + COUNT(DISTINCT c190), + COUNT(DISTINCT c191), + COUNT(DISTINCT c192), + COUNT(DISTINCT c193), + COUNT(DISTINCT c194), + COUNT(DISTINCT c195), + COUNT(DISTINCT c196), + COUNT(DISTINCT c197), + COUNT(DISTINCT c198), + COUNT(DISTINCT c199), + COUNT(DISTINCT c200) +FROM `cdist_gt128_01` +POSTHOOK: type: QUERY +POSTHOOK: Input: default@cdist_gt128_01 +#### A masked pattern was here #### +1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 +PREHOOK: query: DROP TABLE `cdist_gt128_01` +PREHOOK: type: DROPTABLE +PREHOOK: Input: default@cdist_gt128_01 +PREHOOK: Output: default@cdist_gt128_01 +POSTHOOK: query: DROP TABLE `cdist_gt128_01` +POSTHOOK: type: DROPTABLE +POSTHOOK: Input: default@cdist_gt128_01 +POSTHOOK: Output: default@cdist_gt128_01 diff --git a/serde/src/java/org/apache/hadoop/hive/serde2/avro/AvroDeserializer.java b/serde/src/java/org/apache/hadoop/hive/serde2/avro/AvroDeserializer.java index 27583b82b8..e331fd5e4f 100644 --- a/serde/src/java/org/apache/hadoop/hive/serde2/avro/AvroDeserializer.java +++ b/serde/src/java/org/apache/hadoop/hive/serde2/avro/AvroDeserializer.java @@ -406,7 +406,7 @@ private Object deserializeUnion(Object datum, Schema fileSchema, Schema recordSc int rsTag = GenericData.get().resolveUnion(recordSchema, datum); // Determine index of value from recordSchema Object desered = worker(datum, fileSchema == null ? null : fileSchema.getTypes().get(fsTag), recordSchema.getTypes().get(rsTag), columnType.getAllUnionObjectTypeInfos().get(rsTag)); - return new StandardUnionObjectInspector.StandardUnion((byte)rsTag, desered); + return new StandardUnionObjectInspector.StandardUnion(rsTag, desered); } private Object deserializeList(Object datum, Schema fileSchema, Schema recordSchema, diff --git a/serde/src/java/org/apache/hadoop/hive/serde2/avro/AvroLazyObjectInspector.java b/serde/src/java/org/apache/hadoop/hive/serde2/avro/AvroLazyObjectInspector.java index 5a857f2be6..e210bd88c3 100644 --- a/serde/src/java/org/apache/hadoop/hive/serde2/avro/AvroLazyObjectInspector.java +++ b/serde/src/java/org/apache/hadoop/hive/serde2/avro/AvroLazyObjectInspector.java @@ -469,7 +469,7 @@ private Object toLazyUnionObject(Object obj, ObjectInspector objectInspector) { LazyUnionObjectInspector lazyUnionOI = (LazyUnionObjectInspector) objectInspector; // Grab the tag and the field - byte tag = standardUnion.getTag(); + int tag = standardUnion.getTag(); Object field = standardUnion.getObject(); ObjectInspector fieldOI = lazyUnionOI.getObjectInspectors().get(tag); diff --git a/serde/src/java/org/apache/hadoop/hive/serde2/avro/AvroSerializer.java b/serde/src/java/org/apache/hadoop/hive/serde2/avro/AvroSerializer.java index 490434d2f1..e2f3c3191d 100644 --- a/serde/src/java/org/apache/hadoop/hive/serde2/avro/AvroSerializer.java +++ b/serde/src/java/org/apache/hadoop/hive/serde2/avro/AvroSerializer.java @@ -242,7 +242,7 @@ private Object serializePrimitive(TypeInfo typeInfo, PrimitiveObjectInspector fi } private Object serializeUnion(UnionTypeInfo typeInfo, UnionObjectInspector fieldOI, Object structFieldData, Schema schema) throws AvroSerdeException { - byte tag = fieldOI.getTag(structFieldData); + int tag = fieldOI.getTag(structFieldData); // Invariant that Avro's tag ordering must match Hive's. return serialize(typeInfo.getAllUnionObjectTypeInfos().get(tag), diff --git a/serde/src/java/org/apache/hadoop/hive/serde2/binarysortable/BinarySortableSerDe.java b/serde/src/java/org/apache/hadoop/hive/serde2/binarysortable/BinarySortableSerDe.java index 999273cbfb..8540764aba 100644 --- a/serde/src/java/org/apache/hadoop/hive/serde2/binarysortable/BinarySortableSerDe.java +++ b/serde/src/java/org/apache/hadoop/hive/serde2/binarysortable/BinarySortableSerDe.java @@ -561,7 +561,7 @@ static Object deserialize(InputByteBuffer buffer, TypeInfo type, StandardUnion r = reuse == null ? new StandardUnion() : (StandardUnion) reuse; // Read the tag - byte tag = buffer.read(invert); + int tag = deserializeInt(buffer, invert); r.setTag(tag); r.setObject(deserialize(buffer, utype.getAllUnionObjectTypeInfos().get(tag), invert, nullMarker, notNullMarker, null)); @@ -839,8 +839,8 @@ static void serialize(ByteStream.Output buffer, Object o, ObjectInspector oi, } case UNION: { UnionObjectInspector uoi = (UnionObjectInspector) oi; - byte tag = uoi.getTag(o); - writeByte(buffer, tag, invert); + int tag = uoi.getTag(o); + serializeInt(buffer, tag, invert); serialize(buffer, uoi.getField(o), uoi.getObjectInspectors().get(tag), invert, nullMarker, notNullMarker); return; diff --git a/serde/src/java/org/apache/hadoop/hive/serde2/binarysortable/fast/BinarySortableDeserializeRead.java b/serde/src/java/org/apache/hadoop/hive/serde2/binarysortable/fast/BinarySortableDeserializeRead.java index 286e529641..be98573dbf 100644 --- a/serde/src/java/org/apache/hadoop/hive/serde2/binarysortable/fast/BinarySortableDeserializeRead.java +++ b/serde/src/java/org/apache/hadoop/hive/serde2/binarysortable/fast/BinarySortableDeserializeRead.java @@ -259,12 +259,7 @@ private boolean readPrimitive(Field field) throws IOException { return true; case INT: { - final boolean invert = columnSortOrderIsDesc[fieldIndex]; - int v = inputByteBuffer.read(invert) ^ 0x80; - for (int i = 0; i < 3; i++) { - v = (v << 8) + (inputByteBuffer.read(invert) & 0xff); - } - currentInt = v; + currentInt = readInt(fieldIndex); } return true; case LONG: @@ -493,7 +488,14 @@ private boolean readPrimitive(Field field) throws IOException { throw new RuntimeException("Unexpected primitive type category " + field.primitiveCategory); } } - + private int readInt(int fieldIndex) throws IOException { + final boolean invert = columnSortOrderIsDesc[fieldIndex]; + int v = inputByteBuffer.read(invert) ^ 0x80; + for (int i = 0; i < 3; i++) { + v = (v << 8) + (inputByteBuffer.read(invert) & 0xff); + } + return v; + } /* * Reads through an undesired field. * @@ -672,7 +674,7 @@ public boolean readComplexField() throws IOException { if (current.category == Category.UNION) { if (current.index == 0) { - current.tag = inputByteBuffer.read(columnSortOrderIsDesc[root.index]); + current.tag = readInt(root.index); currentInt = current.tag; return true; } diff --git a/serde/src/java/org/apache/hadoop/hive/serde2/binarysortable/fast/BinarySortableSerializeWrite.java b/serde/src/java/org/apache/hadoop/hive/serde2/binarysortable/fast/BinarySortableSerializeWrite.java index cc598d2430..71e83657f1 100644 --- a/serde/src/java/org/apache/hadoop/hive/serde2/binarysortable/fast/BinarySortableSerializeWrite.java +++ b/serde/src/java/org/apache/hadoop/hive/serde2/binarysortable/fast/BinarySortableSerializeWrite.java @@ -430,7 +430,7 @@ public void finishStruct() { @Override public void beginUnion(int tag) throws IOException { beginElement(); - BinarySortableSerDe.writeByte(output, (byte) tag, columnSortOrderIsDesc[index]); + BinarySortableSerDe.serializeInt(output, tag, columnSortOrderIsDesc[index]); level++; } diff --git a/serde/src/java/org/apache/hadoop/hive/serde2/json/HiveJsonWriter.java b/serde/src/java/org/apache/hadoop/hive/serde2/json/HiveJsonWriter.java index cacc70bd30..ba7b929c35 100644 --- a/serde/src/java/org/apache/hadoop/hive/serde2/json/HiveJsonWriter.java +++ b/serde/src/java/org/apache/hadoop/hive/serde2/json/HiveJsonWriter.java @@ -267,8 +267,8 @@ private ObjectNode visitUnion(final ObjectInspector oi, final Object o) final ObjectNode unionNode = this.nodeFactory.objectNode(); - final byte tag = unionInspector.getTag(o); - final String tagText = Byte.toString(tag); + final int tag = unionInspector.getTag(o); + final String tagText = Integer.toString(tag); final JsonNode valueNode = walkObjectGraph(unionInspector.getObjectInspectors().get(tag), unionInspector.getField(o), Collections.emptyList()); diff --git a/serde/src/java/org/apache/hadoop/hive/serde2/lazy/LazySimpleSerDe.java b/serde/src/java/org/apache/hadoop/hive/serde2/lazy/LazySimpleSerDe.java index 1a2266e3be..4017585406 100644 --- a/serde/src/java/org/apache/hadoop/hive/serde2/lazy/LazySimpleSerDe.java +++ b/serde/src/java/org/apache/hadoop/hive/serde2/lazy/LazySimpleSerDe.java @@ -371,8 +371,8 @@ public static void serialize(ByteStream.Output out, Object obj, if (ois == null) { out.write(nullSequence.getBytes(), 0, nullSequence.getLength()); } else { - LazyUtils.writePrimitiveUTF8(out, Byte.valueOf(uoi.getTag(obj)), - PrimitiveObjectInspectorFactory.javaByteObjectInspector, + LazyUtils.writePrimitiveUTF8(out, uoi.getTag(obj), + PrimitiveObjectInspectorFactory.javaIntObjectInspector, escaped, escapeChar, needsEscape); out.write(separator); serialize(out, uoi.getField(obj), ois.get(uoi.getTag(obj)), diff --git a/serde/src/java/org/apache/hadoop/hive/serde2/lazy/LazyUnion.java b/serde/src/java/org/apache/hadoop/hive/serde2/lazy/LazyUnion.java index d22bc254ef..00717461d8 100644 --- a/serde/src/java/org/apache/hadoop/hive/serde2/lazy/LazyUnion.java +++ b/serde/src/java/org/apache/hadoop/hive/serde2/lazy/LazyUnion.java @@ -43,7 +43,7 @@ /** * Tag of the Union */ - private byte tag; + private int tag; /** * Whether init() has been called on the field or not. @@ -63,7 +63,7 @@ public LazyUnion(LazyUnionObjectInspector oi) { } // exceptional use case for avro - public LazyUnion(LazyUnionObjectInspector oi, byte tag, Object field) { + public LazyUnion(LazyUnionObjectInspector oi, int tag, Object field) { super(oi); this.field = field; this.tag = tag; @@ -172,7 +172,7 @@ public Object getField() { * * @return The tag byte */ - public byte getTag() { + public int getTag() { if (fieldSet) { return tag; } diff --git a/serde/src/java/org/apache/hadoop/hive/serde2/lazy/VerifyLazy.java b/serde/src/java/org/apache/hadoop/hive/serde2/lazy/VerifyLazy.java index 14ff6d2053..0eb2dc242f 100644 --- a/serde/src/java/org/apache/hadoop/hive/serde2/lazy/VerifyLazy.java +++ b/serde/src/java/org/apache/hadoop/hive/serde2/lazy/VerifyLazy.java @@ -104,8 +104,8 @@ public static boolean lazyCompareStruct(StructTypeInfo structTypeInfo, List unionFieldObjectI /** * Return the tag of the object. */ - public byte getTag(Object o) { + public int getTag(Object o) { if (o == null) { return -1; } diff --git a/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/ObjectInspectorConverters.java b/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/ObjectInspectorConverters.java index 9129177375..ad1c54dbee 100644 --- a/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/ObjectInspectorConverters.java +++ b/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/ObjectInspectorConverters.java @@ -478,10 +478,10 @@ public Object convert(Object input) { } Object inputFieldValue = inputOI.getField(input); - byte inputFieldTag = inputOI.getTag(input); + int inputFieldTag = inputOI.getTag(input); Object outputFieldValue = null; - int inputFieldTagIndex = ((Byte)inputFieldTag).intValue(); + int inputFieldTagIndex = inputFieldTag; if (inputFieldTagIndex >= 0 && inputFieldTagIndex < fieldConverters.size()) { outputFieldValue = fieldConverters.get(inputFieldTagIndex).convert(inputFieldValue); diff --git a/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/ObjectInspectorUtils.java b/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/ObjectInspectorUtils.java index ff69b47cb6..bc2d49de0a 100644 --- a/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/ObjectInspectorUtils.java +++ b/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/ObjectInspectorUtils.java @@ -790,7 +790,7 @@ public static int hashCode(Object o, ObjectInspector objIns) { case UNION: UnionObjectInspector uOI = (UnionObjectInspector)objIns; - byte tag = uOI.getTag(o); + int tag = uOI.getTag(o); return hashCode(uOI.getField(o), uOI.getObjectInspectors().get(tag)); default: @@ -928,7 +928,7 @@ public static int hashCodeMurmur(Object o, ObjectInspector objIns, ByteBuffer by case UNION: UnionObjectInspector uOI = (UnionObjectInspector)objIns; - byte tag = uOI.getTag(o); + int tag = uOI.getTag(o); return hashCodeMurmur(uOI.getField(o), uOI.getObjectInspectors().get(tag), byteBuffer); default: @@ -1238,8 +1238,8 @@ public static int compare(Object o1, ObjectInspector oi1, Object o2, case UNION: { UnionObjectInspector uoi1 = (UnionObjectInspector) oi1; UnionObjectInspector uoi2 = (UnionObjectInspector) oi2; - byte tag1 = uoi1.getTag(o1); - byte tag2 = uoi2.getTag(o2); + int tag1 = uoi1.getTag(o1); + int tag2 = uoi2.getTag(o2); if (tag1 != tag2) { return tag1 - tag2; } diff --git a/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/SettableUnionObjectInspector.java b/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/SettableUnionObjectInspector.java index 61f6e758f9..171fd74943 100644 --- a/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/SettableUnionObjectInspector.java +++ b/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/SettableUnionObjectInspector.java @@ -30,5 +30,5 @@ public abstract Object create(); /* Sets the field and tag in the union. Returns the union. */ - public abstract Object setFieldAndTag(Object union, Object field, byte tag); + public abstract Object setFieldAndTag(Object union, Object field, int tag); } diff --git a/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/StandardUnionObjectInspector.java b/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/StandardUnionObjectInspector.java index 002514f304..edad76a09c 100644 --- a/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/StandardUnionObjectInspector.java +++ b/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/StandardUnionObjectInspector.java @@ -18,7 +18,6 @@ package org.apache.hadoop.hive.serde2.objectinspector; -import java.util.ArrayList; import java.util.List; /** @@ -46,13 +45,14 @@ public StandardUnionObjectInspector(List ois) { } public static class StandardUnion implements UnionObject { - protected byte tag; + protected int tag; protected Object object; public StandardUnion() { } - public StandardUnion(byte tag, Object object) { + public StandardUnion(int tag, Object object) { + assert tag >= 0; this.tag = tag; this.object = object; } @@ -61,7 +61,7 @@ public void setObject(Object o) { this.object = o; } - public void setTag(byte tag) { + public void setTag(int tag) { this.tag = tag; } @@ -71,7 +71,7 @@ public Object getObject() { } @Override - public byte getTag() { + public int getTag() { return tag; } @@ -109,7 +109,7 @@ public boolean equals(Object obj) { /** * Return the tag of the object. */ - public byte getTag(Object o) { + public int getTag(Object o) { if (o == null) { return -1; } @@ -148,11 +148,11 @@ public Object create() { } @Override - public Object setFieldAndTag(Object union, Object field, byte tag) { + public Object setFieldAndTag(Object union, Object field, int tag) { StandardUnion unionObject = (StandardUnion) union; unionObject.setObject(field); if (field == null) { - unionObject.setTag((byte) -1); + unionObject.setTag(-1); } else { unionObject.setTag(tag); } diff --git a/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/ThriftUnionObjectInspector.java b/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/ThriftUnionObjectInspector.java index cdfaee28bb..0250ebbc4c 100644 --- a/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/ThriftUnionObjectInspector.java +++ b/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/ThriftUnionObjectInspector.java @@ -52,7 +52,7 @@ public boolean shouldIgnoreField(String name) { } @Override - public byte getTag(final Object o) { + public int getTag(final Object o) { if (o == null) { return -1; } diff --git a/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/UnionObject.java b/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/UnionObject.java index 9ea3b48a96..9f6f1625b9 100644 --- a/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/UnionObject.java +++ b/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/UnionObject.java @@ -34,7 +34,7 @@ * * @return the tag byte */ - byte getTag(); + int getTag(); /** * Get the Object. diff --git a/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/UnionObjectInspector.java b/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/UnionObjectInspector.java index dc0b1b15f2..2aeae1357e 100644 --- a/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/UnionObjectInspector.java +++ b/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/UnionObjectInspector.java @@ -44,7 +44,7 @@ /** * Return the tag of the object. */ - byte getTag(Object o); + int getTag(Object o); /** * Return the field based on the tag associated with the Object. diff --git a/serde/src/test/org/apache/hadoop/hive/serde2/SerdeRandomRowSource.java b/serde/src/test/org/apache/hadoop/hive/serde2/SerdeRandomRowSource.java index e77083c5dd..59fdabaf61 100644 --- a/serde/src/test/org/apache/hadoop/hive/serde2/SerdeRandomRowSource.java +++ b/serde/src/test/org/apache/hadoop/hive/serde2/SerdeRandomRowSource.java @@ -740,7 +740,7 @@ public Object randomWritable(TypeInfo typeInfo, ObjectInspector objectInspector, (StandardUnionObjectInspector) objectInspector; final List objectInspectorList = unionObjectInspector.getObjectInspectors(); final int unionCount = objectInspectorList.size(); - final byte tag = (byte) r.nextInt(unionCount); + final int tag = r.nextInt(unionCount); final ObjectInspector fieldObjectInspector = objectInspectorList.get(tag); final TypeInfo fieldTypeInfo = diff --git a/serde/src/test/org/apache/hadoop/hive/serde2/VerifyFast.java b/serde/src/test/org/apache/hadoop/hive/serde2/VerifyFast.java index 7e10af7177..0d9066c023 100644 --- a/serde/src/test/org/apache/hadoop/hive/serde2/VerifyFast.java +++ b/serde/src/test/org/apache/hadoop/hive/serde2/VerifyFast.java @@ -505,7 +505,7 @@ public static void serializeWrite(SerializeWrite serializeWrite, List fieldTypeInfos = unionTypeInfo.getAllUnionObjectTypeInfos(); final int size = fieldTypeInfos.size(); StandardUnion standardUnion = (StandardUnion) object; - byte tag = standardUnion.getTag(); + int tag = standardUnion.getTag(); serializeWrite.beginUnion(tag); serializeWrite(serializeWrite, fieldTypeInfos.get(tag), standardUnion.getObject()); serializeWrite.finishUnion(); @@ -689,7 +689,7 @@ private static Object getComplexField(DeserializeRead deserializeRead, unionObj = null; } else { // Get the union value. - unionObj = new StandardUnion((byte) tag, getComplexField(deserializeRead, unionTypeInfos.get(tag))); + unionObj = new StandardUnion(tag, getComplexField(deserializeRead, unionTypeInfos.get(tag))); } } diff --git a/serde/src/test/org/apache/hadoop/hive/serde2/binarysortable/TestBinarySortableFast.java b/serde/src/test/org/apache/hadoop/hive/serde2/binarysortable/TestBinarySortableFast.java index 2e44074a87..68ba2c25fe 100644 --- a/serde/src/test/org/apache/hadoop/hive/serde2/binarysortable/TestBinarySortableFast.java +++ b/serde/src/test/org/apache/hadoop/hive/serde2/binarysortable/TestBinarySortableFast.java @@ -416,7 +416,7 @@ private void testBinarySortableFastCase( Arrays.fill(columnNotNullMarker, BinarySortableSerDe.ONE); /* - * Acending. + * Ascending. */ testBinarySortableFast(source, rows, columnSortOrderIsDesc, columnNullMarker, columnNotNullMarker, diff --git a/serde/src/test/org/apache/hadoop/hive/serde2/objectinspector/TestObjectInspectorConverters.java b/serde/src/test/org/apache/hadoop/hive/serde2/objectinspector/TestObjectInspectorConverters.java index f829f9412f..1d69bc6fd8 100644 --- a/serde/src/test/org/apache/hadoop/hive/serde2/objectinspector/TestObjectInspectorConverters.java +++ b/serde/src/test/org/apache/hadoop/hive/serde2/objectinspector/TestObjectInspectorConverters.java @@ -125,9 +125,9 @@ private void convertUnion() { Converter unionConverter0 = ObjectInspectorConverters.getConverter(ObjectInspectorFactory.getStandardUnionObjectInspector(fieldObjectInspectors), ObjectInspectorFactory.getStandardUnionObjectInspector(fieldObjectInspectors2)); - Object convertedObject0 = unionConverter0.convert(new StandardUnion((byte)0, 1)); + Object convertedObject0 = unionConverter0.convert(new StandardUnion(0, 1)); StandardUnion expectedObject0 = new StandardUnion(); - expectedObject0.setTag((byte) 0); + expectedObject0.setTag(0); expectedObject0.setObject("1"); assertEquals(expectedObject0, convertedObject0); @@ -135,9 +135,9 @@ private void convertUnion() { Converter unionConverter1 = ObjectInspectorConverters.getConverter(ObjectInspectorFactory.getStandardUnionObjectInspector(fieldObjectInspectors), ObjectInspectorFactory.getStandardUnionObjectInspector(fieldObjectInspectors2)); - Object convertedObject1 = unionConverter1.convert(new StandardUnion((byte)1, "1")); + Object convertedObject1 = unionConverter1.convert(new StandardUnion(1, "1")); StandardUnion expectedObject1 = new StandardUnion(); - expectedObject1.setTag((byte) 1); + expectedObject1.setTag(1); expectedObject1.setObject(1); assertEquals(expectedObject1, convertedObject1); @@ -145,9 +145,9 @@ private void convertUnion() { Converter unionConverter2 = ObjectInspectorConverters.getConverter(ObjectInspectorFactory.getStandardUnionObjectInspector(fieldObjectInspectors), ObjectInspectorFactory.getStandardUnionObjectInspector(fieldObjectInspectors2)); - Object convertedObject2 = unionConverter2.convert(new StandardUnion((byte)2, true)); + Object convertedObject2 = unionConverter2.convert(new StandardUnion(2, true)); StandardUnion expectedObject2 = new StandardUnion(); - expectedObject2.setTag((byte) 2); + expectedObject2.setTag(2); expectedObject2.setObject(true); assertEquals(expectedObject2, convertedObject2); @@ -177,9 +177,9 @@ private void convertUnion() { Converter unionConverterExtra = ObjectInspectorConverters.getConverter(ObjectInspectorFactory.getStandardUnionObjectInspector(fieldObjectInspectorsExtra), ObjectInspectorFactory.getStandardUnionObjectInspector(fieldObjectInspectorsExtra2)); - Object convertedObjectExtra = unionConverterExtra.convert(new StandardUnion((byte)2, true)); + Object convertedObjectExtra = unionConverterExtra.convert(new StandardUnion(2, true)); StandardUnion expectedObjectExtra = new StandardUnion(); - expectedObjectExtra.setTag((byte) -1); + expectedObjectExtra.setTag(-1); expectedObjectExtra.setObject(null); assertEquals(expectedObjectExtra, convertedObjectExtra); // we should get back null diff --git a/serde/src/test/org/apache/hadoop/hive/serde2/objectinspector/TestStandardObjectInspectors.java b/serde/src/test/org/apache/hadoop/hive/serde2/objectinspector/TestStandardObjectInspectors.java index 04ffbb8906..151b5a2318 100644 --- a/serde/src/test/org/apache/hadoop/hive/serde2/objectinspector/TestStandardObjectInspectors.java +++ b/serde/src/test/org/apache/hadoop/hive/serde2/objectinspector/TestStandardObjectInspectors.java @@ -490,25 +490,25 @@ public void testStandardUnionObjectInspector() throws Throwable { assertEquals(-1, uoi1.getTag(null)); // Union - UnionObject union = new StandardUnion((byte) 0, 1); + UnionObject union = new StandardUnion(0, 1); assertEquals(0, uoi1.getTag(union)); assertEquals(1, uoi1.getField(union)); assertEquals("{0:1}", SerDeUtils.getJSONString(union, uoi1)); assertEquals(0, ObjectInspectorUtils.compare(union, uoi1, - new StandardUnion((byte) 0, 1), uoi2)); + new StandardUnion(0, 1), uoi2)); assertTrue(ObjectInspectorUtils.copyToStandardObject( union, uoi1).equals(1)); - union = new StandardUnion((byte) 1, "two"); + union = new StandardUnion(1, "two"); assertEquals(1, uoi1.getTag(union)); assertEquals("two", uoi1.getField(union)); assertEquals("{1:\"two\"}", SerDeUtils.getJSONString(union, uoi1)); assertEquals(0, ObjectInspectorUtils.compare(union, uoi1, - new StandardUnion((byte) 1, "two"), uoi2)); + new StandardUnion(1, "two"), uoi2)); assertTrue(ObjectInspectorUtils.copyToStandardObject( union, uoi1).equals("two")); - union = new StandardUnion((byte) 2, true); + union = new StandardUnion(2, true); assertEquals(2, uoi1.getTag(union)); assertEquals(true, uoi1.getField(union)); assertEquals("{2:true}", SerDeUtils.getJSONString(union, uoi1));