This is an automated email from the ASF dual-hosted git repository.
ihuzenko pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/drill.git.
from b93e085 DRILL-7575: Fix typo in class name of FormSecurityHandler
new 806760b DRILL-5733: Unable to SELECT from parquet file with Hadoop
2.7.4
new 4b85785 DRILL-7361: Support MAP (DICT) type in schema file
new ab65a18 DRILL-7504: Upgrade Parquet library to 1.11.0
new d8ed725 DRILL-7549: Fix validation error when querying absent sub
folder in embedded mode
new 09b805a DRILL-7576: Fail fast for operator errors
The 5 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:
.../common/exceptions/DrillRuntimeException.java | 7 +-
.../drill/maprdb/tests/json/TestSimpleJson.java | 18 +-
.../templates/StatisticsRecordWriterImpl.java | 26 +-
.../drill/exec/client/LoggingResultsListener.java | 11 +-
.../exec/physical/config/UnorderedReceiver.java | 1 -
.../drill/exec/physical/impl/BaseRootExec.java | 59 +++-
.../drill/exec/physical/impl/ImplCreator.java | 10 +-
.../apache/drill/exec/physical/impl/RootExec.java | 39 +--
.../apache/drill/exec/physical/impl/ScanBatch.java | 51 ++--
.../drill/exec/physical/impl/ScreenCreator.java | 68 ++---
.../physical/impl/StatisticsWriterRecordBatch.java | 116 ++++----
.../physical/impl/TopN/PriorityQueueTemplate.java | 23 +-
.../drill/exec/physical/impl/TopN/TopNBatch.java | 319 +++++++++++----------
.../exec/physical/impl/WriterRecordBatch.java | 111 +++----
.../exec/physical/impl/aggregate/HashAggBatch.java | 8 +-
.../impl/aggregate/SpilledRecordBatch.java | 20 +-
.../physical/impl/aggregate/StreamingAggBatch.java | 12 +-
.../physical/impl/filter/FilterRecordBatch.java | 3 +-
.../impl/filter/RuntimeFilterBatchCreator.java | 6 +-
.../impl/filter/RuntimeFilterRecordBatch.java | 41 +--
.../exec/physical/impl/join/HashJoinBatch.java | 14 +-
.../exec/physical/impl/join/MergeJoinBatch.java | 7 +-
.../exec/physical/impl/join/RowKeyJoinBatch.java | 10 +-
.../exec/physical/impl/limit/LimitRecordBatch.java | 7 +-
.../impl/limit/PartitionLimitRecordBatch.java | 3 +-
.../impl/mergereceiver/MergingRecordBatch.java | 166 +++++------
.../impl/metadata/MetadataControllerBatch.java | 73 ++---
.../impl/metadata/MetadataHandlerBatch.java | 10 +-
.../OrderedPartitionRecordBatch.java | 37 +--
.../partitionsender/PartitionSenderRootExec.java | 6 +-
.../impl/partitionsender/PartitionerDecorator.java | 18 +-
.../impl/producer/ProducerConsumerBatch.java | 38 +--
.../impl/protocol/OperatorRecordBatch.java | 5 -
.../RangePartitionRecordBatch.java | 2 +-
.../physical/impl/sort/SortRecordBatchBuilder.java | 7 +-
.../impl/statistics/StatisticsMergeBatch.java | 88 +++---
.../impl/svremover/RemovingRecordBatch.java | 3 +-
.../physical/impl/unnest/UnnestRecordBatch.java | 76 +++--
.../unorderedreceiver/UnorderedReceiverBatch.java | 15 +-
.../impl/unpivot/UnpivotMapsRecordBatch.java | 42 +--
.../physical/impl/window/FrameSupportTemplate.java | 41 ++-
.../impl/window/NoFrameSupportTemplate.java | 27 +-
.../impl/window/WindowFrameRecordBatch.java | 31 +-
.../exec/physical/impl/window/WindowFramer.java | 3 +-
.../ConvertMetadataAggregateToDirectScanRule.java | 40 ++-
.../drill/exec/record/AbstractRecordBatch.java | 10 +-
.../record/AbstractTableFunctionRecordBatch.java | 19 +-
.../exec/record/AbstractUnaryRecordBatch.java | 15 +-
.../drill/exec/record/RecordBatchLoader.java | 3 +-
.../drill/exec/record/SimpleRecordBatch.java | 4 +-
.../exec/record/VectorAccessibleUtilities.java | 7 +
.../exec/record/selection/SelectionVector4.java | 52 ++--
.../drill/exec/store}/StatisticsRecordWriter.java | 21 +-
.../exec/store/easy/json/JsonRecordWriter.java | 10 +-
.../easy/json/JsonStatisticsRecordWriter.java | 27 +-
.../exec/store/parquet/ParquetRecordWriter.java | 6 +-
.../parquet/ParquetTableMetadataProviderImpl.java | 27 +-
.../store/parquet/ParquetTableMetadataUtils.java | 10 +-
.../exec/store/sys/store/LocalPersistentStore.java | 269 ++++++++++-------
.../drill/exec/work/fragment/FragmentExecutor.java | 36 ++-
.../hadoop/ParquetColumnChunkPageWriteStore.java | 127 +++++---
.../java/org/apache/drill/TestSchemaCommands.java | 11 +-
.../drill/exec/physical/impl/MockRecordBatch.java | 5 +-
.../drill/exec/physical/impl/SimpleRootExec.java | 4 +-
.../exec/physical/impl/TestStackAnalyzer.java | 132 +++++++++
.../impl/partitionsender/TestPartitionSender.java | 32 ++-
.../unnest/TestUnnestWithLateralCorrectness.java | 55 ++--
.../drill/exec/server/TestDrillbitResilience.java | 11 +-
.../exec/store/parquet/ParquetResultListener.java | 17 +-
.../store/parquet/TestParquetMetadataCache.java | 3 -
.../parquet/TestPushDownAndPruningForDecimal.java | 210 ++++++++------
.../parquet/TestPushDownAndPruningForVarchar.java | 2 -
.../exec/store/sys/TestLocalPersistentStore.java | 166 +++++++++++
.../org/apache/drill/test/DrillTestWrapper.java | 48 ++--
.../java/org/apache/drill/test/QueryBuilder.java | 41 ++-
.../org/apache/drill/test/QueryRowSetIterator.java | 17 +-
.../org/apache/drill/jdbc/impl/DrillCursor.java | 141 +++++----
.../record/metadata/schema/parser/SchemaParser.g4 | 33 ++-
.../record/metadata/AbstractMapColumnMetadata.java | 38 +--
.../exec/record/metadata/DictColumnMetadata.java | 30 +-
.../exec/record/metadata/MapColumnMetadata.java | 10 +-
.../metadata/schema/parser/SchemaVisitor.java | 118 +++++++-
.../schema/parser/TestParserErrorHandling.java | 25 +-
.../metadata/schema/parser/TestSchemaParser.java | 141 +++++++--
pom.xml | 6 +-
85 files changed, 2146 insertions(+), 1511 deletions(-)
rename exec/java-exec/src/main/{codegen/templates =>
java/org/apache/drill/exec/store}/StatisticsRecordWriter.java (74%)
create mode 100644
exec/java-exec/src/test/java/org/apache/drill/exec/physical/impl/TestStackAnalyzer.java
create mode 100644
exec/java-exec/src/test/java/org/apache/drill/exec/store/sys/TestLocalPersistentStore.java
