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 b2aa1a9 DRILL-7707: Unable to analyze table metadata is it resides in
non-writable workspace
new 7bac742 DRILL-7741: Columns are missing when using convert_from
function
new 64b40be DRILL-7739: Allow implicit casts from required to nullable
data type
new 953280b DRILL-7734: Revise the result set reader
new d280d06 DRILL-7725: Updates to the EVF2 framework
The 4 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:
.../categories/{EvfTests.java => EvfTest.java} | 2 +-
.../drill/exec/store/hdf5/writers/WriterSpec.java | 6 +-
.../exec/expr/ExpressionTreeMaterializer.java | 40 +-
.../physical/impl/project/ProjectRecordBatch.java | 10 +
.../exec/physical/impl/scan/ScanOperatorExec.java | 2 +-
.../impl/scan/columns/ColumnsScanFramework.java | 3 +-
.../scan/convert/AbstractConvertFromString.java | 4 +-
.../impl/scan/convert/StandardConversions.java | 149 +++----
.../exec/physical/impl/scan/v3/FixedReceiver.java | 208 ++++++++++
.../impl/scan/v3/ScanLifecycleBuilder.java | 36 +-
.../physical/impl/scan/v3/SchemaNegotiator.java | 10 +
.../physical/impl/scan/v3/file/FileDescrip.java | 102 ++++-
.../impl/scan/v3/file/FileScanLifecycle.java | 5 +-
.../scan/v3/file/FileScanLifecycleBuilder.java | 37 +-
.../impl/scan/v3/file/FileSchemaNegotiator.java | 22 +-
.../scan/v3/file/FileSchemaNegotiatorImpl.java | 47 ++-
.../impl/scan/v3/file/ImplicitColumnMarker.java | 99 +++++
.../{schema => file}/ImplicitColumnResolver.java | 191 +++++----
.../scan/v3/file/ImplicitFileColumnsHandler.java | 37 +-
.../impl/scan/v3/lifecycle/ReaderLifecycle.java | 191 +++++----
.../impl/scan/v3/lifecycle/ScanLifecycle.java | 20 +-
.../scan/v3/lifecycle/SchemaNegotiatorImpl.java | 9 +
.../impl/scan/v3/lifecycle/StaticBatchBuilder.java | 4 +-
.../impl/scan/v3/schema/AbstractSchemaTracker.java | 31 +-
.../impl/scan/v3/schema/MutableTupleMetadata.java | 220 ----------
.../impl/scan/v3/schema/MutableTupleSchema.java | 71 +++-
.../scan/v3/schema/ProjectionSchemaTracker.java | 44 +-
.../scan/v3/schema/ScanSchemaConfigBuilder.java | 28 +-
.../impl/scan/v3/schema/ScanSchemaResolver.java | 66 ++-
.../impl/scan/v3/schema/ScanSchemaTracker.java | 8 +-
.../impl/scan/v3/schema/SchemaBasedTracker.java | 27 +-
...sultSetReader.java => PullResultSetReader.java} | 86 ++--
.../physical/resultSet/PushResultSetReader.java | 49 +++
.../exec/physical/resultSet/ResultSetCopier.java | 19 +-
.../exec/physical/resultSet/RowSetLoader.java | 7 -
.../resultSet/impl/PullResultSetReaderImpl.java | 134 ++++++
.../resultSet/impl/PushResultSetReaderImpl.java | 107 +++++
.../resultSet/impl/ResultSetCopierImpl.java | 61 ++-
.../resultSet/impl/ResultSetReaderImpl.java | 106 -----
.../apache/drill/exec/resolver/TypeCastRules.java | 4 +-
.../apache/drill/exec/store/ColumnExplorer.java | 9 +-
.../drill/exec/store/avro/AvroBatchReader.java | 4 +-
.../exec/store/avro/ColumnConverterFactory.java | 7 +-
.../easy/text/reader/CompliantTextBatchReader.java | 18 +-
.../drill/exec/store/log/LogBatchReader.java | 8 +-
.../drill/exec/fn/impl/TestVarArgFunctions.java | 21 +-
.../exec/physical/impl/scan/ScanTestUtils.java | 45 ++-
.../physical/impl/scan/TestFileScanFramework.java | 2 +-
.../impl/scan/TestScanOperExecOuputSchema.java | 3 +-
.../scan/TestScanOrchestratorImplicitColumns.java | 2 +-
.../impl/scan/convert/TestDirectConverter.java | 187 ++++-----
.../impl/scan/project/TestScanLevelProjection.java | 4 +-
.../impl/scan/project/TestSchemaSmoothing.java | 52 +--
.../physical/impl/scan/v3/TestFixedReceiver.java | 124 ++++++
.../exec/physical/impl/scan/v3/TestScanBasics.java | 4 +-
.../physical/impl/scan/v3/TestScanEarlySchema.java | 4 +-
.../physical/impl/scan/v3/TestScanLateSchema.java | 4 +-
.../physical/impl/scan/v3/TestScanOuputSchema.java | 7 +-
.../physical/impl/scan/v3/TestScanOverflow.java | 4 +-
.../physical/impl/scan/v3/file/MockFileNames.java | 1 -
.../impl/scan/v3/file/TestFileDescrip.java | 84 ++--
.../physical/impl/scan/v3/file/TestFileScan.java | 9 +-
.../impl/scan/v3/file/TestFileScanLifecycle.java | 4 +-
.../scan/v3/file/TestImplicitColumnLoader.java | 121 +++++-
.../scan/v3/file/TestImplicitColumnResolver.java | 84 +++-
.../scan/v3/lifecycle/BaseTestScanLifecycle.java | 1 -
.../scan/v3/lifecycle/TestMissingColumnLoader.java | 4 +-
.../scan/v3/lifecycle/TestOutputBatchBuilder.java | 4 +-
.../impl/scan/v3/lifecycle/TestReaderErrors.java | 4 +-
.../scan/v3/lifecycle/TestScanLifecycleBasics.java | 15 +-
.../scan/v3/lifecycle/TestScanLifecycleSchema.java | 4 +-
.../v3/lifecycle/TestScanLifecycleTwoReaders.java | 4 +-
.../scan/v3/schema/TestDynamicSchemaFilter.java | 4 +-
.../impl/scan/v3/schema/TestProjectedPath.java | 4 +-
.../impl/scan/v3/schema/TestProjectionParser.java | 4 +-
.../impl/scan/v3/schema/TestScanSchemaTracker.java | 90 ++++-
.../scan/v3/schema/TestScanSchemaTrackerMaps.java | 4 +-
.../scan/v3/schema/TestSchemaTrackerDefined.java | 4 +-
.../schema/TestSchemaTrackerEarlyReaderSchema.java | 27 +-
.../v3/schema/TestSchemaTrackerInputSchema.java | 23 +-
.../v3/schema/TestSchemaTrackerProjection.java | 28 +-
.../resultSet/impl/TestResultSetCopier.java | 447 +++++++++++----------
.../impl/TestResultSetLoaderProjection.java | 4 +-
.../resultSet/impl/TestResultSetReader.java | 182 ++++++---
.../store/easy/text/compliant/TestCsvHeader.java | 4 +-
.../easy/text/compliant/TestCsvIgnoreHeaders.java | 4 +-
.../text/compliant/TestCsvTableProperties.java | 4 +-
.../easy/text/compliant/TestCsvWithHeaders.java | 4 +-
.../easy/text/compliant/TestCsvWithSchema.java | 8 +-
.../easy/text/compliant/TestCsvWithoutHeaders.java | 4 +-
.../easy/text/compliant/TestPartitionRace.java | 4 +-
.../drill/exec/store/mock/TestMockPlugin.java | 2 +-
.../exec/vector/complex/writer/TestJsonReader.java | 22 +
.../drill/test/BufferingQueryEventListener.java | 13 +-
.../java/org/apache/drill/test/PrintingUtils.java | 3 +-
.../java/org/apache/drill/test/ProfileParser.java | 6 +-
.../org/apache/drill/test/QueryBatchIterator.java | 162 ++++++++
.../java/org/apache/drill/test/QueryBuilder.java | 69 +---
.../java/org/apache/drill/test/QueryResultSet.java | 10 +-
.../org/apache/drill/test/QueryRowSetIterator.java | 70 +---
.../org/apache/drill/test/QueryRowSetReader.java} | 30 +-
.../org/apache/drill/test/StatementParser.java | 84 ++++
.../apache/drill/test/rowSet/RowSetUtilities.java | 10 +-
.../drill/exec/record/metadata/MetadataUtils.java | 4 +
104 files changed, 2877 insertions(+), 1611 deletions(-)
rename common/src/test/java/org/apache/drill/categories/{EvfTests.java =>
EvfTest.java} (97%)
create mode 100644
exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/scan/v3/FixedReceiver.java
create mode 100644
exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/scan/v3/file/ImplicitColumnMarker.java
rename
exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/scan/v3/{schema
=> file}/ImplicitColumnResolver.java (70%)
delete mode 100644
exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/scan/v3/schema/MutableTupleMetadata.java
rename
exec/java-exec/src/main/java/org/apache/drill/exec/physical/resultSet/{ResultSetReader.java
=> PullResultSetReader.java} (57%)
create mode 100644
exec/java-exec/src/main/java/org/apache/drill/exec/physical/resultSet/PushResultSetReader.java
create mode 100644
exec/java-exec/src/main/java/org/apache/drill/exec/physical/resultSet/impl/PullResultSetReaderImpl.java
create mode 100644
exec/java-exec/src/main/java/org/apache/drill/exec/physical/resultSet/impl/PushResultSetReaderImpl.java
delete mode 100644
exec/java-exec/src/main/java/org/apache/drill/exec/physical/resultSet/impl/ResultSetReaderImpl.java
create mode 100644
exec/java-exec/src/test/java/org/apache/drill/exec/physical/impl/scan/v3/TestFixedReceiver.java
create mode 100644
exec/java-exec/src/test/java/org/apache/drill/test/QueryBatchIterator.java
copy
exec/java-exec/src/{main/java/org/apache/drill/exec/physical/impl/aggregate/HashAggUpdater.java
=> test/java/org/apache/drill/test/QueryRowSetReader.java} (54%)
create mode 100644
exec/java-exec/src/test/java/org/apache/drill/test/StatementParser.java
