This is an automated email from the ASF dual-hosted git repository.
arina pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/drill.git.
from ddb35ce DRILL-6688 Data batches for Project operator exceed the
maximum specified (#1442)
new 8bcb103 DRILL-6492: Ensure schema / workspace case insensitivity in
Drill
new 9896182 DRILL-6647: Update Calcite version to 1.17.0
new 260a164 DRILL-6693: When a query is started from Drill Web Console,
the UI becomes inaccessible until the query finishes
new a1f3f9a DRILL-6703: Query with complex expressions in lateral and
unnest fails with CannotPlanException
new e9ffb5b DRILL-6644: Don't reserve space for incoming probe batches
unnecessarily during the build phase.
new d8f9fb6 DRILL-6461: Added basic data correctness tests for hash agg,
and improved operator unit testing framework.
The 6 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../drill/common/map/CaseInsensitiveMap.java | 25 +-
.../drill/common/scanner/ClassPathScanner.java | 22 +-
.../drill/common/map/TestCaseInsensitiveMap.java | 15 +
.../drill/exec/store/hbase/HBaseSchemaFactory.java | 26 +-
.../exec/store/hive/schema/HiveDatabaseSchema.java | 11 +-
.../exec/store/hive/schema/HiveSchemaFactory.java | 29 +-
.../apache/drill/exec/hive/TestHiveStorage.java | 5 +
.../exec/hive/TestInfoSchemaOnHiveStorage.java | 2 +-
.../hive/BaseTestHiveImpersonation.java | 11 -
.../hive/TestSqlStdBasedAuthorization.java | 19 +-
.../hive/TestStorageBasedHiveAuthorization.java | 30 +-
.../drill/exec/store/jdbc/JdbcStoragePlugin.java | 2 +-
.../store/kafka/schema/KafkaSchemaFactory.java | 14 +-
.../drill/exec/store/kudu/KuduSchemaFactory.java | 22 +-
.../store/mongo/schema/MongoSchemaFactory.java | 16 +-
contrib/storage-opentsdb/README.md | 16 +-
.../exec/store/openTSDB/OpenTSDBStoragePlugin.java | 5 +-
.../openTSDB/schema/OpenTSDBSchemaFactory.java | 19 +-
exec/java-exec/src/main/codegen/data/Parser.tdd | 8 +-
.../java/org/apache/drill/exec/ExecConstants.java | 1 +
.../drill/exec/coord/zk/ZookeeperClient.java | 2 +-
.../expr/fn/registry/LocalFunctionRegistry.java | 11 +-
.../drill/exec/physical/impl/TopN/TopNBatch.java | 12 -
.../physical/impl/common/HashTableTemplate.java | 12 +-
.../exec/physical/impl/join/HashJoinBatch.java | 23 +-
.../join/HashJoinMechanicalMemoryCalculator.java | 1 -
.../impl/join/HashJoinMemoryCalculator.java | 3 +-
.../impl/join/HashJoinMemoryCalculatorImpl.java | 106 +-
.../physical/impl/project/ProjectRecordBatch.java | 2 +
.../physical/impl/svremover/AbstractCopier.java | 26 +-
.../physical/impl/svremover/AbstractSV2Copier.java | 4 +-
.../physical/impl/svremover/AbstractSV4Copier.java | 4 +-
.../drill/exec/physical/impl/svremover/Copier.java | 4 +-
.../physical/impl/svremover/GenericCopier.java | 7 +-
.../physical/impl/svremover/StraightCopier.java | 3 +-
.../apache/drill/exec/planner/PlannerPhase.java | 3 -
.../logical/DirPrunedEnumerableTableScan.java | 12 +-
.../exec/planner/logical/DrillConditions.java | 20 +-
...rojectComplexRexNodeCorrelateTransposeRule.java | 154 --
.../drill/exec/planner/logical/StoragePlugins.java | 7 +-
.../exec/planner/sql/DrillConvertletTable.java | 35 +-
.../drill/exec/planner/sql/SchemaUtilites.java | 3 +-
.../drill/exec/planner/sql/SqlConverter.java | 2 +-
.../planner/sql/handlers/ComplexUnnestVisitor.java | 199 +++
.../planner/sql/handlers/DefaultSqlHandler.java | 33 +-
.../sql/handlers/DescribeSchemaHandler.java | 6 +-
.../planner/sql/handlers/DescribeTableHandler.java | 69 +-
.../planner/sql/handlers/ShowSchemasHandler.java | 27 +-
.../planner/sql/handlers/ShowTablesHandler.java | 74 +-
.../apache/drill/exec/record/RecordBatchSizer.java | 17 +
.../apache/drill/exec/server/rest/WebServer.java | 5 +-
.../apache/drill/exec/store/AbstractSchema.java | 50 +-
.../AbstractSchemaFactory.java} | 19 +-
.../drill/exec/store/AbstractStoragePlugin.java | 14 +-
.../drill/exec/store/PartitionExplorerImpl.java | 2 +-
.../org/apache/drill/exec/store/SchemaFactory.java | 5 +-
.../org/apache/drill/exec/store/StoragePlugin.java | 2 +
.../apache/drill/exec/store/StoragePluginMap.java | 6 +-
.../drill/exec/store/StoragePluginRegistry.java | 6 +-
.../exec/store/StoragePluginRegistryImpl.java | 468 +++---
.../SystemPlugin.java} | 10 +-
.../drill/exec/store/dfs/FileSystemConfig.java | 6 +-
.../drill/exec/store/dfs/FileSystemPlugin.java | 2 +
.../exec/store/dfs/FileSystemSchemaFactory.java | 20 +-
.../drill/exec/store/ischema/InfoSchemaConfig.java | 3 +-
.../exec/store/ischema/InfoSchemaConstants.java | 2 +-
.../store/ischema/InfoSchemaStoragePlugin.java | 62 +-
.../store/sys/CaseInsensitivePersistentStore.java | 79 ++
.../drill/exec/store/sys/SystemTablePlugin.java | 54 +-
.../exec/store/sys/SystemTablePluginConfig.java | 1 -
.../drill/exec/work/metadata/MetadataProvider.java | 24 +-
.../java-exec/src/main/resources/drill-module.conf | 28 +-
.../drill/common/scanner/TestClassPathScanner.java | 43 +-
.../drill/exec/coord/zk/TestZookeeperClient.java | 10 +-
.../exec/impersonation/BaseTestImpersonation.java | 19 +-
.../TestImpersonationDisabledWithMiniDFS.java | 12 +-
.../impersonation/TestImpersonationMetadata.java | 112 +-
.../impersonation/TestImpersonationQueries.java | 17 +-
.../physical/impl/BaseTestOpBatchEmitOutcome.java | 2 +-
.../drill/exec/physical/impl/MockRecordBatch.java | 196 ++-
.../physical/impl/agg/TestAggWithAnyValue.java | 6 +-
.../exec/physical/impl/agg/TestHashAggBatch.java | 212 +++
.../physical/impl/common/HashPartitionTest.java | 70 +-
.../impl/join/TestBuildSidePartitioningImpl.java | 104 +-
.../exec/physical/impl/join/TestHashJoinJPPD.java | 6 +-
.../exec/physical/impl/join/TestHashJoinSpill.java | 8 +-
.../impl/join/TestPostBuildCalculationsImpl.java | 127 +-
.../impl/lateraljoin/TestE2EUnnestAndLateral.java | 39 +
.../physical/impl/limit/TestLimitOperator.java | 16 +-
.../impl/svremover/AbstractGenericCopierTest.java | 90 +-
.../physical/impl/svremover/GenericCopierTest.java | 4 +-
.../impl/svremover/GenericSV2BatchCopierTest.java | 4 +-
.../impl/svremover/GenericSV2CopierTest.java | 4 +-
.../impl/svremover/GenericSV4CopierTest.java | 9 +-
.../physical/unit/BasicPhysicalOpUnitTest.java | 30 +-
.../exec/physical/unit/MiniPlanUnitTestBase.java | 3 +-
.../exec/physical/unit/TestNullInputMiniPlan.java | 4 +-
.../exec/physical/unit/TestOutputBatchSize.java | 80 +-
.../exec/planner/TestDirectoryExplorerUDFs.java | 2 +-
.../org/apache/drill/exec/sql/TestInfoSchema.java | 64 +-
.../exec/sql/TestSchemaCaseInsensitivity.java | 92 ++
.../columnreaders/TestBatchSizingMemoryUtil.java | 2 +-
.../exec/work/metadata/TestMetadataProvider.java | 38 +-
.../drill/test/LegacyOperatorTestBuilder.java | 178 +++
.../org/apache/drill/test/OperatorTestBuilder.java | 314 ++++
.../apache/drill/test/OperatorTestBuilderTest.java | 157 ++
.../unit => test}/PhysicalOpUnitTestBase.java | 169 +--
.../org/apache/drill/test/rowSet/RowSetBatch.java | 111 --
.../apache/drill/test/rowSet/RowSetComparison.java | 151 +-
.../drill/test/rowSet/TestRowSetComparison.java | 211 +++
.../drill/jdbc/impl/DrillConnectionImpl.java | 400 ++----
.../drill/jdbc/impl/DrillDatabaseMetaDataImpl.java | 354 +++--
.../apache/drill/jdbc/impl/DrillJdbc41Factory.java | 120 +-
.../jdbc/impl/DrillPreparedStatementImpl.java | 463 +-----
.../apache/drill/jdbc/impl/DrillResultSetImpl.java | 1494 ++++++--------------
.../jdbc/impl/DrillResultSetMetaDataImpl.java | 10 +-
.../apache/drill/jdbc/impl/DrillStatementImpl.java | 327 +----
.../java/org/apache/drill/jdbc/JdbcTestBase.java | 129 +-
...rill2489CallsAfterCloseThrowExceptionsTest.java | 107 +-
.../main/codegen/templates/FixedValueVectors.java | 2 +-
.../codegen/templates/NullableValueVectors.java | 2 +-
pom.xml | 4 +-
122 files changed, 4087 insertions(+), 4088 deletions(-)
delete mode 100644
exec/java-exec/src/main/java/org/apache/drill/exec/planner/logical/ProjectComplexRexNodeCorrelateTransposeRule.java
create mode 100644
exec/java-exec/src/main/java/org/apache/drill/exec/planner/sql/handlers/ComplexUnnestVisitor.java
copy
exec/java-exec/src/main/java/org/apache/drill/exec/{compile/sig/CodeGeneratorArgument.java
=> store/AbstractSchemaFactory.java} (72%)
copy
exec/java-exec/src/main/java/org/apache/drill/exec/{physical/impl/PhysicalConfig.java
=> store/SystemPlugin.java} (83%)
create mode 100644
exec/java-exec/src/main/java/org/apache/drill/exec/store/sys/CaseInsensitivePersistentStore.java
create mode 100644
exec/java-exec/src/test/java/org/apache/drill/exec/physical/impl/agg/TestHashAggBatch.java
create mode 100644
exec/java-exec/src/test/java/org/apache/drill/exec/sql/TestSchemaCaseInsensitivity.java
create mode 100644
exec/java-exec/src/test/java/org/apache/drill/test/LegacyOperatorTestBuilder.java
create mode 100644
exec/java-exec/src/test/java/org/apache/drill/test/OperatorTestBuilder.java
create mode 100644
exec/java-exec/src/test/java/org/apache/drill/test/OperatorTestBuilderTest.java
rename exec/java-exec/src/test/java/org/apache/drill/{exec/physical/unit =>
test}/PhysicalOpUnitTestBase.java (71%)
delete mode 100644
exec/java-exec/src/test/java/org/apache/drill/test/rowSet/RowSetBatch.java
create mode 100644
exec/java-exec/src/test/java/org/apache/drill/test/rowSet/TestRowSetComparison.java
