DRILL-6320: Fixed license headers. closes #1207
Project: http://git-wip-us.apache.org/repos/asf/drill/repo Commit: http://git-wip-us.apache.org/repos/asf/drill/commit/62f14690 Tree: http://git-wip-us.apache.org/repos/asf/drill/tree/62f14690 Diff: http://git-wip-us.apache.org/repos/asf/drill/diff/62f14690 Branch: refs/heads/master Commit: 62f14690870568364723dc77494043a9854a0447 Parents: 1ce7d37 Author: Drill Dev <[email protected]> Authored: Fri Apr 13 10:24:45 2018 -0700 Committer: Arina Ielchiieva <[email protected]> Committed: Tue Apr 17 08:59:59 2018 +0300 ---------------------------------------------------------------------- .travis.yml | 3 +- common/pom.xml | 31 ++++++++-------- .../drill/common/AutoCloseablePointer.java | 2 +- .../org/apache/drill/common/AutoCloseables.java | 2 +- .../drill/common/CatastrophicFailure.java | 2 +- .../apache/drill/common/DeferredException.java | 2 +- .../drill/common/DrillAutoCloseables.java | 2 +- .../org/apache/drill/common/EventProcessor.java | 2 +- .../org/apache/drill/common/HistoricalLog.java | 2 +- .../org/apache/drill/common/KerberosUtil.java | 2 +- .../drill/common/SelfCleaningRunnable.java | 2 +- .../org/apache/drill/common/StackTrace.java | 2 +- .../common/collections/ImmutableEntry.java | 6 ++-- .../common/collections/MapWithOrdinal.java | 2 +- .../common/concurrent/AutoCloseableLock.java | 2 +- .../drill/common/concurrent/ExtendedLatch.java | 2 +- .../drill/common/config/CommonConstants.java | 2 +- .../drill/common/config/ConfigProvider.java | 2 +- .../apache/drill/common/config/DrillConfig.java | 2 +- .../drill/common/config/NestedConfig.java | 2 +- .../drill/common/config/package-info.java | 2 +- .../exceptions/DrillConfigurationException.java | 2 +- .../drill/common/exceptions/DrillError.java | 2 +- .../drill/common/exceptions/DrillException.java | 2 +- .../common/exceptions/DrillIOException.java | 2 +- .../exceptions/DrillRuntimeException.java | 2 +- .../drill/common/exceptions/ErrorHelper.java | 2 +- .../exceptions/RetryAfterSpillException.java | 2 +- .../drill/common/exceptions/UserException.java | 2 +- .../common/exceptions/UserExceptionContext.java | 2 +- .../common/exceptions/UserRemoteException.java | 2 +- .../drill/common/exceptions/package-info.java | 2 +- .../org/apache/drill/common/package-info.java | 2 +- .../drill/common/scanner/BuildTimeScan.java | 2 +- .../drill/common/scanner/ClassPathScanner.java | 2 +- .../drill/common/scanner/RunTimeScan.java | 2 +- .../persistence/AnnotatedClassDescriptor.java | 2 +- .../persistence/AnnotationDescriptor.java | 2 +- .../persistence/AttributeDescriptor.java | 2 +- .../persistence/ChildClassDescriptor.java | 2 +- .../scanner/persistence/FieldDescriptor.java | 2 +- .../persistence/ParentClassDescriptor.java | 2 +- .../common/scanner/persistence/ScanResult.java | 2 +- .../scanner/persistence/TypeDescriptor.java | 2 +- .../apache/drill/common/types/package-info.java | 2 +- .../drill/common/util/ConstructorChecker.java | 2 +- .../drill/common/util/CoreDecimalUtility.java | 2 +- .../drill/common/util/DataInputInputStream.java | 2 +- .../common/util/DataOutputOutputStream.java | 2 +- .../util/DecimalScalePrecisionAddFunction.java | 2 +- .../DecimalScalePrecisionDivideFunction.java | 3 +- .../util/DecimalScalePrecisionModFunction.java | 3 +- .../util/DecimalScalePrecisionMulFunction.java | 3 +- .../util/DrillBaseComputeScalePrecision.java | 2 +- .../drill/common/util/DrillFileUtils.java | 2 +- .../drill/common/util/DrillStringUtils.java | 2 +- .../drill/common/util/RepeatTestRule.java | 2 +- .../apache/drill/common/util/package-info.java | 2 +- .../apache/drill/exec/metrics/DrillMetrics.java | 2 +- .../apache/drill/exec/util/AssertionUtil.java | 2 +- .../drill/exec/util/SystemPropertyUtil.java | 2 +- .../drill/categories/HbaseStorageTest.java | 3 +- .../drill/categories/HiveStorageTest.java | 3 +- .../drill/categories/JdbcStorageTest.java | 3 +- .../org/apache/drill/categories/JdbcTest.java | 3 +- .../drill/categories/KafkaStorageTest.java | 1 - .../drill/categories/KuduStorageTest.java | 3 +- .../org/apache/drill/categories/MemoryTest.java | 3 +- .../drill/categories/MongoStorageTest.java | 3 +- .../apache/drill/categories/OperatorTest.java | 3 +- .../apache/drill/categories/OptionsTest.java | 3 +- .../apache/drill/categories/ParquetTest.java | 3 +- .../apache/drill/categories/PlannerTest.java | 3 +- .../apache/drill/categories/SecurityTest.java | 3 +- .../drill/categories/SqlFunctionTest.java | 3 +- .../org/apache/drill/categories/SqlTest.java | 3 +- .../org/apache/drill/categories/VectorTest.java | 3 +- .../apache/drill/categories/package-info.java | 3 +- .../common/exceptions/TestUserException.java | 2 +- .../common/map/TestCaseInsensitiveMap.java | 2 +- .../org/apache/drill/test/DirTestWatcher.java | 1 - ...rill2130CommonHamcrestConfigurationTest.java | 2 +- .../java/org/apache/drill/test/DrillAssert.java | 2 +- .../apache/drill/test/SubDirTestWatcher.java | 1 - .../apache/drill/test/UserExceptionMatcher.java | 2 +- common/src/test/resources/logback-test.xml | 29 +++++++++------ contrib/data/pom.xml | 27 +++++++------- contrib/data/tpch-sample-data/bin/pom.xml | 29 +++++++++------ contrib/data/tpch-sample-data/pom.xml | 29 +++++++++------ contrib/format-maprdb/pom.xml | 27 +++++++------- .../exec/store/mapr/TableFormatPlugin.java | 2 +- .../store/mapr/TableFormatPluginConfig.java | 2 +- .../exec/store/mapr/db/MapRDBGroupScan.java | 2 +- .../store/mapr/db/MapRDBPushFilterIntoScan.java | 2 +- .../exec/store/mapr/db/MapRDBSubScanSpec.java | 2 +- .../exec/store/mapr/db/MapRDBTableStats.java | 2 +- .../exec/store/mapr/db/TabletFragmentInfo.java | 2 +- .../mapr/db/json/CompareFunctionsProcessor.java | 2 +- .../exec/store/mapr/db/json/JsonScanSpec.java | 2 +- .../store/mapr/db/json/JsonSubScanSpec.java | 2 +- .../exec/store/mapr/db/util/CommonFns.java | 2 +- .../store/mapr/db/util/FieldPathHelper.java | 31 ++++++++-------- .../mapr/streams/StreamsFormatMatcher.java | 2 +- .../store/mapr/streams/StreamsFormatPlugin.java | 2 +- .../mapr/streams/StreamsFormatPluginConfig.java | 2 +- .../src/main/resources/checkstyle-config.xml | 29 +++++++++------ .../main/resources/checkstyle-suppressions.xml | 29 +++++++++------ .../drill/maprdb/tests/MaprDBTestsSuite.java | 2 +- .../tests/binary/TestMapRDBCFAsJSONString.java | 2 +- .../tests/binary/TestMapRDBFilterPushDown.java | 2 +- .../tests/binary/TestMapRDBProjectPushDown.java | 2 +- .../maprdb/tests/binary/TestMapRDBQueries.java | 2 +- .../maprdb/tests/binary/TestMapRDBSimple.java | 2 +- .../drill/maprdb/tests/json/BaseJsonTest.java | 2 +- .../src/test/resources/hbase-site.xml | 27 +++++++------- contrib/gis/pom.xml | 27 +++++++------- .../exec/expr/fn/impl/gis/STAsGeoJSON.java | 1 - .../drill/exec/expr/fn/impl/gis/STAsJson.java | 1 - .../drill/exec/expr/fn/impl/gis/STAsText.java | 2 +- .../drill/exec/expr/fn/impl/gis/STDWithin.java | 2 +- .../exec/expr/fn/impl/gis/STGeomFromText.java | 2 +- .../expr/fn/impl/gis/STGeomFromTextSrid.java | 2 +- .../exec/expr/fn/impl/gis/STPointFunc.java | 2 +- .../drill/exec/expr/fn/impl/gis/STWithin.java | 2 +- .../exec/expr/fn/impl/gis/GISTestSuite.java | 2 +- .../expr/fn/impl/gis/TestGeometryFunctions.java | 2 +- .../native/client/example/querySubmitter.cpp | 1 - contrib/native/client/readme.boost | 1 - contrib/native/client/readme.macos | 2 -- contrib/native/client/readme.sasl | 1 - contrib/native/client/readme.ssl | 1 - contrib/native/client/scripts/cpProtofiles.sh | 1 - contrib/native/client/scripts/fixProtodefs.sh | 1 - contrib/native/client/src/clientlib/channel.cpp | 1 - contrib/native/client/src/clientlib/channel.hpp | 1 - .../client/src/clientlib/collectionsImpl.hpp | 1 - .../client/src/clientlib/decimalUtils.cpp | 2 -- .../native/client/src/clientlib/drillClient.cpp | 1 - .../client/src/clientlib/drillClientImpl.cpp | 2 -- .../client/src/clientlib/drillClientImpl.hpp | 2 -- .../native/client/src/clientlib/drillConfig.cpp | 1 - .../native/client/src/clientlib/drillError.cpp | 2 -- contrib/native/client/src/clientlib/env.h.in | 1 - contrib/native/client/src/clientlib/errmsgs.cpp | 1 - contrib/native/client/src/clientlib/errmsgs.hpp | 1 - .../native/client/src/clientlib/fieldmeta.cpp | 1 - contrib/native/client/src/clientlib/logger.cpp | 33 +++++++++-------- contrib/native/client/src/clientlib/logger.hpp | 33 +++++++++-------- .../native/client/src/clientlib/metadata.cpp | 1 - .../native/client/src/clientlib/metadata.hpp | 2 -- .../native/client/src/clientlib/recordBatch.cpp | 1 - .../native/client/src/clientlib/rpcMessage.cpp | 2 -- .../native/client/src/clientlib/rpcMessage.hpp | 2 -- .../src/clientlib/saslAuthenticatorImpl.cpp | 1 - .../src/clientlib/saslAuthenticatorImpl.hpp | 1 - .../client/src/clientlib/streamSocket.hpp | 2 -- .../client/src/clientlib/userProperties.cpp | 1 - contrib/native/client/src/clientlib/utils.cpp | 33 +++++++++-------- contrib/native/client/src/clientlib/utils.hpp | 33 +++++++++-------- contrib/native/client/src/clientlib/wincert.ipp | 1 - .../native/client/src/clientlib/y2038/time64.c | 2 +- .../native/client/src/clientlib/y2038/time64.h | 2 +- .../client/src/clientlib/y2038/time64_config.h | 2 +- .../client/src/clientlib/y2038/time64_limits.h | 2 +- .../client/src/clientlib/zookeeperClient.cpp | 1 - .../client/src/clientlib/zookeeperClient.hpp | 1 - .../client/src/include/drill/collections.hpp | 1 - .../native/client/src/include/drill/common.hpp | 2 -- .../client/src/include/drill/decimalUtils.hpp | 2 -- .../client/src/include/drill/drillClient.hpp | 2 -- .../client/src/include/drill/drillConfig.hpp | 2 -- .../client/src/include/drill/drillError.hpp | 2 -- .../native/client/src/include/drill/drillc.hpp | 1 - .../client/src/include/drill/fieldmeta.hpp | 1 - .../src/include/drill/preparedStatement.hpp | 1 - .../client/src/include/drill/recordBatch.hpp | 1 - .../native/client/src/test/CollectionsTest.cpp | 1 - contrib/native/client/src/test/UtilsTest.cpp | 1 - contrib/native/client/src/test/main.cpp | 1 - contrib/native/client/test/ssl/testClient.cpp | 1 - contrib/native/client/test/ssl/testSSL.cpp | 1 - contrib/native/client/test/ssl/testServer.cpp | 2 -- contrib/pom.xml | 27 +++++++------- contrib/sqlline/pom.xml | 31 ++++++++-------- contrib/storage-hbase/pom.xml | 27 +++++++------- .../conv/OrderedBytesBigIntConvertFrom.java | 5 ++- .../impl/conv/OrderedBytesBigIntConvertTo.java | 5 ++- .../conv/OrderedBytesBigIntDescConvertTo.java | 5 ++- .../conv/OrderedBytesDoubleConvertFrom.java | 5 ++- .../impl/conv/OrderedBytesDoubleConvertTo.java | 5 ++- .../conv/OrderedBytesDoubleDescConvertTo.java | 5 ++- .../impl/conv/OrderedBytesFloatConvertFrom.java | 5 ++- .../impl/conv/OrderedBytesFloatConvertTo.java | 5 ++- .../conv/OrderedBytesFloatDescConvertTo.java | 5 ++- .../impl/conv/OrderedBytesIntConvertFrom.java | 5 ++- .../fn/impl/conv/OrderedBytesIntConvertTo.java | 5 ++- .../impl/conv/OrderedBytesIntDescConvertTo.java | 5 ++- .../exec/store/hbase/DrillHBaseConstants.java | 2 +- .../store/hbase/HBaseConnectionManager.java | 2 +- .../store/hbase/HBasePushFilterIntoScan.java | 3 +- .../exec/store/hbase/HBaseRegexParser.java | 2 +- .../exec/store/hbase/HBaseScanBatchCreator.java | 2 +- .../drill/exec/store/hbase/HBaseScanSpec.java | 2 +- .../store/hbase/HBaseStoragePluginConfig.java | 2 +- .../exec/store/hbase/TableStatsCalculator.java | 4 +-- .../store/hbase/config/HBasePStoreProvider.java | 6 ++-- .../config/HBasePersistentStoreProvider.java | 2 +- .../org/apache/drill/hbase/BaseHBaseTest.java | 2 +- .../drill/hbase/HBaseRecordReaderTest.java | 2 +- .../drill/hbase/TestHBaseCFAsJSONString.java | 2 +- .../drill/hbase/TestHBaseConnectionManager.java | 2 +- .../drill/hbase/TestHBaseFilterPushDown.java | 2 +- .../drill/hbase/TestHBaseProjectPushDown.java | 2 +- .../apache/drill/hbase/TestHBaseQueries.java | 2 +- .../drill/hbase/TestHBaseRegexParser.java | 2 +- .../hbase/TestHBaseRegionScanAssignments.java | 2 +- .../hbase/TestOrderedBytesConvertFunctions.java | 2 +- .../apache/drill/hbase/TestTableGenerator.java | 2 +- ...30StorageHBaseHamcrestConfigurationTest.java | 2 +- .../src/test/resources/hbase-site.xml | 36 +++++++++---------- contrib/storage-hive/core/pom.xml | 27 +++++++------- .../core/src/main/codegen/includes/license.ftl | 36 ++++++++++--------- .../codegen/templates/HiveRecordReaders.java | 1 - .../templates/ObjectInspectorHelper.java | 3 +- .../codegen/templates/ObjectInspectors.java | 2 +- .../drill/exec/expr/HiveFuncHolderExpr.java | 2 +- .../exec/expr/fn/HiveFunctionRegistry.java | 2 +- .../AbstractDrillPrimitiveObjectInspector.java | 2 +- .../expr/fn/impl/hive/DrillDeferredObject.java | 2 +- .../exec/planner/sql/HivePartitionLocation.java | 2 +- .../drill/exec/planner/sql/HiveUDFOperator.java | 3 +- .../sql/HiveUDFOperatorWithoutInference.java | 2 +- .../HivePushPartitionFilterIntoScan.java | 3 +- .../drill/exec/store/hive/ColumnListsCache.java | 31 ++++++++-------- .../store/hive/HiveAuthorizationHelper.java | 2 +- .../exec/store/hive/HiveFieldConverter.java | 2 +- .../drill/exec/store/hive/HivePartition.java | 31 ++++++++-------- .../drill/exec/store/hive/HiveReadEntry.java | 2 +- .../store/hive/HiveStoragePluginConfig.java | 2 +- .../store/hive/HiveTableWithColumnCache.java | 31 ++++++++-------- .../drill/exec/store/hive/HiveTableWrapper.java | 2 +- .../inspectors/AbstractRecordsInspector.java | 13 +++---- .../inspectors/DefaultRecordsInspector.java | 13 +++---- .../inspectors/SkipFooterRecordsInspector.java | 13 +++---- .../store/hive/schema/DrillHiveViewTable.java | 2 +- .../drill/exec/TestHivePartitionPruning.java | 2 +- .../drill/exec/TestHiveProjectPushDown.java | 2 +- .../drill/exec/fn/hive/HiveTestUDFImpls.java | 6 ++-- .../apache/drill/exec/fn/hive/TestHiveUDFs.java | 2 +- .../drill/exec/fn/hive/TestSampleHiveUDFs.java | 2 +- .../apache/drill/exec/hive/HiveTestBase.java | 4 +-- .../drill/exec/hive/HiveTestUtilities.java | 4 +-- .../apache/drill/exec/hive/TestHiveStorage.java | 2 +- .../exec/hive/TestInfoSchemaOnHiveStorage.java | 2 +- .../hive/BaseTestHiveImpersonation.java | 2 +- .../hive/TestSqlStdBasedAuthorization.java | 2 +- .../hive/TestStorageBasedHiveAuthorization.java | 2 +- .../sql/hive/TestViewSupportOnHiveTables.java | 4 +-- .../exec/store/hive/HiveTestDataGenerator.java | 1 - .../SkipFooterRecordsInspectorTest.java | 31 ++++++++-------- .../store/hive/schema/TestColumnListCache.java | 31 ++++++++-------- ...torageHiveCoreHamcrestConfigurationTest.java | 2 +- contrib/storage-hive/hive-exec-shade/pom.xml | 27 +++++++------- contrib/storage-hive/pom.xml | 27 +++++++------- contrib/storage-jdbc/pom.xml | 29 ++++++++------- .../drill/exec/store/jdbc/JdbcBatchCreator.java | 2 +- .../apache/drill/exec/store/jdbc/JdbcDrel.java | 2 +- .../drill/exec/store/jdbc/JdbcGroupScan.java | 2 +- .../exec/store/jdbc/JdbcIntermediatePrel.java | 2 +- .../drill/exec/store/jdbc/JdbcRecordReader.java | 2 +- .../exec/store/jdbc/JdbcStorageConfig.java | 2 +- .../drill/exec/store/jdbc/JdbcSubScan.java | 2 +- contrib/storage-kafka/pom.xml | 29 +++++++++------ contrib/storage-kudu/pom.xml | 29 +++++++++------ .../codegen/templates/KuduRecordWriter.java | 3 +- .../drill/exec/store/kudu/DrillKuduTable.java | 2 +- .../exec/store/kudu/KuduScanBatchCreator.java | 2 +- .../drill/exec/store/kudu/KuduScanSpec.java | 2 +- .../exec/store/kudu/KuduSchemaFactory.java | 2 +- .../exec/store/kudu/KuduStoragePlugin.java | 2 +- .../store/kudu/KuduStoragePluginConfig.java | 2 +- .../drill/exec/store/kudu/KuduWriter.java | 2 +- .../exec/store/kudu/KuduWriterBatchCreator.java | 2 +- .../drill/store/kudu/TestKuduConnect.java | 2 +- contrib/storage-mongo/pom.xml | 27 +++++++------- .../exec/store/mongo/DrillMongoConstants.java | 2 +- .../drill/exec/store/mongo/MongoCnxnKey.java | 2 +- .../mongo/MongoCompareFunctionProcessor.java | 2 +- .../drill/exec/store/mongo/MongoGroupScan.java | 2 +- .../store/mongo/MongoPushDownFilterForScan.java | 2 +- .../exec/store/mongo/MongoRecordReader.java | 2 +- .../exec/store/mongo/MongoScanBatchCreator.java | 2 +- .../drill/exec/store/mongo/MongoScanSpec.java | 2 +- .../exec/store/mongo/MongoStoragePlugin.java | 2 +- .../store/mongo/MongoStoragePluginConfig.java | 2 +- .../drill/exec/store/mongo/MongoSubScan.java | 2 +- .../drill/exec/store/mongo/MongoUtils.java | 2 +- .../exec/store/mongo/common/ChunkInfo.java | 2 +- .../exec/store/mongo/common/MongoCompareOp.java | 2 +- .../config/MongoPersistentStoreProvider.java | 2 +- .../drill/exec/store/mongo/package-info.java | 2 +- .../store/mongo/schema/MongoDatabaseSchema.java | 2 +- .../store/mongo/schema/MongoSchemaFactory.java | 2 +- .../drill/exec/store/mongo/MongoTestBase.java | 2 +- .../exec/store/mongo/MongoTestConstants.java | 2 +- .../store/mongo/TestMongoChunkAssignment.java | 2 +- .../store/mongo/TestMongoFilterPushDown.java | 2 +- .../store/mongo/TestMongoProjectPushDown.java | 2 +- .../exec/store/mongo/TestMongoQueries.java | 2 +- .../exec/store/mongo/TestTableGenerator.java | 2 +- contrib/storage-opentsdb/pom.xml | 27 +++++++------- distribution/pom.xml | 29 +++++++++------ distribution/src/assemble/bin.xml | 27 +++++++------- distribution/src/resources/auto-setup.sh | 17 +++++---- .../src/resources/core-site-example.xml | 28 ++++++++------- distribution/src/resources/distrib-env.sh | 17 +++++---- distribution/src/resources/distrib-setup.sh | 17 +++++---- distribution/src/resources/drill-am-log.xml | 31 ++++++++-------- distribution/src/resources/drill-am.sh | 16 +++++---- distribution/src/resources/drill-config.sh | 17 +++++---- distribution/src/resources/drill-env.sh | 18 +++++----- distribution/src/resources/drill-on-yarn.sh | 17 +++++---- distribution/src/resources/drill-setup.sh | 17 +++++---- distribution/src/resources/drillbit.sh | 4 +-- distribution/src/resources/logback.xml | 27 +++++++------- distribution/src/resources/saffron.properties | 15 ++++---- distribution/src/resources/sqlline.bat | 18 ++++++++++ distribution/src/resources/yarn-client-log.xml | 27 +++++++------- distribution/src/resources/yarn-drillbit.sh | 18 +++++----- drill-yarn/pom.xml | 27 +++++++------- .../yarn/appMaster/http/AuthDynamicFeature.java | 2 +- .../drill/yarn/appMaster/http/package-info.java | 3 +- .../drill/yarn/appMaster/package-info.java | 1 - .../apache/drill/yarn/client/package-info.java | 1 - .../apache/drill/yarn/core/package-info.java | 1 - .../org/apache/drill/yarn/package-info.java | 1 - .../org/apache/drill/yarn/zk/package-info.java | 1 - .../src/main/resources/drill-am/config.ftl | 28 +++++++++------ .../src/main/resources/drill-am/confirm.ftl | 28 +++++++++------ .../src/main/resources/drill-am/generic.ftl | 28 +++++++++------ .../src/main/resources/drill-am/history.ftl | 28 +++++++++------ .../src/main/resources/drill-am/index.ftl | 28 +++++++++------ .../src/main/resources/drill-am/login.ftl | 28 +++++++++------ .../src/main/resources/drill-am/manage.ftl | 28 +++++++++------ .../src/main/resources/drill-am/redirect.ftl | 28 +++++++++------ .../main/resources/drill-am/shrink-warning.ftl | 28 +++++++++------ .../src/main/resources/drill-am/tasks.ftl | 28 +++++++++------ .../src/test/resources/doy-test-logback.xml | 29 +++++++++------ drill-yarn/src/test/resources/wrapper.sh | 16 +++++---- .../org/apache/drill/exec/expr/TestPrune.java | 4 +-- exec/java-exec/pom.xml | 29 +++++++++------ .../codegen/includes/compoundIdentifier.ftl | 29 +++++++++------ .../src/main/codegen/includes/license.ftl | 35 +++++++++--------- .../src/main/codegen/includes/parserImpls.ftl | 28 +++++++++------ .../src/main/codegen/includes/vv_imports.ftl | 28 +++++++++------ .../codegen/templates/AbstractRecordWriter.java | 3 +- .../AggrBitwiseLogicalTypeFunctions.java | 2 +- .../codegen/templates/AggrTypeFunctions1.java | 2 +- .../codegen/templates/AggrTypeFunctions2.java | 2 +- .../codegen/templates/AggrTypeFunctions3.java | 2 +- .../main/codegen/templates/CastDateDate.java | 2 +- ...astEmptyStringVarTypesToNullableNumeric.java | 2 +- .../templates/CastFunctionsSrcVarLen.java | 2 +- .../src/main/codegen/templates/CastHigh.java | 2 +- .../codegen/templates/CastIntervalInterval.java | 2 +- .../codegen/templates/CastVarCharInterval.java | 2 +- .../codegen/templates/ComparisonFunctions.java | 4 +-- .../templates/CorrelationTypeFunctions.java | 2 +- .../templates/CountAggregateFunctions.java | 3 +- .../codegen/templates/CovarTypeFunctions.java | 2 +- .../templates/DateIntervalAggrFunctions1.java | 2 +- .../DateDateArithmeticFunctions.java | 3 +- .../DateIntervalArithmeticFunctions.java | 2 +- .../DateToCharFunctions.java | 3 +- .../DateTruncFunctions.java | 3 +- .../DateIntervalFunctionTemplates/Extract.java | 2 +- .../IntervalIntervalArithmetic.java | 2 +- .../IntervalNumericArithmetic.java | 2 +- .../SqlToDateTypeFunctions.java | 3 +- .../ToDateTypeFunctions.java | 3 +- .../ToTimeStampFunction.java | 3 +- .../templates/Decimal/CastDecimalFloat.java | 2 +- .../Decimal/DecimalAggrTypeFunctions1.java | 2 -- .../Decimal/DecimalAggrTypeFunctions2.java | 1 - .../templates/Decimal/DecimalFunctions.java | 1 - .../codegen/templates/DirectoryExplorers.java | 5 ++- .../codegen/templates/DrillVersionInfo.java | 5 ++- .../templates/EventBasedRecordWriter.java | 1 - .../templates/IntervalAggrFunctions2.java | 2 +- .../templates/JsonOutputRecordWriter.java | 3 +- .../templates/MathFunctionTemplates.java | 2 +- .../main/codegen/templates/MathFunctions.java | 2 +- .../codegen/templates/NewValueFunctions.java | 2 +- .../main/codegen/templates/NullOperator.java | 2 +- .../templates/NumericFunctionsTemplates.java | 3 +- .../templates/NumericToCharFunctions.java | 3 +- .../templates/ParquetOutputRecordWriter.java | 3 +- .../codegen/templates/ParquetTypeHelper.java | 3 +- .../codegen/templates/RecordValueAccessor.java | 2 +- .../main/codegen/templates/RecordWriter.java | 2 +- .../main/codegen/templates/SqlAccessors.java | 1 - .../templates/StringOutputRecordWriter.java | 1 - .../src/main/codegen/templates/SumZeroAggr.java | 2 +- .../src/main/codegen/templates/TypeHelper.java | 3 +- .../main/codegen/templates/UnionFunctions.java | 3 +- .../templates/VarCharAggrFunctions1.java | 2 +- .../apache/drill/exec/TestMemoryRetention.java | 2 +- .../exec/cache/AbstractStreamSerializable.java | 2 +- .../drill/exec/cache/CachedVectorContainer.java | 2 +- .../org/apache/drill/exec/cache/Counter.java | 2 +- .../drill/exec/cache/DistributedCache.java | 2 +- .../apache/drill/exec/cache/DistributedMap.java | 2 +- .../drill/exec/cache/DistributedMultiMap.java | 2 +- .../drill/exec/cache/DrillSerializable.java | 2 +- .../cache/LoopedAbstractDrillSerializable.java | 2 +- .../exec/cache/SerializationDefinition.java | 2 +- .../apache/drill/exec/cache/package-info.java | 2 +- .../apache/drill/exec/client/DrillClient.java | 2 +- .../drill/exec/client/QuerySubmitter.java | 2 +- .../apache/drill/exec/client/package-info.java | 2 +- .../exec/compile/AbstractClassCompiler.java | 2 +- .../org/apache/drill/exec/compile/AsmUtil.java | 2 +- .../drill/exec/compile/ByteCodeLoader.java | 2 +- .../drill/exec/compile/CachedClassLoader.java | 2 +- .../exec/compile/CheckClassVisitorFsm.java | 2 +- .../exec/compile/CheckMethodVisitorFsm.java | 2 +- .../drill/exec/compile/ClassBodyBuilder.java | 2 +- .../drill/exec/compile/CompilationConfig.java | 2 +- .../exec/compile/DrillCheckClassAdapter.java | 2 +- .../exec/compile/DrillDiagnosticListener.java | 2 +- .../exec/compile/DrillInitMethodVisitor.java | 2 +- .../exec/compile/DrillJavaFileManager.java | 2 +- .../drill/exec/compile/DrillJavaFileObject.java | 2 +- .../apache/drill/exec/compile/FsmCursor.java | 2 +- .../drill/exec/compile/FsmDescriptor.java | 2 +- .../exec/compile/InnerClassAccessStripper.java | 2 +- .../drill/exec/compile/JDKClassCompiler.java | 2 +- .../drill/exec/compile/JaninoClassCompiler.java | 2 +- .../apache/drill/exec/compile/LogWriter.java | 2 +- .../apache/drill/exec/compile/MergeAdapter.java | 2 +- .../exec/compile/RetargetableClassVisitor.java | 2 +- .../exec/compile/TemplateClassDefinition.java | 2 +- .../exec/compile/bytecode/AloadPopRemover.java | 2 +- .../exec/compile/bytecode/DirectSorter.java | 2 +- .../compile/bytecode/InstructionModifier.java | 2 +- .../exec/compile/bytecode/MethodAnalyzer.java | 2 +- .../compile/bytecode/ReplacingBasicValue.java | 2 +- .../compile/bytecode/ReplacingInterpreter.java | 2 +- .../compile/bytecode/ScalarReplacementNode.java | 2 +- .../bytecode/ScalarReplacementTypes.java | 2 +- .../bytecode/TrackingInstructionList.java | 2 +- .../exec/compile/bytecode/ValueHolderIden.java | 2 +- .../bytecode/ValueHolderReplacementVisitor.java | 2 +- .../exec/compile/bytecode/package-info.java | 2 +- .../apache/drill/exec/compile/package-info.java | 2 +- .../exec/compile/sig/CodeGeneratorArgument.java | 2 +- .../exec/compile/sig/CodeGeneratorMethod.java | 2 +- .../compile/sig/CodeGeneratorSignature.java | 2 +- .../exec/compile/sig/GeneratorMapping.java | 2 +- .../drill/exec/compile/sig/MappingSet.java | 2 +- .../exec/compile/sig/RuntimeOverridden.java | 2 +- .../drill/exec/compile/sig/Signature.java | 2 +- .../drill/exec/compile/sig/VVReadBatch.java | 2 +- .../drill/exec/compile/sig/VVWriteBatch.java | 2 +- .../drill/exec/compile/sig/package-info.java | 2 +- .../drill/exec/coord/ClusterCoordinator.java | 2 +- .../drill/exec/coord/DistributedSemaphore.java | 2 +- .../exec/coord/DrillServiceInstanceHelper.java | 2 +- .../drill/exec/coord/DrillbitEndpointSerDe.java | 2 +- .../coord/local/LocalClusterCoordinator.java | 2 +- .../drill/exec/coord/local/MapBackedStore.java | 6 ++-- .../drill/exec/coord/local/package-info.java | 2 +- .../apache/drill/exec/coord/package-info.java | 2 +- .../exec/coord/store/BaseTransientStore.java | 6 ++-- .../store/CachingTransientStoreFactory.java | 6 ++-- .../drill/exec/coord/store/TransientStore.java | 6 ++-- .../exec/coord/store/TransientStoreConfig.java | 6 ++-- .../store/TransientStoreConfigBuilder.java | 6 ++-- .../exec/coord/store/TransientStoreEvent.java | 6 ++-- .../coord/store/TransientStoreEventType.java | 6 ++-- .../exec/coord/store/TransientStoreFactory.java | 6 ++-- .../coord/store/TransientStoreListener.java | 6 ++-- .../drill/exec/coord/zk/EventDispatcher.java | 6 ++-- .../apache/drill/exec/coord/zk/PathUtils.java | 4 +-- .../exec/coord/zk/ZKClusterCoordinator.java | 2 +- .../exec/coord/zk/ZKRegistrationHandle.java | 2 +- .../exec/coord/zk/ZkDistributedSemaphore.java | 2 +- .../drill/exec/coord/zk/ZkEphemeralStore.java | 6 ++-- .../exec/coord/zk/ZkTransientStoreFactory.java | 6 ++-- .../drill/exec/coord/zk/ZookeeperClient.java | 4 +-- .../drill/exec/coord/zk/package-info.java | 2 +- .../java/org/apache/drill/exec/disk/Spool.java | 2 +- .../apache/drill/exec/disk/package-info.java | 2 +- .../drill/exec/dotdrill/DotDrillFile.java | 2 +- .../drill/exec/dotdrill/DotDrillType.java | 2 +- .../drill/exec/dotdrill/DotDrillUtil.java | 2 +- .../drill/exec/dotdrill/package-info.java | 2 +- .../drill/exec/exception/BitComException.java | 2 +- .../exception/ClassTransformationException.java | 2 +- .../exception/DrillbitStartupException.java | 2 +- .../exec/exception/FragmentSetupException.java | 2 +- .../exception/FunctionValidationException.java | 6 ++-- .../exec/exception/JarValidationException.java | 6 ++-- .../exec/exception/OptimizerException.java | 2 +- .../exec/exception/SchemaChangeException.java | 2 +- .../drill/exec/exception/SetupException.java | 2 +- .../drill/exec/exception/StoreException.java | 6 ++-- .../exception/UnsupportedOperatorCollector.java | 2 +- .../exception/VersionMismatchException.java | 6 ++-- .../drill/exec/exception/package-info.java | 2 +- .../apache/drill/exec/expr/BatchReference.java | 13 +++---- .../org/apache/drill/exec/expr/BooleanType.java | 2 +- .../apache/drill/exec/expr/CloneVisitor.java | 6 ++-- .../drill/exec/expr/DebugStringBuilder.java | 2 +- .../drill/exec/expr/DirectExpression.java | 2 +- .../apache/drill/exec/expr/DrillAggFunc.java | 2 +- .../org/apache/drill/exec/expr/DrillFunc.java | 2 +- .../apache/drill/exec/expr/DrillSimpleFunc.java | 2 +- .../apache/drill/exec/expr/EqualityVisitor.java | 4 +-- .../drill/exec/expr/GetSetVectorHelper.java | 2 +- .../org/apache/drill/exec/expr/HashVisitor.java | 6 ++-- .../exec/expr/HoldingContainerExpression.java | 2 +- .../exec/expr/SingleClassStringWriter.java | 2 +- .../org/apache/drill/exec/expr/SizedJBlock.java | 3 +- .../exec/expr/ValueVectorWriteExpression.java | 2 +- .../drill/exec/expr/annotations/Output.java | 2 +- .../drill/exec/expr/annotations/Param.java | 2 +- .../drill/exec/expr/annotations/Workspace.java | 2 +- .../expr/fn/DrillComplexWriterFuncHolder.java | 1 - .../drill/exec/expr/fn/ExceptionFunction.java | 6 ++-- .../exec/expr/fn/FunctionLookupContext.java | 2 +- .../drill/exec/expr/fn/FunctionUtils.java | 13 +++---- .../exec/expr/fn/MethodGrabbingVisitor.java | 2 +- .../exec/expr/fn/ModifiedUnparseVisitor.java | 2 +- .../exec/expr/fn/PluggableFunctionRegistry.java | 2 +- .../expr/fn/impl/AggregateErrorFunctions.java | 2 +- .../drill/exec/expr/fn/impl/Alternator.java | 2 +- .../drill/exec/expr/fn/impl/BitFunctions.java | 2 +- .../exec/expr/fn/impl/BooleanAggrFunctions.java | 7 ++-- .../drill/exec/expr/fn/impl/ByteSubstring.java | 2 +- .../drill/exec/expr/fn/impl/CastBigIntDate.java | 2 +- .../exec/expr/fn/impl/CastBigIntTimeStamp.java | 2 +- .../drill/exec/expr/fn/impl/CastIntTime.java | 2 +- .../exec/expr/fn/impl/CastVarCharVar16Char.java | 2 +- .../exec/expr/fn/impl/CharSequenceWrapper.java | 4 ++- .../drill/exec/expr/fn/impl/CharSubstring.java | 2 +- .../exec/expr/fn/impl/ContextFunctions.java | 2 +- .../exec/expr/fn/impl/CryptoFunctions.java | 14 ++++---- .../exec/expr/fn/impl/DateTypeFunctions.java | 1 - .../drill/exec/expr/fn/impl/DrillByteArray.java | 2 +- .../drill/exec/expr/fn/impl/DrillHash.java | 3 +- .../drill/exec/expr/fn/impl/Hash32AsDouble.java | 2 +- .../exec/expr/fn/impl/Hash32Functions.java | 2 +- .../expr/fn/impl/Hash32FunctionsWithSeed.java | 2 +- .../expr/fn/impl/Hash32WithSeedAsDouble.java | 2 +- .../drill/exec/expr/fn/impl/Hash64AsDouble.java | 2 +- .../exec/expr/fn/impl/Hash64Functions.java | 2 +- .../expr/fn/impl/Hash64FunctionsWithSeed.java | 2 +- .../expr/fn/impl/Hash64WithSeedAsDouble.java | 2 +- .../drill/exec/expr/fn/impl/HashHelper.java | 2 +- .../apache/drill/exec/expr/fn/impl/IsFalse.java | 3 +- .../drill/exec/expr/fn/impl/IsNotFalse.java | 3 +- .../drill/exec/expr/fn/impl/IsNotTrue.java | 3 +- .../apache/drill/exec/expr/fn/impl/IsTrue.java | 3 +- .../apache/drill/exec/expr/fn/impl/Mappify.java | 2 +- .../drill/exec/expr/fn/impl/MappifyUtility.java | 2 +- .../drill/exec/expr/fn/impl/MathFunctions.java | 2 +- .../drill/exec/expr/fn/impl/MurmurHash3.java | 5 +-- .../exec/expr/fn/impl/NetworkFunctions.java | 1 - .../org/apache/drill/exec/expr/fn/impl/Not.java | 3 +- .../exec/expr/fn/impl/ParseQueryFunction.java | 34 +++++++++--------- .../exec/expr/fn/impl/ParseUrlFunction.java | 18 +++++----- .../drill/exec/expr/fn/impl/RegexpUtil.java | 2 +- .../expr/fn/impl/SimpleRepeatedFunctions.java | 2 +- .../exec/expr/fn/impl/SqlPatternFactory.java | 1 - .../expr/fn/impl/StringFunctionHelpers.java | 3 +- .../exec/expr/fn/impl/StringFunctionUtil.java | 2 +- .../drill/exec/expr/fn/impl/UnionFunctions.java | 2 +- .../drill/exec/expr/fn/impl/VarHelpers.java | 2 +- .../apache/drill/exec/expr/fn/impl/XXHash.java | 2 +- .../expr/fn/impl/conv/BigIntBEConvertFrom.java | 2 +- .../expr/fn/impl/conv/BigIntBEConvertTo.java | 2 +- .../expr/fn/impl/conv/BigIntConvertFrom.java | 5 ++- .../exec/expr/fn/impl/conv/BigIntConvertTo.java | 5 ++- .../fn/impl/conv/BigIntVLongConvertFrom.java | 2 +- .../expr/fn/impl/conv/BigIntVLongConvertTo.java | 2 +- .../fn/impl/conv/BooleanByteConvertFrom.java | 5 ++- .../expr/fn/impl/conv/BooleanByteConvertTo.java | 5 ++- .../impl/conv/ConvertFromImpalaTimestamp.java | 4 +-- .../fn/impl/conv/DateEpochBEConvertFrom.java | 2 +- .../expr/fn/impl/conv/DateEpochBEConvertTo.java | 2 +- .../expr/fn/impl/conv/DateEpochConvertFrom.java | 5 ++- .../expr/fn/impl/conv/DateEpochConvertTo.java | 5 ++- .../expr/fn/impl/conv/DoubleBEConvertFrom.java | 5 ++- .../expr/fn/impl/conv/DoubleBEConvertTo.java | 5 ++- .../expr/fn/impl/conv/DoubleConvertFrom.java | 5 ++- .../exec/expr/fn/impl/conv/DoubleConvertTo.java | 5 ++- .../expr/fn/impl/conv/DummyConvertFrom.java | 5 ++- .../exec/expr/fn/impl/conv/DummyConvertTo.java | 5 ++- .../exec/expr/fn/impl/conv/DummyFlatten.java | 4 +-- .../expr/fn/impl/conv/FloatBEConvertFrom.java | 5 ++- .../expr/fn/impl/conv/FloatBEConvertTo.java | 5 ++- .../expr/fn/impl/conv/FloatConvertFrom.java | 5 ++- .../exec/expr/fn/impl/conv/FloatConvertTo.java | 5 ++- .../expr/fn/impl/conv/IntBEConvertFrom.java | 2 +- .../exec/expr/fn/impl/conv/IntBEConvertTo.java | 2 +- .../exec/expr/fn/impl/conv/IntConvertFrom.java | 5 ++- .../exec/expr/fn/impl/conv/IntConvertTo.java | 5 ++- .../expr/fn/impl/conv/IntVIntConvertFrom.java | 2 +- .../expr/fn/impl/conv/IntVIntConvertTo.java | 2 +- .../exec/expr/fn/impl/conv/JsonConvertFrom.java | 3 +- .../exec/expr/fn/impl/conv/JsonConvertTo.java | 3 +- .../exec/expr/fn/impl/conv/RoundFunctions.java | 5 ++- .../fn/impl/conv/SmallIntBEConvertFrom.java | 5 ++- .../expr/fn/impl/conv/SmallIntBEConvertTo.java | 5 ++- .../expr/fn/impl/conv/SmallIntConvertFrom.java | 5 ++- .../expr/fn/impl/conv/SmallIntConvertTo.java | 5 ++- .../fn/impl/conv/TimeEpochBEConvertFrom.java | 2 +- .../expr/fn/impl/conv/TimeEpochBEConvertTo.java | 2 +- .../expr/fn/impl/conv/TimeEpochConvertFrom.java | 5 ++- .../expr/fn/impl/conv/TimeEpochConvertTo.java | 5 ++- .../impl/conv/TimeStampEpochBEConvertFrom.java | 2 +- .../fn/impl/conv/TimeStampEpochBEConvertTo.java | 2 +- .../fn/impl/conv/TimeStampEpochConvertFrom.java | 5 ++- .../fn/impl/conv/TimeStampEpochConvertTo.java | 5 ++- .../expr/fn/impl/conv/TinyIntConvertFrom.java | 5 ++- .../expr/fn/impl/conv/TinyIntConvertTo.java | 5 ++- .../expr/fn/impl/conv/UInt4BEConvertFrom.java | 2 +- .../expr/fn/impl/conv/UInt4BEConvertTo.java | 2 +- .../expr/fn/impl/conv/UInt4ConvertFrom.java | 5 ++- .../exec/expr/fn/impl/conv/UInt4ConvertTo.java | 5 ++- .../expr/fn/impl/conv/UInt8ConvertFrom.java | 5 ++- .../exec/expr/fn/impl/conv/UInt8ConvertTo.java | 5 ++- .../expr/fn/impl/conv/UTF16ConvertFrom.java | 5 ++- .../exec/expr/fn/impl/conv/UTF16ConvertTo.java | 5 ++- .../exec/expr/fn/impl/conv/UTF8ConvertFrom.java | 5 ++- .../exec/expr/fn/impl/conv/UTF8ConvertTo.java | 5 ++- .../fn/interpreter/InterpreterEvaluator.java | 2 +- .../fn/output/ConcatReturnTypeInference.java | 13 +++---- .../fn/output/DecimalReturnTypeInference.java | 13 +++---- .../fn/output/DefaultReturnTypeInference.java | 13 +++---- .../expr/fn/output/PadReturnTypeInference.java | 13 +++---- .../expr/fn/output/ReturnTypeInference.java | 13 +++---- .../SameInOutLengthReturnTypeInference.java | 13 +++---- .../output/StringCastReturnTypeInference.java | 13 +++---- .../exec/expr/fn/registry/FunctionHolder.java | 6 ++-- .../fn/registry/FunctionRegistryHolder.java | 4 +-- .../drill/exec/expr/fn/registry/JarScan.java | 6 ++-- .../fn/registry/RemoteFunctionRegistry.java | 4 +-- .../apache/drill/exec/expr/package-info.java | 2 +- .../expr/stat/ParquetBooleanPredicates.java | 13 +++---- .../expr/stat/ParquetComparisonPredicates.java | 13 +++---- .../exec/expr/stat/ParquetFilterPredicate.java | 7 ++-- .../exec/expr/stat/ParquetIsPredicates.java | 13 +++---- .../exec/expr/stat/ParquetPredicatesHelper.java | 4 +-- .../exec/expr/stat/RangeExprEvaluator.java | 4 +-- .../exec/ops/AccountingUserConnection.java | 2 +- .../org/apache/drill/exec/ops/Consumer.java | 2 +- .../drill/exec/ops/ContextInformation.java | 4 +-- .../apache/drill/exec/ops/FragmentStats.java | 2 +- .../org/apache/drill/exec/ops/MetricDef.java | 2 +- .../org/apache/drill/exec/ops/OpProfileDef.java | 2 +- .../drill/exec/ops/OperatorMetricRegistry.java | 6 ++-- .../drill/exec/ops/OptimizerRulesContext.java | 2 +- .../apache/drill/exec/ops/SendingAccountor.java | 2 +- .../apache/drill/exec/ops/StatusHandler.java | 2 +- .../org/apache/drill/exec/ops/UdfUtilities.java | 4 +-- .../drill/exec/ops/ViewExpansionContext.java | 4 +-- .../apache/drill/exec/opt/BasicOptimizer.java | 2 +- .../drill/exec/opt/IdentityOptimizer.java | 2 +- .../org/apache/drill/exec/opt/Optimizer.java | 2 +- .../org/apache/drill/exec/package-info.java | 2 +- .../drill/exec/physical/DataValidationMode.java | 2 +- .../drill/exec/physical/EndpointAffinity.java | 2 +- .../exec/physical/MinorFragmentEndpoint.java | 4 +-- .../PhysicalOperatorSetupException.java | 2 +- .../apache/drill/exec/physical/WriteEntry.java | 2 +- .../exec/physical/base/AbstractExchange.java | 2 +- .../physical/base/AbstractFileGroupScan.java | 2 +- .../exec/physical/base/AbstractMultiple.java | 2 +- .../physical/base/AbstractPhysicalVisitor.java | 2 +- .../exec/physical/base/AbstractReceiver.java | 2 +- .../exec/physical/base/AbstractSender.java | 2 +- .../exec/physical/base/AbstractSingle.java | 2 +- .../drill/exec/physical/base/AbstractStore.java | 2 +- .../exec/physical/base/AbstractSubScan.java | 2 +- .../drill/exec/physical/base/Exchange.java | 2 +- .../drill/exec/physical/base/FileGroupScan.java | 2 +- .../drill/exec/physical/base/FragmentLeaf.java | 2 +- .../drill/exec/physical/base/HasAffinity.java | 2 +- .../apache/drill/exec/physical/base/Leaf.java | 2 +- .../exec/physical/base/PhysicalOperator.java | 2 +- .../physical/base/PhysicalOperatorUtil.java | 2 +- .../exec/physical/base/PhysicalVisitor.java | 2 +- .../drill/exec/physical/base/Receiver.java | 2 +- .../apache/drill/exec/physical/base/Root.java | 2 +- .../apache/drill/exec/physical/base/Scan.java | 2 +- .../drill/exec/physical/base/ScanStats.java | 2 +- .../exec/physical/base/SchemalessScan.java | 13 +++---- .../apache/drill/exec/physical/base/Sender.java | 2 +- .../apache/drill/exec/physical/base/Store.java | 2 +- .../drill/exec/physical/base/SubScan.java | 2 +- .../apache/drill/exec/physical/base/Writer.java | 3 +- .../physical/config/AbstractDeMuxExchange.java | 2 +- .../physical/config/AbstractMuxExchange.java | 2 +- .../exec/physical/config/BroadcastExchange.java | 4 +-- .../exec/physical/config/BroadcastSender.java | 3 +- .../exec/physical/config/ComplexToJson.java | 2 +- .../drill/exec/physical/config/Filter.java | 2 +- .../drill/exec/physical/config/FlattenPOP.java | 4 +-- .../exec/physical/config/HashAggregate.java | 2 +- .../drill/exec/physical/config/HashJoinPOP.java | 3 +- .../physical/config/HashPartitionSender.java | 2 +- .../physical/config/HashToMergeExchange.java | 2 +- .../physical/config/HashToRandomExchange.java | 2 +- .../exec/physical/config/IteratorValidator.java | 2 +- .../drill/exec/physical/config/Limit.java | 4 +-- .../exec/physical/config/MergeJoinPOP.java | 2 +- .../physical/config/MergingReceiverPOP.java | 2 +- .../exec/physical/config/NestedLoopJoinPOP.java | 1 - .../physical/config/OrderedMuxExchange.java | 2 +- .../config/OrderedPartitionExchange.java | 2 +- .../exec/physical/config/PartitionRange.java | 2 +- .../exec/physical/config/ProducerConsumer.java | 2 +- .../drill/exec/physical/config/Project.java | 2 +- .../drill/exec/physical/config/RangeSender.java | 2 +- .../drill/exec/physical/config/Screen.java | 2 +- .../physical/config/SelectionVectorRemover.java | 2 +- .../physical/config/SingleMergeExchange.java | 3 +- .../exec/physical/config/SingleSender.java | 2 +- .../apache/drill/exec/physical/config/Sort.java | 2 +- .../physical/config/StreamingAggregate.java | 2 +- .../apache/drill/exec/physical/config/TopN.java | 2 +- .../drill/exec/physical/config/Trace.java | 3 +- .../drill/exec/physical/config/UnionAll.java | 2 +- .../physical/config/UnorderedDeMuxExchange.java | 2 +- .../physical/config/UnorderedMuxExchange.java | 2 +- .../exec/physical/config/UnorderedReceiver.java | 2 +- .../drill/exec/physical/config/Values.java | 2 +- .../drill/exec/physical/config/WindowPOP.java | 3 +- .../drill/exec/physical/impl/BaseRootExec.java | 2 +- .../drill/exec/physical/impl/BatchCreator.java | 2 +- .../physical/impl/OperatorCreatorRegistry.java | 2 +- .../drill/exec/physical/impl/OutputMutator.java | 2 +- .../exec/physical/impl/PhysicalConfig.java | 2 +- .../drill/exec/physical/impl/RootCreator.java | 2 +- .../drill/exec/physical/impl/RootExec.java | 2 +- .../drill/exec/physical/impl/ScreenCreator.java | 2 +- .../exec/physical/impl/SingleSenderCreator.java | 2 +- .../exec/physical/impl/TopN/PriorityQueue.java | 2 +- .../impl/TopN/TopNSortBatchCreator.java | 2 +- .../drill/exec/physical/impl/TraceInjector.java | 1 - .../exec/physical/impl/WriterRecordBatch.java | 1 - .../physical/impl/aggregate/BatchIterator.java | 2 +- .../impl/aggregate/HashAggBatchCreator.java | 2 +- .../physical/impl/aggregate/HashAggregator.java | 2 +- .../aggregate/StreamingAggBatchCreator.java | 2 +- .../impl/aggregate/StreamingAggregator.java | 2 +- .../broadcastsender/BroadcastSenderCreator.java | 2 +- .../BroadcastSenderRootExec.java | 4 +-- .../physical/impl/common/ChainedHashTable.java | 14 ++++---- .../exec/physical/impl/common/Comparator.java | 6 ++-- .../exec/physical/impl/common/HashTable.java | 2 +- .../physical/impl/common/HashTableConfig.java | 2 +- .../physical/impl/common/HashTableStats.java | 2 +- .../exec/physical/impl/common/IndexPointer.java | 2 +- .../impl/filter/EvalSetupException.java | 2 +- .../impl/filter/EvaluationPredicate.java | 2 +- .../impl/filter/FilterBatchCreator.java | 2 +- .../physical/impl/filter/FilterSignature.java | 2 +- .../physical/impl/filter/FilterTemplate4.java | 2 +- .../impl/filter/ReturnValueExpression.java | 2 +- .../impl/flatten/FlattenBatchCreator.java | 2 +- .../exec/physical/impl/flatten/Flattener.java | 2 +- .../impl/join/HashJoinBatchCreator.java | 2 +- .../exec/physical/impl/join/HashJoinHelper.java | 3 +- .../exec/physical/impl/join/HashJoinProbe.java | 3 +- .../impl/join/HashJoinProbeTemplate.java | 2 +- .../exec/physical/impl/join/JoinTemplate.java | 2 +- .../exec/physical/impl/join/JoinUtils.java | 1 - .../exec/physical/impl/join/JoinWorker.java | 2 +- .../physical/impl/join/MergeJoinCreator.java | 2 +- .../impl/join/NestedLoopJoinBatchCreator.java | 2 +- .../physical/impl/limit/LimitBatchCreator.java | 2 +- .../physical/impl/limit/LimitRecordBatch.java | 2 +- .../impl/materialize/QueryWritableBatch.java | 2 +- .../impl/materialize/RecordMaterializer.java | 2 +- .../materialize/VectorRecordMaterializer.java | 2 +- .../OrderedPartitionProjector.java | 2 +- .../OrderedPartitionSenderCreator.java | 2 +- .../impl/orderedpartitioner/SampleCopier.java | 2 +- .../SampleCopierTemplate.java | 2 +- .../orderedpartitioner/SampleSortTemplate.java | 2 +- .../impl/orderedpartitioner/SampleSorter.java | 2 +- .../partitionsender/PartitionOutgoingBatch.java | 2 +- .../partitionsender/PartitionSenderCreator.java | 2 +- .../impl/partitionsender/Partitioner.java | 2 +- .../partitionsender/PartitionerDecorator.java | 2 +- .../producer/ProducerConsumerBatchCreator.java | 2 +- .../impl/project/ComplexToJsonBatchCreator.java | 2 +- .../impl/project/ProjectBatchCreator.java | 2 +- .../exec/physical/impl/project/Projector.java | 2 +- .../physical/impl/sort/SortBatchCreator.java | 2 +- .../exec/physical/impl/sort/SortTemplate.java | 2 +- .../drill/exec/physical/impl/sort/Sorter.java | 2 +- .../impl/svremover/SVRemoverCreator.java | 2 +- .../physical/impl/trace/TraceBatchCreator.java | 3 +- .../physical/impl/trace/TraceRecordBatch.java | 5 ++- .../impl/union/UnionAllBatchCreator.java | 2 +- .../exec/physical/impl/union/UnionAller.java | 2 +- .../physical/impl/union/UnionAllerTemplate.java | 1 - .../physical/impl/validate/BatchValidator.java | 2 +- .../validate/IteratorValidatorInjector.java | 2 +- .../impl/window/FrameSupportTemplate.java | 2 +- .../exec/physical/impl/window/Partition.java | 2 +- .../physical/impl/window/WindowDataBatch.java | 4 +-- .../impl/window/WindowFrameBatchCreator.java | 3 +- .../physical/impl/window/WindowFunction.java | 2 +- .../exec/physical/impl/xsort/BatchGroup.java | 2 +- .../impl/xsort/ExternalSortBatchCreator.java | 2 +- .../drill/exec/physical/impl/xsort/MSorter.java | 2 +- .../impl/xsort/PriorityQueueCopier.java | 2 +- .../impl/xsort/PriorityQueueCopierTemplate.java | 2 +- .../exec/physical/rowSet/impl/package-info.java | 1 - .../rowSet/model/hyper/package-info.java | 1 - .../physical/rowSet/model/package-info.java | 1 - .../exec/planner/AbstractOpWrapperVisitor.java | 2 +- .../planner/AbstractPartitionDescriptor.java | 2 +- .../exec/planner/DFSDirPartitionLocation.java | 3 +- .../exec/planner/DFSFilePartitionLocation.java | 2 +- .../drill/exec/planner/DrillRelBuilder.java | 13 +++---- .../planner/ParquetPartitionDescriptor.java | 2 +- .../exec/planner/ParquetPartitionLocation.java | 2 +- .../drill/exec/planner/PartitionDescriptor.java | 2 +- .../drill/exec/planner/PartitionLocation.java | 2 +- .../drill/exec/planner/PhysicalPlanReader.java | 2 +- .../apache/drill/exec/planner/PlannerType.java | 2 +- .../apache/drill/exec/planner/RuleInstance.java | 13 +++---- .../exec/planner/SimplePartitionLocation.java | 3 +- .../drill/exec/planner/common/DrillRelNode.java | 3 +- .../exec/planner/common/DrillUnionRelBase.java | 2 +- .../exec/planner/common/DrillValuesRelBase.java | 13 +++---- .../exec/planner/common/DrillWindowRelBase.java | 3 +- .../exec/planner/common/DrillWriterRelBase.java | 2 +- .../drill/exec/planner/cost/DrillCostBase.java | 1 - .../exec/planner/cost/DrillRelOptCost.java | 5 ++- .../planner/cost/DrillRelOptCostFactory.java | 6 ++-- .../planner/fragment/DistributionAffinity.java | 6 ++-- .../drill/exec/planner/fragment/Fragment.java | 2 +- .../planner/fragment/FragmentParallelizer.java | 6 ++-- .../exec/planner/fragment/FragmentVisitor.java | 2 +- .../HardAffinityFragmentParallelizer.java | 6 ++-- .../planner/fragment/MakeFragmentsVisitor.java | 2 +- .../planner/fragment/ParallelizationInfo.java | 4 +-- .../fragment/ParallelizationParameters.java | 6 ++-- .../SoftAffinityFragmentParallelizer.java | 4 +-- .../drill/exec/planner/fragment/Stats.java | 2 +- .../exec/planner/fragment/StatsCollector.java | 2 +- .../drill/exec/planner/fragment/Wrapper.java | 2 +- .../contrib/ExchangeRemoverMaterializer.java | 2 +- .../fragment/contrib/OperatorIdVisitor.java | 2 +- .../fragment/contrib/SplittingParallelizer.java | 2 +- .../exec/planner/logical/CreateTableEntry.java | 3 +- .../logical/DirPrunedEnumerableTableScan.java | 3 +- .../planner/logical/DrillConstExecutor.java | 2 +- .../DrillFilterAggregateTransposeRule.java | 1 - .../exec/planner/logical/DrillFilterRel.java | 2 +- .../exec/planner/logical/DrillImplementor.java | 2 +- .../exec/planner/logical/DrillJoinRel.java | 2 +- .../exec/planner/logical/DrillLimitRel.java | 2 +- .../planner/logical/DrillMergeFilterRule.java | 2 +- .../exec/planner/logical/DrillParseContext.java | 2 +- .../exec/planner/logical/DrillProjectRel.java | 2 +- .../logical/DrillProjectSetOpTransposeRule.java | 1 - .../logical/DrillPushLimitToScanRule.java | 1 - .../logical/DrillReduceAggregatesRule.java | 1 - .../drill/exec/planner/logical/DrillRel.java | 2 +- .../exec/planner/logical/DrillRelFactories.java | 1 - .../exec/planner/logical/DrillScreenRel.java | 2 +- .../planner/logical/DrillViewInfoProvider.java | 2 +- .../exec/planner/logical/DrillWindowRel.java | 3 +- .../exec/planner/logical/DrillWindowRule.java | 1 - .../exec/planner/logical/DrillWriterRel.java | 2 +- .../exec/planner/logical/DynamicDrillTable.java | 2 +- .../planner/logical/EnumerableDrillRule.java | 2 +- .../drill/exec/planner/logical/ExprHelper.java | 2 +- .../planner/logical/ExtendableRelDataType.java | 13 +++---- .../exec/planner/logical/RelOptHelper.java | 2 +- .../planner/logical/ScanFieldDeterminer.java | 2 +- .../exec/planner/logical/StoragePlugins.java | 2 +- .../partition/FindPartitionConditions.java | 2 +- .../logical/partition/ParquetPruneScanRule.java | 2 +- .../partition/RewriteAsBinaryOperators.java | 34 +++++++++--------- .../RewriteCombineBinaryOperators.java | 34 +++++++++--------- .../exec/planner/physical/AggPruleBase.java | 1 - .../planner/physical/BroadcastExchangePrel.java | 1 - .../planner/physical/ComplexToJsonPrel.java | 2 +- .../physical/ConvertCountToDirectScan.java | 1 - .../exec/planner/physical/DirectScanPrule.java | 2 +- .../physical/DrillDistributionTrait.java | 2 +- .../physical/DrillDistributionTraitDef.java | 2 +- .../exec/planner/physical/DrillScanPrel.java | 2 +- .../exec/planner/physical/ExchangePrel.java | 3 +- .../drill/exec/planner/physical/FilterPrel.java | 3 +- .../exec/planner/physical/FilterPrule.java | 2 +- .../exec/planner/physical/FlattenPrel.java | 4 +-- .../physical/HasDistributionAffinity.java | 6 ++-- .../exec/planner/physical/HashPrelUtil.java | 2 +- .../drill/exec/planner/physical/JoinPrel.java | 1 - .../exec/planner/physical/JoinPruleBase.java | 1 - .../drill/exec/planner/physical/LimitPrel.java | 2 +- .../drill/exec/planner/physical/LimitPrule.java | 2 +- .../LimitUnionExchangeTransposeRule.java | 2 +- .../physical/OrderedMuxExchangePrel.java | 2 +- .../planner/physical/ProducerConsumerPrel.java | 2 +- .../planner/physical/ProjectAllowDupPrel.java | 3 +- .../exec/planner/physical/PushLimitToTopN.java | 3 +- .../drill/exec/planner/physical/ScanPrule.java | 2 +- .../drill/exec/planner/physical/ScreenPrel.java | 2 +- .../exec/planner/physical/ScreenPrule.java | 2 +- .../physical/SelectionVectorRemoverPrel.java | 2 +- .../drill/exec/planner/physical/SinglePrel.java | 2 +- .../drill/exec/planner/physical/SortPrule.java | 2 +- .../drill/exec/planner/physical/UnionPrel.java | 3 +- .../physical/UnorderedDeMuxExchangePrel.java | 3 +- .../physical/UnorderedMuxExchangePrel.java | 3 +- .../drill/exec/planner/physical/WindowPrel.java | 3 +- .../exec/planner/physical/WindowPrule.java | 1 - .../drill/exec/planner/physical/WriterPrel.java | 2 +- .../planner/physical/explain/PrelSequencer.java | 2 +- .../physical/visitor/BasePrelVisitor.java | 2 +- .../visitor/ComplexToJsonPrelVisitor.java | 2 +- .../physical/visitor/FinalColumnReorderer.java | 2 +- .../visitor/InsertLocalExchangeVisitor.java | 4 +-- .../physical/visitor/JoinPrelRenameVisitor.java | 3 +- .../planner/physical/visitor/PrelVisitor.java | 2 +- .../visitor/ProducerConsumerPrelVisitor.java | 2 +- .../planner/physical/visitor/RelUniqifier.java | 2 +- .../visitor/RewriteProjectToFlatten.java | 4 +-- .../visitor/RexVisitorComplexExprSplitter.java | 4 +-- .../visitor/SelectionVectorPrelVisitor.java | 2 +- .../visitor/SplitUpComplexExpressions.java | 2 +- .../physical/visitor/StarColumnConverter.java | 1 - .../physical/visitor/SwapHashJoinVisitor.java | 1 - .../physical/visitor/TopProjectVisitor.java | 13 +++---- .../apache/drill/exec/planner/sql/Checker.java | 2 +- .../planner/sql/DrillCalciteSqlWrapper.java | 2 +- .../planner/sql/DrillExtractConvertlet.java | 2 +- .../exec/planner/sql/DrillSqlAggOperator.java | 4 +-- .../DrillSqlAggOperatorWithoutInference.java | 6 ++-- .../exec/planner/sql/DrillSqlOperator.java | 7 ++-- .../sql/DrillSqlOperatorWithoutInference.java | 6 ++-- .../exec/planner/sql/DynamicReturnType.java | 2 +- .../drill/exec/planner/sql/DynamicType.java | 2 +- .../planner/sql/ExpandingConcurrentMap.java | 2 +- .../drill/exec/planner/sql/FixedRange.java | 2 +- .../exec/planner/sql/QueryInputException.java | 2 +- .../sql/handlers/AbstractSqlHandler.java | 2 +- .../sql/handlers/CreateFunctionHandler.java | 4 +-- .../sql/handlers/DescribeSchemaHandler.java | 6 ++-- .../sql/handlers/DescribeTableHandler.java | 1 - .../sql/handlers/DropFunctionHandler.java | 4 +-- .../sql/handlers/FindHardDistributionScans.java | 6 ++-- .../planner/sql/handlers/SetOptionHandler.java | 2 +- .../sql/handlers/ShowFilesCommandResult.java | 3 +- .../sql/handlers/ShowSchemasHandler.java | 3 +- .../planner/sql/handlers/ShowTablesHandler.java | 1 - .../sql/handlers/SimpleCommandResult.java | 2 +- .../planner/sql/handlers/SqlHandlerConfig.java | 3 +- .../planner/sql/handlers/UseSchemaHandler.java | 2 +- .../sql/parser/DrillCalciteWrapperUtility.java | 3 +- .../planner/sql/parser/DrillParserUtil.java | 3 +- .../exec/planner/sql/parser/DrillSqlCall.java | 2 +- .../sql/parser/DrillSqlDescribeTable.java | 31 ++++++++-------- .../planner/sql/parser/SqlCreateFunction.java | 6 ++-- .../exec/planner/sql/parser/SqlCreateView.java | 2 +- .../planner/sql/parser/SqlDropFunction.java | 6 ++-- .../exec/planner/sql/parser/SqlDropTable.java | 2 +- .../exec/planner/sql/parser/SqlDropView.java | 2 +- .../planner/sql/parser/SqlRefreshMetadata.java | 2 +- .../exec/planner/sql/parser/SqlShowFiles.java | 2 +- .../exec/planner/sql/parser/SqlShowSchemas.java | 2 +- .../exec/planner/sql/parser/SqlShowTables.java | 2 +- .../exec/planner/sql/parser/SqlUseSchema.java | 2 +- .../DrillParserWithCompoundIdConverter.java | 2 +- .../types/AbstractRelDataTypeHolder.java | 13 +++---- .../types/DrillFixedRelDataTypeImpl.java | 2 +- .../planner/types/DrillRelDataTypeSystem.java | 3 +- .../types/ExtendableRelDataTypeHolder.java | 13 +++---- .../drill/exec/proto/helper/QueryIdHelper.java | 3 +- .../exec/record/AbstractBinaryRecordBatch.java | 3 +- .../exec/record/AbstractSingleRecordBatch.java | 2 +- .../drill/exec/record/CloseableRecordBatch.java | 2 +- .../org/apache/drill/exec/record/DeadBuf.java | 2 +- .../exec/record/FragmentWritableBatch.java | 2 +- .../drill/exec/record/MajorTypeSerDe.java | 2 +- .../drill/exec/record/MaterializeVisitor.java | 2 +- .../drill/exec/record/RawFragmentBatch.java | 2 +- .../exec/record/RawFragmentBatchProvider.java | 2 +- .../exec/record/RecordBatchMemoryManager.java | 1 - .../apache/drill/exec/record/SchemaBuilder.java | 2 +- .../apache/drill/exec/record/SchemaUtil.java | 4 +-- .../drill/exec/record/SchemalessBatch.java | 1 - .../drill/exec/record/SimpleRecordBatch.java | 1 - .../drill/exec/record/SimpleVectorWrapper.java | 2 +- .../apache/drill/exec/record/TypedFieldId.java | 2 +- .../drill/exec/record/VectorAccessible.java | 2 +- .../record/VectorAccessibleComplexWriter.java | 2 +- .../apache/drill/exec/record/VectorWrapper.java | 2 +- .../selection/SelectionVector4Builder.java | 2 +- .../exec/resolver/DefaultFunctionResolver.java | 3 +- .../exec/resolver/ExactFunctionResolver.java | 2 +- .../drill/exec/resolver/FunctionResolver.java | 3 +- .../exec/resolver/FunctionResolverFactory.java | 3 +- .../exec/resolver/ResolverTypePrecedence.java | 3 +- .../drill/exec/resolver/TypeCastRules.java | 1 - .../exec/rpc/AbstractClientConnection.java | 2 +- .../exec/rpc/AbstractConnectionConfig.java | 4 +-- .../AbstractDisposableUserClientConnection.java | 2 +- .../drill/exec/rpc/AbstractRpcMetrics.java | 2 +- .../exec/rpc/AbstractServerConnection.java | 2 +- .../drill/exec/rpc/BitConnectionConfig.java | 4 +-- .../apache/drill/exec/rpc/BitRpcUtility.java | 2 +- .../apache/drill/exec/rpc/ConnectionConfig.java | 4 +-- .../drill/exec/rpc/FailingRequestHandler.java | 4 +-- .../drill/exec/rpc/UserClientConnection.java | 2 +- .../exec/rpc/control/ControlConnection.java | 2 +- .../rpc/control/ControlConnectionManager.java | 2 +- .../control/ControlProtobufLengthDecoder.java | 2 +- .../exec/rpc/control/ControlRpcConfig.java | 2 +- .../exec/rpc/control/ControlRpcMetrics.java | 2 +- .../drill/exec/rpc/control/ControlTunnel.java | 2 +- .../drill/exec/rpc/control/Controller.java | 2 +- .../exec/rpc/control/CustomHandlerRegistry.java | 2 +- .../rpc/control/DefaultInstanceHandler.java | 2 +- .../drill/exec/rpc/control/WorkEventBus.java | 2 +- .../apache/drill/exec/rpc/data/AckSender.java | 2 +- .../exec/rpc/data/DataClientConnection.java | 2 +- .../exec/rpc/data/DataConnectionConfig.java | 4 +-- .../exec/rpc/data/DataConnectionCreator.java | 2 +- .../exec/rpc/data/DataConnectionManager.java | 2 +- .../rpc/data/DataDefaultInstanceHandler.java | 2 +- .../rpc/data/DataProtobufLengthDecoder.java | 2 +- .../drill/exec/rpc/data/DataRpcConfig.java | 2 +- .../drill/exec/rpc/data/DataRpcMetrics.java | 2 +- .../exec/rpc/data/DataServerConnection.java | 4 +-- .../exec/rpc/data/DataServerRequestHandler.java | 4 +-- .../apache/drill/exec/rpc/data/DataTunnel.java | 2 +- .../drill/exec/rpc/data/IncomingDataBatch.java | 2 +- .../rpc/security/AuthenticatorProvider.java | 4 +-- .../security/ClientAuthenticatorProvider.java | 4 +-- .../rpc/security/FastSaslClientFactory.java | 4 +-- .../rpc/security/FastSaslServerFactory.java | 2 +- .../rpc/security/SecurityConfiguration.java | 2 +- .../security/ServerAuthenticationHandler.java | 4 +-- .../rpc/security/kerberos/KerberosFactory.java | 4 +-- .../drill/exec/rpc/security/package-info.java | 3 +- .../exec/rpc/security/plain/PlainServer.java | 2 +- .../rpc/user/AwaitableUserResultsListener.java | 2 +- .../rpc/user/InboundImpersonationManager.java | 2 +- .../drill/exec/rpc/user/QueryDataBatch.java | 2 +- .../drill/exec/rpc/user/QueryResultHandler.java | 2 +- .../rpc/user/UserProtobufLengthDecoder.java | 2 +- .../exec/rpc/user/UserResultsListener.java | 2 +- .../drill/exec/rpc/user/UserRpcConfig.java | 2 +- .../drill/exec/rpc/user/UserRpcMetrics.java | 2 +- .../user/security/Pam4jUserAuthenticator.java | 2 +- .../rpc/user/security/PamUserAuthenticator.java | 2 +- .../security/UserAuthenticationException.java | 4 +-- .../rpc/user/security/UserAuthenticator.java | 4 +-- .../user/security/UserAuthenticatorFactory.java | 2 +- .../security/UserAuthenticatorTemplate.java | 4 +-- .../apache/drill/exec/schema/BackedRecord.java | 2 +- .../apache/drill/exec/schema/DataRecord.java | 2 +- .../apache/drill/exec/schema/DiffSchema.java | 2 +- .../org/apache/drill/exec/schema/Field.java | 2 +- .../apache/drill/exec/schema/IdGenerator.java | 2 +- .../apache/drill/exec/schema/ListSchema.java | 2 +- .../apache/drill/exec/schema/NamedField.java | 2 +- .../apache/drill/exec/schema/ObjectSchema.java | 2 +- .../apache/drill/exec/schema/OrderedField.java | 2 +- .../org/apache/drill/exec/schema/Record.java | 2 +- .../apache/drill/exec/schema/RecordSchema.java | 2 +- .../drill/exec/schema/SchemaIdGenerator.java | 2 +- .../exec/schema/json/jackson/JacksonHelper.java | 2 +- .../exec/serialization/InstanceSerializer.java | 6 ++-- .../exec/serialization/JacksonSerializer.java | 6 ++-- .../exec/serialization/ProtoSerializer.java | 6 ++-- .../drill/exec/server/DrillbitStateManager.java | 1 - .../exec/server/QueryProfileStoreContext.java | 2 +- .../drill/exec/server/RemoteServiceSet.java | 2 +- .../drill/exec/server/StartupOptions.java | 2 +- .../server/options/DrillConfigIterator.java | 2 +- .../server/options/FragmentOptionManager.java | 2 +- .../server/options/InMemoryOptionManager.java | 2 +- .../exec/server/options/OptionDefinition.java | 3 +- .../drill/exec/server/options/OptionList.java | 2 +- .../exec/server/options/OptionManager.java | 2 +- .../exec/server/options/OptionMetaData.java | 3 +- .../drill/exec/server/options/OptionValue.java | 2 +- .../server/options/PersistedOptionValue.java | 1 - .../exec/server/options/QueryOptionManager.java | 2 +- .../server/options/SessionOptionManager.java | 2 +- .../server/rest/GenericExceptionMapper.java | 2 +- .../drill/exec/server/rest/LogsResources.java | 8 ++--- .../exec/server/rest/MetricsResources.java | 2 +- .../exec/server/rest/PluginConfigWrapper.java | 3 +- .../drill/exec/server/rest/QueryWrapper.java | 1 - .../exec/server/rest/ThreadsResources.java | 2 +- .../drill/exec/server/rest/UserNameFilter.java | 4 +-- .../drill/exec/server/rest/WebServer.java | 4 +-- .../exec/server/rest/WebServerConstants.java | 2 +- .../exec/server/rest/WebSessionResources.java | 7 ++-- .../exec/server/rest/WebUserConnection.java | 2 +- .../server/rest/auth/AuthDynamicFeature.java | 2 +- .../DrillHttpConstraintSecurityHandler.java | 4 +-- .../auth/DrillHttpSecurityHandlerProvider.java | 6 ++-- .../rest/auth/DrillSpnegoAuthenticator.java | 2 -- .../rest/auth/DrillSpnegoLoginService.java | 6 ++-- .../server/rest/auth/FormSecurityHanlder.java | 2 +- .../exec/server/rest/auth/SpnegoConfig.java | 6 ++-- .../server/rest/auth/SpnegoSecurityHandler.java | 2 +- .../exec/server/rest/profile/Comparators.java | 2 +- .../drill/exec/server/rest/profile/Filters.java | 2 +- .../server/rest/profile/FragmentWrapper.java | 2 +- .../rest/profile/OperatorPathBuilder.java | 2 +- .../server/rest/profile/OperatorWrapper.java | 2 +- .../rest/profile/SimpleDurationFormat.java | 2 +- .../exec/server/rest/profile/TableBuilder.java | 2 +- .../drill/exec/service/ServiceEngine.java | 2 +- .../drill/exec/store/AbstractRecordReader.java | 2 +- .../drill/exec/store/AbstractStoragePlugin.java | 2 +- .../exec/store/BatchExceededException.java | 2 +- .../drill/exec/store/ClassPathFileSystem.java | 2 +- .../apache/drill/exec/store/ColumnExplorer.java | 4 +-- .../exec/store/DistributedStorageEngine.java | 2 +- .../exec/store/LocalSyncableFileSystem.java | 2 +- .../exec/store/NamedStoragePluginConfig.java | 2 +- .../drill/exec/store/PartitionExplorer.java | 4 +-- .../drill/exec/store/PartitionExplorerImpl.java | 4 +-- .../exec/store/PartitionNotFoundException.java | 4 +-- .../apache/drill/exec/store/RecordDataType.java | 2 +- .../apache/drill/exec/store/RecordReader.java | 2 +- .../drill/exec/store/ResourceInputStream.java | 2 +- .../apache/drill/exec/store/SchemaConfig.java | 4 +-- .../exec/store/SchemaPartitionExplorer.java | 4 +-- .../drill/exec/store/SchemaTreeProvider.java | 4 +-- .../drill/exec/store/StoragePluginMap.java | 2 +- .../drill/exec/store/StorageStrategy.java | 4 +-- .../apache/drill/exec/store/TimedRunnable.java | 2 +- .../drill/exec/store/avro/AvroFormatConfig.java | 2 +- .../drill/exec/store/avro/AvroRecordReader.java | 2 +- .../drill/exec/store/avro/AvroTypeHelper.java | 2 +- .../drill/exec/store/bson/BsonRecordReader.java | 2 +- .../exec/store/dfs/DrillFSDataInputStream.java | 2 +- .../drill/exec/store/dfs/FormatCreator.java | 2 +- .../drill/exec/store/dfs/FormatPlugin.java | 2 +- .../store/dfs/FormatPluginOptionExtractor.java | 2 +- .../dfs/FormatPluginOptionsDescriptor.java | 2 +- .../drill/exec/store/dfs/FormatSelection.java | 2 +- .../exec/store/dfs/NamedFormatPluginConfig.java | 2 +- .../drill/exec/store/dfs/OpenFileTracker.java | 4 +-- .../drill/exec/store/dfs/ReadEntryWithPath.java | 2 +- .../drill/exec/store/dfs/SubDirectoryList.java | 4 +-- .../drill/exec/store/dfs/WorkspaceConfig.java | 2 +- .../exec/store/dfs/easy/EasyGroupScan.java | 2 +- .../store/dfs/easy/EasyReaderBatchCreator.java | 2 +- .../store/dfs/easy/EasyWriterBatchCreator.java | 2 +- .../exec/store/direct/DirectBatchCreator.java | 2 +- .../drill/exec/store/direct/DirectSubScan.java | 2 +- .../exec/store/easy/json/JSONRecordReader.java | 2 +- .../exec/store/easy/json/JsonProcessor.java | 2 +- .../easy/json/reader/BaseJsonProcessor.java | 2 +- .../easy/json/reader/CountingJsonReader.java | 2 +- .../sequencefile/SequenceFileFormatConfig.java | 2 +- .../sequencefile/SequenceFileFormatPlugin.java | 2 +- .../sequencefile/SequenceFileRecordReader.java | 2 +- .../easy/text/compliant/FieldVarCharOutput.java | 2 +- .../StreamFinishedPseudoException.java | 2 +- .../store/easy/text/compliant/TextInput.java | 2 +- .../store/easy/text/compliant/TextOutput.java | 2 +- .../easy/text/compliant/TextParsingContext.java | 2 +- .../text/compliant/TextParsingSettings.java | 2 +- .../store/easy/text/compliant/TextReader.java | 2 +- .../drill/exec/store/httpd/HttpdLogRecord.java | 14 ++++---- .../drill/exec/store/httpd/HttpdParser.java | 14 ++++---- .../drill/exec/store/httpd/HttpdParserTest.java | 14 ++++---- .../store/ischema/InfoSchemaBatchCreator.java | 2 +- .../exec/store/ischema/InfoSchemaConfig.java | 2 +- .../exec/store/ischema/InfoSchemaConstants.java | 4 +-- .../store/ischema/InfoSchemaDrillTable.java | 2 +- .../exec/store/ischema/InfoSchemaFilter.java | 4 +-- .../store/ischema/InfoSchemaFilterBuilder.java | 2 +- .../exec/store/ischema/InfoSchemaGroupScan.java | 2 +- ...InfoSchemaPushFilterIntoRecordGenerator.java | 3 +- .../store/ischema/InfoSchemaStoragePlugin.java | 2 +- .../exec/store/ischema/InfoSchemaSubScan.java | 2 +- .../exec/store/ischema/InfoSchemaTable.java | 2 +- .../exec/store/ischema/InfoSchemaTableType.java | 2 +- .../drill/exec/store/ischema/Records.java | 3 +- .../drill/exec/store/ischema/package-info.java | 2 +- .../exec/store/parquet/ColumnDataReader.java | 2 +- .../drill/exec/store/parquet/Metadata.java | 4 +-- .../exec/store/parquet/MetadataVersion.java | 4 +-- .../ParquetDirectByteBufferAllocator.java | 3 +- .../store/parquet/ParquetFilterBuilder.java | 2 ++ .../exec/store/parquet/ParquetGroupScan.java | 4 +-- .../store/parquet/ParquetPushDownFilter.java | 2 ++ .../store/parquet/ParquetRGFilterEvaluator.java | 6 ++-- .../parquet/ParquetWriterBatchCreator.java | 2 +- .../exec/store/parquet/RowGroupReadEntry.java | 2 +- .../parquet/columnreaders/AsyncPageReader.java | 2 +- .../store/parquet/columnreaders/BitReader.java | 2 +- .../columnreaders/ColumnReaderFactory.java | 4 +-- .../columnreaders/FixedByteAlignedReader.java | 2 +- .../columnreaders/FixedWidthRepeatedReader.java | 2 +- .../columnreaders/NullableBitReader.java | 2 +- .../columnreaders/NullableColumnReader.java | 2 +- .../NullableFixedByteAlignedReaders.java | 2 +- .../NullableVarLengthValuesColumn.java | 4 +-- .../store/parquet/columnreaders/PageReader.java | 2 +- .../ParquetFixedWidthDictionaryReaders.java | 4 +-- .../ParquetToDrillTypeConverter.java | 4 +-- .../columnreaders/VarLenBinaryReader.java | 2 +- .../parquet/columnreaders/VarLengthColumn.java | 4 +-- .../columnreaders/VarLengthColumnReaders.java | 4 +-- .../columnreaders/VarLengthValuesColumn.java | 4 +-- .../store/parquet/stat/ColumnStatCollector.java | 6 ++-- .../store/parquet/stat/ColumnStatistics.java | 6 ++-- .../stat/ParquetFooterStatCollector.java | 6 ++-- .../DrillParquetRecordMaterializer.java | 2 +- .../drill/exec/store/pcap/PcapDrillTable.java | 17 ++++----- .../drill/exec/store/pcap/PcapFormatConfig.java | 17 ++++----- .../drill/exec/store/pcap/PcapFormatPlugin.java | 17 ++++----- .../drill/exec/store/pcap/PcapFormatUtils.java | 17 ++++----- .../drill/exec/store/pcap/PcapRecordReader.java | 17 ++++----- .../drill/exec/store/pcap/package-info.java | 17 ++++----- .../drill/exec/store/pcap/schema/Schema.java | 17 ++++----- .../store/pojo/AbstractPojoRecordReader.java | 13 +++---- .../drill/exec/store/pojo/PojoDataType.java | 2 +- .../exec/store/schedule/AffinityCreator.java | 2 +- .../exec/store/schedule/AssignmentCreator.java | 2 +- .../exec/store/schedule/BlockMapBuilder.java | 2 +- .../exec/store/schedule/CompleteFileWork.java | 2 +- .../drill/exec/store/schedule/CompleteWork.java | 2 +- .../exec/store/schedule/EndpointByteMap.java | 2 +- .../store/schedule/EndpointByteMapImpl.java | 2 +- .../exec/store/sys/BasePersistentStore.java | 4 +-- .../store/sys/BitToUserConnectionIterator.java | 2 +- .../drill/exec/store/sys/DrillbitIterator.java | 2 +- .../exec/store/sys/ExtendedOptionIterator.java | 2 +- .../drill/exec/store/sys/MemoryIterator.java | 2 +- .../drill/exec/store/sys/OptionIterator.java | 2 +- .../exec/store/sys/PersistentStoreConfig.java | 2 +- .../exec/store/sys/PersistentStoreMode.java | 6 ++-- .../exec/store/sys/PersistentStoreProvider.java | 2 +- .../exec/store/sys/PersistentStoreRegistry.java | 2 +- .../drill/exec/store/sys/StaticDrillTable.java | 2 +- .../org/apache/drill/exec/store/sys/Store.java | 13 ++++--- .../exec/store/sys/SystemTablePluginConfig.java | 2 +- .../drill/exec/store/sys/ThreadsIterator.java | 2 +- .../drill/exec/store/sys/VersionIterator.java | 2 +- .../store/sys/VersionedPersistentStore.java | 13 ++++--- .../store/sys/local/LocalPStoreProvider.java | 6 ++-- .../exec/store/sys/store/DataChangeVersion.java | 6 ++-- .../exec/store/sys/store/InMemoryStore.java | 4 +-- .../sys/store/VersionedDelegatingStore.java | 13 ++++--- .../provider/BasePersistentStoreProvider.java | 6 ++-- .../CachingPersistentStoreProvider.java | 2 +- .../provider/LocalPersistentStoreProvider.java | 2 +- .../ZookeeperPersistentStoreProvider.java | 2 +- .../exec/store/sys/zk/ZkPStoreProvider.java | 6 ++-- .../drill/exec/testing/ControlsInjector.java | 2 +- .../exec/testing/ControlsInjectorFactory.java | 2 +- .../exec/testing/CountDownLatchInjection.java | 2 +- .../testing/CountDownLatchInjectionImpl.java | 2 +- .../drill/exec/testing/ExceptionInjection.java | 2 +- .../exec/testing/ExecutionControlsInjector.java | 2 +- .../apache/drill/exec/testing/Injection.java | 2 +- .../InjectionConfigurationException.java | 2 +- .../drill/exec/testing/InjectionSite.java | 2 +- .../exec/testing/NoOpControlsInjector.java | 2 +- .../drill/exec/testing/PauseInjection.java | 2 +- .../exec/testing/store/NoWriteLocalStore.java | 4 +-- .../exec/util/ApproximateStringMatcher.java | 4 +-- .../drill/exec/util/ArrayWrappedIntIntMap.java | 4 +-- .../org/apache/drill/exec/util/ByteBufUtil.java | 2 +- .../drill/exec/util/DrillFileSystemUtil.java | 4 +-- .../apache/drill/exec/util/FileSystemUtil.java | 4 +-- .../apache/drill/exec/util/GuavaPatcher.java | 2 +- .../drill/exec/util/ImpersonationUtil.java | 2 +- .../org/apache/drill/exec/util/JarUtil.java | 6 ++-- .../drill/exec/util/StoragePluginTestUtils.java | 2 +- .../BufferedDirectBufInputStream.java | 6 ++-- .../util/filereader/DirectBufInputStream.java | 6 ++-- .../org/apache/drill/exec/vector/CopyUtil.java | 2 +- .../drill/exec/vector/VectorValidator.java | 2 +- .../vector/accessor/AbstractSqlAccessor.java | 2 +- .../vector/accessor/BoundCheckingAccessor.java | 2 +- .../exec/vector/accessor/GenericAccessor.java | 2 +- .../vector/accessor/InvalidAccessException.java | 2 +- .../drill/exec/vector/accessor/SqlAccessor.java | 2 +- .../exec/vector/accessor/UnionSqlAccessor.java | 2 +- .../drill/exec/vector/complex/FieldIdUtil.java | 4 +-- .../exec/vector/complex/fn/BasicJsonOutput.java | 2 +- .../vector/complex/fn/DateOutputFormat.java | 2 +- .../vector/complex/fn/DrillBufInputStream.java | 2 +- .../vector/complex/fn/ExtendedJsonOutput.java | 2 +- .../exec/vector/complex/fn/ExtendedType.java | 2 +- .../vector/complex/fn/ExtendedTypeName.java | 2 +- .../exec/vector/complex/fn/JsonOutput.java | 2 +- .../exec/vector/complex/fn/JsonReader.java | 2 +- .../exec/vector/complex/fn/JsonReaderUtils.java | 2 +- .../exec/vector/complex/fn/JsonWriter.java | 2 +- .../exec/vector/complex/fn/SeekableBAIS.java | 2 +- .../exec/vector/complex/fn/WorkingBuffer.java | 2 +- .../complex/impl/VectorContainerWriter.java | 2 +- .../drill/exec/work/EndpointListener.java | 2 +- .../drill/exec/work/ExecErrorConstants.java | 2 +- .../org/apache/drill/exec/work/WorkManager.java | 2 +- .../exec/work/batch/AbstractDataCollector.java | 2 +- .../exec/work/batch/BaseRawBatchBuffer.java | 2 +- .../drill/exec/work/batch/DataCollector.java | 2 +- .../drill/exec/work/batch/IncomingBuffers.java | 2 +- .../drill/exec/work/batch/MergingCollector.java | 2 +- .../exec/work/batch/PartitionedCollector.java | 2 +- .../drill/exec/work/batch/RawBatchBuffer.java | 2 +- .../exec/work/batch/ResponseSenderQueue.java | 2 +- .../exec/work/batch/SpoolingRawBatchBuffer.java | 2 +- .../work/batch/UnlimitedRawBatchBuffer.java | 2 +- .../work/foreman/DrillbitStatusListener.java | 2 +- .../exec/work/foreman/ForemanException.java | 2 +- .../work/foreman/ForemanSetupException.java | 2 +- .../drill/exec/work/foreman/FragmentData.java | 2 +- .../work/foreman/FragmentStatusListener.java | 2 +- .../exec/work/foreman/FragmentsRunner.java | 13 +++---- .../drill/exec/work/foreman/LoggedQuery.java | 2 +- .../work/foreman/SqlUnsupportedException.java | 3 +- .../foreman/UnsupportedDataTypeException.java | 2 +- .../foreman/UnsupportedFunctionException.java | 2 +- .../UnsupportedRelOperatorException.java | 2 +- .../work/fragment/AbstractFragmentManager.java | 2 +- .../exec/work/fragment/FragmentExecutor.java | 2 +- .../exec/work/fragment/FragmentManager.java | 2 +- .../work/fragment/FragmentStatusReporter.java | 2 +- .../work/fragment/NonRootFragmentManager.java | 2 +- .../exec/work/fragment/RootFragmentManager.java | 2 +- .../work/fragment/StateTransitionException.java | 2 +- .../exec/work/metadata/MetadataProvider.java | 6 ++-- .../exec/work/metadata/ServerMetaProvider.java | 4 +-- .../work/prepare/PreparedStatementProvider.java | 4 +-- .../apache/drill/exec/work/user/UserWorker.java | 2 +- .../parquet/hadoop/ColumnChunkIncReadStore.java | 2 +- .../ParquetColumnChunkPageWriteStore.java | 13 ++++--- .../java-exec/src/main/resources/rest/error.ftl | 28 +++++++++------ .../src/main/resources/rest/generic.ftl | 28 +++++++++------ .../java-exec/src/main/resources/rest/index.ftl | 28 +++++++++------ .../java-exec/src/main/resources/rest/login.ftl | 28 +++++++++------ .../src/main/resources/rest/logs/list.ftl | 28 +++++++++------ .../src/main/resources/rest/logs/log.ftl | 28 +++++++++------ .../src/main/resources/rest/mainLogin.ftl | 29 +++++++++------ .../src/main/resources/rest/metrics/metrics.ftl | 28 +++++++++------ .../src/main/resources/rest/options.ftl | 28 +++++++++------ .../src/main/resources/rest/profile/list.ftl | 28 +++++++++------ .../src/main/resources/rest/profile/profile.ftl | 28 +++++++++------ .../main/resources/rest/query/errorMessage.ftl | 28 +++++++++------ .../src/main/resources/rest/query/list.ftl | 28 +++++++++------ .../src/main/resources/rest/query/query.ftl | 28 +++++++++------ .../src/main/resources/rest/query/result.ftl | 28 +++++++++------ .../src/main/resources/rest/status.ftl | 28 +++++++++------ .../src/main/resources/rest/storage/list.ftl | 28 +++++++++------ .../src/main/resources/rest/storage/update.ftl | 28 +++++++++------ .../src/main/resources/rest/threads/threads.ftl | 28 +++++++++------ exec/java-exec/src/main/sh/drill-config.sh | 35 +++++++++--------- exec/java-exec/src/main/sh/drillbit.sh | 37 +++++++++----------- .../org/apache/drill/ParquetSchemaMerge.java | 2 +- .../java/org/apache/drill/PlanTestBase.java | 1 - .../org/apache/drill/SingleRowListener.java | 2 +- .../java/org/apache/drill/TestAggNullable.java | 2 +- .../org/apache/drill/TestAltSortQueries.java | 2 +- .../java/org/apache/drill/TestCTASJson.java | 2 +- .../apache/drill/TestCTASPartitionFilter.java | 2 +- .../org/apache/drill/TestCaseSensitivity.java | 3 +- .../java/org/apache/drill/TestCorrelation.java | 2 +- .../apache/drill/TestDisabledFunctionality.java | 2 +- .../org/apache/drill/TestDynamicUDFSupport.java | 4 +-- .../org/apache/drill/TestExampleQueries.java | 2 +- .../org/apache/drill/TestFrameworkTest.java | 4 +-- .../org/apache/drill/TestFunctionsQuery.java | 2 +- .../org/apache/drill/TestImplicitCasting.java | 2 +- .../test/java/org/apache/drill/TestInList.java | 2 +- .../org/apache/drill/TestMergeFilterPlan.java | 3 +- .../apache/drill/TestOutOfMemoryOutcome.java | 2 +- .../org/apache/drill/TestPartitionFilter.java | 2 +- .../drill/TestPlanVerificationUtilities.java | 4 +-- .../org/apache/drill/TestProjectPushDown.java | 3 +- .../java/org/apache/drill/TestSchemaChange.java | 2 +- .../java/org/apache/drill/TestSelectivity.java | 2 +- .../java/org/apache/drill/TestTextJoin.java | 2 +- .../org/apache/drill/TestTpchDistributed.java | 2 +- .../drill/TestTpchDistributedConcurrent.java | 2 +- .../drill/TestTpchDistributedStreaming.java | 2 +- .../java/org/apache/drill/TestTpchExplain.java | 2 +- .../java/org/apache/drill/TestTpchLimit0.java | 2 +- .../java/org/apache/drill/TestTpchPlanning.java | 2 +- .../org/apache/drill/TestTpchSingleMode.java | 2 +- .../drill/TestUtf8SupportInQueryString.java | 13 +++---- .../common/scanner/TestClassPathScanner.java | 2 +- .../apache/drill/exec/DrillSystemTestBase.java | 2 +- .../drill/exec/HyperVectorValueIterator.java | 4 +-- .../java/org/apache/drill/exec/RunRootExec.java | 2 +- .../java/org/apache/drill/exec/SortTest.java | 2 +- .../apache/drill/exec/TestEmptyInputSql.java | 1 - .../apache/drill/exec/TestOpSerialization.java | 1 - .../drill/exec/TestQueriesOnLargeFile.java | 3 +- .../apache/drill/exec/TestRepeatedReaders.java | 1 - .../org/apache/drill/exec/TestSSLConfig.java | 7 ++-- .../apache/drill/exec/TestWithZookeeper.java | 2 +- .../apache/drill/exec/ZookeeperTestUtil.java | 31 ++++++++-------- .../ConnectTriesPropertyTestClusterBits.java | 6 ++-- .../exec/client/DrillClientSystemTest.java | 2 +- .../drill/exec/client/DrillClientTest.java | 6 ++-- .../apache/drill/exec/client/DumpCatTest.java | 2 +- .../exec/compile/CodeCompilerTestFactory.java | 2 +- .../exec/compile/ExampleExternalInterface.java | 2 +- .../drill/exec/compile/ExampleTemplate.java | 2 +- .../exec/compile/TestClassCompilationTypes.java | 2 +- .../compile/bytecode/ReplaceMethodInvoke.java | 2 +- .../drill/exec/coord/zk/TestEphemeralStore.java | 4 +-- .../exec/coord/zk/TestEventDispatcher.java | 6 ++-- .../drill/exec/coord/zk/TestPathUtils.java | 6 ++-- .../exec/coord/zk/TestZookeeperClient.java | 4 +-- .../org/apache/drill/exec/expr/EscapeTest1.java | 2 +- .../apache/drill/exec/expr/ExpressionTest.java | 2 +- .../drill/exec/expr/TestLogicalExprSerDe.java | 5 ++- .../exec/expr/fn/FunctionInitializerTest.java | 13 +++---- .../fn/impl/TestSimpleRepeatedFunctions.java | 2 +- .../exec/expr/fn/impl/TestSqlPatterns.java | 1 - .../fn/registry/FunctionRegistryHolderTest.java | 4 +-- .../exec/fn/impl/TestAggregateFunction.java | 2 +- .../fn/impl/TestByteComparisonFunctions.java | 2 +- .../exec/fn/impl/TestCastEmptyStrings.java | 7 ++-- .../exec/fn/impl/TestContextFunctions.java | 2 +- .../drill/exec/fn/impl/TestCryptoFunctions.java | 14 ++++---- .../exec/fn/impl/TestDateAddFunctions.java | 31 ++++++++-------- .../drill/exec/fn/impl/TestDateFunctions.java | 6 ++-- .../exec/fn/impl/TestDateTruncFunctions.java | 6 ++-- .../drill/exec/fn/impl/TestMathFunctions.java | 3 +- .../fn/impl/TestMathFunctionsWithNanInf.java | 32 ++++++++--------- .../drill/exec/fn/impl/TestMultiInputAdd.java | 7 ++-- .../exec/fn/impl/TestNetworkFunctions.java | 1 - .../exec/fn/impl/TestNewAggregateFunctions.java | 2 +- .../exec/fn/impl/TestNewDateFunctions.java | 2 +- .../exec/fn/impl/TestNewMathFunctions.java | 3 +- .../fn/impl/TestNewSimpleRepeatedFunctions.java | 2 +- .../exec/fn/impl/TestRepeatedFunction.java | 2 +- .../drill/exec/fn/impl/TestTrigFunctions.java | 6 ++-- .../fn/impl/testing/GeneratorFunctions.java | 2 +- .../fn/impl/testing/TestDateConversions.java | 31 ++++++++-------- .../exec/fn/interp/TestConstantFolding.java | 4 +-- .../impersonation/BaseTestImpersonation.java | 4 +-- .../TestImpersonationDisabledWithMiniDFS.java | 4 +-- .../TestImpersonationMetadata.java | 4 +-- .../impersonation/TestImpersonationQueries.java | 4 +-- .../impersonation/TestInboundImpersonation.java | 2 +- .../TestInboundImpersonationPrivileges.java | 4 +-- .../drill/exec/memory/TestAllocators.java | 3 +- .../exec/nested/TestFastComplexSchema.java | 2 +- .../exec/nested/TestNestedComplexSchema.java | 2 +- .../drill/exec/opt/BasicOptimizerTest.java | 2 +- .../physical/config/TestParsePhysicalPlan.java | 2 +- .../exec/physical/impl/SimpleRootExec.java | 2 +- .../physical/impl/TestBroadcastExchange.java | 2 +- .../exec/physical/impl/TestCastFunctions.java | 2 +- .../physical/impl/TestCastVarCharToBigInt.java | 2 +- .../physical/impl/TestComparisonFunctions.java | 2 +- .../drill/exec/physical/impl/TestDecimal.java | 2 +- .../impl/TestDistributedFragmentRun.java | 2 +- .../physical/impl/TestExtractFunctions.java | 2 +- .../physical/impl/TestHashToRandomExchange.java | 2 +- .../impl/TestImplicitCastFunctions.java | 2 +- .../exec/physical/impl/TestLocalExchange.java | 4 +-- .../physical/impl/TestOrderedMuxExchange.java | 4 +-- .../physical/impl/TestReverseImplicitCast.java | 2 +- .../exec/physical/impl/TestSimpleFunctions.java | 2 +- .../exec/physical/impl/TestStringFunctions.java | 2 +- .../exec/physical/impl/TestUnionExchange.java | 2 +- .../impl/TopN/TestTopNSchemaChanges.java | 2 +- .../drill/exec/physical/impl/agg/TestAgg.java | 2 +- .../exec/physical/impl/agg/TestHashAggr.java | 1 - .../physical/impl/agg/TestHashAggrSpill.java | 1 - .../impl/broadcastsender/TestBroadcast.java | 2 +- .../physical/impl/filter/TestLargeInClause.java | 2 +- .../physical/impl/filter/TestSimpleFilter.java | 2 +- .../exec/physical/impl/flatten/TestFlatten.java | 2 +- .../impl/flatten/TestFlattenPlanning.java | 6 ++-- .../exec/physical/impl/join/TestHashJoin.java | 2 +- .../impl/join/TestHashJoinAdvanced.java | 1 - .../impl/join/TestMergeJoinMulCondition.java | 2 +- .../physical/impl/join/TestNestedLoopJoin.java | 1 - .../impl/limit/TestEarlyLimit0Optimization.java | 4 +-- .../impl/limit/TestLimitWithExchanges.java | 2 +- .../physical/impl/limit/TestSimpleLimit.java | 2 +- .../impl/mergereceiver/TestMergingReceiver.java | 1 - .../TestOrderedPartitionExchange.java | 2 +- .../impl/project/TestSimpleProjection.java | 2 +- .../exec/physical/impl/sort/TestSimpleSort.java | 2 +- .../drill/exec/physical/impl/sort/TestSort.java | 2 +- .../physical/impl/svremover/TestSVRemover.java | 2 +- .../impl/trace/TestTraceMultiRecordBatch.java | 2 +- .../impl/trace/TestTraceOutputDump.java | 2 +- .../impl/validate/TestBatchValidator.java | 2 +- .../physical/impl/window/GenerateTestData.java | 2 +- .../physical/impl/window/TestWindowFrame.java | 4 +-- .../TestCorruptParquetDateCorrection.java | 4 +-- .../physical/impl/xsort/TestExternalSort.java | 4 +-- .../physical/unit/BasicPhysicalOpUnitTest.java | 6 ++-- .../physical/unit/MiniPlanUnitTestBase.java | 5 ++- .../physical/unit/PhysicalOpUnitTestBase.java | 4 +-- .../drill/exec/physical/unit/TestMiniPlan.java | 5 ++- .../physical/unit/TestNullInputMiniPlan.java | 5 ++- .../exec/physical/unit/TestOutputBatchSize.java | 5 ++- .../planner/PhysicalPlanReaderTestFactory.java | 2 +- .../exec/planner/TestDirectoryExplorerUDFs.java | 2 +- .../TestHardAffinityFragmentParallelizer.java | 6 ++-- .../exec/planner/logical/FilterSplitTest.java | 2 +- .../planner/logical/TestCaseNullableTypes.java | 31 ++++++++-------- .../apache/drill/exec/pop/PopUnitTestBase.java | 2 +- .../drill/exec/pop/TestFragmentChecker.java | 2 +- .../apache/drill/exec/pop/TestFragmenter.java | 2 +- .../drill/exec/pop/TestInjectionValue.java | 2 +- .../exec/record/TestMaterializedField.java | 4 +-- .../drill/exec/record/TestRecordIterator.java | 2 +- .../drill/exec/record/vector/TestDateTypes.java | 2 +- .../exec/rpc/control/TestCustomTunnel.java | 2 +- .../apache/drill/exec/rpc/data/TestBitRpc.java | 2 +- .../drill/exec/rpc/security/KerberosHelper.java | 2 +- .../user/TemporaryTablesAutomaticDropTest.java | 4 +-- .../security/TestCustomUserAuthenticator.java | 2 +- .../rpc/user/security/TestUserBitKerberos.java | 2 +- .../security/TestUserBitKerberosEncryption.java | 2 +- .../exec/rpc/user/security/TestUserBitSSL.java | 2 +- .../rpc/user/security/TestUserBitSSLServer.java | 2 +- .../security/TestUserBitSaslCompatibility.java | 2 +- .../testing/UserAuthenticatorTestImpl.java | 4 +-- .../drill/exec/server/DrillClientFactory.java | 2 +- .../apache/drill/exec/server/HelloResource.java | 2 +- .../drill/exec/server/TestDurationFormat.java | 2 +- .../apache/drill/exec/server/TestOptions.java | 2 +- .../exec/server/TestOptionsAuthEnabled.java | 2 +- .../drill/exec/server/TestTpcdsSf1Leaks.java | 2 +- .../exec/server/options/OptionValueTest.java | 1 - .../options/PersistedOptionValueTest.java | 1 - .../exec/server/options/TestConfigLinkage.java | 3 +- .../exec/server/rest/StatusResourcesTest.java | 1 - .../server/rest/TestMainLoginPageModel.java | 2 +- .../server/rest/WebSessionResourcesTest.java | 2 +- .../spnego/TestDrillSpnegoAuthenticator.java | 2 +- .../rest/spnego/TestSpnegoAuthentication.java | 4 +-- .../server/rest/spnego/TestSpnegoConfig.java | 2 +- .../drill/exec/sql/TestBaseViewSupport.java | 2 +- .../org/apache/drill/exec/sql/TestCTTAS.java | 4 +-- .../apache/drill/exec/sql/TestInfoSchema.java | 2 +- .../drill/exec/sql/TestSimpleCastFunctions.java | 2 +- .../exec/sql/TestSqlBracketlessSyntax.java | 2 +- .../apache/drill/exec/sql/TestViewSupport.java | 2 +- .../apache/drill/exec/sql/TestWithClause.java | 2 +- .../apache/drill/exec/store/ByteArrayUtil.java | 2 +- .../exec/store/CachedSingleFileSystem.java | 2 +- .../drill/exec/store/FormatPluginSerDeTest.java | 13 +++---- .../drill/exec/store/StorageStrategyTest.java | 13 +++---- .../exec/store/TestAffinityCalculator.java | 2 +- .../exec/store/TestImplicitFileColumns.java | 6 ++-- .../drill/exec/store/TestTimedRunnable.java | 2 +- .../exec/store/bson/TestBsonRecordReader.java | 2 +- .../exec/store/dfs/TestDrillFileSystem.java | 4 +-- .../dfs/TestFormatPluginOptionExtractor.java | 2 +- .../apache/drill/exec/store/dfs/TestGlob.java | 6 ++-- .../exec/store/easy/text/compliant/TestCsv.java | 2 +- .../Drill2283InfoSchemaVarchar1BugTest.java | 4 +-- .../ischema/TestInfoSchemaFilterPushDown.java | 2 +- .../exec/store/json/TestJsonRecordReader.java | 2 +- .../drill/exec/store/parquet/FieldInfo.java | 4 +-- .../store/parquet/ParquetRecordReaderTest.java | 2 +- .../parquet/ParquetSimpleTestFileGenerator.java | 2 +- .../store/parquet/ParquetTestProperties.java | 4 +-- .../exec/store/parquet/TestFileGenerator.java | 2 +- .../exec/store/parquet/TestFixedlenDecimal.java | 2 +- .../parquet/TestParquetFilterPushDown.java | 1 - .../exec/store/parquet/WrapAroundCounter.java | 4 +-- .../columnreaders/TestColumnReaderFactory.java | 2 +- .../parquet/columnreaders/TestDateReader.java | 2 +- .../store/parquet2/TestDrillParquetReader.java | 2 +- .../drill/exec/store/pcap/TestPcapDecoder.java | 17 ++++----- .../exec/store/pcap/TestPcapRecordReader.java | 17 ++++----- .../sequencefile/TestSequenceFileReader.java | 2 +- .../drill/exec/store/store/TestAssignment.java | 2 +- .../drill/exec/store/sys/PStoreTestUtil.java | 2 +- .../exec/store/sys/TestPStoreProviders.java | 3 +- .../drill/exec/store/text/TestCsvHeader.java | 2 +- .../exec/store/text/TestNewTextReader.java | 2 +- .../drill/exec/store/text/TestTextColumn.java | 21 ++++++----- .../exec/store/text/TextRecordReaderTest.java | 2 +- ...ll2130JavaExecHamcrestConfigurationTest.java | 2 +- .../org/apache/drill/exec/testing/Controls.java | 2 +- .../exec/testing/ControlsInjectionUtil.java | 2 +- .../testing/TestCountDownLatchInjection.java | 2 +- .../exec/testing/TestExceptionInjection.java | 2 +- .../drill/exec/testing/TestPauseInjection.java | 2 +- .../drill/exec/testing/TestResourceLeak.java | 2 +- .../exec/util/DrillFileSystemUtilTest.java | 13 +++---- .../drill/exec/util/FileSystemUtilTest.java | 4 +-- .../drill/exec/util/FileSystemUtilTestBase.java | 13 +++---- .../drill/exec/util/MiniZooKeeperCluster.java | 2 +- .../exec/util/TestApproximateStringMatcher.java | 4 +-- .../exec/util/TestArrayWrappedIntIntMap.java | 4 +-- .../drill/exec/vector/TestSplitAndTransfer.java | 2 +- .../vector/accessor/GenericAccessorTest.java | 2 +- .../vector/accessor/TestTimePrintMillis.java | 2 +- .../vector/complex/TestEmptyPopulation.java | 2 +- .../fn/TestJsonReaderWithSparseFiles.java | 2 +- .../complex/writer/TestComplexToJson.java | 2 +- .../complex/writer/TestComplexTypeReader.java | 1 - .../complex/writer/TestComplexTypeWriter.java | 3 +- .../complex/writer/TestExtendedTypes.java | 2 +- .../vector/complex/writer/TestJsonNanInf.java | 32 ++++++++--------- .../complex/writer/TestPromotableWriter.java | 6 ++-- .../vector/complex/writer/TestRepeated.java | 2 +- .../apache/drill/exec/work/batch/FileTest.java | 2 +- .../exec/work/batch/TestSpoolingBuffer.java | 2 +- .../fragment/FragmentStatusReporterTest.java | 15 ++++---- .../fragment/TestFragmentExecutorCancel.java | 2 +- .../work/metadata/TestMetadataProvider.java | 6 ++-- .../work/metadata/TestServerMetaProvider.java | 4 +-- .../work/prepare/PreparedStatementTestBase.java | 13 +++---- .../TestLimit0VsRegularQueriesMetadata.java | 13 +++---- .../prepare/TestPreparedStatementProvider.java | 4 +-- .../apache/drill/test/BaseDirTestWatcher.java | 1 - .../drill/test/ClusterFixtureBuilder.java | 2 +- .../java/org/apache/drill/test/ClusterTest.java | 2 +- .../org/apache/drill/test/ConfigBuilder.java | 2 +- .../java/org/apache/drill/test/FieldDef.java | 2 +- .../org/apache/drill/test/ProfileParser.java | 2 +- .../org/apache/drill/test/QueryTestUtil.java | 2 +- .../apache/drill/test/RestClientFixture.java | 1 - .../apache/drill/test/TestGracefulShutdown.java | 1 - .../drill/test/rowSet/file/JsonFileBuilder.java | 1 - .../apache/drill/vector/TestFillEmpties.java | 3 +- exec/java-exec/src/test/resources/core-site.xml | 28 ++++++++------- .../src/test/resources/saffron.properties | 15 ++++---- .../src/test/resources/ssl-server-invalid.xml | 19 ++++++++++ exec/jdbc-all/pom.xml | 31 ++++++++-------- .../apache/drill/jdbc/DrillbitClassLoader.java | 2 +- .../org/apache/drill/jdbc/ITTestShadedJar.java | 2 +- exec/jdbc/pom.xml | 29 +++++++++------ .../org/apache/drill/jdbc/DrillConnection.java | 2 +- .../drill/jdbc/DrillConnectionConfig.java | 2 +- .../drill/jdbc/DrillDatabaseMetaData.java | 13 +++---- .../drill/jdbc/DrillPreparedStatement.java | 15 ++++---- .../org/apache/drill/jdbc/DrillResultSet.java | 2 +- .../org/apache/drill/jdbc/DrillStatement.java | 15 ++++---- .../main/java/org/apache/drill/jdbc/Driver.java | 2 +- .../drill/jdbc/SQLConversionException.java | 2 +- .../jdbc/SQLConversionOverflowException.java | 2 +- .../apache/drill/jdbc/SchemaChangeListener.java | 2 +- .../apache/drill/jdbc/SqlTimeoutException.java | 2 +- .../jdbc/impl/AvaticaDrillSqlAccessor.java | 2 +- .../org/apache/drill/jdbc/impl/BasicList.java | 2 +- .../drill/jdbc/impl/DrillAccessorList.java | 2 +- .../org/apache/drill/jdbc/impl/DrillCursor.java | 2 +- .../apache/drill/jdbc/impl/DrillFactory.java | 3 +- .../apache/drill/jdbc/impl/DrillHandler.java | 2 +- .../drill/jdbc/impl/DrillJdbc40Factory.java | 2 +- .../drill/jdbc/impl/DrillJdbc41Factory.java | 1 - .../drill/jdbc/impl/DrillRemoteStatement.java | 2 +- .../jdbc/impl/DrillResultSetMetaDataImpl.java | 3 +- .../drill/jdbc/impl/DrillStatementImpl.java | 2 +- .../drill/jdbc/impl/DrillStatementRegistry.java | 2 +- .../org/apache/drill/jdbc/impl/DriverImpl.java | 2 +- .../jdbc/impl/GlobalServiceSetReference.java | 2 +- .../jdbc/impl/TypeConvertingSqlAccessor.java | 4 +-- .../apache/drill/jdbc/impl/WrappedAccessor.java | 5 ++- .../org/apache/drill/jdbc/package-info.java | 1 - .../apache/drill/jdbc/proxy/package-info.java | 1 - .../main/resources/apache-drill-jdbc.properties | 1 + .../drill/jdbc/CachingConnectionFactory.java | 2 +- .../apache/drill/jdbc/ConnectionFactory.java | 2 +- .../org/apache/drill/jdbc/ConnectionInfo.java | 2 +- .../jdbc/ConnectionTransactionMethodsTest.java | 2 +- .../drill/jdbc/NonClosableConnection.java | 2 +- .../jdbc/ResultSetGetMethodConversionsTest.java | 2 +- .../drill/jdbc/ResultSetMetaDataTest.java | 2 +- .../org/apache/drill/jdbc/StatementTest.java | 2 +- .../impl/TypeConvertingSqlAccessorTest.java | 2 +- .../jdbc/test/Bug1735ConnectionCloseTest.java | 2 +- ...ug1735ResultSetCloseReleasesBuffersTest.java | 2 +- ...etColumnsDataTypeNotTypeCodeIntBugsTest.java | 2 +- ...ll2130JavaJdbcHamcrestConfigurationTest.java | 2 +- ...ill2288GetColumnsMetadataWhenNoRowsTest.java | 2 +- ...39GetBooleanFailsSayingWrongTypeBugTest.java | 2 +- ...rill2461IntervalsBreakInfoSchemaBugTest.java | 2 +- ...2463GetNullsFailedWithAssertionsBugTest.java | 2 +- .../java/org/apache/drill/jdbc/test/Hook.java | 2 +- .../test/JdbcConnectTriesTestEmbeddedBits.java | 7 ++-- .../apache/drill/jdbc/test/JdbcDataTest.java | 2 +- .../test/JdbcNullOrderingAndGroupingTest.java | 2 +- .../drill/jdbc/test/JdbcTestActionBase.java | 2 +- .../drill/jdbc/test/JdbcTestQueryBase.java | 2 +- .../jdbc/test/TestAggregateFunctionsQuery.java | 2 +- .../apache/drill/jdbc/test/TestBugFixes.java | 2 +- .../drill/jdbc/test/TestJdbcDistQuery.java | 2 +- .../drill/jdbc/test/TestJdbcMetadata.java | 2 +- exec/memory/base/pom.xml | 29 +++++++++------ .../java/io/netty/buffer/ExpandableByteBuf.java | 2 +- .../main/java/io/netty/buffer/LargeBuffer.java | 2 +- .../io/netty/buffer/MutableWrappedByteBuf.java | 2 +- .../netty/buffer/UnsafeDirectLittleEndian.java | 3 +- .../exec/exception/OutOfMemoryException.java | 2 +- .../drill/exec/memory/AllocationManager.java | 2 +- .../exec/memory/AllocationReservation.java | 2 +- .../exec/memory/AllocatorClosedException.java | 2 +- .../drill/exec/memory/BoundsChecking.java | 2 +- .../drill/exec/memory/BufferAllocator.java | 2 +- .../exec/memory/DrillByteBufAllocator.java | 2 +- .../apache/drill/exec/memory/RootAllocator.java | 2 +- .../apache/drill/exec/memory/package-info.java | 2 +- .../apache/drill/exec/ops/BufferManager.java | 4 +-- .../org/apache/drill/exec/util/Pointer.java | 2 +- .../drill/exec/memory/BoundsCheckingTest.java | 13 ++++--- .../drill/exec/memory/TestAccountant.java | 2 +- .../drill/exec/memory/TestBaseAllocator.java | 2 +- .../apache/drill/exec/memory/TestEndianess.java | 2 +- exec/memory/pom.xml | 27 +++++++------- exec/pom.xml | 31 ++++++++-------- exec/rpc/pom.xml | 29 +++++++++------ .../apache/drill/common/SerializedExecutor.java | 2 +- .../exec/rpc/AbstractHandshakeHandler.java | 2 +- .../java/org/apache/drill/exec/rpc/Acks.java | 2 +- .../drill/exec/rpc/BaseRpcOutcomeListener.java | 2 +- .../drill/exec/rpc/ChannelClosedException.java | 2 +- .../rpc/ChannelListenerWithCoordinationId.java | 2 +- .../drill/exec/rpc/ChunkCreationHandler.java | 2 +- .../apache/drill/exec/rpc/ClientConnection.java | 4 +-- .../drill/exec/rpc/ConnectionThrottle.java | 2 +- .../apache/drill/exec/rpc/DrillRpcFuture.java | 2 +- .../drill/exec/rpc/DrillRpcFutureImpl.java | 2 +- .../drill/exec/rpc/EncryptionContext.java | 3 +- .../drill/exec/rpc/EncryptionContextImpl.java | 2 +- .../apache/drill/exec/rpc/FutureBitCommand.java | 2 +- .../drill/exec/rpc/InboundRpcMessage.java | 2 +- .../apache/drill/exec/rpc/ListeningCommand.java | 2 +- .../drill/exec/rpc/NamedThreadFactory.java | 2 +- .../exec/rpc/NonTransientRpcException.java | 2 +- .../drill/exec/rpc/OutOfMemoryHandler.java | 2 +- .../drill/exec/rpc/OutboundRpcMessage.java | 2 +- .../drill/exec/rpc/ProtobufLengthDecoder.java | 2 +- .../drill/exec/rpc/ReconnectingConnection.java | 2 +- .../drill/exec/rpc/ResettableBarrier.java | 2 +- .../org/apache/drill/exec/rpc/Response.java | 2 +- .../apache/drill/exec/rpc/ResponseSender.java | 2 +- .../apache/drill/exec/rpc/RpcCheckedFuture.java | 2 +- .../org/apache/drill/exec/rpc/RpcCommand.java | 2 +- .../org/apache/drill/exec/rpc/RpcConfig.java | 2 +- .../drill/exec/rpc/RpcConnectionHandler.java | 2 +- .../org/apache/drill/exec/rpc/RpcDecoder.java | 2 +- .../org/apache/drill/exec/rpc/RpcEncoder.java | 2 +- .../org/apache/drill/exec/rpc/RpcException.java | 2 +- .../drill/exec/rpc/RpcExceptionHandler.java | 2 +- .../org/apache/drill/exec/rpc/RpcMessage.java | 2 +- .../org/apache/drill/exec/rpc/RpcMetrics.java | 5 ++- .../org/apache/drill/exec/rpc/RpcOutcome.java | 2 +- .../drill/exec/rpc/RpcOutcomeListener.java | 2 +- .../org/apache/drill/exec/rpc/SaslCodec.java | 1 - .../drill/exec/rpc/SaslDecryptionHandler.java | 1 - .../drill/exec/rpc/SaslEncryptionHandler.java | 1 - .../apache/drill/exec/rpc/TransportCheck.java | 2 +- .../apache/drill/exec/rpc/UserRpcException.java | 2 +- .../security/AuthenticationOutcomeListener.java | 2 +- .../drill/exec/rpc/security/SaslProperties.java | 2 +- exec/vector/pom.xml | 29 +++++++++------ .../src/main/codegen/includes/license.ftl | 36 ++++++++++--------- .../src/main/codegen/includes/vv_imports.ftl | 28 +++++++++------ .../codegen/templates/AbstractFieldReader.java | 1 - .../codegen/templates/AbstractFieldWriter.java | 3 +- .../AbstractPromotableFieldWriter.java | 3 +- .../src/main/codegen/templates/BaseReader.java | 3 +- .../src/main/codegen/templates/BaseWriter.java | 3 +- .../main/codegen/templates/BasicTypeHelper.java | 1 - .../main/codegen/templates/ComplexCopier.java | 3 +- .../main/codegen/templates/ComplexReaders.java | 3 +- .../main/codegen/templates/ComplexWriters.java | 3 +- .../codegen/templates/FixedValueVectors.java | 1 - .../codegen/templates/HolderReaderImpl.java | 3 +- .../src/main/codegen/templates/ListWriters.java | 1 - .../src/main/codegen/templates/MapWriters.java | 3 +- .../src/main/codegen/templates/NullReader.java | 3 +- .../codegen/templates/RepeatedValueVectors.java | 1 - .../main/codegen/templates/UnionListWriter.java | 1 - .../src/main/codegen/templates/UnionReader.java | 3 +- .../src/main/codegen/templates/UnionVector.java | 1 - .../src/main/codegen/templates/UnionWriter.java | 1 - .../main/codegen/templates/ValueHolders.java | 2 +- .../templates/VariableLengthVectors.java | 1 - .../exception/OversizedAllocationException.java | 2 +- .../exception/SchemaChangeRuntimeException.java | 2 +- .../exec/expr/fn/impl/ByteFunctionHelpers.java | 5 ++- .../drill/exec/expr/fn/impl/DateUtility.java | 1 - .../drill/exec/expr/holders/ComplexHolder.java | 2 +- .../drill/exec/expr/holders/ListHolder.java | 2 +- .../drill/exec/expr/holders/MapHolder.java | 2 +- .../drill/exec/expr/holders/ObjectHolder.java | 3 +- .../exec/expr/holders/RepeatedListHolder.java | 2 +- .../exec/expr/holders/RepeatedMapHolder.java | 2 +- .../drill/exec/expr/holders/UnionHolder.java | 2 +- .../drill/exec/expr/holders/ValueHolder.java | 2 +- .../apache/drill/exec/record/TransferPair.java | 2 +- .../org/apache/drill/exec/util/CallBack.java | 2 +- .../drill/exec/util/JsonStringArrayList.java | 2 +- .../drill/exec/util/JsonStringHashMap.java | 2 +- .../java/org/apache/drill/exec/util/Text.java | 2 +- .../drill/exec/vector/AddOrGetResult.java | 2 +- .../apache/drill/exec/vector/DateUtilities.java | 1 - .../vector/NullableVectorDefinitionSetter.java | 2 +- .../drill/exec/vector/SchemaChangeCallBack.java | 3 +- .../drill/exec/vector/UntypedNullHolder.java | 1 - .../drill/exec/vector/UntypedNullVector.java | 3 +- .../drill/exec/vector/ValueHolderHelper.java | 2 +- .../apache/drill/exec/vector/VectorTrimmer.java | 2 +- .../accessor/writer/dummy/package-info.java | 1 - .../vector/accessor/writer/package-info.java | 1 - .../vector/complex/ContainerVectorLike.java | 2 +- .../vector/complex/EmptyValuePopulator.java | 2 +- .../drill/exec/vector/complex/Positionable.java | 2 +- .../complex/RepeatedFixedWidthVectorLike.java | 2 +- .../vector/complex/RepeatedValueVector.java | 2 +- .../RepeatedVariableWidthVectorLike.java | 2 +- .../exec/vector/complex/VectorWithOrdinal.java | 2 +- .../vector/complex/impl/AbstractBaseReader.java | 2 +- .../vector/complex/impl/AbstractBaseWriter.java | 2 +- .../vector/complex/impl/ComplexWriterImpl.java | 2 +- .../complex/impl/MapOrListWriterImpl.java | 2 +- .../vector/complex/impl/PromotableWriter.java | 4 +-- .../complex/impl/RepeatedListReaderImpl.java | 5 ++- .../complex/impl/RepeatedMapReaderImpl.java | 5 ++- .../impl/SingleLikeRepeatedMapReaderImpl.java | 3 +- .../complex/impl/SingleListReaderImpl.java | 6 ++-- .../complex/impl/SingleMapReaderImpl.java | 7 ++-- .../vector/complex/impl/UnionListReader.java | 5 ++- .../exec/vector/complex/reader/FieldReader.java | 2 +- .../exec/vector/complex/writer/FieldWriter.java | 2 +- .../exec/vector/VariableLengthVectorTest.java | 2 +- header | 2 +- logical/pom.xml | 31 ++++++++-------- .../org/apache/drill/common/JSONOptions.java | 2 +- .../common/config/LogicalPlanPersistence.java | 2 +- .../exceptions/ExecutionSetupException.java | 2 +- .../exceptions/ExpressionParsingException.java | 2 +- .../LogicalOperatorValidationException.java | 2 +- .../exceptions/LogicalPlanParsingException.java | 2 +- .../common/expression/BooleanOperator.java | 3 +- .../drill/common/expression/CastExpression.java | 2 +- .../common/expression/ConvertExpression.java | 2 +- .../drill/common/expression/ErrorCollector.java | 2 +- .../common/expression/ErrorCollectorImpl.java | 2 +- .../common/expression/ExpressionFunction.java | 2 +- .../common/expression/ExpressionPosition.java | 2 +- .../drill/common/expression/FunctionCall.java | 2 +- .../common/expression/FunctionCallFactory.java | 2 +- .../drill/common/expression/FunctionName.java | 2 +- .../MajorTypeInLogicalExpression.java | 2 +- .../drill/common/expression/NullExpression.java | 2 +- .../common/expression/OutputTypeDeterminer.java | 2 +- .../common/expression/TypedNullConstant.java | 2 +- .../common/expression/ValidationError.java | 2 +- .../common/expression/fn/CastFunctions.java | 2 +- .../drill/common/expression/fn/FuncHolder.java | 2 +- .../common/expression/fn/JodaDateValidator.java | 31 ++++++++-------- .../common/expression/fn/package-info.java | 2 +- .../drill/common/expression/package-info.java | 2 +- .../drill/common/expression/types/AtomType.java | 2 +- .../drill/common/expression/types/DataType.java | 2 +- .../expression/types/DataTypeFactory.java | 2 +- .../common/expression/types/LateBindType.java | 2 +- .../common/expression/types/package-info.java | 2 +- .../visitors/ConditionalExprOptimizer.java | 3 +- .../visitors/ExpressionValidationError.java | 2 +- .../visitors/ExpressionValidationException.java | 2 +- .../common/expression/visitors/OpVisitor.java | 2 +- .../expression/visitors/SimpleExprVisitor.java | 2 +- .../expression/visitors/package-info.java | 2 +- .../drill/common/graph/AdjacencyList.java | 2 +- .../common/graph/AdjacencyListBuilder.java | 2 +- .../org/apache/drill/common/graph/Edge.java | 2 +- .../org/apache/drill/common/graph/Graph.java | 2 +- .../apache/drill/common/graph/GraphAlgos.java | 2 +- .../apache/drill/common/graph/GraphValue.java | 2 +- .../apache/drill/common/graph/GraphVisitor.java | 2 +- .../apache/drill/common/graph/Visitable.java | 2 +- .../apache/drill/common/graph/package-info.java | 2 +- .../common/logical/FormatPluginConfig.java | 2 +- .../drill/common/logical/LogicalPlan.java | 2 +- .../common/logical/LogicalPlanBuilder.java | 4 +-- .../drill/common/logical/PlanProperties.java | 4 +-- .../common/logical/StoragePluginConfig.java | 2 +- .../common/logical/StoragePluginConfigBase.java | 2 +- .../common/logical/UnexpectedOperatorType.java | 2 +- .../drill/common/logical/ValidationError.java | 2 +- .../common/logical/data/AbstractBuilder.java | 2 +- .../logical/data/AbstractSingleBuilder.java | 2 +- .../drill/common/logical/data/Filter.java | 2 +- .../drill/common/logical/data/Flatten.java | 2 +- .../common/logical/data/GroupingAggregate.java | 2 +- .../apache/drill/common/logical/data/Join.java | 2 +- .../common/logical/data/JoinCondition.java | 2 +- .../apache/drill/common/logical/data/Limit.java | 2 +- .../common/logical/data/LogicalOperator.java | 2 +- .../logical/data/LogicalOperatorBase.java | 2 +- .../common/logical/data/NamedExpression.java | 2 +- .../drill/common/logical/data/Project.java | 2 +- .../common/logical/data/RunningAggregate.java | 2 +- .../apache/drill/common/logical/data/Scan.java | 2 +- .../drill/common/logical/data/Sequence.java | 2 +- .../logical/data/SingleInputOperator.java | 2 +- .../drill/common/logical/data/SinkOperator.java | 2 +- .../common/logical/data/SourceOperator.java | 2 +- .../apache/drill/common/logical/data/Store.java | 2 +- .../drill/common/logical/data/Transform.java | 2 +- .../apache/drill/common/logical/data/Union.java | 2 +- .../drill/common/logical/data/Values.java | 2 +- .../drill/common/logical/data/Window.java | 2 +- .../drill/common/logical/data/Writer.java | 2 +- .../drill/common/logical/data/package-info.java | 2 +- .../data/visitors/AbstractLogicalVisitor.java | 2 +- .../logical/data/visitors/LogicalVisitor.java | 2 +- .../logical/data/visitors/package-info.java | 2 +- .../drill/common/logical/package-info.java | 2 +- .../drill/common/util/AbstractDynamicBean.java | 2 +- .../common/expression/PathSegmentTests.java | 2 +- .../expression/fn/JodaDateValidatorTest.java | 31 ++++++++-------- .../common/expression/parser/TreeTest.java | 2 +- .../drill/storage/CheckStorageConfig.java | 2 +- .../org/apache/drill/common/types/DataMode.java | 2 +- .../apache/drill/common/types/MajorType.java | 2 +- .../apache/drill/common/types/MinorType.java | 2 +- .../drill/common/types/SchemaTypeProtos.java | 2 +- .../apache/drill/common/types/TypeProtos.java | 2 +- .../org/apache/drill/exec/proto/BitControl.java | 2 +- .../org/apache/drill/exec/proto/BitData.java | 2 +- .../drill/exec/proto/CoordinationProtos.java | 2 +- .../org/apache/drill/exec/proto/ExecProtos.java | 2 +- .../drill/exec/proto/GeneralRPCProtos.java | 2 +- .../drill/exec/proto/SchemaBitControl.java | 2 +- .../apache/drill/exec/proto/SchemaBitData.java | 2 +- .../exec/proto/SchemaCoordinationProtos.java | 2 +- .../drill/exec/proto/SchemaDefProtos.java | 2 +- .../drill/exec/proto/SchemaExecProtos.java | 2 +- .../exec/proto/SchemaGeneralRPCProtos.java | 2 +- .../drill/exec/proto/SchemaSchemaDefProtos.java | 2 +- .../drill/exec/proto/SchemaUserBitShared.java | 2 +- .../drill/exec/proto/SchemaUserProtos.java | 2 +- .../apache/drill/exec/proto/UserBitShared.java | 2 +- .../org/apache/drill/exec/proto/UserProtos.java | 2 +- .../org/apache/drill/exec/proto/beans/Ack.java | 2 +- .../exec/proto/beans/BitClientHandshake.java | 2 +- .../exec/proto/beans/BitControlHandshake.java | 2 +- .../exec/proto/beans/BitServerHandshake.java | 2 +- .../drill/exec/proto/beans/BitStatus.java | 2 +- .../exec/proto/beans/BitToUserHandshake.java | 2 +- .../drill/exec/proto/beans/CatalogMetadata.java | 2 +- .../drill/exec/proto/beans/CollateSupport.java | 2 +- .../drill/exec/proto/beans/Collector.java | 2 +- .../drill/exec/proto/beans/ColumnMetadata.java | 2 +- .../exec/proto/beans/ColumnSearchability.java | 2 +- .../exec/proto/beans/ColumnUpdatability.java | 2 +- .../exec/proto/beans/CompleteRpcMessage.java | 2 +- .../drill/exec/proto/beans/ConvertSupport.java | 2 +- .../exec/proto/beans/CoreOperatorType.java | 2 +- .../proto/beans/CorrelationNamesSupport.java | 2 +- .../proto/beans/CreatePreparedStatementReq.java | 2 +- .../beans/CreatePreparedStatementResp.java | 2 +- .../drill/exec/proto/beans/CustomMessage.java | 2 +- .../proto/beans/DateTimeLiteralsSupport.java | 2 +- .../drill/exec/proto/beans/DrillPBError.java | 2 +- .../exec/proto/beans/DrillServiceInstance.java | 2 +- .../exec/proto/beans/DrillbitEndpoint.java | 2 +- .../exec/proto/beans/ExceptionWrapper.java | 2 +- .../exec/proto/beans/FinishedReceiver.java | 2 +- .../drill/exec/proto/beans/FragmentHandle.java | 2 +- .../exec/proto/beans/FragmentRecordBatch.java | 2 +- .../drill/exec/proto/beans/FragmentState.java | 2 +- .../drill/exec/proto/beans/FragmentStatus.java | 2 +- .../drill/exec/proto/beans/GetCatalogsReq.java | 2 +- .../drill/exec/proto/beans/GetCatalogsResp.java | 2 +- .../drill/exec/proto/beans/GetColumnsReq.java | 2 +- .../drill/exec/proto/beans/GetColumnsResp.java | 2 +- .../exec/proto/beans/GetQueryPlanFragments.java | 2 +- .../drill/exec/proto/beans/GetSchemasReq.java | 2 +- .../drill/exec/proto/beans/GetSchemasResp.java | 2 +- .../exec/proto/beans/GetServerMetaResp.java | 2 +- .../drill/exec/proto/beans/GetTablesReq.java | 2 +- .../drill/exec/proto/beans/GetTablesResp.java | 2 +- .../drill/exec/proto/beans/GroupBySupport.java | 2 +- .../drill/exec/proto/beans/HandshakeStatus.java | 2 +- .../exec/proto/beans/IdentifierCasing.java | 2 +- .../exec/proto/beans/InitializeFragments.java | 2 +- .../org/apache/drill/exec/proto/beans/Jar.java | 2 +- .../drill/exec/proto/beans/LikeFilter.java | 2 +- .../exec/proto/beans/MajorFragmentProfile.java | 2 +- .../drill/exec/proto/beans/MetricValue.java | 2 +- .../exec/proto/beans/MinorFragmentProfile.java | 2 +- .../apache/drill/exec/proto/beans/NamePart.java | 2 +- .../drill/exec/proto/beans/NodeStatus.java | 2 +- .../drill/exec/proto/beans/NullCollation.java | 2 +- .../drill/exec/proto/beans/OperatorProfile.java | 2 +- .../drill/exec/proto/beans/OrderBySupport.java | 2 +- .../exec/proto/beans/OuterJoinSupport.java | 2 +- .../drill/exec/proto/beans/ParsingError.java | 2 +- .../drill/exec/proto/beans/PlanFragment.java | 2 +- .../exec/proto/beans/PreparedStatement.java | 2 +- .../proto/beans/PreparedStatementHandle.java | 2 +- .../apache/drill/exec/proto/beans/Property.java | 2 +- .../proto/beans/QueryContextInformation.java | 2 +- .../drill/exec/proto/beans/QueryData.java | 2 +- .../apache/drill/exec/proto/beans/QueryId.java | 2 +- .../drill/exec/proto/beans/QueryInfo.java | 2 +- .../exec/proto/beans/QueryPlanFragments.java | 2 +- .../drill/exec/proto/beans/QueryProfile.java | 2 +- .../drill/exec/proto/beans/QueryResult.java | 2 +- .../exec/proto/beans/QueryResultsMode.java | 2 +- .../drill/exec/proto/beans/QueryType.java | 2 +- .../drill/exec/proto/beans/RecordBatchDef.java | 2 +- .../apache/drill/exec/proto/beans/Registry.java | 2 +- .../drill/exec/proto/beans/RequestResults.java | 2 +- .../drill/exec/proto/beans/RequestStatus.java | 2 +- .../exec/proto/beans/ResultColumnMetadata.java | 2 +- .../apache/drill/exec/proto/beans/Roles.java | 2 +- .../drill/exec/proto/beans/RpcChannel.java | 2 +- .../exec/proto/beans/RpcEndpointInfos.java | 2 +- .../drill/exec/proto/beans/RpcHeader.java | 2 +- .../apache/drill/exec/proto/beans/RpcMode.java | 2 +- .../apache/drill/exec/proto/beans/RpcType.java | 2 +- .../apache/drill/exec/proto/beans/RunQuery.java | 2 +- .../drill/exec/proto/beans/SaslMessage.java | 2 +- .../drill/exec/proto/beans/SaslStatus.java | 2 +- .../drill/exec/proto/beans/SaslSupport.java | 2 +- .../drill/exec/proto/beans/SchemaMetadata.java | 2 +- .../drill/exec/proto/beans/SerializedField.java | 2 +- .../drill/exec/proto/beans/ServerMeta.java | 2 +- .../beans/ServerPreparedStatementState.java | 2 +- .../proto/beans/StackTraceElementWrapper.java | 2 +- .../drill/exec/proto/beans/StreamProfile.java | 2 +- .../drill/exec/proto/beans/SubQuerySupport.java | 2 +- .../drill/exec/proto/beans/TableMetadata.java | 2 +- .../drill/exec/proto/beans/UnionSupport.java | 2 +- .../drill/exec/proto/beans/UserCredentials.java | 2 +- .../drill/exec/proto/beans/UserProperties.java | 2 +- .../exec/proto/beans/UserToBitHandshake.java | 2 +- .../drill/exec/proto/beans/ValueMode.java | 2 +- .../drill/exec/proto/beans/WorkQueueStatus.java | 2 +- .../resources/assemblies/source-assembly.xml | 29 +++++++++------ src/main/resources/checkstyle-config.xml | 31 ++++++++++------ src/main/resources/checkstyle-suppressions.xml | 29 +++++++++------ tools/drill-patch-review.py | 7 ++-- tools/fmpp/pom.xml | 29 +++++++++------ .../org/apache/drill/fmpp/mojo/FMPPMojo.java | 2 +- tools/pom.xml | 27 +++++++------- tools/verify_release.sh | 34 ++++++++---------- 2067 files changed, 4511 insertions(+), 4259 deletions(-) ----------------------------------------------------------------------
