You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by am...@apache.org on 2021/10/21 13:26:03 UTC
[ignite-3] branch ignite-15212 updated (e336c7c -> 8d43c01)
This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-15212
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.
from e336c7c Update modules/api/src/main/java/org/apache/ignite/query/sql/ColumnMetadata.java
add 4d06262 IGNITE-13667: Add schema columns mapping from user order to system order (#401)
add 0744f75 IGNITE-15601 Implement stop for calcite module in 3.0 (#395)
add dc30df6 IGNITE-15402 Partition drop in storage & table folder deletion. (#402)
add da1e280 IGNITE-15599 Get rid Guava in Calcite module (#398)
add 0a7efa3 IGNITE-15600 Cache for Calcite SQL plans in 3.0 (#403)
add 8d43c01 Drop TxSession.
No new revisions were added by this update.
Summary of changes:
examples/pom.xml | 7 +
.../ignite/example/sql/jdbc/SqlExamplesTest.java | 21 +--
.../ignite/example/table/TableExamplesTest.java | 21 +--
.../java/org/apache/ignite/query/sql/Session.java | 11 +-
.../org/apache/ignite/query/sql/TxSession.java | 33 ----
.../schema/definition/PrimaryKeyDefinition.java | 6 +-
.../ignite/schema/definition/TableDefinition.java | 10 +-
modules/calcite/pom.xml | 17 ++
.../processors/query/calcite/QueryProcessor.java | 3 +
.../query/calcite/SqlQueryProcessor.java | 88 ++++++---
.../calcite/exec/ClosableIteratorsHolder.java | 50 ++---
.../query/calcite/exec/ExchangeService.java | 2 +-
.../query/calcite/exec/ExchangeServiceImpl.java | 25 ++-
.../query/calcite/exec/ExecutionService.java | 2 +-
.../query/calcite/exec/ExecutionServiceImpl.java | 30 ++-
.../{RuntimeIndex.java => LifecycleAware.java} | 17 +-
.../query/calcite/exec/MailboxRegistry.java | 2 +-
.../query/calcite/exec/MailboxRegistryImpl.java | 14 ++
.../query/calcite/exec/PlannerHelper.java | 6 +-
.../query/calcite/exec/QueryTaskExecutor.java | 2 +-
.../query/calcite/exec/QueryTaskExecutorImpl.java | 38 +++-
.../query/calcite/exec/exp/ExpressionFactory.java | 3 +-
.../calcite/exec/exp/ExpressionFactoryImpl.java | 25 ++-
.../query/calcite/exec/exp/RexImpTable.java | 7 +-
.../query/calcite/exec/exp/RexToLixTranslator.java | 3 +-
.../calcite/exec/exp/agg/AccumulatorsFactory.java | 25 +--
.../query/calcite/exec/rel/RootNode.java | 9 +-
.../query/calcite/externalize/RelJson.java | 28 ++-
.../query/calcite/externalize/RelJsonReader.java | 17 +-
.../query/calcite/message/MessageService.java | 3 +-
.../query/calcite/message/MessageServiceImpl.java | 11 +-
.../query/calcite/metadata/IgniteMdCollation.java | 115 ++++++++----
.../calcite/metadata/IgniteMdFragmentMapping.java | 7 +-
.../query/calcite/metadata/IgniteMetadata.java | 5 +-
.../processors/query/calcite/prepare/Cloner.java | 11 +-
.../query/calcite/prepare/ExecutionPlan.java | 6 +-
.../processors/query/calcite/prepare/Fragment.java | 5 +-
.../query/calcite/prepare/FragmentSplitter.java | 5 +-
.../query/calcite/prepare/IgnitePlanner.java | 9 +-
.../query/calcite/prepare/PlannerHelper.java | 6 +-
.../query/calcite/prepare/QueryPlanCache.java | 4 +-
...DummyPlanCache.java => QueryPlanCacheImpl.java} | 35 +++-
.../query/calcite/prepare/QueryTemplate.java | 16 +-
.../processors/query/calcite/prepare/Splitter.java | 5 +-
.../query/calcite/rel/AbstractIgniteJoin.java | 31 ++-
.../query/calcite/rel/IgniteAggregate.java | 3 +-
.../rel/IgniteCorrelatedNestedLoopJoin.java | 24 ++-
.../processors/query/calcite/rel/IgniteFilter.java | 13 +-
.../query/calcite/rel/IgniteIndexScan.java | 3 +-
.../processors/query/calcite/rel/IgniteLimit.java | 5 +-
.../query/calcite/rel/IgniteMergeJoin.java | 10 +-
.../query/calcite/rel/IgniteNestedLoopJoin.java | 3 +-
.../query/calcite/rel/IgniteProject.java | 23 ++-
.../processors/query/calcite/rel/IgniteSort.java | 5 +-
.../query/calcite/rel/IgniteTableFunctionScan.java | 3 +-
.../query/calcite/rel/IgniteTableScan.java | 4 +-
.../query/calcite/rel/IgniteUnionAll.java | 16 +-
.../calcite/rel/agg/IgniteHashAggregateBase.java | 7 +-
.../calcite/rel/agg/IgniteMapAggregateBase.java | 10 +-
.../calcite/rel/agg/IgniteReduceAggregateBase.java | 14 +-
.../calcite/rel/agg/IgniteReduceHashAggregate.java | 5 +-
.../calcite/rel/agg/IgniteSingleAggregateBase.java | 10 +-
.../calcite/rel/agg/IgniteSortAggregateBase.java | 7 +-
.../rel/logical/IgniteLogicalIndexScan.java | 3 +-
.../rel/logical/IgniteLogicalTableScan.java | 3 +-
.../query/calcite/rel/set/IgniteMapSetOp.java | 13 +-
.../query/calcite/rel/set/IgniteMinusBase.java | 4 +-
.../calcite/rel/set/IgniteReduceIntersect.java | 3 +-
.../query/calcite/rel/set/IgniteReduceMinus.java | 3 +-
.../query/calcite/rel/set/IgniteReduceSetOp.java | 11 +-
.../query/calcite/rel/set/IgniteSetOp.java | 3 +-
.../query/calcite/rel/set/IgniteSingleSetOp.java | 11 +-
.../FilterSpoolMergeToSortedIndexSpoolRule.java | 5 +-
.../calcite/rule/logical/LogicalOrToUnionRule.java | 5 +-
.../query/calcite/schema/IgniteTableImpl.java | 5 +-
.../query/calcite/schema/SchemaHolderImpl.java | 11 +-
.../calcite/sql/IgniteSqlCreateTableOption.java | 3 +-
.../query/calcite/trait/CorrelationTrait.java | 5 +-
.../query/calcite/trait/DistributionTrait.java | 27 ++-
.../processors/query/calcite/trait/TraitUtils.java | 26 +--
.../processors/query/calcite/util/Commons.java | 16 ++
.../processors/query/calcite/util/HintUtils.java | 6 +-
.../processors/query/calcite/util/Primitives.java | 105 +++++++++++
.../processors/query/calcite/util/TypeUtils.java | 3 +-
.../query/calcite/StopCalciteModuleTest.java | 208 +++++++++++++++++++++
.../calcite/exec/rel/AbstractExecutionTest.java | 19 +-
.../query/calcite/exec/rel/BaseAggregateTest.java | 21 +--
.../query/calcite/exec/rel/ExecutionTest.java | 4 +-
.../exec/rel/HashAggregateExecutionTest.java | 6 +-
.../rel/HashAggregateSingleGroupExecutionTest.java | 21 +--
.../exec/rel/SortAggregateExecutionTest.java | 6 +-
.../query/calcite/planner/AbstractPlannerTest.java | 5 +-
.../query/calcite/planner/PlannerTest.java | 4 +-
.../query/calcite/sql/SqlDdlParserTest.java | 15 +-
.../configuration/ConfigurationChanger.java | 2 +-
.../ignite/internal/thread/IgniteThread.java | 105 +++++++++++
.../ignite/internal/thread/NamedThreadFactory.java | 2 +-
.../apache/ignite/lang/NodeStoppingException.java | 2 +-
.../internal/metastorage/MetaStorageManager.java | 54 +++---
.../java/org/apache/ignite/internal/raft/Loza.java | 12 +-
.../java/org/apache/ignite/internal/ITUtils.java} | 27 +--
.../calcite/AbstractBasicIntegrationTest.java | 5 +-
.../ignite/internal/calcite/ITAggregatesTest.java | 8 +-
.../ignite/internal/calcite/ITDataTypesTest.java | 9 +-
.../ignite/internal/calcite/ITFunctionsTest.java | 16 +-
.../ignite/internal/calcite/ITMetadataTest.java | 25 +++
.../calcite/ITProjectScanMergeRuleTest.java | 8 +-
.../ignite/internal/calcite/ITSetOpTest.java | 4 +-
.../ignite/internal/calcite/util/Commons.java | 4 +-
.../runner/app/AbstractSchemaChangeTest.java | 5 +-
.../internal/runner/app/ITBaselineChangesTest.java | 5 +-
.../runner/app/ITDynamicTableCreationTest.java | 5 +-
.../ignite/internal/runner/app/ITIgnitionTest.java | 5 +-
.../internal/runner/app/ITTablesApiTest.java | 5 +-
.../runner/app/ITThinClientConnectionTest.java | 5 +-
.../org/apache/ignite/internal/schema/Column.java | 54 ++++--
.../org/apache/ignite/internal/schema/Columns.java | 16 +-
.../ignite/internal/schema/SchemaDescriptor.java | 13 +-
.../SchemaConfigurationConverter.java | 9 +-
.../configuration/SchemaDescriptorConverter.java | 40 ++--
.../schema/configuration/TableValidatorImpl.java | 14 +-
.../schema/definition/TableDefinitionImpl.java | 45 ++---
.../builder/PrimaryKeyDefinitionBuilderImpl.java | 8 +-
.../marshaller/schema/SchemaSerializerImpl.java | 5 +-
.../internal/schema/ColumnDefinitionTest.java | 2 +-
.../internal/schema/SchemaDescriptorTest.java | 38 ++++
.../SchemaConfigurationConverterTest.java | 2 +-
.../SchemaDescriptorConverterTest.java | 41 +++-
.../schema/serializer/AbstractSerializerTest.java | 41 ++++
modules/sql/src/test/java/IgniteSqlTest.java | 27 +--
.../ignite/internal/storage/PartitionStorage.java | 7 +
.../internal/storage/engine/TableStorage.java | 55 +++++-
.../basic/ConcurrentHashMapPartitionStorage.java | 5 +
.../storage/rocksdb/RocksDbPartitionStorage.java | 25 ++-
.../storage/rocksdb/RocksDbTableStorage.java | 147 ++++++++++++---
.../storage/rocksdb/RocksDbStorageTest.java | 1 +
.../internal/table/distributed/TableManager.java | 33 +++-
parent/pom.xml | 7 +
138 files changed, 1734 insertions(+), 755 deletions(-)
delete mode 100644 modules/api/src/main/java/org/apache/ignite/query/sql/TxSession.java
copy modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/{RuntimeIndex.java => LifecycleAware.java} (76%)
rename modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/{DummyPlanCache.java => QueryPlanCacheImpl.java} (55%)
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/Primitives.java
create mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/StopCalciteModuleTest.java
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/thread/IgniteThread.java
copy modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/FieldsMetadata.java => runner/src/integrationTest/java/org/apache/ignite/internal/ITUtils.java} (67%)