This is an automated email from the ASF dual-hosted git repository.
arina pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/drill.git.
from bf1bdec DRILL-7021: HTTPD Throws NPE and Doesn't Recognize Timeformat
new df00912 DRILL-7095: Expose table schema (TupleMetadata) to physical
operator (EasySubScan)
new 8712ffd DRILL-7111: Fix table function execution for directories
new 71c1a4c DRILL-7106: Fix Intellij warning for FieldSchemaNegotiator
new a6474c5 DRILL-7086: Output schema for row set mechanism
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:
.../java/org/apache/drill/exec/ExecConstants.java | 4 +
.../drill/exec/physical/impl/scan/ReaderState.java | 23 +
.../impl/scan/columns/ColumnsScanFramework.java | 13 +-
...kage-info.java => ColumnsSchemaNegotiator.java} | 14 +-
.../exec/physical/rowSet/impl/ColumnBuilder.java | 240 ++++++++--
.../exec/physical/rowSet/impl/ContainerState.java | 2 +-
.../rowSet/impl/DefaultSchemaTransformer.java | 73 +++
.../exec/physical/rowSet/impl/LoaderInternals.java | 2 +
.../exec/physical/rowSet/impl/OptionBuilder.java | 21 +-
.../physical/rowSet/impl/ResultSetLoaderImpl.java | 17 +
.../physical/rowSet/impl/SchemaTransformer.java | 44 ++
.../rowSet/impl/SchemaTransformerImpl.java | 197 ++++++++
.../physical/rowSet/model/MetadataProvider.java | 6 +-
.../rowSet/model/single/BaseWriterBuilder.java | 12 +-
.../rowSet/project/RequestedTupleImpl.java | 15 +-
.../drill/exec/planner/logical/DrillTable.java | 8 +-
.../record/metadata/AbstractColumnMetadata.java | 150 +++---
.../record/metadata/PrimitiveColumnMetadata.java | 139 ++----
.../drill/exec/record/metadata/TupleSchema.java | 21 +-
.../metadata/schema/parser/SchemaVisitor.java | 4 +-
.../exec/server/options/SystemOptionManager.java | 1 +
.../drill/exec/store/AbstractStoragePlugin.java | 12 +-
.../org/apache/drill/exec/store/StoragePlugin.java | 24 +
.../drill/exec/store/dfs/FileSystemPlugin.java | 14 +-
.../apache/drill/exec/store/dfs/FormatPlugin.java | 17 +-
.../exec/store/dfs/WorkspaceSchemaFactory.java | 84 ++--
.../exec/store/dfs/easy/EasyFormatPlugin.java | 9 +-
.../drill/exec/store/dfs/easy/EasyGroupScan.java | 41 +-
.../drill/exec/store/dfs/easy/EasySubScan.java | 32 +-
.../sequencefile/SequenceFileFormatPlugin.java | 2 +-
.../exec/store/easy/text/TextFormatPlugin.java | 23 +-
.../compliant/v3/CompliantTextBatchReader.java | 2 +-
.../exec/store/parquet/ParquetFormatPlugin.java | 2 +-
.../java-exec/src/main/resources/drill-module.conf | 1 +
.../test/java/org/apache/drill/PlanningBase.java | 2 +
.../java/org/apache/drill/TestSchemaCommands.java | 14 +-
.../org/apache/drill/TestSelectWithOption.java | 39 +-
.../impl/scan/TestColumnsArrayFramework.java | 2 +-
.../physical/rowSet/impl/TestProjectedTuple.java | 7 +-
.../rowSet/impl/TestResultSetLoaderProjection.java | 187 ++++++++
.../rowSet/impl/TestResultSetLoaderProtocol.java | 53 ---
.../impl/TestResultSetLoaderTypeConversion.java | 149 ++++++
.../record/metadata/TestMetadataProperties.java | 229 +++++++++
.../record/{ => metadata}/TestTupleSchema.java | 17 +-
.../record/metadata/schema/TestSchemaProvider.java | 13 +-
.../metadata/schema/parser/TestSchemaParser.java | 14 +-
.../store/easy/text/compliant/BaseCsvTest.java | 1 -
.../org/apache/drill/test/rowSet/DirectRowSet.java | 11 +-
.../apache/drill/test/rowSet/RowSetBuilder.java | 17 +-
.../drill/test/rowSet/test/DummyWriterTest.java | 10 +-
.../drill/test/rowSet/test/PerformanceTool.java | 2 +-
.../test/rowSet/test/TestColumnConverter.java | 510 ++++++++++++++++++++-
exec/jdbc-all/pom.xml | 2 +-
.../main/codegen/templates/BasicTypeHelper.java | 47 +-
.../main/codegen/templates/ColumnAccessors.java | 95 +++-
.../exec/record/metadata/AbstractPropertied.java | 72 +++
.../drill/exec/record/metadata/ColumnMetadata.java | 104 ++---
.../drill/exec/record/metadata/Propertied.java} | 27 +-
.../exec/record/metadata/PropertyAccessor.java | 62 +++
.../drill/exec/record/metadata/TupleMetadata.java | 13 +-
.../apache/drill/exec/vector/DateUtilities.java | 15 +-
.../vector/accessor/InvalidConversionError.java | 55 +++
.../drill/exec/vector/accessor/ScalarWriter.java | 6 +
.../accessor/UnsupportedConversionError.java | 16 +-
.../AbstractWriteConverter.java | 23 +-
.../{ => convert}/ColumnConversionFactory.java | 15 +-
.../accessor/convert/ConvertStringToDate.java | 57 +++
.../ConvertStringToDouble.java} | 30 +-
.../ConvertStringToInt.java} | 31 +-
.../ConvertStringToInterval.java} | 33 +-
.../ConvertStringToLong.java} | 30 +-
.../accessor/convert/ConvertStringToTime.java | 56 +++
.../accessor/convert/ConvertStringToTimeStamp.java | 55 +++
.../accessor/convert/StandardConversions.java | 262 +++++++++++
.../vector/accessor/convert}/package-info.java | 7 +-
.../accessor/writer/AbstractObjectWriter.java | 16 +
.../accessor/writer/AbstractScalarWriter.java | 17 +-
.../accessor/writer/AbstractScalarWriterImpl.java | 19 +-
.../vector/accessor/writer/BaseScalarWriter.java | 18 +
.../accessor/writer/ColumnWriterFactory.java | 47 +-
.../accessor/writer/NullableScalarWriter.java | 31 +-
.../vector/accessor/writer/ScalarArrayWriter.java | 11 +-
.../vector/accessor/writer/UnionVectorShim.java | 2 +-
.../accessor/writer/dummy/DummyScalarWriter.java | 12 +
84 files changed, 3181 insertions(+), 651 deletions(-)
copy
exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/scan/columns/{package-info.java
=> ColumnsSchemaNegotiator.java} (71%)
create mode 100644
exec/java-exec/src/main/java/org/apache/drill/exec/physical/rowSet/impl/DefaultSchemaTransformer.java
create mode 100644
exec/java-exec/src/main/java/org/apache/drill/exec/physical/rowSet/impl/SchemaTransformer.java
create mode 100644
exec/java-exec/src/main/java/org/apache/drill/exec/physical/rowSet/impl/SchemaTransformerImpl.java
create mode 100644
exec/java-exec/src/test/java/org/apache/drill/exec/physical/rowSet/impl/TestResultSetLoaderTypeConversion.java
create mode 100644
exec/java-exec/src/test/java/org/apache/drill/exec/record/metadata/TestMetadataProperties.java
rename exec/java-exec/src/test/java/org/apache/drill/exec/record/{ =>
metadata}/TestTupleSchema.java (97%)
create mode 100644
exec/vector/src/main/java/org/apache/drill/exec/record/metadata/AbstractPropertied.java
copy
exec/{java-exec/src/main/java/org/apache/drill/exec/record/metadata/SchemaContainer.java
=> vector/src/main/java/org/apache/drill/exec/record/metadata/Propertied.java}
(56%)
create mode 100644
exec/vector/src/main/java/org/apache/drill/exec/record/metadata/PropertyAccessor.java
create mode 100644
exec/vector/src/main/java/org/apache/drill/exec/vector/accessor/InvalidConversionError.java
rename exec/vector/src/main/java/org/apache/drill/exec/vector/accessor/{writer
=> convert}/AbstractWriteConverter.java (83%)
rename exec/vector/src/main/java/org/apache/drill/exec/vector/accessor/{ =>
convert}/ColumnConversionFactory.java (80%)
create mode 100644
exec/vector/src/main/java/org/apache/drill/exec/vector/accessor/convert/ConvertStringToDate.java
copy
exec/vector/src/main/java/org/apache/drill/exec/vector/accessor/{writer/OffsetVectorWriter.java
=> convert/ConvertStringToDouble.java} (54%)
copy
exec/vector/src/main/java/org/apache/drill/exec/vector/accessor/{writer/OffsetVectorWriter.java
=> convert/ConvertStringToInt.java} (52%)
copy
exec/vector/src/main/java/org/apache/drill/exec/vector/accessor/{writer/OffsetVectorWriter.java
=> convert/ConvertStringToInterval.java} (52%)
copy
exec/vector/src/main/java/org/apache/drill/exec/vector/accessor/{writer/OffsetVectorWriter.java
=> convert/ConvertStringToLong.java} (55%)
create mode 100644
exec/vector/src/main/java/org/apache/drill/exec/vector/accessor/convert/ConvertStringToTime.java
create mode 100644
exec/vector/src/main/java/org/apache/drill/exec/vector/accessor/convert/ConvertStringToTimeStamp.java
create mode 100644
exec/vector/src/main/java/org/apache/drill/exec/vector/accessor/convert/StandardConversions.java
copy exec/{java-exec/src/main/java/org/apache/drill/exec/physical/impl/spill
=>
vector/src/main/java/org/apache/drill/exec/vector/accessor/convert}/package-info.java
(85%)
