This is an automated email from the ASF dual-hosted git repository.
amansinha pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/drill.git.
from 8fb85cd DRILL-7006: Add type conversion to row writers
new 982e980 DRILL-6997: Semijoin is changing the join ordering for some
tpcds queries.
new 0242241 DRILL-7002: whatever exec.hashjoin.num_partitions is set,
output right results
new 9c82e06 DRILL-7008: Drillbits: clear stale shutdown hooks
new b1594cb DRILL-7018: Fixed Parquet buffer overflow when reading
timestamp column
new 0a61b8f DRILL-6964: Implement CREATE / DROP SCHEMA commands
The 3455 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:
exec/java-exec/pom.xml | 21 +
.../record/metadata/schema/parser/SchemaLexer.g4 | 90 ++++
.../record/metadata/schema/parser/SchemaParser.g4 | 72 +++
exec/java-exec/src/main/codegen/data/Parser.tdd | 9 +-
.../src/main/codegen/includes/parserImpls.ftl | 259 +++++++++--
.../exec/physical/impl/join/HashJoinBatch.java | 18 +-
.../apache/drill/exec/planner/PlannerPhase.java | 13 +-
.../apache/drill/exec/planner/RuleInstance.java | 1 -
.../exec/planner/logical/DrillSemiJoinRel.java | 56 ++-
.../exec/planner/logical/DrillSemiJoinRule.java | 183 ++++++++
.../drill/exec/planner/physical/JoinPrel.java | 58 +--
.../drill/exec/planner/sql/DrillSqlWorker.java | 2 +-
.../drill/exec/planner/sql/SchemaUtilites.java | 19 +-
.../planner/sql/handlers/DefaultSqlHandler.java | 10 +-
.../planner/sql/handlers/DropTableHandler.java | 24 +-
.../exec/planner/sql/handlers/SchemaHandler.java | 214 +++++++++
.../exec/planner/sql/handlers/ViewHandler.java | 4 +-
.../sql/parser/CompoundIdentifierConverter.java | 2 +
.../sql/parser/SqlCreateType.java} | 26 +-
.../exec/planner/sql/parser/SqlCreateView.java | 16 +-
.../drill/exec/planner/sql/parser/SqlSchema.java | 280 ++++++++++++
.../record/metadata/AbstractColumnMetadata.java | 30 ++
.../exec/record/metadata/MapColumnMetadata.java | 14 +
.../record/metadata/PrimitiveColumnMetadata.java | 46 ++
.../metadata/RepeatedListColumnMetadata.java | 6 +
.../drill/exec/record/metadata/TupleSchema.java | 7 +
.../metadata/schema/FsMetastoreSchemaProvider.java | 51 +++
.../metadata/schema/InlineSchemaProvider.java} | 46 +-
.../record/metadata/schema/PathSchemaProvider.java | 132 ++++++
.../record/metadata/schema/SchemaContainer.java | 145 ++++++
.../record/metadata/schema/SchemaProvider.java | 66 +++
.../metadata/schema/parser/SchemaExprParser.java | 96 ++++
.../schema/parser/SchemaParsingException.java} | 9 +-
.../metadata/schema/parser/SchemaVisitor.java | 269 +++++++++++
.../schema/parser/UpperCaseCharStream.java | 84 ++++
.../org/apache/drill/exec/server/Drillbit.java | 15 +-
.../NullableFixedByteAlignedReaders.java | 5 +-
.../java/org/apache/drill/TestSchemaCommands.java | 501 +++++++++++++++++++++
.../exec/physical/impl/join/TestSemiJoin.java | 25 +-
.../record/metadata/schema/TestSchemaProvider.java | 232 ++++++++++
.../schema/parser/TestParserErrorHandling.java | 157 +++++++
.../metadata/schema/parser/TestSchemaParser.java | 279 ++++++++++++
.../java/org/apache/drill/exec/sql/TestCTTAS.java | 10 +-
.../org/apache/drill/exec/sql/TestViewSupport.java | 2 +-
.../drill/exec/record/metadata/ColumnMetadata.java | 17 +
.../drill/exec/record/metadata/TupleMetadata.java | 8 +
46 files changed, 3426 insertions(+), 203 deletions(-)
create mode 100644
exec/java-exec/src/main/antlr4/org/apache/drill/exec/record/metadata/schema/parser/SchemaLexer.g4
create mode 100644
exec/java-exec/src/main/antlr4/org/apache/drill/exec/record/metadata/schema/parser/SchemaParser.g4
create mode 100644
exec/java-exec/src/main/java/org/apache/drill/exec/planner/logical/DrillSemiJoinRule.java
create mode 100644
exec/java-exec/src/main/java/org/apache/drill/exec/planner/sql/handlers/SchemaHandler.java
copy
exec/java-exec/src/main/java/org/apache/drill/exec/{physical/impl/common/SpilledPartitionMetadata.java
=> planner/sql/parser/SqlCreateType.java} (59%)
create mode 100644
exec/java-exec/src/main/java/org/apache/drill/exec/planner/sql/parser/SqlSchema.java
create mode 100644
exec/java-exec/src/main/java/org/apache/drill/exec/record/metadata/schema/FsMetastoreSchemaProvider.java
copy
exec/java-exec/src/main/java/org/apache/drill/exec/{physical/rowSet/model/ReaderIndex.java
=> record/metadata/schema/InlineSchemaProvider.java} (50%)
create mode 100644
exec/java-exec/src/main/java/org/apache/drill/exec/record/metadata/schema/PathSchemaProvider.java
create mode 100644
exec/java-exec/src/main/java/org/apache/drill/exec/record/metadata/schema/SchemaContainer.java
create mode 100644
exec/java-exec/src/main/java/org/apache/drill/exec/record/metadata/schema/SchemaProvider.java
create mode 100644
exec/java-exec/src/main/java/org/apache/drill/exec/record/metadata/schema/parser/SchemaExprParser.java
copy
exec/java-exec/src/main/java/org/apache/drill/exec/{exception/JarValidationException.java
=> record/metadata/schema/parser/SchemaParsingException.java} (79%)
create mode 100644
exec/java-exec/src/main/java/org/apache/drill/exec/record/metadata/schema/parser/SchemaVisitor.java
create mode 100644
exec/java-exec/src/main/java/org/apache/drill/exec/record/metadata/schema/parser/UpperCaseCharStream.java
create mode 100644
exec/java-exec/src/test/java/org/apache/drill/TestSchemaCommands.java
create mode 100644
exec/java-exec/src/test/java/org/apache/drill/exec/record/metadata/schema/TestSchemaProvider.java
create mode 100644
exec/java-exec/src/test/java/org/apache/drill/exec/record/metadata/schema/parser/TestParserErrorHandling.java
create mode 100644
exec/java-exec/src/test/java/org/apache/drill/exec/record/metadata/schema/parser/TestSchemaParser.java
