This is an automated email from the ASF dual-hosted git repository.
volodymyr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/drill.git.
from 6c80a46 Update Slack Link in README.md
new ba601b0 DRILL-7393: Revisit Drill tests to ensure that patching is
executed before any test run
new f3e32c3 DRILL-6540: Upgrade to HADOOP-3.0.3 libraries
new db64882 DRILL-6540: Updated Hadoop and HBase libraries to the latest
versions
new de41559 DRILL-5844: Incorrect values of TABLE_TYPE returned from
method DatabaseMetaData.getTables of JDBC API
new 20293b6 DRILL-7450: Improve performance for ANALYZE command
new 93a39cd DRILL-7324: Final set of "batch count" fixes
new 364a4d3 DRILL-7463: Apache license is not added to the generated
classes
new 5655dbb DRILL-7208: Reuse root git.properties file
new 2b9a25c DRILL-6904: Update maven-javadoc-plugin,
maven-compiler-plugin and maven-assembly-plugin to the latest version
new 086ecbd DRILL-7221: Exclude debug files generated by maven debug
option from jar
new 51df52d Add Volodymyr's PGP key
The 11 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:
KEYS | 297 +++++++++++------
.../org/apache/drill/common/util/GuavaPatcher.java | 232 +++++++-------
.../apache/drill/common/util/ProtobufPatcher.java | 154 +++++----
.../java/org/apache/drill/common/TestVersion.java | 3 +-
.../drill/common/exceptions/TestUserException.java | 3 +-
.../drill/common/map/TestCaseInsensitiveMap.java | 3 +-
.../common/util/function/TestCheckedFunction.java | 3 +-
.../test/java/org/apache/drill/test/BaseTest.java | 29 +-
.../Drill2130CommonHamcrestConfigurationTest.java | 2 +-
.../test/java/org/apache/drill/test/DrillTest.java | 4 +-
.../mapr/drill/maprdb/tests/MaprDBTestsSuite.java | 3 +-
.../maprdb/tests/json/TestFieldPathHelper.java | 3 +-
.../org/apache/drill/hbase/HBaseTestsSuite.java | 10 +-
...l2130StorageHBaseHamcrestConfigurationTest.java | 3 +-
.../core/src/main/codegen/includes/license.ftl | 17 +
.../inspectors/SkipFooterRecordsInspectorTest.java | 3 +-
.../store/hive/schema/TestColumnListCache.java | 3 +-
.../store/hive/schema/TestSchemaConversion.java | 3 +-
...30StorageHiveCoreHamcrestConfigurationTest.java | 3 +-
.../exec/store/jdbc/TestJdbcPluginWithH2IT.java | 11 +
.../exec/store/jdbc/TestJdbcPluginWithMySQLIT.java | 12 +
.../drill/exec/store/kafka/TestKafkaSuit.java | 3 +-
.../kafka/decoders/MessageReaderFactoryTest.java | 3 +-
contrib/storage-kudu/.gitignore | 15 -
.../apache/drill/store/kudu/TestKuduConnect.java | 3 +-
.../drill/exec/store/mongo/MongoTestSuit.java | 3 +-
.../exec/store/mongo/TestMongoChunkAssignment.java | 3 +-
distribution/pom.xml | 79 ++++-
distribution/src/assemble/component.xml | 81 +++--
distribution/src/{ => main}/resources/LICENSE | 0
distribution/src/{ => main}/resources/NOTICE | 0
distribution/src/{ => main}/resources/README.md | 0
.../src/{ => main}/resources/auto-setup.sh | 0
.../src/{ => main}/resources/core-site-example.xml | 0
.../src/{ => main}/resources/distrib-env.sh | 0
.../src/{ => main}/resources/distrib-setup.sh | 0
.../src/{ => main}/resources/drill-am-log.xml | 4 +-
distribution/src/{ => main}/resources/drill-am.sh | 0
distribution/src/{ => main}/resources/drill-conf | 0
.../src/{ => main}/resources/drill-config.sh | 0
.../src/{ => main}/resources/drill-embedded | 0
.../src/{ => main}/resources/drill-embedded.bat | 0
distribution/src/{ => main}/resources/drill-env.sh | 0
.../src/{ => main}/resources/drill-localhost | 0
.../resources/drill-on-yarn-example.conf | 0
.../src/{ => main}/resources/drill-on-yarn.sh | 0
.../resources/drill-override-example.conf | 48 +--
.../src/{ => main}/resources/drill-override.conf | 4 +-
.../src/{ => main}/resources/drill-setup.sh | 0
.../resources/drill-sqlline-override-example.conf | 0
distribution/src/{ => main}/resources/drillbit | 0
distribution/src/{ => main}/resources/drillbit.sh | 0
distribution/src/{ => main}/resources/dumpcat | 0
.../src/{ => main}/resources/hadoop-excludes.txt | 0
distribution/src/{ => main}/resources/logback.xml | 8 +-
distribution/src/{ => main}/resources/runbit | 0
.../src/{ => main}/resources/saffron.properties | 0
distribution/src/{ => main}/resources/sqlline | 0
distribution/src/{ => main}/resources/sqlline.bat | 1 +
.../storage-plugins-override-example.conf | 0
distribution/src/{ => main}/resources/submit_plan | 0
.../src/main/resources/winutils/hadoop.dll | Bin 0 -> 85504 bytes
.../src/main/resources/winutils/winutils.exe | Bin 0 -> 112640 bytes
.../src/{ => main}/resources/yarn-client-log.xml | 2 +-
.../src/{ => main}/resources/yarn-drillbit.sh | 0
docs/dev/HadoopWinutils.md | 11 +
docs/dev/MetastoreAnalyze.md | 61 +++-
drill-yarn/pom.xml | 6 +
.../yarn/appMaster/DrillApplicationMaster.java | 5 +-
.../org/apache/drill/yarn/client/DrillOnYarn.java | 5 +-
.../org/apache/drill/yarn/client/TestClient.java | 3 +-
.../drill/yarn/client/TestCommandLineOptions.java | 3 +-
.../org/apache/drill/yarn/core/TestConfig.java | 3 +-
.../org/apache/drill/yarn/scripts/TestScripts.java | 3 +-
.../apache/drill/yarn/zk/TestAmRegistration.java | 3 +-
.../org/apache/drill/yarn/zk/TestZkRegistry.java | 3 +-
.../java/org/apache/drill/exec/expr/TestPrune.java | 38 ---
exec/java-exec/pom.xml | 59 ++++
.../src/main/codegen/includes/license.ftl | 17 +
.../apache/commons/logging/impl/Log4JLogger.java | 7 +-
.../org/apache/drill/exec/expr/IsPredicate.java | 2 +-
.../drill/exec/expr/fn/DrillAggFuncHolder.java | 4 +-
.../expr/fn/DrillComplexWriterAggFuncHolder.java | 40 ++-
.../apache/drill/exec/expr/fn/DrillFuncHolder.java | 78 +++--
.../drill/exec/metastore/ColumnNamesOptions.java | 80 +++++
.../metastore/analyze/AnalyzeFileInfoProvider.java | 24 +-
.../metastore/analyze/AnalyzeInfoProvider.java | 20 +-
.../analyze/AnalyzeParquetInfoProvider.java | 18 +-
.../analyze/FileMetadataInfoCollector.java | 3 +-
.../analyze/MetadataAggregateContext.java | 24 ++
.../base/AbstractGroupScanWithMetadata.java | 36 ++-
.../exec/physical/config/HashToMergeExchange.java | 3 +-
...MetadataAggPOP.java => MetadataHashAggPOP.java} | 26 +-
...tadataAggPOP.java => MetadataStreamAggPOP.java} | 19 +-
.../apache/drill/exec/physical/impl/ScanBatch.java | 1 -
.../drill/exec/physical/impl/TopN/TopNBatch.java | 6 +-
.../exec/physical/impl/aggregate/HashAggBatch.java | 138 +++++---
.../physical/impl/aggregate/HashAggTemplate.java | 15 +-
.../physical/impl/aggregate/StreamingAggBatch.java | 15 +-
.../exec/physical/impl/filter/FilterTemplate2.java | 7 +-
.../physical/impl/flatten/FlattenRecordBatch.java | 2 +-
.../exec/physical/impl/join/HashJoinBatch.java | 5 +-
.../physical/impl/join/NestedLoopJoinBatch.java | 8 +-
...aAggBatch.java => MetadataAggregateHelper.java} | 173 ++++++----
.../impl/metadata/MetadataControllerBatch.java | 77 +++--
.../impl/metadata/MetadataHandlerBatch.java | 49 ++-
.../impl/metadata/MetadataHashAggBatch.java | 56 ++++
...eator.java => MetadataHashAggBatchCreator.java} | 8 +-
.../impl/metadata/MetadataStreamAggBatch.java | 62 ++++
...tor.java => MetadataStreamAggBatchCreator.java} | 8 +-
.../physical/impl/project/ProjectRecordBatch.java | 4 +-
.../RangePartitionRecordBatch.java | 1 -
.../impl/scan/file/FileMetadataManager.java | 8 +-
.../impl/statistics/StatisticsMergeBatch.java | 52 ++-
.../impl/svremover/RemovingRecordBatch.java | 7 +-
.../physical/impl/union/UnionAllRecordBatch.java | 7 +-
.../physical/impl/unnest/UnnestRecordBatch.java | 1 +
.../impl/unpivot/UnpivotMapsRecordBatch.java | 4 +-
.../physical/impl/validate/BatchValidator.java | 106 +------
.../impl/window/WindowFrameRecordBatch.java | 14 +-
.../resultSet/model/single/BaseReaderBuilder.java | 2 +-
.../exec/physical/rowSet/RowSetFormatter.java | 13 +-
.../apache/drill/exec/planner/PlannerPhase.java | 2 +
.../logical/ConvertCountToDirectScanRule.java | 2 +-
.../ConvertMetadataAggregateToDirectScanRule.java | 271 ++++++++++++++++
.../planner/physical/DrillDistributionTrait.java | 81 ++++-
.../drill/exec/planner/physical/HashAggPrule.java | 14 +-
.../drill/exec/planner/physical/HashPrelUtil.java | 37 +--
.../exec/planner/physical/MetadataAggPrule.java | 202 +++++++++++-
.../planner/physical/MetadataHandlerPrule.java | 2 +-
...tadataAggPrel.java => MetadataHashAggPrel.java} | 22 +-
...dataAggPrel.java => MetadataStreamAggPrel.java} | 21 +-
.../drill/exec/planner/physical/PrelUtil.java | 27 +-
.../sql/handlers/MetastoreAnalyzeTableHandler.java | 42 +--
.../apache/drill/exec/record/VectorAccessible.java | 2 -
.../apache/drill/exec/record/VectorContainer.java | 6 +
.../org/apache/drill/exec/server/Drillbit.java | 5 +-
.../apache/drill/exec/store/ColumnExplorer.java | 25 +-
.../drill/exec/store/LocalSyncableFileSystem.java | 10 +-
.../exec/store/easy/json/JSONRecordReader.java | 22 +-
.../drill/exec/store/ischema/FilterEvaluator.java | 2 +-
.../drill/exec/store/ischema/RecordCollector.java | 2 +-
.../store/parquet/AbstractParquetGroupScan.java | 98 +++++-
.../ParquetFileTableMetadataProviderBuilder.java | 4 +
.../exec/store/pojo/DynamicPojoRecordReader.java | 25 +-
.../java/org/apache/drill/BaseTestInheritance.java | 54 ++++
.../java/org/apache/drill/TestImplicitCasting.java | 3 +-
.../drill/common/scanner/TestClassPathScanner.java | 3 +-
.../org/apache/drill/exec/TestOpSerialization.java | 3 +-
.../java/org/apache/drill/exec/TestSSLConfig.java | 3 +-
.../ConnectTriesPropertyTestClusterBits.java | 3 +-
.../exec/client/DrillSqlLineApplicationTest.java | 3 +-
.../drill/exec/compile/TestEvaluationVisitor.java | 3 +-
.../drill/exec/coord/zk/TestEphemeralStore.java | 3 +-
.../drill/exec/coord/zk/TestEventDispatcher.java | 3 +-
.../apache/drill/exec/coord/zk/TestPathUtils.java | 3 +-
.../org/apache/drill/exec/coord/zk/TestZKACL.java | 3 +-
.../drill/exec/coord/zk/TestZookeeperClient.java | 3 +-
.../drill/exec/dotdrill/TestDotDrillUtil.java | 3 +-
.../exec/expr/fn/FunctionInitializerTest.java | 3 +-
.../drill/exec/expr/fn/impl/TestSqlPatterns.java | 3 +-
.../fn/registry/FunctionRegistryHolderTest.java | 3 +-
.../drill/exec/fn/impl/TestAggregateFunction.java | 2 +-
.../drill/exec/fn/impl/TestAggregateFunctions.java | 206 +++++++++---
.../impersonation/TestImpersonationMetadata.java | 15 +-
.../physical/impl/agg/TestAggWithAnyValue.java | 304 ++++++++++++++----
.../physical/impl/agg/TestHashAggEmitOutcome.java | 205 ++++++------
.../physical/impl/common/HashPartitionTest.java | 3 +-
.../common/HashTableAllocationTrackerTest.java | 3 +-
.../impl/join/TestBatchSizePredictorImpl.java | 3 +-
.../impl/join/TestBuildSidePartitioningImpl.java | 3 +-
.../join/TestHashJoinHelperSizeCalculatorImpl.java | 3 +-
.../impl/join/TestHashJoinMemoryCalculator.java | 3 +-
...estHashTableSizeCalculatorConservativeImpl.java | 3 +-
.../join/TestHashTableSizeCalculatorLeanImpl.java | 3 +-
.../exec/physical/impl/join/TestPartitionStat.java | 5 +-
.../impl/join/TestPostBuildCalculationsImpl.java | 3 +-
.../scan/project/projSet/TestProjectionSet.java | 3 +-
.../impl/svremover/AbstractGenericCopierTest.java | 3 +-
.../resultSet/project/TestProjectedTuple.java | 3 +-
.../resultSet/project/TestProjectionType.java | 3 +-
.../exec/physical/unit/TestOutputBatchSize.java | 6 +-
.../common/TestNumericEquiDepthHistogram.java | 3 +-
.../TestHardAffinityFragmentParallelizer.java | 3 +-
.../drill/exec/planner/logical/DrillOptiqTest.java | 3 +-
.../exec/planner/logical/FilterSplitTest.java | 3 +-
.../drill/exec/record/TestMaterializedField.java | 3 +-
.../record/metadata/schema/TestSchemaProvider.java | 3 +-
.../exec/resourcemgr/TestResourcePoolTree.java | 3 +-
.../TestBestFitSelectionPolicy.java | 3 +-
.../TestDefaultSelectionPolicy.java | 3 +-
.../config/selectors/TestAclSelector.java | 3 +-
.../config/selectors/TestComplexSelectors.java | 3 +-
.../config/selectors/TestNotEqualSelector.java | 3 +-
.../selectors/TestResourcePoolSelectors.java | 3 +-
.../config/selectors/TestTagSelector.java | 3 +-
.../rpc/control/ConnectionManagerRegistryTest.java | 3 +-
.../control/TestLocalControlConnectionManager.java | 3 +-
.../apache/drill/exec/server/TestFailureUtils.java | 3 +-
.../drill/exec/server/options/OptionValueTest.java | 3 +-
.../server/options/PersistedOptionValueTest.java | 3 +-
.../exec/server/options/TestConfigLinkage.java | 3 +-
.../exec/server/rest/StatusResourcesTest.java | 3 +-
.../exec/server/rest/TestMainLoginPageModel.java | 3 +-
.../exec/server/rest/WebSessionResourcesTest.java | 3 +-
.../rest/spnego/TestDrillSpnegoAuthenticator.java | 3 +-
.../rest/spnego/TestSpnegoAuthentication.java | 3 +-
.../exec/server/rest/spnego/TestSpnegoConfig.java | 3 +-
.../drill/exec/sql/TestMetastoreCommands.java | 285 ++++++++++++++---
.../drill/exec/sql/TestSqlBracketlessSyntax.java | 3 +-
.../drill/exec/store/StorageStrategyTest.java | 3 +-
.../exec/store/bson/TestBsonRecordReader.java | 3 +-
.../drill/exec/store/dfs/TestDrillFileSystem.java | 3 +-
.../store/dfs/TestFormatPluginOptionExtractor.java | 3 +-
.../store/parquet/TestComplexColumnInSchema.java | 3 +-
.../store/parquet/TestParquetMetadataVersion.java | 3 +-
.../store/parquet/TestParquetReaderConfig.java | 3 +-
.../store/parquet/TestParquetReaderUtility.java | 3 +-
.../drill/exec/store/store/TestAssignment.java | 3 +-
...Drill2130JavaExecHamcrestConfigurationTest.java | 3 +-
.../drill/exec/util/DrillExceptionUtilTest.java | 3 +-
.../drill/exec/util/FileSystemUtilTestBase.java | 3 +-
.../exec/util/TestApproximateStringMatcher.java | 3 +-
.../drill/exec/util/TestArrayWrappedIntIntMap.java | 3 +-
.../exec/util/TestValueVectorElementFormatter.java | 3 +-
.../drill/exec/vector/TestSplitAndTransfer.java | 3 +-
.../exec/vector/accessor/GenericAccessorTest.java | 3 +-
.../exec/vector/accessor/TestTimePrintMillis.java | 3 +-
.../exec/vector/complex/writer/TestJsonReader.java | 159 ++++++----
.../complex/writer/TestPromotableWriter.java | 3 +-
.../exec/vector/complex/writer/TestRepeated.java | 3 +-
.../org/apache/drill/exec/work/batch/FileTest.java | 4 +-
.../drill/exec/work/filter/BloomFilterTest.java | 3 +-
.../work/fragment/FragmentStatusReporterTest.java | 3 +-
.../exec/work/metadata/TestMetadataProvider.java | 2 +-
.../java/org/apache/drill/test/ExampleTest.java | 2 +-
.../test/rowSet/test/TestRowSetComparison.java | 3 +-
.../test/resources/functions/test_covariance.json | 6 +-
.../resources/functions/test_logical_aggr.json | 6 +-
exec/jdbc-all/pom.xml | 5 +-
.../org/apache/drill/jdbc/DrillbitClassLoader.java | 45 +--
.../org/apache/drill/jdbc/ITTestShadedJar.java | 9 +-
.../jdbc/ConnectionTransactionMethodsTest.java | 3 +-
.../apache/drill/jdbc/DatabaseMetaDataTest.java | 3 +-
.../drill/jdbc/DrillColumnMetaDataListTest.java | 3 +-
.../jdbc/impl/TypeConvertingSqlAccessorTest.java | 3 +-
...Drill2130JavaJdbcHamcrestConfigurationTest.java | 3 +-
.../Drill2288GetColumnsMetadataWhenNoRowsTest.java | 3 +-
.../apache/drill/jdbc/test/TestJdbcMetadata.java | 2 +-
.../drill/exec/memory/BoundsCheckingTest.java | 4 +-
.../apache/drill/exec/memory/TestAccountant.java | 3 +-
.../drill/exec/memory/TestBaseAllocator.java | 3 +-
.../apache/drill/exec/memory/TestEndianess.java | 3 +-
exec/vector/src/main/codegen/includes/license.ftl | 17 +
.../src/main/codegen/templates/ComplexWriters.java | 6 +-
.../record/metadata/TestMetadataProperties.java | 3 +-
.../schema/parser/TestParserErrorHandling.java | 3 +-
.../metadata/schema/parser/TestSchemaParser.java | 3 +-
.../exec/vector/VariableLengthVectorTest.java | 4 +-
.../org/apache/drill/exec/vector/VectorTest.java | 3 +-
.../expression/FunctionHolderExpression.java | 2 +-
.../common/logical/data/MetadataAggregate.java | 2 +-
.../drill/common/expression/SchemaPathTest.java | 3 +-
.../expression/fn/JodaDateValidatorTest.java | 3 +-
.../drill/common/logical/data/OrderTest.java | 3 +-
.../drill/metastore/iceberg/IcebergBaseTest.java | 11 +-
.../components/tables/TestBasicTablesRequests.java | 3 +-
.../tables/TestBasicTablesTransformer.java | 3 +-
.../components/tables/TestMetastoreTableInfo.java | 3 +-
.../tables/TestTableMetadataUnitConversion.java | 3 +-
.../metastore/metadata/MetadataSerDeTest.java | 3 +-
pom.xml | 350 +++++++++++++--------
272 files changed, 3662 insertions(+), 1791 deletions(-)
copy
exec/java-exec/src/main/java/org/apache/drill/exec/expr/fn/output/OutputWidthCalculator.java
=> common/src/test/java/org/apache/drill/test/BaseTest.java (52%)
delete mode 100644 contrib/storage-kudu/.gitignore
rename distribution/src/{ => main}/resources/LICENSE (100%)
rename distribution/src/{ => main}/resources/NOTICE (100%)
rename distribution/src/{ => main}/resources/README.md (100%)
rename distribution/src/{ => main}/resources/auto-setup.sh (100%)
rename distribution/src/{ => main}/resources/core-site-example.xml (100%)
rename distribution/src/{ => main}/resources/distrib-env.sh (100%)
rename distribution/src/{ => main}/resources/distrib-setup.sh (100%)
rename distribution/src/{ => main}/resources/drill-am-log.xml (99%)
rename distribution/src/{ => main}/resources/drill-am.sh (100%)
rename distribution/src/{ => main}/resources/drill-conf (100%)
rename distribution/src/{ => main}/resources/drill-config.sh (100%)
rename distribution/src/{ => main}/resources/drill-embedded (100%)
rename distribution/src/{ => main}/resources/drill-embedded.bat (100%)
rename distribution/src/{ => main}/resources/drill-env.sh (100%)
rename distribution/src/{ => main}/resources/drill-localhost (100%)
rename distribution/src/{ => main}/resources/drill-on-yarn-example.conf (100%)
rename distribution/src/{ => main}/resources/drill-on-yarn.sh (100%)
rename distribution/src/{ => main}/resources/drill-override-example.conf (88%)
rename distribution/src/{ => main}/resources/drill-override.conf (97%)
rename distribution/src/{ => main}/resources/drill-setup.sh (100%)
rename distribution/src/{ =>
main}/resources/drill-sqlline-override-example.conf (100%)
rename distribution/src/{ => main}/resources/drillbit (100%)
rename distribution/src/{ => main}/resources/drillbit.sh (100%)
rename distribution/src/{ => main}/resources/dumpcat (100%)
rename distribution/src/{ => main}/resources/hadoop-excludes.txt (100%)
rename distribution/src/{ => main}/resources/logback.xml (99%)
rename distribution/src/{ => main}/resources/runbit (100%)
rename distribution/src/{ => main}/resources/saffron.properties (100%)
rename distribution/src/{ => main}/resources/sqlline (100%)
rename distribution/src/{ => main}/resources/sqlline.bat (96%)
rename distribution/src/{ =>
main}/resources/storage-plugins-override-example.conf (100%)
rename distribution/src/{ => main}/resources/submit_plan (100%)
create mode 100644 distribution/src/main/resources/winutils/hadoop.dll
create mode 100644 distribution/src/main/resources/winutils/winutils.exe
rename distribution/src/{ => main}/resources/yarn-client-log.xml (99%)
rename distribution/src/{ => main}/resources/yarn-drillbit.sh (100%)
create mode 100644 docs/dev/HadoopWinutils.md
delete mode 100644
exec/interpreter/src/test/java/org/apache/drill/exec/expr/TestPrune.java
copy common/src/test/java/org/apache/drill/categories/HbaseStorageTest.java =>
exec/java-exec/src/main/java/org/apache/commons/logging/impl/Log4JLogger.java
(73%)
create mode 100644
exec/java-exec/src/main/java/org/apache/drill/exec/metastore/ColumnNamesOptions.java
copy
exec/java-exec/src/main/java/org/apache/drill/exec/physical/config/{MetadataAggPOP.java
=> MetadataHashAggPOP.java} (62%)
rename
exec/java-exec/src/main/java/org/apache/drill/exec/physical/config/{MetadataAggPOP.java
=> MetadataStreamAggPOP.java} (72%)
rename
exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/metadata/{MetadataAggBatch.java
=> MetadataAggregateHelper.java} (68%)
create mode 100644
exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/metadata/MetadataHashAggBatch.java
copy
exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/metadata/{MetadataAggBatchCreator.java
=> MetadataHashAggBatchCreator.java} (80%)
create mode 100644
exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/metadata/MetadataStreamAggBatch.java
rename
exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/metadata/{MetadataAggBatchCreator.java
=> MetadataStreamAggBatchCreator.java} (80%)
create mode 100644
exec/java-exec/src/main/java/org/apache/drill/exec/planner/logical/ConvertMetadataAggregateToDirectScanRule.java
copy
exec/java-exec/src/main/java/org/apache/drill/exec/planner/physical/{MetadataAggPrel.java
=> MetadataHashAggPrel.java} (78%)
rename
exec/java-exec/src/main/java/org/apache/drill/exec/planner/physical/{MetadataAggPrel.java
=> MetadataStreamAggPrel.java} (77%)
create mode 100644
exec/java-exec/src/test/java/org/apache/drill/BaseTestInheritance.java
