This is an automated email from the ASF dual-hosted git repository.
volodymyr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/drill.git.
from d8f9fb6 DRILL-6461: Added basic data correctness tests for hash agg,
and improved operator unit testing framework.
new 44e63bd DRILL-6422: Update guava to 23.0 and shade it
new 8edeb49 DRILL-6422: Replace guava imports with shaded ones
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../org/apache/drill/common/DeferredException.java | 4 +-
.../java/org/apache/drill/common/KerberosUtil.java | 4 +-
.../main/java/org/apache/drill/common/Version.java | 4 +-
.../drill/common/collections/Collectors.java | 2 +-
.../drill/common/collections/ImmutableEntry.java | 4 +-
.../drill/common/collections/MapWithOrdinal.java | 12 ++--
.../apache/drill/common/config/DrillConfig.java | 8 +--
.../drill/common/config/DrillProperties.java | 4 +-
.../drill/common/map/CaseInsensitiveMap.java | 4 +-
.../drill/common/scanner/ClassPathScanner.java | 6 +-
.../apache/drill/common/scanner/RunTimeScan.java | 2 +-
.../scanner/persistence/AnnotationDescriptor.java | 2 +-
.../common/scanner/persistence/ScanResult.java | 8 +--
.../apache/drill/common/util/DrillFileUtils.java | 6 +-
.../apache/drill/common/util/DrillStringUtils.java | 2 +-
.../org/apache/drill/common/util/GuavaUtils.java | 47 ++++++++++++++
.../org/apache/drill/test/SubDirTestWatcher.java | 4 +-
.../drill/exec/store/mapr/TableFormatPlugin.java | 2 +-
.../exec/store/mapr/db/MapRDBFormatPlugin.java | 2 +-
.../drill/exec/store/mapr/db/MapRDBGroupScan.java | 10 +--
.../store/mapr/db/MapRDBPushFilterIntoScan.java | 2 +-
.../exec/store/mapr/db/MapRDBScanBatchCreator.java | 2 +-
.../drill/exec/store/mapr/db/MapRDBSubScan.java | 4 +-
.../store/mapr/db/binary/BinaryTableGroupScan.java | 2 +-
.../store/mapr/db/binary/MapRDBFilterBuilder.java | 4 +-
.../db/binary/MaprDBCompareFunctionsProcessor.java | 2 +-
.../mapr/db/json/CompareFunctionsProcessor.java | 4 +-
.../store/mapr/db/json/JsonConditionBuilder.java | 2 +-
.../store/mapr/db/json/JsonTableGroupScan.java | 2 +-
.../store/mapr/db/json/MaprDBJsonRecordReader.java | 6 +-
.../exec/store/mapr/db/util/FieldPathHelper.java | 2 +-
.../store/hbase/CompareFunctionsProcessor.java | 6 +-
.../exec/store/hbase/HBaseConnectionManager.java | 14 ++--
.../drill/exec/store/hbase/HBaseFilterBuilder.java | 4 +-
.../drill/exec/store/hbase/HBaseGroupScan.java | 8 +--
.../exec/store/hbase/HBasePushFilterIntoScan.java | 2 +-
.../drill/exec/store/hbase/HBaseRecordReader.java | 6 +-
.../exec/store/hbase/HBaseScanBatchCreator.java | 2 +-
.../drill/exec/store/hbase/HBaseSchemaFactory.java | 2 +-
.../drill/exec/store/hbase/HBaseStoragePlugin.java | 2 +-
.../exec/store/hbase/HBaseStoragePluginConfig.java | 6 +-
.../drill/exec/store/hbase/HBaseSubScan.java | 2 +-
.../apache/drill/exec/store/hbase/HBaseUtils.java | 2 +-
.../store/hbase/config/HBasePersistentStore.java | 2 +-
.../hbase/config/HBasePersistentStoreProvider.java | 2 +-
.../java/org/apache/drill/hbase/BaseHBaseTest.java | 6 +-
.../hbase/TestHBaseRegionScanAssignments.java | 4 +-
.../apache/drill/hbase/TestHBaseTableProvider.java | 2 +-
.../hbase/TestOrderedBytesConvertFunctions.java | 4 +-
.../codegen/templates/ObjectInspectorHelper.java | 4 +-
.../drill/exec/expr/fn/HiveFunctionRegistry.java | 4 +-
.../exec/planner/sql/HivePartitionDescriptor.java | 2 +-
.../exec/planner/sql/HivePartitionLocation.java | 2 +-
.../drill/exec/store/hive/ColumnListsCache.java | 6 +-
.../exec/store/hive/DrillHiveMetaStoreClient.java | 12 ++--
.../exec/store/hive/HiveAuthorizationHelper.java | 2 +-
.../hive/HiveDrillNativeParquetRowGroupScan.java | 2 +-
.../store/hive/HiveDrillNativeParquetScan.java | 2 +-
.../HiveDrillNativeParquetScanBatchCreator.java | 2 +-
.../drill/exec/store/hive/HiveFieldConverter.java | 2 +-
.../exec/store/hive/HiveMetadataProvider.java | 14 ++--
.../drill/exec/store/hive/HiveReadEntry.java | 2 +-
.../drill/exec/store/hive/HiveStoragePlugin.java | 2 +-
.../apache/drill/exec/store/hive/HiveSubScan.java | 6 +-
.../drill/exec/store/hive/HiveTableWrapper.java | 2 +-
.../drill/exec/store/hive/HiveUtilities.java | 4 +-
.../store/hive/readers/HiveAbstractReader.java | 4 +-
.../exec/store/hive/schema/DrillHiveTable.java | 2 +-
.../exec/store/hive/schema/HiveDatabaseSchema.java | 4 +-
.../exec/store/hive/schema/HiveSchemaFactory.java | 12 ++--
.../apache/drill/exec/fn/hive/TestHiveUDFs.java | 4 +-
.../drill/exec/fn/hive/TestInbuiltHiveUDFs.java | 2 +-
.../apache/drill/exec/hive/TestHiveStorage.java | 4 +-
.../exec/hive/TestInfoSchemaOnHiveStorage.java | 2 +-
.../hive/TestSqlStdBasedAuthorization.java | 4 +-
.../hive/TestStorageBasedHiveAuthorization.java | 4 +-
.../exec/sql/hive/TestViewSupportOnHiveTables.java | 2 +-
.../exec/store/hive/HiveTestDataGenerator.java | 4 +-
.../store/hive/schema/TestColumnListCache.java | 2 +-
.../drill/exec/store/jdbc/DrillJdbcRuleBase.java | 10 +--
.../drill/exec/store/jdbc/JdbcBatchCreator.java | 2 +-
.../drill/exec/store/jdbc/JdbcRecordReader.java | 6 +-
.../drill/exec/store/jdbc/JdbcStoragePlugin.java | 14 ++--
.../drill/exec/store/kafka/KafkaGroupScan.java | 10 +--
.../drill/exec/store/kafka/KafkaNodeProcessor.java | 4 +-
.../store/kafka/KafkaPartitionScanSpecBuilder.java | 12 ++--
.../store/kafka/KafkaPushDownFilterIntoScan.java | 2 +-
.../drill/exec/store/kafka/KafkaRecordReader.java | 6 +-
.../exec/store/kafka/KafkaScanBatchCreator.java | 2 +-
.../drill/exec/store/kafka/KafkaStoragePlugin.java | 4 +-
.../drill/exec/store/kafka/KafkaSubScan.java | 2 +-
.../drill/exec/store/kafka/MessageIterator.java | 4 +-
.../store/kafka/decoders/JsonMessageReader.java | 2 +-
.../store/kafka/schema/KafkaMessageSchema.java | 4 +-
.../exec/store/kafka/KafkaMessageGenerator.java | 6 +-
.../drill/exec/store/kafka/KafkaQueriesTest.java | 2 +-
.../drill/exec/store/kafka/KafkaTestBase.java | 2 +-
.../main/codegen/templates/KuduRecordWriter.java | 4 +-
.../drill/exec/store/kudu/DrillKuduTable.java | 2 +-
.../drill/exec/store/kudu/KuduGroupScan.java | 10 +--
.../drill/exec/store/kudu/KuduRecordReader.java | 4 +-
.../exec/store/kudu/KuduScanBatchCreator.java | 2 +-
.../drill/exec/store/kudu/KuduSchemaFactory.java | 2 +-
.../apache/drill/exec/store/kudu/KuduSubScan.java | 4 +-
.../store/mongo/MongoCompareFunctionProcessor.java | 4 +-
.../drill/exec/store/mongo/MongoFilterBuilder.java | 2 +-
.../drill/exec/store/mongo/MongoGroupScan.java | 14 ++--
.../store/mongo/MongoPushDownFilterForScan.java | 2 +-
.../drill/exec/store/mongo/MongoRecordReader.java | 8 +--
.../exec/store/mongo/MongoScanBatchCreator.java | 2 +-
.../drill/exec/store/mongo/MongoStoragePlugin.java | 12 ++--
.../drill/exec/store/mongo/MongoSubScan.java | 6 +-
.../apache/drill/exec/store/mongo/MongoUtils.java | 4 +-
.../store/mongo/config/MongoPersistentStore.java | 2 +-
.../store/mongo/schema/MongoDatabaseSchema.java | 4 +-
.../store/mongo/schema/MongoSchemaFactory.java | 12 ++--
.../drill/exec/store/mongo/MongoTestSuit.java | 2 +-
.../exec/store/mongo/TestMongoChunkAssignment.java | 6 +-
.../drill/exec/store/mongo/TestTableGenerator.java | 2 +-
.../exec/store/openTSDB/DrillOpenTSDBTable.java | 2 +-
.../exec/store/openTSDB/OpenTSDBGroupScan.java | 4 +-
.../exec/store/openTSDB/OpenTSDBRecordReader.java | 4 +-
.../drill/exec/store/openTSDB/OpenTSDBSubScan.java | 2 +-
.../org/apache/drill/exec/store/openTSDB/Util.java | 2 +-
distribution/src/assemble/bin.xml | 1 +
docs/dev/UpgradeGuava.md | 62 ++++++++++++++++++
drill-shaded/drill-shaded-guava/pom.xml | 72 +++++++++++++++++++++
drill-shaded/pom.xml | 74 ++++++++++++++++++++++
.../drill/yarn/appMaster/http/WebServer.java | 2 +-
.../apache/drill/yarn/zk/ZKClusterCoordinator.java | 12 ++--
.../java/org/apache/drill/yarn/zk/ZKRegistry.java | 2 +-
.../src/main/codegen/includes/vv_imports.ftl | 14 ++--
.../codegen/templates/EventBasedRecordWriter.java | 4 +-
.../templates/ParquetOutputRecordWriter.java | 6 +-
.../codegen/templates/RecordValueAccessor.java | 2 +-
.../templates/StringOutputRecordWriter.java | 2 +-
.../org/apache/drill/exec/TestMemoryRetention.java | 2 +-
.../exec/cache/VectorAccessibleSerializable.java | 4 +-
.../apache/drill/exec/cache/VectorSerializer.java | 2 +-
.../org/apache/drill/exec/client/DrillClient.java | 12 ++--
.../java/org/apache/drill/exec/client/DumpCat.java | 2 +-
.../drill/exec/client/LoggingResultsListener.java | 2 +-
.../apache/drill/exec/client/QuerySubmitter.java | 6 +-
.../org/apache/drill/exec/client/ServerMethod.java | 8 +--
.../apache/drill/exec/compile/ByteCodeLoader.java | 8 +--
.../drill/exec/compile/CachedClassLoader.java | 2 +-
.../drill/exec/compile/ClassTransformer.java | 10 +--
.../apache/drill/exec/compile/CodeCompiler.java | 10 +--
.../drill/exec/compile/DrillJavaFileManager.java | 4 +-
.../drill/exec/compile/DrillJavaFileObject.java | 2 +-
.../org/apache/drill/exec/compile/FsmCursor.java | 2 +-
.../apache/drill/exec/compile/FsmDescriptor.java | 2 +-
.../drill/exec/compile/JDKClassCompiler.java | 4 +-
.../org/apache/drill/exec/compile/LogWriter.java | 2 +-
.../apache/drill/exec/compile/MergeAdapter.java | 2 +-
.../drill/exec/compile/QueryClassLoader.java | 2 +-
.../exec/compile/bytecode/InstructionModifier.java | 2 +-
.../compile/bytecode/ReplacingInterpreter.java | 4 +-
.../compile/bytecode/ScalarReplacementTypes.java | 2 +-
.../exec/compile/bytecode/ValueHolderIden.java | 2 +-
.../exec/compile/sig/CodeGeneratorMethod.java | 4 +-
.../compile/sig/ConstantExpressionIdentifier.java | 2 +-
.../drill/exec/compile/sig/GeneratorMapping.java | 2 +-
.../apache/drill/exec/compile/sig/MappingSet.java | 2 +-
.../drill/exec/compile/sig/SignatureHolder.java | 8 +--
.../exec/coord/local/LocalClusterCoordinator.java | 2 +-
.../drill/exec/coord/local/MapBackedStore.java | 2 +-
.../drill/exec/coord/store/BaseTransientStore.java | 8 +--
.../coord/store/CachingTransientStoreFactory.java | 6 +-
.../exec/coord/store/TransientStoreConfig.java | 6 +-
.../coord/store/TransientStoreConfigBuilder.java | 2 +-
.../exec/coord/store/TransientStoreEvent.java | 4 +-
.../drill/exec/coord/zk/EventDispatcher.java | 4 +-
.../org/apache/drill/exec/coord/zk/PathUtils.java | 2 +-
.../drill/exec/coord/zk/ZKClusterCoordinator.java | 15 +++--
.../drill/exec/coord/zk/ZkEphemeralStore.java | 6 +-
.../exec/coord/zk/ZkTransientStoreFactory.java | 2 +-
.../drill/exec/coord/zk/ZookeeperClient.java | 8 +--
.../apache/drill/exec/dotdrill/DotDrillFile.java | 2 +-
.../apache/drill/exec/dotdrill/DotDrillUtil.java | 2 +-
.../java/org/apache/drill/exec/dotdrill/View.java | 4 +-
.../org/apache/drill/exec/expr/BatchReference.java | 2 +-
.../org/apache/drill/exec/expr/ClassGenerator.java | 6 +-
.../org/apache/drill/exec/expr/CloneVisitor.java | 2 +-
.../org/apache/drill/exec/expr/CodeGenerator.java | 2 +-
.../apache/drill/exec/expr/EqualityVisitor.java | 2 +-
.../apache/drill/exec/expr/EvaluationVisitor.java | 4 +-
.../exec/expr/ExpressionTreeMaterializer.java | 14 ++--
.../exec/expr/HoldingContainerExpression.java | 5 +-
.../drill/exec/expr/SingleClassStringWriter.java | 2 +-
.../drill/exec/expr/ValueVectorReadExpression.java | 2 +-
.../exec/expr/ValueVectorWriteExpression.java | 2 +-
.../drill/exec/expr/fn/DrillAggFuncHolder.java | 6 +-
.../apache/drill/exec/expr/fn/DrillFuncHolder.java | 4 +-
.../drill/exec/expr/fn/DrillSimpleFuncHolder.java | 2 +-
.../drill/exec/expr/fn/FunctionConverter.java | 4 +-
.../exec/expr/fn/FunctionGenerationHelper.java | 2 +-
.../expr/fn/FunctionImplementationRegistry.java | 12 ++--
.../drill/exec/expr/fn/FunctionInitializer.java | 2 +-
.../apache/drill/exec/expr/fn/ImportGrabber.java | 2 +-
.../drill/exec/expr/fn/MethodGrabbingVisitor.java | 2 +-
.../apache/drill/exec/expr/fn/ValueReference.java | 2 +-
.../drill/exec/expr/fn/WorkspaceReference.java | 2 +-
.../expr/fn/impl/AbstractSqlPatternMatcher.java | 2 +-
.../drill/exec/expr/fn/impl/MappifyUtility.java | 2 +-
.../exec/expr/fn/impl/StringFunctionHelpers.java | 2 +-
.../expr/fn/interpreter/InterpreterEvaluator.java | 4 +-
.../expr/fn/output/DefaultReturnTypeInference.java | 2 +-
.../fn/output/StringCastReturnTypeInference.java | 2 +-
.../expr/fn/registry/FunctionRegistryHolder.java | 10 +--
.../expr/fn/registry/LocalFunctionRegistry.java | 12 ++--
.../expr/fn/registry/RemoteFunctionRegistry.java | 4 +-
.../drill/exec/memory/RootAllocatorFactory.java | 2 +-
.../apache/drill/exec/ops/BaseOperatorContext.java | 2 +-
.../org/apache/drill/exec/ops/FragmentContext.java | 2 +-
.../apache/drill/exec/ops/FragmentContextImpl.java | 8 +--
.../org/apache/drill/exec/ops/OperatorContext.java | 2 +-
.../apache/drill/exec/ops/OperatorContextImpl.java | 6 +-
.../org/apache/drill/exec/ops/OperatorStats.java | 2 +-
.../org/apache/drill/exec/ops/QueryContext.java | 6 +-
.../org/apache/drill/exec/ops/UdfUtilities.java | 4 +-
.../drill/exec/ops/ViewExpansionContext.java | 2 +-
.../drill/exec/physical/EndpointAffinity.java | 2 +-
.../apache/drill/exec/physical/PhysicalPlan.java | 2 +-
.../drill/exec/physical/base/AbstractBase.java | 2 +-
.../drill/exec/physical/base/AbstractExchange.java | 6 +-
.../exec/physical/base/AbstractGroupScan.java | 2 +-
.../drill/exec/physical/base/AbstractJoinPop.java | 2 +-
.../drill/exec/physical/base/AbstractReceiver.java | 12 ++--
.../drill/exec/physical/base/AbstractSender.java | 2 +-
.../drill/exec/physical/base/AbstractSingle.java | 4 +-
.../drill/exec/physical/base/AbstractSubScan.java | 5 +-
.../apache/drill/exec/physical/base/GroupScan.java | 2 +-
.../exec/physical/base/PhysicalOperatorUtil.java | 2 +-
.../drill/exec/physical/base/SchemalessScan.java | 2 +-
.../physical/config/AbstractDeMuxExchange.java | 10 +--
.../exec/physical/config/AbstractMuxExchange.java | 10 +--
.../drill/exec/physical/config/FlattenPOP.java | 2 +-
.../drill/exec/physical/config/HashJoinPOP.java | 6 +-
.../drill/exec/physical/config/LateralJoinPOP.java | 2 +-
.../drill/exec/physical/config/MergeJoinPOP.java | 4 +-
.../exec/physical/config/NestedLoopJoinPOP.java | 2 +-
.../physical/config/OrderedPartitionExchange.java | 2 +-
.../physical/config/OrderedPartitionSender.java | 2 +-
.../exec/physical/config/SingleMergeExchange.java | 2 +-
.../drill/exec/physical/config/UnionExchange.java | 2 +-
.../drill/exec/physical/config/UnnestPOP.java | 4 +-
.../apache/drill/exec/physical/config/Values.java | 4 +-
.../drill/exec/physical/impl/ImplCreator.java | 8 +--
.../apache/drill/exec/physical/impl/ScanBatch.java | 4 +-
.../drill/exec/physical/impl/ScreenCreator.java | 2 +-
.../physical/impl/TopN/PriorityQueueTemplate.java | 2 +-
.../drill/exec/physical/impl/TopN/TopNBatch.java | 2 +-
.../physical/impl/TopN/TopNSortBatchCreator.java | 2 +-
.../drill/exec/physical/impl/TraceInjector.java | 2 +-
.../exec/physical/impl/aggregate/HashAggBatch.java | 2 +-
.../impl/aggregate/HashAggBatchCreator.java | 2 +-
.../physical/impl/aggregate/StreamingAggBatch.java | 2 +-
.../impl/aggregate/StreamingAggBatchCreator.java | 2 +-
.../broadcastsender/BroadcastSenderCreator.java | 2 +-
.../broadcastsender/BroadcastSenderRootExec.java | 2 +-
.../exec/physical/impl/common/HashPartition.java | 4 +-
.../impl/common/HashTableAllocationTracker.java | 2 +-
.../physical/impl/common/HashTableTemplate.java | 2 +-
.../physical/impl/filter/FilterBatchCreator.java | 2 +-
.../physical/impl/filter/FilterRecordBatch.java | 2 +-
.../impl/filter/ReturnValueExpression.java | 2 +-
.../impl/filter/RuntimeFilterBatchCreator.java | 2 +-
.../physical/impl/flatten/FlattenBatchCreator.java | 2 +-
.../physical/impl/flatten/FlattenRecordBatch.java | 2 +-
.../physical/impl/flatten/FlattenTemplate.java | 2 +-
.../physical/impl/join/BatchSizePredictorImpl.java | 2 +-
.../exec/physical/impl/join/HashJoinBatch.java | 4 +-
.../physical/impl/join/HashJoinBatchCreator.java | 2 +-
.../join/HashJoinHelperSizeCalculatorImpl.java | 2 +-
.../join/HashJoinMechanicalMemoryCalculator.java | 2 +-
.../impl/join/HashJoinMemoryCalculator.java | 4 +-
.../impl/join/HashJoinMemoryCalculatorImpl.java | 4 +-
.../HashTableSizeCalculatorConservativeImpl.java | 2 +-
.../impl/join/HashTableSizeCalculatorLeanImpl.java | 2 +-
.../drill/exec/physical/impl/join/JoinStatus.java | 2 +-
.../exec/physical/impl/join/LateralJoinBatch.java | 4 +-
.../exec/physical/impl/join/MergeJoinBatch.java | 4 +-
.../exec/physical/impl/join/MergeJoinCreator.java | 2 +-
.../physical/impl/join/NestedLoopJoinBatch.java | 4 +-
.../physical/impl/limit/LimitBatchCreator.java | 2 +-
.../exec/physical/impl/limit/LimitRecordBatch.java | 4 +-
.../impl/limit/PartitionLimitBatchCreator.java | 2 +-
.../impl/limit/PartitionLimitRecordBatch.java | 2 +-
.../impl/mergereceiver/MergingRecordBatch.java | 4 +-
.../OrderedPartitionProjectorTemplate.java | 2 +-
.../OrderedPartitionRecordBatch.java | 4 +-
.../OrderedPartitionSenderCreator.java | 2 +-
.../partitionsender/PartitionSenderRootExec.java | 2 +-
.../impl/partitionsender/PartitionerDecorator.java | 6 +-
.../impl/partitionsender/PartitionerTemplate.java | 2 +-
.../producer/ProducerConsumerBatchCreator.java | 2 +-
.../impl/project/ComplexToJsonBatchCreator.java | 2 +-
.../physical/impl/project/OutputWidthVisitor.java | 2 +-
.../physical/impl/project/ProjectBatchCreator.java | 2 +-
.../impl/project/ProjectMemoryManager.java | 2 +-
.../physical/impl/project/ProjectRecordBatch.java | 6 +-
.../physical/impl/project/ProjectorTemplate.java | 2 +-
.../exec/physical/impl/sort/RecordBatchData.java | 2 +-
.../exec/physical/impl/sort/SortBatchCreator.java | 2 +-
.../physical/impl/sort/SortRecordBatchBuilder.java | 4 +-
.../exec/physical/impl/sort/SortTemplate.java | 4 +-
.../drill/exec/physical/impl/spill/SpillSet.java | 6 +-
.../physical/impl/svremover/SVRemoverCreator.java | 2 +-
.../physical/impl/svremover/StraightCopier.java | 2 +-
.../physical/impl/union/UnionAllBatchCreator.java | 2 +-
.../physical/impl/union/UnionAllRecordBatch.java | 4 +-
.../physical/impl/union/UnionAllerTemplate.java | 2 +-
.../exec/physical/impl/unnest/UnnestImpl.java | 4 +-
.../physical/impl/unnest/UnnestRecordBatch.java | 4 +-
.../impl/validate/IteratorValidatorCreator.java | 2 +-
.../impl/validate/IteratorValidatorInjector.java | 2 +-
.../exec/physical/impl/window/WindowDataBatch.java | 2 +-
.../impl/window/WindowFrameBatchCreator.java | 2 +-
.../impl/window/WindowFrameRecordBatch.java | 4 +-
.../drill/exec/physical/impl/xsort/BatchGroup.java | 2 +-
.../physical/impl/xsort/ExternalSortBatch.java | 10 +--
.../impl/xsort/ExternalSortBatchCreator.java | 2 +-
.../exec/physical/impl/xsort/MSortTemplate.java | 4 +-
.../impl/xsort/SingleBatchSorterTemplate.java | 4 +-
.../physical/impl/xsort/managed/BatchGroup.java | 2 +-
.../impl/xsort/managed/BufferedBatches.java | 2 +-
.../physical/impl/xsort/managed/MSortTemplate.java | 4 +-
.../xsort/managed/PriorityQueueCopierWrapper.java | 2 +-
.../exec/physical/impl/xsort/managed/SortImpl.java | 2 +-
.../impl/xsort/managed/SortMemoryManager.java | 2 +-
.../physical/impl/xsort/managed/SpilledRuns.java | 2 +-
.../exec/planner/DFSDirPartitionLocation.java | 2 +-
.../planner/FileSystemPartitionDescriptor.java | 13 ++--
.../exec/planner/ParquetPartitionDescriptor.java | 6 +-
.../drill/exec/planner/PhysicalPlanReader.java | 2 +-
.../apache/drill/exec/planner/PlannerPhase.java | 6 +-
.../exec/planner/SimplePartitionLocation.java | 2 +-
.../exec/planner/common/DrillJoinRelBase.java | 2 +-
.../planner/common/DrillLateralJoinRelBase.java | 4 +-
.../exec/planner/common/DrillProjectRelBase.java | 2 +-
.../drill/exec/planner/common/DrillRelOptUtil.java | 4 +-
.../exec/planner/common/DrillValuesRelBase.java | 12 ++--
.../exec/planner/common/DrillWriterRelBase.java | 4 +-
.../cost/DrillDefaultRelMetadataProvider.java | 2 +-
.../drill/exec/planner/fragment/Fragment.java | 2 +-
.../fragment/HardAffinityFragmentParallelizer.java | 4 +-
.../drill/exec/planner/fragment/Materializer.java | 2 +-
.../exec/planner/fragment/ParallelizationInfo.java | 8 +--
.../drill/exec/planner/fragment/PlanningSet.java | 2 +-
.../exec/planner/fragment/SimpleParallelizer.java | 8 +--
.../fragment/SoftAffinityFragmentParallelizer.java | 6 +-
.../exec/planner/fragment/StatsCollector.java | 2 +-
.../drill/exec/planner/fragment/Wrapper.java | 6 +-
.../contrib/ExchangeRemoverMaterializer.java | 2 +-
.../fragment/contrib/SplittingParallelizer.java | 4 +-
.../logical/DirPrunedEnumerableTableScan.java | 2 +-
.../exec/planner/logical/DrillAggregateRel.java | 2 +-
.../exec/planner/logical/DrillConstExecutor.java | 4 +-
.../exec/planner/logical/DrillImplementor.java | 2 +-
.../drill/exec/planner/logical/DrillJoinRule.java | 2 +-
.../drill/exec/planner/logical/DrillOptiq.java | 4 +-
.../exec/planner/logical/DrillProjectRel.java | 2 +-
.../logical/DrillPushFilterPastProjectRule.java | 2 +-
.../planner/logical/DrillPushLimitToScanRule.java | 2 +-
.../logical/DrillPushProjectIntoScanRule.java | 6 +-
.../planner/logical/DrillReduceAggregatesRule.java | 6 +-
.../exec/planner/logical/DrillRelFactories.java | 3 +-
.../drill/exec/planner/logical/DrillScanRel.java | 2 +-
.../drill/exec/planner/logical/DrillSortRel.java | 4 +-
.../drill/exec/planner/logical/DrillValuesRel.java | 6 +-
.../drill/exec/planner/logical/DrillViewTable.java | 2 +-
.../drill/exec/planner/logical/DrillWindowRel.java | 2 +-
.../drill/exec/planner/logical/DrillWriterRel.java | 4 +-
.../exec/planner/logical/PreProcessLogicalRel.java | 2 +-
.../exec/planner/logical/ScanFieldDeterminer.java | 6 +-
.../drill/exec/planner/logical/StoragePlugins.java | 4 +-
.../logical/partition/FindPartitionConditions.java | 2 +-
.../planner/logical/partition/PruneScanRule.java | 6 +-
.../partition/RewriteAsBinaryOperators.java | 4 +-
.../partition/RewriteCombineBinaryOperators.java | 4 +-
.../drill/exec/planner/physical/AggPrelBase.java | 2 +-
.../drill/exec/planner/physical/AggPruleBase.java | 2 +-
.../planner/physical/ConvertCountToDirectScan.java | 2 +-
.../planner/physical/DrillDistributionTrait.java | 2 +-
.../drill/exec/planner/physical/HashAggPrule.java | 4 +-
.../drill/exec/planner/physical/HashJoinPrel.java | 2 +-
.../drill/exec/planner/physical/HashPrelUtil.java | 4 +-
.../planner/physical/HashToRandomExchangePrel.java | 2 +-
.../drill/exec/planner/physical/JoinPrel.java | 2 +-
.../drill/exec/planner/physical/JoinPruleBase.java | 4 +-
.../exec/planner/physical/LateralJoinPrel.java | 4 +-
.../drill/exec/planner/physical/MergeJoinPrel.java | 2 +-
.../exec/planner/physical/MergeJoinPrule.java | 2 +-
.../exec/planner/physical/NestedLoopJoinPrule.java | 2 +-
.../exec/planner/physical/PhysicalPlanCreator.java | 2 +-
.../drill/exec/planner/physical/PrelUtil.java | 2 +-
.../exec/planner/physical/ProjectAllowDupPrel.java | 2 +-
.../drill/exec/planner/physical/ProjectPrel.java | 2 +-
.../drill/exec/planner/physical/ProjectPrule.java | 4 +-
.../drill/exec/planner/physical/SortPrel.java | 2 +-
.../drill/exec/planner/physical/SortPrule.java | 4 +-
.../exec/planner/physical/StreamAggPrule.java | 4 +-
.../exec/planner/physical/SubsetTransformer.java | 2 +-
.../drill/exec/planner/physical/TopNPrel.java | 2 +-
.../drill/exec/planner/physical/UnionAllPrel.java | 2 +-
.../drill/exec/planner/physical/UnionAllPrule.java | 6 +-
.../exec/planner/physical/UnionDistinctPrel.java | 2 +-
.../exec/planner/physical/UnionDistinctPrule.java | 2 +-
.../drill/exec/planner/physical/ValuesPrel.java | 8 ++-
.../drill/exec/planner/physical/WindowPrel.java | 4 +-
.../drill/exec/planner/physical/WindowPrule.java | 8 +--
.../drill/exec/planner/physical/WriterPrule.java | 4 +-
.../physical/explain/NumberingRelWriter.java | 2 +-
.../planner/physical/explain/PrelSequencer.java | 4 +-
.../visitor/AdjustOperatorsSchemaVisitor.java | 4 +-
.../visitor/ExcessiveExchangeIdentifier.java | 2 +-
.../physical/visitor/FinalColumnReorderer.java | 2 +-
.../visitor/InsertLocalExchangeVisitor.java | 2 +-
.../visitor/LateralUnnestRowIDVisitor.java | 2 +-
.../visitor/ProducerConsumerPrelVisitor.java | 2 +-
.../planner/physical/visitor/RelUniqifier.java | 4 +-
.../physical/visitor/RewriteProjectToFlatten.java | 2 +-
.../physical/visitor/RuntimeFilterVisitor.java | 2 +-
.../visitor/SelectionVectorPrelVisitor.java | 2 +-
.../visitor/SplitUpComplexExpressions.java | 4 +-
.../physical/visitor/StarColumnConverter.java | 2 +-
.../physical/visitor/SwapHashJoinVisitor.java | 2 +-
.../org/apache/drill/exec/planner/sql/Checker.java | 2 +-
.../drill/exec/planner/sql/DrillOperatorTable.java | 6 +-
.../exec/planner/sql/DrillSqlAggOperator.java | 2 +-
.../drill/exec/planner/sql/DrillSqlOperator.java | 2 +-
.../sql/DrillSqlOperatorWithoutInference.java | 2 +-
.../exec/planner/sql/ExpandingConcurrentMap.java | 2 +-
.../drill/exec/planner/sql/SchemaUtilites.java | 6 +-
.../drill/exec/planner/sql/SqlConverter.java | 8 +--
.../drill/exec/planner/sql/TypeInferenceUtils.java | 6 +-
.../planner/sql/handlers/ComplexUnnestVisitor.java | 2 +-
.../sql/handlers/CreateFunctionHandler.java | 4 +-
.../planner/sql/handlers/CreateTableHandler.java | 4 +-
.../planner/sql/handlers/DefaultSqlHandler.java | 10 +--
.../sql/handlers/DescribeSchemaHandler.java | 2 +-
.../planner/sql/handlers/DropFunctionHandler.java | 2 +-
.../planner/sql/handlers/FindLimit0Visitor.java | 4 +-
.../planner/sql/handlers/SqlHandlerConfig.java | 2 +-
.../exec/planner/sql/handlers/SqlHandlerUtil.java | 4 +-
.../sql/parser/CompoundIdentifierConverter.java | 2 +-
.../sql/parser/DrillCompoundIdentifier.java | 6 +-
.../exec/planner/sql/parser/DrillParserUtil.java | 2 +-
.../exec/planner/sql/parser/SqlCreateFunction.java | 2 +-
.../exec/planner/sql/parser/SqlCreateTable.java | 6 +-
.../exec/planner/sql/parser/SqlCreateView.java | 4 +-
.../exec/planner/sql/parser/SqlDropFunction.java | 2 +-
.../exec/planner/sql/parser/SqlDropTable.java | 2 +-
.../drill/exec/planner/sql/parser/SqlDropView.java | 2 +-
.../planner/sql/parser/SqlRefreshMetadata.java | 4 +-
.../exec/planner/sql/parser/SqlShowSchemas.java | 2 +-
.../exec/planner/sql/parser/SqlShowTables.java | 2 +-
.../sql/parser/UnsupportedOperatorsVisitor.java | 2 +-
.../planner/types/AbstractRelDataTypeHolder.java | 4 +-
.../planner/types/DrillFixedRelDataTypeImpl.java | 2 +-
.../exec/planner/types/RelDataTypeHolder.java | 2 +-
.../record/AbstractTableFunctionRecordBatch.java | 2 +-
.../org/apache/drill/exec/record/BatchSchema.java | 4 +-
.../drill/exec/record/HyperVectorWrapper.java | 2 +-
.../drill/exec/record/RecordBatchLoader.java | 2 +-
.../exec/record/RecordBatchMemoryManager.java | 2 +-
.../apache/drill/exec/record/RecordBatchSizer.java | 2 +-
.../apache/drill/exec/record/RecordIterator.java | 4 +-
.../apache/drill/exec/record/SchemaBuilder.java | 2 +-
.../org/apache/drill/exec/record/SchemaUtil.java | 8 +--
.../drill/exec/record/SimpleVectorWrapper.java | 2 +-
.../org/apache/drill/exec/record/TypedFieldId.java | 2 +-
.../apache/drill/exec/record/VectorContainer.java | 6 +-
.../drill/exec/record/VectorInitializer.java | 2 +-
.../apache/drill/exec/record/WritableBatch.java | 4 +-
.../metadata/RepeatedListColumnMetadata.java | 2 +-
.../drill/exec/record/metadata/VariantSchema.java | 2 +-
.../record/selection/SelectionVector4Builder.java | 2 +-
.../exec/resolver/DefaultFunctionResolver.java | 2 +-
.../drill/exec/resolver/ExactFunctionResolver.java | 2 +-
.../apache/drill/exec/resolver/TypeCastRules.java | 4 +-
.../drill/exec/rpc/AbstractClientConnection.java | 2 +-
.../AbstractDisposableUserClientConnection.java | 2 +-
.../drill/exec/rpc/AbstractServerConnection.java | 4 +-
.../org/apache/drill/exec/rpc/BitRpcUtility.java | 2 +-
.../rpc/control/ConnectionManagerRegistry.java | 2 +-
.../drill/exec/rpc/control/ControlConnection.java | 2 +-
.../exec/rpc/control/ControlConnectionConfig.java | 2 +-
.../drill/exec/rpc/control/ControllerImpl.java | 2 +-
.../exec/rpc/control/CustomHandlerRegistry.java | 2 +-
.../drill/exec/rpc/control/WorkEventBus.java | 2 +-
.../org/apache/drill/exec/rpc/data/AckSender.java | 2 +-
.../drill/exec/rpc/data/DataConnectionCreator.java | 2 +-
.../drill/exec/rpc/data/IncomingDataBatch.java | 2 +-
.../drill/exec/rpc/security/AuthStringUtil.java | 6 +-
.../rpc/security/AuthenticatorProviderImpl.java | 2 +-
.../exec/rpc/security/FastSaslClientFactory.java | 6 +-
.../exec/rpc/security/FastSaslServerFactory.java | 6 +-
.../exec/rpc/security/SecurityConfiguration.java | 2 +-
.../rpc/security/ServerAuthenticationHandler.java | 6 +-
.../exec/rpc/user/InboundImpersonationManager.java | 4 +-
.../drill/exec/rpc/user/QueryResultHandler.java | 4 +-
.../org/apache/drill/exec/rpc/user/UserClient.java | 14 ++--
.../apache/drill/exec/rpc/user/UserRpcConfig.java | 4 +-
.../apache/drill/exec/rpc/user/UserRpcUtils.java | 2 +-
.../apache/drill/exec/rpc/user/UserSession.java | 6 +-
.../user/security/UserAuthenticatorFactory.java | 2 +-
.../org/apache/drill/exec/schema/DataRecord.java | 6 +-
.../org/apache/drill/exec/schema/DiffSchema.java | 2 +-
.../java/org/apache/drill/exec/schema/Field.java | 10 +--
.../org/apache/drill/exec/schema/ListSchema.java | 8 +--
.../org/apache/drill/exec/schema/NamedField.java | 46 +++++++-------
.../org/apache/drill/exec/schema/ObjectSchema.java | 8 +--
.../org/apache/drill/exec/schema/OrderedField.java | 34 +++++-----
.../exec/serialization/JacksonSerializer.java | 2 +-
.../drill/exec/serialization/ProtoSerializer.java | 4 +-
.../org/apache/drill/exec/server/Drillbit.java | 4 +-
.../apache/drill/exec/server/DrillbitContext.java | 2 +-
.../exec/server/options/FallbackOptionManager.java | 2 +-
.../exec/server/options/FragmentOptionManager.java | 2 +-
.../exec/server/options/OptionDefinition.java | 2 +-
.../drill/exec/server/options/OptionValue.java | 2 +-
.../exec/server/options/PersistedOptionValue.java | 2 +-
.../exec/server/options/SessionOptionManager.java | 4 +-
.../exec/server/options/SystemOptionManager.java | 4 +-
.../drill/exec/server/options/TypeValidators.java | 4 +-
.../drill/exec/server/rest/DrillRestServer.java | 2 +-
.../apache/drill/exec/server/rest/DrillRoot.java | 6 +-
.../exec/server/rest/LogInLogOutResources.java | 2 +-
.../drill/exec/server/rest/LogsResources.java | 4 +-
.../drill/exec/server/rest/QueryResources.java | 6 +-
.../drill/exec/server/rest/QueryWrapper.java | 2 +-
.../drill/exec/server/rest/StorageResources.java | 2 +-
.../drill/exec/server/rest/UserNameFilter.java | 2 +-
.../exec/server/rest/ViewableWithPermissions.java | 2 +-
.../drill/exec/server/rest/WebUserConnection.java | 6 +-
.../auth/DrillHttpConstraintSecurityHandler.java | 2 +-
.../auth/DrillHttpSecurityHandlerProvider.java | 2 +-
.../exec/server/rest/auth/DrillUserPrincipal.java | 2 +-
.../drill/exec/server/rest/profile/Filters.java | 4 +-
.../exec/server/rest/profile/FragmentWrapper.java | 4 +-
.../exec/server/rest/profile/OperatorWrapper.java | 2 +-
.../exec/server/rest/profile/ProfileResources.java | 2 +-
.../exec/server/rest/profile/ProfileWrapper.java | 4 +-
.../apache/drill/exec/service/ServiceEngine.java | 2 +-
.../org/apache/drill/exec/ssl/SSLConfigServer.java | 2 +-
.../drill/exec/store/AbstractRecordReader.java | 4 +-
.../apache/drill/exec/store/AbstractSchema.java | 6 +-
.../drill/exec/store/AbstractStoragePlugin.java | 2 +-
.../drill/exec/store/ClassPathFileSystem.java | 2 +-
.../apache/drill/exec/store/ColumnExplorer.java | 4 +-
.../drill/exec/store/ResourceInputStream.java | 2 +-
.../org/apache/drill/exec/store/SchemaConfig.java | 4 +-
.../drill/exec/store/SchemaTreeProvider.java | 2 +-
.../apache/drill/exec/store/StoragePluginMap.java | 6 +-
.../exec/store/StoragePluginRegistryImpl.java | 20 +++---
.../exec/store/StoragePluginsHandlerService.java | 4 +-
.../apache/drill/exec/store/StorageStrategy.java | 2 +-
.../apache/drill/exec/store/SubSchemaWrapper.java | 2 +-
.../org/apache/drill/exec/store/TimedCallable.java | 8 +--
.../drill/exec/store/avro/AvroDrillTable.java | 2 +-
.../drill/exec/store/avro/AvroFormatPlugin.java | 4 +-
.../drill/exec/store/avro/AvroRecordReader.java | 4 +-
.../drill/exec/store/bson/BsonRecordReader.java | 2 +-
.../drill/exec/store/dfs/BasicFormatMatcher.java | 6 +-
.../drill/exec/store/dfs/DrillFileSystem.java | 4 +-
.../apache/drill/exec/store/dfs/FileSelection.java | 8 +--
.../drill/exec/store/dfs/FileSystemPlugin.java | 4 +-
.../store/dfs/FormatPluginOptionExtractor.java | 2 +-
.../drill/exec/store/dfs/MetadataContext.java | 2 +-
.../exec/store/dfs/WorkspaceSchemaFactory.java | 32 ++++------
.../exec/store/dfs/easy/EasyFormatPlugin.java | 8 +--
.../drill/exec/store/dfs/easy/EasyGroupScan.java | 8 +--
.../drill/exec/store/dfs/easy/EasySubScan.java | 2 +-
.../drill/exec/store/dfs/easy/EasyWriter.java | 2 +-
.../exec/store/easy/json/JSONFormatPlugin.java | 2 +-
.../exec/store/easy/json/JSONRecordReader.java | 4 +-
.../exec/store/easy/json/JsonRecordWriter.java | 2 +-
.../store/easy/json/reader/BaseJsonProcessor.java | 2 +-
.../sequencefile/SequenceFileFormatConfig.java | 2 +-
.../sequencefile/SequenceFileRecordReader.java | 2 +-
.../exec/store/easy/text/TextFormatPlugin.java | 2 +-
.../text/compliant/CompliantTextRecordReader.java | 6 +-
.../store/easy/text/compliant/HeaderBuilder.java | 2 +-
.../easy/text/compliant/RepeatedVarCharOutput.java | 2 +-
.../exec/store/easy/text/compliant/TextInput.java | 2 +-
.../easy/text/compliant/TextParsingSettings.java | 2 +-
.../exec/store/httpd/HttpdLogFormatPlugin.java | 4 +-
.../drill/exec/store/httpd/HttpdLogRecord.java | 4 +-
.../apache/drill/exec/store/httpd/HttpdParser.java | 4 +-
.../drill/exec/store/image/ImageFormatConfig.java | 2 +-
.../drill/exec/store/ischema/InfoSchemaFilter.java | 2 +-
.../store/ischema/InfoSchemaFilterBuilder.java | 4 +-
.../exec/store/ischema/InfoSchemaGroupScan.java | 2 +-
.../InfoSchemaPushFilterIntoRecordGenerator.java | 2 +-
.../store/ischema/InfoSchemaRecordGenerator.java | 8 +--
.../store/ischema/InfoSchemaStoragePlugin.java | 2 +-
.../drill/exec/store/ischema/InfoSchemaTable.java | 4 +-
.../apache/drill/exec/store/ischema/Records.java | 2 +-
.../drill/exec/store/log/LogFormatConfig.java | 2 +-
.../drill/exec/store/log/LogFormatPlugin.java | 2 +-
.../drill/exec/store/log/LogRecordReader.java | 2 +-
.../drill/exec/store/mock/MockGroupScanPOP.java | 2 +-
.../exec/store/mock/MockScanBatchCreator.java | 2 +-
.../drill/exec/store/mock/MockStorageEngine.java | 6 +-
.../drill/exec/store/mock/MockSubScanPOP.java | 2 +-
.../store/parquet/AbstractParquetGroupScan.java | 6 +-
.../parquet/AbstractParquetScanBatchCreator.java | 6 +-
.../drill/exec/store/parquet/FooterGatherer.java | 2 +-
.../exec/store/parquet/ParquetFilterBuilder.java | 2 +-
.../exec/store/parquet/ParquetFormatPlugin.java | 4 +-
.../drill/exec/store/parquet/ParquetGroupScan.java | 4 +-
.../exec/store/parquet/ParquetPushDownFilter.java | 6 +-
.../store/parquet/ParquetRGFilterEvaluator.java | 2 +-
.../exec/store/parquet/ParquetReaderUtility.java | 2 +-
.../exec/store/parquet/ParquetRecordWriter.java | 2 +-
.../exec/store/parquet/ParquetRowGroupScan.java | 2 +-
.../store/parquet/ParquetScanBatchCreator.java | 2 +-
.../drill/exec/store/parquet/ParquetWriter.java | 2 +-
.../parquet/columnreaders/AsyncPageReader.java | 2 +-
.../store/parquet/columnreaders/BatchReader.java | 6 +-
.../columnreaders/FixedByteAlignedReader.java | 4 +-
.../NullableFixedByteAlignedReaders.java | 4 +-
.../store/parquet/columnreaders/PageReader.java | 4 +-
.../ParquetFixedWidthDictionaryReaders.java | 4 +-
.../parquet/columnreaders/ParquetRecordReader.java | 4 +-
.../store/parquet/columnreaders/ParquetSchema.java | 2 +-
.../columnreaders/ParquetToDrillTypeConverter.java | 2 +-
.../parquet/columnreaders/VarLenBinaryReader.java | 6 +-
.../columnreaders/VarLenBulkPageReader.java | 2 +-
.../columnreaders/VarLenEntryDictionaryReader.java | 2 +-
.../parquet/columnreaders/VarLenEntryReader.java | 2 +-
.../columnreaders/VarLenFixedEntryReader.java | 2 +-
.../VarLenNullableDictionaryReader.java | 2 +-
.../columnreaders/VarLenNullableEntryReader.java | 2 +-
.../VarLenNullableFixedEntryReader.java | 2 +-
.../columnreaders/VarLenOverflowReader.java | 2 +-
.../decimal/Int32DecimalParquetValueWriter.java | 2 +-
.../decimal/Int64DecimalParquetValueWriter.java | 2 +-
.../exec/store/parquet/metadata/Metadata.java | 6 +-
.../store/parquet/metadata/MetadataPathUtils.java | 2 +-
.../store/parquet/metadata/MetadataVersion.java | 6 +-
.../parquet/stat/ParquetFooterStatCollector.java | 2 +-
.../parquet/stat/ParquetMetaStatCollector.java | 2 +-
.../store/parquet2/DrillParquetGroupConverter.java | 6 +-
.../exec/store/parquet2/DrillParquetReader.java | 6 +-
.../drill/exec/store/pcap/PcapDrillTable.java | 2 +-
.../drill/exec/store/pcap/PcapFormatPlugin.java | 4 +-
.../drill/exec/store/pcap/PcapFormatUtils.java | 4 +-
.../drill/exec/store/pcap/PcapRecordReader.java | 4 +-
.../drill/exec/store/pcap/decoder/Packet.java | 2 +-
.../exec/store/pcap/decoder/PacketDecoder.java | 2 +-
.../exec/store/pojo/DynamicPojoRecordReader.java | 2 +-
.../apache/drill/exec/store/pojo/PojoWriters.java | 2 +-
.../drill/exec/store/schedule/AffinityCreator.java | 4 +-
.../exec/store/schedule/AssignmentCreator.java | 12 ++--
.../drill/exec/store/schedule/BlockMapBuilder.java | 14 ++--
.../exec/store/sys/ExtendedOptionIterator.java | 2 +-
.../drill/exec/store/sys/OptionIterator.java | 4 +-
.../exec/store/sys/PersistentStoreConfig.java | 4 +-
.../exec/store/sys/PersistentStoreRegistry.java | 2 +-
.../drill/exec/store/sys/ProfileInfoIterator.java | 4 +-
.../drill/exec/store/sys/ProfileJsonIterator.java | 4 +-
.../exec/store/sys/SystemTableBatchCreator.java | 2 +-
.../drill/exec/store/sys/SystemTableScan.java | 2 +-
.../drill/exec/store/sys/VersionIterator.java | 2 +-
.../drill/exec/store/sys/store/InMemoryStore.java | 2 +-
.../exec/store/sys/store/LocalPersistentStore.java | 8 +--
.../store/sys/store/ZookeeperPersistentStore.java | 6 +-
.../provider/CachingPersistentStoreProvider.java | 4 +-
.../provider/ZookeeperPersistentStoreProvider.java | 2 +-
.../exec/store/text/DrillTextRecordReader.java | 8 +--
.../exec/store/text/DrillTextRecordWriter.java | 2 +-
.../exec/testing/CountDownLatchInjectionImpl.java | 2 +-
.../drill/exec/testing/ExecutionControls.java | 2 +-
.../exec/testing/ExecutionControlsInjector.java | 2 +-
.../apache/drill/exec/testing/InjectionSite.java | 2 +-
.../exec/testing/store/NoWriteLocalStore.java | 4 +-
.../drill/exec/util/ArrayWrappedIntIntMap.java | 2 +-
.../org/apache/drill/exec/util/BatchPrinter.java | 2 +-
.../apache/drill/exec/util/ImpersonationUtil.java | 12 ++--
.../drill/exec/util/MemoryAllocationUtilities.java | 2 +-
.../drill/exec/util/StoragePluginTestUtils.java | 2 +-
.../java/org/apache/drill/exec/util/Utilities.java | 6 +-
.../org/apache/drill/exec/util/VectorUtil.java | 4 +-
.../filereader/BufferedDirectBufInputStream.java | 4 +-
.../exec/util/filereader/DirectBufInputStream.java | 4 +-
.../exec/vector/complex/fn/BasicJsonOutput.java | 2 +-
.../exec/vector/complex/fn/FieldSelection.java | 2 +-
.../drill/exec/vector/complex/fn/JsonReader.java | 6 +-
.../exec/vector/complex/fn/JsonReaderUtils.java | 2 +-
.../exec/vector/complex/fn/WorkingBuffer.java | 2 +-
.../org/apache/drill/exec/work/QueryWorkUnit.java | 2 +-
.../org/apache/drill/exec/work/WorkManager.java | 6 +-
.../exec/work/batch/AbstractDataCollector.java | 2 +-
.../drill/exec/work/batch/IncomingBuffers.java | 4 +-
.../drill/exec/work/batch/ResponseSenderQueue.java | 4 +-
.../exec/work/batch/SpoolingRawBatchBuffer.java | 8 +--
.../exec/work/batch/UnlimitedRawBatchBuffer.java | 2 +-
.../apache/drill/exec/work/filter/BloomFilter.java | 2 +-
.../exec/work/filter/RuntimeFilterManager.java | 2 +-
.../apache/drill/exec/work/foreman/Foreman.java | 4 +-
.../drill/exec/work/foreman/FragmentsRunner.java | 8 +--
.../drill/exec/work/foreman/QueryManager.java | 6 +-
.../exec/work/foreman/rm/EmbeddedQueryQueue.java | 2 +-
.../work/foreman/rm/ThrottledResourceManager.java | 4 +-
.../exec/work/fragment/NonRootFragmentManager.java | 2 +-
.../drill/exec/work/metadata/MetadataProvider.java | 8 +--
.../exec/work/metadata/ServerMetaProvider.java | 4 +-
.../work/prepare/PreparedStatementProvider.java | 2 +-
.../apache/drill/exec/work/user/PlanSplitter.java | 2 +-
.../hadoop/ParquetColumnChunkPageWriteStore.java | 6 +-
.../test/java/org/apache/drill/PlanTestBase.java | 2 +-
.../test/java/org/apache/drill/PlanningBase.java | 8 +--
.../test/java/org/apache/drill/TestBugFixes.java | 2 +-
.../java/org/apache/drill/TestFrameworkTest.java | 2 +-
.../drill/TestFunctionsWithTypeExpoQueries.java | 2 +-
.../java/org/apache/drill/TestImplicitCasting.java | 2 +-
.../drill/TestTpchDistributedConcurrent.java | 2 +-
.../test/java/org/apache/drill/TestUnionAll.java | 2 +-
.../java/org/apache/drill/TestUnionDistinct.java | 2 +-
.../drill/exec/DrillSeparatePlanningTest.java | 2 +-
.../org/apache/drill/exec/DrillSystemTestBase.java | 6 +-
.../test/java/org/apache/drill/exec/ExecTest.java | 2 +-
.../java/org/apache/drill/exec/RunRootExec.java | 8 +--
.../org/apache/drill/exec/TestEmptyInputSql.java | 2 +-
.../org/apache/drill/exec/TestOpSerialization.java | 2 +-
.../apache/drill/exec/TestQueriesOnLargeFile.java | 16 ++---
.../org/apache/drill/exec/ZookeeperHelper.java | 4 +-
.../apache/drill/exec/cache/TestWriteToDisk.java | 4 +-
.../drill/exec/client/DrillClientSystemTest.java | 4 +-
.../org/apache/drill/exec/client/DumpCatTest.java | 6 +-
.../exec/compile/CodeCompilerTestFactory.java | 2 +-
.../exec/compile/bytecode/ReplaceMethodInvoke.java | 4 +-
.../drill/exec/coord/zk/TestZookeeperClient.java | 2 +-
.../exec/expr/fn/FunctionInitializerTest.java | 2 +-
.../exec/expr/fn/impl/TestStringFunctions.java | 2 +-
.../fn/registry/FunctionRegistryHolderTest.java | 8 +--
.../drill/exec/fn/impl/TestAggregateFunction.java | 6 +-
.../drill/exec/fn/impl/TestAggregateFunctions.java | 6 +-
.../drill/exec/fn/impl/TestCastFunctions.java | 4 +-
.../drill/exec/fn/impl/TestDateFunctions.java | 6 +-
.../drill/exec/fn/impl/TestMathFunctions.java | 6 +-
.../drill/exec/fn/impl/TestMultiInputAdd.java | 6 +-
.../exec/fn/impl/TestNewAggregateFunctions.java | 8 +--
.../drill/exec/fn/impl/TestNewMathFunctions.java | 4 +-
.../drill/exec/fn/impl/TestRepeatedFunction.java | 6 +-
.../exec/fn/interp/ExpressionInterpreterTest.java | 2 +-
.../drill/exec/fn/interp/TestConstantFolding.java | 4 +-
.../exec/impersonation/BaseTestImpersonation.java | 4 +-
.../TestImpersonationDisabledWithMiniDFS.java | 2 +-
.../impersonation/TestImpersonationMetadata.java | 4 +-
.../impersonation/TestImpersonationQueries.java | 2 +-
.../impersonation/TestInboundImpersonation.java | 2 +-
.../TestInboundImpersonationPrivileges.java | 10 +--
.../apache/drill/exec/memory/TestAllocators.java | 10 +--
.../physical/config/TestParsePhysicalPlan.java | 6 +-
.../drill/exec/physical/impl/MockRecordBatch.java | 2 +-
.../drill/exec/physical/impl/SimpleRootExec.java | 2 +-
.../exec/physical/impl/TestBroadcastExchange.java | 12 ++--
.../exec/physical/impl/TestCastFunctions.java | 22 +++----
.../physical/impl/TestCastVarCharToBigInt.java | 8 +--
.../physical/impl/TestComparisonFunctions.java | 4 +-
.../exec/physical/impl/TestConvertFunctions.java | 4 +-
.../drill/exec/physical/impl/TestDecimal.java | 28 ++++----
.../physical/impl/TestDistributedFragmentRun.java | 12 ++--
.../exec/physical/impl/TestExtractFunctions.java | 13 ++--
.../physical/impl/TestHashToRandomExchange.java | 8 +--
.../physical/impl/TestImplicitCastFunctions.java | 4 +-
.../exec/physical/impl/TestLocalExchange.java | 6 +-
.../physical/impl/TestReverseImplicitCast.java | 6 +-
.../exec/physical/impl/TestSimpleFragmentRun.java | 8 +--
.../exec/physical/impl/TestSimpleFunctions.java | 10 +--
.../exec/physical/impl/TestStringFunctions.java | 4 +-
.../exec/physical/impl/TestUnionExchange.java | 10 +--
.../physical/impl/TopN/TestTopNEmitOutcome.java | 2 +-
.../exec/physical/impl/TopN/TopNBatchTest.java | 2 +-
.../drill/exec/physical/impl/agg/TestAgg.java | 6 +-
.../physical/impl/agg/TestAggWithAnyValue.java | 2 +-
.../exec/physical/impl/agg/TestHashAggBatch.java | 6 +-
.../physical/impl/common/HashPartitionTest.java | 2 +-
.../common/HashTableAllocationTrackerTest.java | 2 +-
.../physical/impl/filter/TestSimpleFilter.java | 8 +--
.../exec/physical/impl/flatten/TestFlatten.java | 2 +-
.../exec/physical/impl/join/PartitionStatImpl.java | 4 +-
.../impl/join/TestBuildSidePartitioningImpl.java | 2 +-
.../exec/physical/impl/join/TestHashJoin.java | 18 +++---
.../exec/physical/impl/join/TestHashJoinJPPD.java | 2 +-
.../exec/physical/impl/join/TestHashJoinSpill.java | 2 +-
...estHashTableSizeCalculatorConservativeImpl.java | 2 +-
.../join/TestHashTableSizeCalculatorLeanImpl.java | 2 +-
.../exec/physical/impl/join/TestMergeJoin.java | 36 +++++------
.../impl/join/TestMergeJoinMulCondition.java | 18 +++---
.../impl/join/TestPostBuildCalculationsImpl.java | 4 +-
.../impl/limit/TestEarlyLimit0Optimization.java | 2 +-
.../physical/impl/limit/TestLimitOperator.java | 2 +-
.../exec/physical/impl/limit/TestSimpleLimit.java | 8 +--
.../impl/mergereceiver/TestMergingReceiver.java | 24 +++----
.../TestOrderedPartitionExchange.java | 10 +--
.../impl/partitionsender/TestPartitionSender.java | 2 +-
.../impl/project/TestSimpleProjection.java | 6 +-
.../exec/physical/impl/sort/TestSimpleSort.java | 8 +--
.../impl/trace/TestTraceMultiRecordBatch.java | 6 +-
.../physical/impl/trace/TestTraceOutputDump.java | 14 ++--
.../exec/physical/impl/union/TestSimpleUnion.java | 6 +-
.../unnest/TestUnnestWithLateralCorrectness.java | 2 +-
.../physical/impl/writer/TestParquetWriter.java | 4 +-
.../exec/physical/impl/writer/TestWriter.java | 6 +-
.../impl/xsort/managed/SortTestUtilities.java | 2 +-
.../impl/xsort/managed/TestExternalSortExec.java | 2 +-
.../impl/xsort/managed/TestSortEmitOutcome.java | 2 +-
.../physical/impl/xsort/managed/TestSortImpl.java | 4 +-
.../physical/impl/xsort/managed/TestSorter.java | 2 +-
.../exec/physical/rowSet/impl/RowSetTestUtils.java | 2 +-
.../impl/TestResultSetLoaderEmptyProject.java | 2 +-
.../rowSet/impl/TestResultSetLoaderOverflow.java | 2 +-
.../rowSet/impl/TestResultSetLoaderTorture.java | 2 +-
.../physical/unit/BasicPhysicalOpUnitTest.java | 2 +-
.../exec/physical/unit/MiniPlanUnitTestBase.java | 4 +-
.../drill/exec/physical/unit/TestMiniPlan.java | 2 +-
.../exec/physical/unit/TestNullInputMiniPlan.java | 2 +-
.../exec/physical/unit/TestOutputBatchSize.java | 4 +-
.../exec/planner/TestDirectoryExplorerUDFs.java | 6 +-
.../TestHardAffinityFragmentParallelizer.java | 4 +-
.../planner/logical/DrillLogicalTestutils.java | 2 +-
.../drill/exec/planner/logical/DrillOptiqTest.java | 7 +-
.../org/apache/drill/exec/pop/PopUnitTestBase.java | 6 +-
.../apache/drill/exec/pop/TestFragmentChecker.java | 2 +-
.../apache/drill/exec/pop/TestInjectionValue.java | 6 +-
.../record/ExpressionTreeMaterializerTest.java | 4 +-
.../drill/exec/record/TestRecordIterator.java | 17 ++---
.../drill/exec/record/TestVectorContainer.java | 2 +-
.../drill/exec/record/vector/TestDateTypes.java | 22 +++----
.../drill/exec/record/vector/TestValueVector.java | 4 +-
.../drill/exec/rpc/data/TestBitBitKerberos.java | 6 +-
.../org/apache/drill/exec/rpc/data/TestBitRpc.java | 4 +-
.../rpc/user/security/TestUserBitKerberos.java | 2 +-
.../security/TestUserBitKerberosEncryption.java | 2 +-
.../security/TestUserBitSaslCompatibility.java | 2 +-
.../drill/exec/server/TestDrillbitResilience.java | 2 +-
.../drill/exec/server/TestOptionsAuthEnabled.java | 2 +-
.../exec/server/rest/TestMainLoginPageModel.java | 2 +-
.../rest/spnego/TestDrillSpnegoAuthenticator.java | 2 +-
.../rest/spnego/TestSpnegoAuthentication.java | 2 +-
.../exec/server/rest/spnego/TestSpnegoConfig.java | 2 +-
.../apache/drill/exec/sql/TestBaseViewSupport.java | 2 +-
.../java/org/apache/drill/exec/sql/TestCTAS.java | 2 +-
.../java/org/apache/drill/exec/sql/TestCTTAS.java | 2 +-
.../drill/exec/sql/TestSimpleCastFunctions.java | 4 +-
.../org/apache/drill/exec/sql/TestViewSupport.java | 2 +-
.../drill/exec/store/StorageStrategyTest.java | 4 +-
.../drill/exec/store/TestAffinityCalculator.java | 4 +-
.../drill/exec/store/TestImplicitFileColumns.java | 8 +--
.../apache/drill/exec/store/TestOutputMutator.java | 4 +-
.../drill/exec/store/avro/AvroFormatTest.java | 2 +-
.../drill/exec/store/dfs/TestFileSelection.java | 2 +-
.../easy/text/compliant/TestHeaderBuilder.java | 2 +-
.../store/parquet/ParquetRecordReaderTest.java | 26 ++++----
.../exec/store/parquet/ParquetResultListener.java | 4 +-
.../store/parquet/TestParquetMetadataCache.java | 2 +-
.../store/parquet/TestParquetPhysicalPlan.java | 6 +-
.../drill/exec/store/parquet/TestParquetScan.java | 2 +-
.../drill/exec/store/pcap/TestPcapDecoder.java | 2 +-
.../drill/exec/store/store/TestAssignment.java | 8 +--
.../drill/exec/store/sys/PStoreTestUtil.java | 2 +-
.../drill/exec/store/text/TestCsvHeader.java | 2 +-
.../exec/store/text/TextRecordReaderTest.java | 8 +--
.../org/apache/drill/exec/testing/Controls.java | 2 +-
.../drill/exec/testing/TestResourceLeak.java | 4 +-
.../exec/udf/dynamic/TestDynamicUDFSupport.java | 2 +-
.../drill/exec/util/FileSystemUtilTestBase.java | 4 +-
.../exec/vector/complex/writer/TestJsonReader.java | 8 +--
.../org/apache/drill/exec/work/batch/FileTest.java | 2 +-
.../drill/exec/work/batch/TestSpoolingBuffer.java | 10 +--
.../TestLimit0VsRegularQueriesMetadata.java | 4 +-
.../prepare/TestPreparedStatementProvider.java | 2 +-
.../org/apache/drill/test/BaseDirTestWatcher.java | 2 +-
.../java/org/apache/drill/test/BaseFixture.java | 2 +-
.../java/org/apache/drill/test/BaseTestQuery.java | 6 +-
.../drill/test/BufferingQueryEventListener.java | 2 +-
.../java/org/apache/drill/test/ClusterFixture.java | 6 +-
.../apache/drill/test/ClusterFixtureBuilder.java | 2 +-
.../org/apache/drill/test/DrillTestWrapper.java | 2 +-
.../drill/test/LegacyOperatorTestBuilder.java | 4 +-
.../org/apache/drill/test/OperatorFixture.java | 14 ++--
.../org/apache/drill/test/OperatorTestBuilder.java | 2 +-
.../apache/drill/test/OperatorTestBuilderTest.java | 2 +-
.../java/org/apache/drill/test/ProfileParser.java | 2 +-
.../java/org/apache/drill/test/QueryBuilder.java | 2 +-
.../org/apache/drill/test/RestClientFixture.java | 2 +-
.../java/org/apache/drill/test/TestBuilder.java | 4 +-
.../org/apache/drill/test/rowSet/DirectRowSet.java | 2 +-
.../apache/drill/test/rowSet/IndirectRowSet.java | 2 +-
.../apache/drill/test/rowSet/RowSetBuilder.java | 2 +-
.../apache/drill/test/rowSet/RowSetComparison.java | 6 +-
.../drill/test/rowSet/file/JsonFileBuilder.java | 8 +--
.../drill/test/rowSet/test/PerformanceTool.java | 2 +-
.../test/rowSet/test/TestScalarAccessors.java | 2 +-
.../test/rowSet/test/TestVariableWidthWriter.java | 2 +-
exec/jdbc-all/pom.xml | 22 ++++++-
.../drill/jdbc/impl/DrillColumnMetaDataList.java | 2 +-
.../drill/jdbc/impl/DrillConnectionImpl.java | 4 +-
.../org/apache/drill/jdbc/impl/DrillCursor.java | 4 +-
.../drill/jdbc/impl/DrillDatabaseMetaDataImpl.java | 16 ++---
.../org/apache/drill/jdbc/impl/DrillMetaImpl.java | 6 +-
.../apache/drill/jdbc/impl/DrillResultSetImpl.java | 2 +-
.../java/org/apache/drill/jdbc/ConnectionInfo.java | 6 +-
.../java/org/apache/drill/jdbc/DriverTest.java | 2 +-
.../java/org/apache/drill/jdbc/JdbcTestBase.java | 6 +-
.../drill/jdbc/MultiConnectionCachingFactory.java | 2 +-
.../apache/drill/jdbc/NonClosableConnection.java | 2 +-
.../apache/drill/jdbc/PreparedStatementTest.java | 2 +-
.../Bug1735ResultSetCloseReleasesBuffersTest.java | 2 +-
.../test/java/org/apache/drill/jdbc/test/Hook.java | 2 +-
.../org/apache/drill/jdbc/test/JdbcDataTest.java | 10 +--
.../apache/drill/jdbc/test/JdbcTestActionBase.java | 2 +-
.../apache/drill/jdbc/test/JdbcTestQueryBase.java | 2 +-
.../apache/drill/jdbc/test/TestJdbcDistQuery.java | 4 +-
.../org/apache/drill/jdbc/test/TestJdbcQuery.java | 2 +-
.../src/main/java/io/netty/buffer/DrillBuf.java | 2 +-
.../org/apache/drill/exec/memory/Accountant.java | 4 +-
.../drill/exec/memory/AllocationManager.java | 4 +-
.../apache/drill/exec/memory/BaseAllocator.java | 2 +-
.../apache/drill/exec/memory/BoundsChecking.java | 2 +-
.../apache/drill/exec/memory/RootAllocator.java | 2 +-
.../org/apache/drill/exec/rpc/BasicClient.java | 2 +-
.../org/apache/drill/exec/rpc/BasicServer.java | 2 +-
.../drill/exec/rpc/ChunkCreationHandler.java | 2 +-
.../org/apache/drill/exec/rpc/DrillRpcFuture.java | 2 +-
.../apache/drill/exec/rpc/DrillRpcFutureImpl.java | 4 +-
.../apache/drill/exec/rpc/FutureBitCommand.java | 2 +-
.../apache/drill/exec/rpc/OutboundRpcMessage.java | 2 +-
.../drill/exec/rpc/ReconnectingConnection.java | 4 +-
.../org/apache/drill/exec/rpc/RequestIdMap.java | 2 +-
.../java/org/apache/drill/exec/rpc/RpcBus.java | 4 +-
.../apache/drill/exec/rpc/RpcCheckedFuture.java | 4 +-
.../java/org/apache/drill/exec/rpc/RpcConfig.java | 6 +-
.../security/AuthenticationOutcomeListener.java | 6 +-
.../src/main/codegen/includes/vv_imports.ftl | 14 ++--
.../main/codegen/templates/ColumnAccessors.java | 2 +-
.../src/main/codegen/templates/MapWriters.java | 2 +-
.../src/main/codegen/templates/UnionVector.java | 4 +-
.../exec/expr/fn/impl/ByteFunctionHelpers.java | 2 +-
.../drill/exec/record/metadata/TupleNameSpace.java | 2 +-
.../org/apache/drill/exec/util/DecimalUtility.java | 2 +-
.../apache/drill/exec/vector/AddOrGetResult.java | 2 +-
.../apache/drill/exec/vector/BaseValueVector.java | 2 +-
.../org/apache/drill/exec/vector/BitVector.java | 2 +-
.../drill/exec/vector/UntypedNullVector.java | 2 +-
.../drill/exec/vector/ValueHolderHelper.java | 2 +-
.../apache/drill/exec/vector/VectorDescriptor.java | 2 +-
.../exec/vector/accessor/impl/VectorPrinter.java | 2 +-
.../vector/accessor/reader/ArrayReaderImpl.java | 2 +-
.../vector/complex/AbstractContainerVector.java | 8 +--
.../exec/vector/complex/AbstractMapVector.java | 4 +-
.../vector/complex/BaseRepeatedValueVector.java | 4 +-
.../exec/vector/complex/EmptyValuePopulator.java | 2 +-
.../drill/exec/vector/complex/ListVector.java | 2 +-
.../drill/exec/vector/complex/MapVector.java | 6 +-
.../exec/vector/complex/RepeatedListVector.java | 4 +-
.../exec/vector/complex/RepeatedMapVector.java | 2 +-
.../vector/complex/impl/ComplexWriterImpl.java | 2 +-
.../vector/complex/impl/RepeatedMapReaderImpl.java | 2 +-
.../vector/complex/impl/SingleMapReaderImpl.java | 2 +-
.../java/org/apache/drill/common/JSONOptions.java | 2 +-
.../drill/common/expression/CastExpression.java | 2 +-
.../drill/common/expression/ErrorCollector.java | 2 +-
.../common/expression/ErrorCollectorImpl.java | 6 +-
.../common/expression/ExpressionFunction.java | 4 +-
.../common/expression/ExpressionStringBuilder.java | 2 +-
.../drill/common/expression/FunctionCall.java | 4 +-
.../common/expression/FunctionCallFactory.java | 2 +-
.../expression/FunctionHolderExpression.java | 4 +-
.../drill/common/expression/IfExpression.java | 6 +-
.../drill/common/expression/NullExpression.java | 5 +-
.../apache/drill/common/expression/SchemaPath.java | 2 +-
.../drill/common/expression/TypedNullConstant.java | 5 +-
.../drill/common/expression/ValueExpressions.java | 30 ++++-----
.../common/expression/fn/JodaDateValidator.java | 2 +-
.../visitors/ConditionalExprOptimizer.java | 2 +-
.../apache/drill/common/graph/AdjacencyList.java | 6 +-
.../drill/common/logical/LogicalPlanBuilder.java | 4 +-
.../common/logical/data/AbstractSingleBuilder.java | 2 +-
.../apache/drill/common/logical/data/Filter.java | 2 +-
.../apache/drill/common/logical/data/Flatten.java | 2 +-
.../common/logical/data/GroupingAggregate.java | 4 +-
.../org/apache/drill/common/logical/data/Join.java | 6 +-
.../drill/common/logical/data/LateralJoin.java | 2 +-
.../apache/drill/common/logical/data/Limit.java | 2 +-
.../apache/drill/common/logical/data/Order.java | 8 +--
.../apache/drill/common/logical/data/Project.java | 2 +-
.../common/logical/data/RunningAggregate.java | 2 +-
.../common/logical/data/SingleInputOperator.java | 2 +-
.../drill/common/logical/data/SourceOperator.java | 5 +-
.../apache/drill/common/logical/data/Store.java | 2 +-
.../drill/common/logical/data/Transform.java | 2 +-
.../apache/drill/common/logical/data/Union.java | 2 +-
.../apache/drill/common/logical/data/Values.java | 2 +-
.../apache/drill/common/logical/data/Window.java | 6 +-
.../expression/fn/JodaDateValidatorTest.java | 2 +-
pom.xml | 18 ++++--
src/main/resources/checkstyle-config.xml | 5 +-
.../java/org/apache/drill/fmpp/mojo/FMPPMojo.java | 2 +-
1004 files changed, 2290 insertions(+), 2014 deletions(-)
create mode 100644
common/src/main/java/org/apache/drill/common/util/GuavaUtils.java
create mode 100644 docs/dev/UpgradeGuava.md
create mode 100644 drill-shaded/drill-shaded-guava/pom.xml
create mode 100644 drill-shaded/pom.xml
