This is an automated email from the ASF dual-hosted git repository.
vitalii pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/drill.git.
from 9ac8c99 DRILL-6674: Minor fixes to avoid auto boxing cost in logging
in LateralJoinBatch
new 9a90164 DRILL-6649: Query with unnest of column from nested star
subquery fails
new 3e3cd2b DRILL-6656: Disallow extra semicolons and multiple statements
on the same line.
new 93a1c5a DRILL-6671: Multi level lateral unnest join is throwing an
exception during materializing the plan.
The 3 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:
.../java/org/apache/drill/common/types/Types.java | 2 +-
.../apache/drill/common/util/DrillStringUtils.java | 2 +-
.../java/org/apache/drill/test/DrillAssert.java | 9 +-
.../drill/exec/store/hbase/HBaseFilterBuilder.java | 2 +-
.../exec/store/hbase/HBasePushFilterIntoScan.java | 2 +-
.../drill/hbase/TestHBaseConnectionManager.java | 12 +-
.../drill/hbase/TestHBaseFilterPushDown.java | 118 ++++++++++----------
.../drill/hbase/TestHBaseProjectPushDown.java | 16 +--
.../org/apache/drill/hbase/TestHBaseQueries.java | 8 +-
.../hbase/TestHBaseRegionScanAssignments.java | 6 +-
.../org/apache/drill/hbase/TestTableGenerator.java | 17 +--
.../drill/exec/store/hive/HiveUtilities.java | 2 +-
.../initilializers/DefaultReadersInitializer.java | 2 +-
.../drill/exec/fn/hive/TestSampleHiveUDFs.java | 6 +-
.../drill/exec/store/jdbc/JdbcExpressionCheck.java | 1 -
.../drill/exec/store/jdbc/JdbcStoragePlugin.java | 6 +-
.../store/kafka/KafkaPartitionScanSpecBuilder.java | 2 +-
.../drill/yarn/appMaster/BatchScheduler.java | 5 +-
.../yarn/appMaster/http/AMSecurityManagerImpl.java | 1 -
.../org/apache/drill/yarn/client/CleanCommand.java | 1 -
.../org/apache/drill/yarn/core/TestConfig.java | 2 +-
.../org/apache/drill/yarn/scripts/ScriptUtils.java | 2 +-
.../java/org/apache/drill/exec/ExecConstants.java | 2 +-
.../drill/exec/cache/SerializationDefinition.java | 3 +-
.../org/apache/drill/exec/client/DrillClient.java | 2 +-
.../java/org/apache/drill/exec/client/DumpCat.java | 6 +-
.../exec/compile/sig/CodeGeneratorMethod.java | 2 +-
.../apache/drill/exec/dotdrill/DotDrillType.java | 6 +-
.../apache/drill/exec/expr/EvaluationVisitor.java | 4 +-
.../org/apache/drill/exec/expr/SizedJBlock.java | 2 +-
.../drill/exec/expr/fn/DrillAggFuncHolder.java | 6 +-
.../drill/exec/expr/fn/impl/Hash32Functions.java | 2 +-
.../drill/exec/expr/fn/impl/StringFunctions.java | 18 +--
.../exec/expr/fn/impl/conv/JsonConvertTo.java | 3 +-
.../expr/fn/registry/FunctionRegistryHolder.java | 2 +-
.../drill/exec/physical/config/HashAggregate.java | 2 +-
.../drill/exec/physical/config/HashJoinPOP.java | 2 +-
.../physical/impl/aggregate/HashAggTemplate.java | 59 ++++++----
.../physical/impl/aggregate/HashAggregator.java | 2 +-
.../impl/aggregate/SpilledRecordbatch.java | 4 +-
.../impl/aggregate/StreamingAggregator.java | 3 +-
.../exec/physical/impl/common/HashTableStats.java | 8 +-
.../physical/impl/common/HashTableTemplate.java | 2 +-
.../physical/impl/flatten/FlattenTemplate.java | 2 +-
.../exec/physical/impl/join/HashJoinBatch.java | 2 +-
.../physical/impl/join/HashJoinProbeTemplate.java | 4 +-
.../drill/exec/physical/impl/join/JoinUtils.java | 2 +-
.../exec/physical/impl/join/LateralJoinBatch.java | 4 +-
.../partitionsender/PartitionSenderRootExec.java | 2 +-
.../exec/physical/impl/unnest/UnnestImpl.java | 2 +-
.../impl/xsort/managed/SortMemoryManager.java | 2 +-
.../exec/physical/rowSet/impl/ColumnState.java | 3 +-
.../physical/rowSet/impl/ResultSetLoaderImpl.java | 3 +-
.../exec/planner/AbstractPartitionDescriptor.java | 2 +-
.../drill/exec/planner/StarColumnHelper.java | 2 +-
.../exec/planner/common/DrillJoinRelBase.java | 4 +-
.../exec/planner/common/DrillLimitRelBase.java | 2 +-
.../exec/planner/common/DrillProjectRelBase.java | 6 +-
.../drill/exec/planner/cost/DrillCostBase.java | 2 +-
.../drill/exec/planner/fragment/Materializer.java | 19 ++--
.../drill/exec/planner/logical/DrillFilterRel.java | 2 +-
.../drill/exec/planner/logical/DrillOptiq.java | 35 ++++--
.../exec/planner/logical/DrillUnionAllRule.java | 2 +-
.../drill/exec/planner/logical/DrillUnionRel.java | 2 +-
.../drill/exec/planner/physical/AggPrelBase.java | 2 +-
.../planner/physical/BroadcastExchangePrel.java | 2 +-
.../planner/physical/DrillDistributionTrait.java | 4 +-
.../drill/exec/planner/physical/HashAggPrule.java | 2 +-
.../planner/physical/HashToMergeExchangePrel.java | 2 +-
.../planner/physical/SingleMergeExchangePrel.java | 2 +-
.../exec/planner/physical/StreamAggPrule.java | 4 +-
.../drill/exec/planner/physical/UnnestPrel.java | 10 ++
.../physical/explain/NumberingRelWriter.java | 4 +-
.../visitor/LateralUnnestRowIDVisitor.java | 54 ++++++++-
.../physical/visitor/StarColumnConverter.java | 2 +-
.../apache/drill/exec/rpc/control/Controller.java | 2 +-
.../exec/server/rest/profile/ProfileWrapper.java | 2 +-
.../server/rest/profile/SimpleDurationFormat.java | 2 +-
.../java/org/apache/drill/exec/ssl/SSLConfig.java | 3 +-
.../drill/exec/store/easy/json/JsonProcessor.java | 2 +-
.../store/easy/text/compliant/HeaderBuilder.java | 2 +-
.../exec/store/easy/text/compliant/TextInput.java | 2 +-
.../apache/drill/exec/store/ischema/Records.java | 100 ++++++++++++-----
.../exec/store/parquet/ParquetFilterBuilder.java | 2 +-
.../exec/store/parquet/ParquetPushDownFilter.java | 2 +-
.../store/parquet/columnreaders/ColumnReader.java | 5 +-
.../store/parquet/metadata/MetadataPathUtils.java | 2 +-
.../drill/exec/store/schedule/BlockMapBuilder.java | 2 +-
.../org/apache/drill/exec/util/VectorUtil.java | 2 +-
.../drill/exec/work/batch/DataCollector.java | 2 +-
.../exec/work/batch/UnlimitedRawBatchBuffer.java | 2 +-
.../work/foreman/rm/ResourceManagerBuilder.java | 2 +-
.../test/java/org/apache/drill/PlanningBase.java | 2 +-
.../java/org/apache/drill/TestStarQueries.java | 2 +-
.../test/java/org/apache/drill/TestUnionAll.java | 4 +-
.../java/org/apache/drill/exec/RunRootExec.java | 2 +-
.../fn/registry/FunctionRegistryHolderTest.java | 4 +-
.../drill/exec/fn/impl/TestAggregateFunction.java | 2 +-
.../drill/exec/fn/impl/TestDateTruncFunctions.java | 4 +-
.../exec/fn/interp/ExpressionInterpreterTest.java | 2 +-
.../impersonation/TestImpersonationMetadata.java | 2 +-
.../apache/drill/exec/memory/TestAllocators.java | 3 +-
.../PartitionLimit/TestPartitionLimitBatch.java | 6 +-
.../drill/exec/physical/impl/TestDecimal.java | 4 +-
.../physical/impl/TestDistributedFragmentRun.java | 31 +++---
.../physical/impl/TopN/TestTopNSchemaChanges.java | 4 +-
.../physical/impl/agg/TestHashAggEmitOutcome.java | 4 +-
.../exec/physical/impl/agg/TestHashAggrSpill.java | 2 +-
.../physical/impl/common/HashPartitionTest.java | 6 +-
.../exec/physical/impl/flatten/TestFlatten.java | 2 +-
.../exec/physical/impl/join/TestHashJoinSpill.java | 2 +-
.../impl/lateraljoin/TestE2EUnnestAndLateral.java | 97 ++++++++++++----
.../impl/lateraljoin/TestLateralPlans.java | 124 ++++++++++-----------
.../impl/protocol/TestOperatorRecordBatch.java | 5 +-
.../physical/impl/writer/TestParquetWriter.java | 2 +-
.../rowSet/impl/TestResultSetLoaderMapArray.java | 9 +-
.../rowSet/impl/TestResultSetLoaderMaps.java | 9 +-
.../rowSet/impl/TestResultSetLoaderTorture.java | 5 +-
.../exec/physical/unit/MiniPlanUnitTestBase.java | 10 +-
.../exec/physical/unit/TestNullInputMiniPlan.java | 2 +-
.../drill/exec/record/TestRecordBatchSizer.java | 2 +-
.../drill/exec/record/vector/TestDateTypes.java | 4 +-
.../drill/exec/store/dfs/TestFileSelection.java | 4 +-
.../exec/store/parquet/ParquetInternalsTest.java | 4 +-
.../parquet/ParquetSimpleTestFileGenerator.java | 14 ++-
.../exec/store/parquet/TestParquetComplex.java | 76 ++++++-------
.../store/parquet/TestParquetPhysicalPlan.java | 3 +-
.../store/parquet2/TestDrillParquetReader.java | 82 +++++++-------
.../drill/exec/vector/TestSplitAndTransfer.java | 4 +-
.../exec/vector/complex/writer/TestJsonReader.java | 2 +-
.../org/apache/drill/test/DrillTestWrapper.java | 2 +-
.../java/org/apache/drill/test/ExampleTest.java | 3 +-
.../org/apache/drill/test/QueryRowSetIterator.java | 2 +-
.../java/org/apache/drill/test/TestBuilder.java | 8 +-
.../apache/drill/test/TestGracefulShutdown.java | 4 +-
.../test/rowSet/test/TestFixedWidthWriter.java | 2 +-
.../test/rowSet/test/TestOffsetVectorWriter.java | 2 +-
.../test/rowSet/test/TestVariableWidthWriter.java | 2 +-
.../org/apache/drill/jdbc/ITTestShadedJar.java | 3 +-
.../drill/jdbc/impl/DrillColumnMetaDataList.java | 12 +-
.../apache/drill/jdbc/proxy/ProxiesManager.java | 3 +-
.../apache/drill/jdbc/PreparedStatementTest.java | 8 +-
.../java/org/apache/drill/jdbc/StatementTest.java | 8 +-
.../apache/drill/exec/memory/BaseAllocator.java | 3 +-
.../java/org/apache/drill/exec/rpc/RpcBus.java | 1 -
.../drill/common/expression/BooleanOperator.java | 2 +-
.../drill/common/expression/IfExpression.java | 2 +-
.../drill/common/expression/NullExpression.java | 2 +-
pom.xml | 4 +-
src/main/resources/checkstyle-config.xml | 4 +
150 files changed, 764 insertions(+), 551 deletions(-)
