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 a8c9a0f DRILL-7603: Allow default schema to be set for HTTP queries
new 2b7ab27 DRILL-7634: Rollup of code cleanup changes
new cc51f24 DRILL-7631: Updates to the Json Structure Parser
The 2 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:
.../exceptions/DrillConfigurationException.java | 8 +-
.../apache/drill/common/exceptions/DrillError.java | 8 +-
.../drill/common/exceptions/DrillIOException.java | 8 +-
.../exceptions/RetryAfterSpillException.java | 5 +-
.../common/exceptions/UserRemoteException.java | 6 +-
.../java/org/apache/drill/common/types/Types.java | 5 -
.../store/mapr/db/binary/MapRDBFilterBuilder.java | 33 +--
.../mapr/db/json/CompareFunctionsProcessor.java | 21 +-
.../store/mapr/db/json/JsonConditionBuilder.java | 82 +++---
.../exec/store/mapr/db/json/JsonScanSpec.java | 6 +-
.../store/mapr/db/json/OjaiFunctionsProcessor.java | 14 +-
.../store/hbase/CompareFunctionsProcessor.java | 67 ++---
.../drill/exec/store/hbase/HBaseFilterBuilder.java | 36 +--
.../drill/exec/store/hbase/HBaseRegexParser.java | 6 +-
.../drill/exec/expr/fn/HiveFunctionRegistry.java | 22 +-
.../drill/exec/store/kafka/KafkaNodeProcessor.java | 27 +-
.../exec/store/kafka/KafkaPartitionScanSpec.java | 11 +-
.../store/kafka/KafkaPartitionScanSpecBuilder.java | 28 +-
.../store/mongo/MongoCompareFunctionProcessor.java | 24 +-
.../drill/exec/store/mongo/MongoFilterBuilder.java | 40 ++-
.../codegen/templates/ComparisonFunctions.java | 310 ++++++++++-----------
.../apache/drill/exec/expr/BooleanPredicate.java | 9 +-
.../org/apache/drill/exec/expr/CloneVisitor.java | 2 +-
.../drill/exec/expr/ComparisonPredicate.java | 14 +-
.../apache/drill/exec/expr/EvaluationVisitor.java | 14 +-
.../exec/expr/ExpressionTreeMaterializer.java | 33 ++-
.../org/apache/drill/exec/expr/FilterBuilder.java | 34 +--
.../apache/drill/exec/expr/StatisticsProvider.java | 3 +-
.../drill/exec/expr/fn/DrillAggFuncHolder.java | 75 +++--
.../exec/expr/fn/FunctionGenerationHelper.java | 22 +-
.../expr/fn/FunctionImplementationRegistry.java | 4 +-
.../drill/exec/expr/fn/impl/BitFunctions.java | 14 +-
.../drill/exec/expr/fn/impl/StringFunctions.java | 6 +-
.../expr/fn/interpreter/InterpreterEvaluator.java | 44 ++-
.../drill/exec/ops/ExecutorFragmentContext.java | 2 +-
.../exec/physical/base/AbstractDbGroupScan.java | 1 -
.../exec/physical/base/AbstractDbSubScan.java | 2 +-
.../exec/physical/base/AbstractGroupScan.java | 6 +-
.../base/AbstractGroupScanWithMetadata.java | 4 +-
.../physical/base/AbstractPhysicalVisitor.java | 25 +-
.../drill/exec/physical/base/FragmentLeaf.java | 4 +-
.../org/apache/drill/exec/physical/base/Leaf.java | 6 +-
.../apache/drill/exec/physical/base/ScanStats.java | 7 +-
.../exec/physical/config/SingleMergeExchange.java | 5 +-
.../exec/physical/impl/aggregate/HashAggBatch.java | 6 +-
.../impl/scan/project/ResolvedMapColumn.java | 1 -
.../exec/physical/impl/window/WindowFunction.java | 39 ++-
.../physical/resultSet/impl/BuildFromSchema.java | 3 +-
.../physical/resultSet/impl/ColumnBuilder.java | 2 +-
.../exec/physical/resultSet/impl/ColumnState.java | 2 +-
.../exec/planner/AbstractPartitionDescriptor.java | 18 +-
.../exec/planner/DFSFilePartitionLocation.java | 4 +-
.../planner/FileSystemPartitionDescriptor.java | 24 +-
.../drill/exec/planner/PartitionDescriptor.java | 8 +-
.../apache/drill/exec/planner/PlannerPhase.java | 27 +-
.../drill/exec/planner/common/DrillRelOptUtil.java | 17 +-
.../exec/planner/common/DrillScanRelBase.java | 2 +-
.../planner/fragment/DistributionAffinity.java | 22 +-
.../fragment/HardAffinityFragmentParallelizer.java | 10 +-
.../drill/exec/planner/fragment/Materializer.java | 18 +-
.../exec/planner/fragment/MemoryCalculator.java | 4 +-
.../drill/exec/planner/fragment/PlanningSet.java | 13 +-
.../exec/planner/fragment/QueryParallelizer.java | 6 +-
.../exec/planner/fragment/SimpleParallelizer.java | 56 ++--
.../fragment/SoftAffinityFragmentParallelizer.java | 10 +-
.../apache/drill/exec/planner/fragment/Stats.java | 2 +-
.../drill/exec/planner/fragment/Wrapper.java | 61 ++--
.../fragment/contrib/SplittingParallelizer.java | 51 ++--
.../drill/exec/planner/index/PathInExpr.java | 30 +-
.../generators/AbstractIndexPlanGenerator.java | 19 +-
.../drill/exec/planner/logical/DrillOptiq.java | 48 ++--
.../planner/logical/DrillPushLimitToScanRule.java | 6 +-
.../drill/exec/planner/logical/ExprHelper.java | 8 +-
.../planner/physical/DrillDistributionTrait.java | 3 +-
.../physical/DrillDistributionTraitDef.java | 3 +-
.../drill/exec/planner/physical/ExchangePrel.java | 5 +-
.../drill/exec/planner/physical/HashPrelUtil.java | 5 +-
.../drill/exec/planner/physical/JoinPrel.java | 19 +-
.../planner/physical/MetadataControllerPrel.java | 3 +-
.../exec/planner/physical/NestedLoopJoinPrule.java | 2 -
.../exec/planner/physical/PhysicalPlanCreator.java | 8 +-
.../apache/drill/exec/planner/physical/Prel.java | 5 +-
.../drill/exec/planner/physical/ScanPrel.java | 16 +-
.../drill/exec/planner/physical/ScanPrule.java | 2 +-
.../planner/physical/SingleMergeExchangePrel.java | 5 +-
.../drill/exec/planner/physical/SortPrel.java | 2 +-
.../drill/exec/planner/physical/SortPrule.java | 14 +-
.../exec/planner/physical/SubsetTransformer.java | 22 +-
.../drill/exec/planner/physical/TopNPrel.java | 4 +-
.../exec/planner/physical/UnionExchangePrel.java | 2 +-
.../visitor/ExcessiveExchangeIdentifier.java | 10 +-
.../physical/visitor/MemoryEstimationVisitor.java | 9 +-
.../drill/exec/planner/sql/TypeInferenceUtils.java | 7 +-
.../planner/sql/handlers/DefaultSqlHandler.java | 20 +-
.../exec/planner/sql/handlers/ExplainHandler.java | 31 ++-
.../exec/resolver/DefaultFunctionResolver.java | 2 +-
.../drill/exec/resolver/ExactFunctionResolver.java | 2 +-
.../drill/exec/store/dfs/FileSystemPlugin.java | 15 +-
.../apache/drill/exec/store/dfs/FormatPlugin.java | 16 +-
.../exec/store/dfs/easy/EasyFormatPlugin.java | 14 +-
.../drill/exec/store/dfs/easy/EasyGroupScan.java | 9 +-
.../easy/json/parser/AbstractElementParser.java | 3 +
.../exec/store/easy/json/parser/ArrayListener.java | 89 ++----
.../exec/store/easy/json/parser/ArrayParser.java | 63 ++++-
.../store/easy/json/parser/DummyValueParser.java | 2 -
.../easy/json/parser/JsonStructureParser.java | 12 +
.../exec/store/easy/json/parser/JsonType.java | 25 --
.../store/easy/json/parser/JsonValueParser.java | 116 ++++++++
.../store/easy/json/parser/ObjectListener.java | 110 ++++----
.../exec/store/easy/json/parser/ObjectParser.java | 60 +++-
.../exec/store/easy/json/parser/TokenIterator.java | 16 ++
.../exec/store/easy/json/parser/ValueDef.java | 85 ++++++
.../store/easy/json/parser/ValueDefFactory.java | 99 +++++++
.../exec/store/easy/json/parser/ValueFactory.java | 222 ---------------
.../exec/store/easy/json/parser/ValueListener.java | 37 +--
.../exec/store/easy/json/parser/ValueParser.java | 55 ++--
.../drill/exec/store/ischema/InfoSchemaFilter.java | 20 +-
.../store/ischema/InfoSchemaFilterBuilder.java | 37 +--
.../exec/store/parquet/FilterEvaluatorUtils.java | 10 +-
.../exec/store/schedule/AssignmentCreator.java | 35 ++-
.../drill/exec/work/metadata/MetadataProvider.java | 13 +-
.../impl/TestResultSetLoaderMapArray.java | 1 -
.../impl/TestResultSetLoaderRepeatedList.java | 31 +--
.../{ => easy}/json/parser/BaseTestJsonParser.java | 128 ++++-----
.../json/parser/TestJsonParserArrays.java | 86 +++---
.../json/parser/TestJsonParserBasics.java | 92 ++++--
.../json/parser/TestJsonParserErrors.java | 5 +-
.../json/parser/TestJsonParserObjects.java | 9 +-
.../easy/json/parser/TestJsonParserUnknowns.java | 294 +++++++++++++++++++
.../easy/text/compliant/TestCsvWithHeaders.java | 4 +-
.../store/parquet/TestParquetFilterPushDown.java | 6 +-
.../drill/exec/record/MaterializedField.java | 32 +--
.../record/metadata/AbstractColumnMetadata.java | 5 +-
.../exec/record/metadata/PropertyAccessor.java | 2 +-
.../accessor/reader/AbstractScalarReader.java | 2 +-
.../accessor/writer/AbstractTupleWriter.java | 12 +-
.../vector/accessor/writer/ObjectArrayWriter.java | 2 -
.../org/apache/drill/common/FunctionNames.java | 54 ++++
.../drill/common/expression/BooleanOperator.java | 8 +-
.../common/expression/ExpressionStringBuilder.java | 4 +-
.../drill/common/expression/FunctionCall.java | 21 +-
.../common/expression/FunctionCallFactory.java | 56 ++--
.../apache/drill/common/expression/SchemaPath.java | 3 +-
.../drill/common/expression/TypedFieldExpr.java | 7 +-
.../drill/common/expression/ValueExpressions.java | 96 +++----
.../expression/visitors/AggregateChecker.java | 3 +-
.../visitors/ConditionalExprOptimizer.java | 2 +-
.../expression/visitors/ConstantChecker.java | 2 +-
.../expression/visitors/ExpressionValidator.java | 3 +-
.../common/parser/LogicalExpressionParser.java | 6 +-
150 files changed, 2251 insertions(+), 1709 deletions(-)
delete mode 100644
exec/java-exec/src/main/java/org/apache/drill/exec/store/easy/json/parser/JsonType.java
create mode 100644
exec/java-exec/src/main/java/org/apache/drill/exec/store/easy/json/parser/JsonValueParser.java
create mode 100644
exec/java-exec/src/main/java/org/apache/drill/exec/store/easy/json/parser/ValueDef.java
create mode 100644
exec/java-exec/src/main/java/org/apache/drill/exec/store/easy/json/parser/ValueDefFactory.java
delete mode 100644
exec/java-exec/src/main/java/org/apache/drill/exec/store/easy/json/parser/ValueFactory.java
rename exec/java-exec/src/test/java/org/apache/drill/exec/store/{ =>
easy}/json/parser/BaseTestJsonParser.java (71%)
rename exec/java-exec/src/test/java/org/apache/drill/exec/store/{ =>
easy}/json/parser/TestJsonParserArrays.java (82%)
rename exec/java-exec/src/test/java/org/apache/drill/exec/store/{ =>
easy}/json/parser/TestJsonParserBasics.java (74%)
rename exec/java-exec/src/test/java/org/apache/drill/exec/store/{ =>
easy}/json/parser/TestJsonParserErrors.java (94%)
rename exec/java-exec/src/test/java/org/apache/drill/exec/store/{ =>
easy}/json/parser/TestJsonParserObjects.java (94%)
create mode 100644
exec/java-exec/src/test/java/org/apache/drill/exec/store/easy/json/parser/TestJsonParserUnknowns.java
create mode 100644
logical/src/main/java/org/apache/drill/common/FunctionNames.java
