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/06/09 19:36:19 UTC
[ignite-3] 07/15: Merge branch 'main' into gg-14743
This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a commit to branch ignite-14743
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
commit d55c967388998a6c581d9e590f5784d170ebf796
Merge: 1d9efdd 44d69d3
Author: Andrew Mashenkov <an...@gmail.com>
AuthorDate: Mon Jun 7 17:05:47 2021 +0300
Merge branch 'main' into gg-14743
.../main/java/org/apache/ignite/app/Ignition.java | 7 +-
.../org/apache/ignite/app/IgnitionManager.java | 12 +-
.../schemas/runner/NodeConfigurationSchema.java | 5 -
modules/baseline/pom.xml | 2 +-
modules/calcite/README.txt | 35 ++
modules/calcite/pom.xml | 230 +++++++
modules/calcite/src/main/codegen/config.fmpp | 646 +++++++++++++++++++
.../src/main/codegen/includes/parserImpls.ftl | 201 ++++++
.../apache/calcite/plan/volcano/VolcanoUtils.java} | 12 +-
.../internal/processors/query/calcite/Stubs.java} | 20 +-
.../query/calcite/metadata/IgniteMdCollation.java | 574 +++++++++++++++++
.../calcite/metadata/IgniteMdCumulativeCost.java | 113 ++++
.../calcite/metadata/IgniteMdDistinctRowCount.java | 52 ++
.../calcite/metadata/IgniteMdDistribution.java | 111 ++++
.../metadata/IgniteMdNonCumulativeCost.java | 46 ++
.../metadata/IgniteMdPercentageOriginalRows.java | 161 +++++
.../query/calcite/metadata/IgniteMdPredicates.java | 50 ++
.../query/calcite/metadata/IgniteMdRowCount.java | 133 ++++
.../calcite/metadata/IgniteMdSelectivity.java | 125 ++++
.../query/calcite/metadata/IgniteMetadata.java | 45 ++
.../query/calcite/metadata/RelMetadataQueryEx.java | 77 +++
.../query/calcite/metadata/cost/IgniteCost.java | 234 +++++++
.../calcite/metadata/cost/IgniteCostFactory.java | 101 +++
.../query/calcite/prepare/IgnitePlanner.java | 394 ++++++++++++
.../query/calcite/prepare/IgnitePrograms.java | 71 +++
.../query/calcite/prepare/IgniteRelShuttle.java | 228 +++++++
.../query/calcite/prepare/IgniteSqlValidator.java | 382 +++++++++++
.../query/calcite/prepare/PlannerHelper.java | 230 +++++++
.../query/calcite/prepare/PlannerPhase.java | 226 +++++++
.../query/calcite/prepare/PlanningContext.java | 370 +++++++++++
.../query/calcite/prepare/ValidationResult.java | 70 +++
.../calcite/prepare/ddl/ColumnDefinition.java | 83 +++
.../calcite/prepare/ddl/CreateTableCommand.java | 302 +++++++++
.../query/calcite/prepare/ddl/DdlCommand.java} | 9 +-
.../prepare/ddl/DdlSqlToCommandConverter.java | 367 +++++++++++
.../calcite/prepare/ddl/DropTableCommand.java | 74 +++
.../query/calcite/rel/AbstractIgniteJoin.java | 318 ++++++++++
.../query/calcite/rel/AbstractIndexScan.java | 163 +++++
.../query/calcite/rel/IgniteAggregate.java | 120 ++++
.../query/calcite/rel/IgniteConvention.java} | 42 +-
.../rel/IgniteCorrelatedNestedLoopJoin.java | 240 +++++++
.../query/calcite/rel/IgniteExchange.java | 98 +++
.../processors/query/calcite/rel/IgniteFilter.java | 138 ++++
.../query/calcite/rel/IgniteHashIndexSpool.java | 143 +++++
.../query/calcite/rel/IgniteIndexScan.java | 148 +++++
.../processors/query/calcite/rel/IgniteLimit.java | 178 ++++++
.../query/calcite/rel/IgniteMergeJoin.java | 277 ++++++++
.../query/calcite/rel/IgniteNestedLoopJoin.java | 114 ++++
.../query/calcite/rel/IgniteProject.java | 223 +++++++
.../query/calcite/rel/IgniteReceiver.java | 145 +++++
.../processors/query/calcite/rel/IgniteRel.java | 89 +++
.../query/calcite/rel/IgniteRelVisitor.java | 185 ++++++
.../processors/query/calcite/rel/IgniteSender.java | 144 +++++
.../processors/query/calcite/rel/IgniteSort.java | 125 ++++
.../query/calcite/rel/IgniteSortedIndexSpool.java | 152 +++++
.../query/calcite/rel/IgniteTableFunctionScan.java | 77 +++
.../query/calcite/rel/IgniteTableModify.java | 104 +++
.../query/calcite/rel/IgniteTableScan.java | 136 ++++
.../query/calcite/rel/IgniteTableSpool.java | 91 +++
.../query/calcite/rel/IgniteTrimExchange.java | 119 ++++
.../query/calcite/rel/IgniteUnionAll.java | 146 +++++
.../processors/query/calcite/rel/IgniteValues.java | 74 +++
.../rel/ProjectableFilterableTableScan.java | 185 ++++++
.../query/calcite/rel/SourceAwareIgniteRel.java} | 15 +-
.../calcite/rel/agg/IgniteHashAggregateBase.java | 46 ++
.../calcite/rel/agg/IgniteMapAggregateBase.java | 94 +++
.../calcite/rel/agg/IgniteMapHashAggregate.java | 101 +++
.../calcite/rel/agg/IgniteMapSortAggregate.java | 140 +++++
.../calcite/rel/agg/IgniteReduceAggregateBase.java | 174 +++++
.../calcite/rel/agg/IgniteReduceHashAggregate.java | 116 ++++
.../calcite/rel/agg/IgniteReduceSortAggregate.java | 126 ++++
.../calcite/rel/agg/IgniteSingleAggregateBase.java | 95 +++
.../calcite/rel/agg/IgniteSingleHashAggregate.java | 71 +++
.../calcite/rel/agg/IgniteSingleSortAggregate.java | 106 ++++
.../calcite/rel/agg/IgniteSortAggregateBase.java | 71 +++
.../rel/logical/IgniteLogicalIndexScan.java | 110 ++++
.../rel/logical/IgniteLogicalTableScan.java | 64 ++
.../query/calcite/rel/set/IgniteMapMinus.java | 141 +++++
.../query/calcite/rel/set/IgniteMinusBase.java | 100 +++
.../query/calcite/rel/set/IgniteReduceMinus.java | 135 ++++
.../query/calcite/rel/set/IgniteSingleMinus.java | 134 ++++
.../calcite/rule/AbstractIgniteConverterRule.java | 54 ++
.../calcite/rule/CorrelateToNestedLoopRule.java | 123 ++++
.../calcite/rule/CorrelatedNestedLoopJoinRule.java | 192 ++++++
.../query/calcite/rule/FilterConverterRule.java | 58 ++
.../rule/FilterSpoolMergeToHashIndexSpoolRule.java | 114 ++++
.../FilterSpoolMergeToSortedIndexSpoolRule.java | 118 ++++
.../calcite/rule/HashAggregateConverterRule.java | 117 ++++
.../calcite/rule/LogicalScanConverterRule.java | 83 +++
.../query/calcite/rule/MergeJoinConverterRule.java | 75 +++
.../query/calcite/rule/MinusConverterRule.java | 94 +++
.../calcite/rule/NestedLoopJoinConverterRule.java | 56 ++
.../query/calcite/rule/ProjectConverterRule.java | 51 ++
.../calcite/rule/SortAggregateConverterRule.java | 144 +++++
.../query/calcite/rule/SortConverterRule.java | 77 +++
.../rule/TableFunctionScanConverterRule.java | 65 ++
.../calcite/rule/TableModifyConverterRule.java | 60 ++
.../query/calcite/rule/UnionConverterRule.java | 95 +++
.../query/calcite/rule/ValuesConverterRule.java | 56 ++
.../calcite/rule/logical/ExposeIndexRule.java | 73 +++
.../calcite/rule/logical/FilterScanMergeRule.java | 182 ++++++
.../calcite/rule/logical/LogicalOrToUnionRule.java | 117 ++++
.../calcite/rule/logical/ProjectScanMergeRule.java | 190 ++++++
.../query/calcite/schema/ColumnDescriptor.java} | 50 +-
.../query/calcite/schema/IgniteIndex.java} | 49 +-
.../query/calcite/schema/IgniteSchema.java | 71 +++
.../query/calcite/schema/IgniteTable.java | 109 ++++
.../query/calcite/schema/TableDescriptor.java | 87 +++
.../query/calcite/sql/IgniteSqlCreateTable.java | 117 ++++
.../calcite/sql/IgniteSqlCreateTableOption.java | 113 ++++
.../sql/IgniteSqlCreateTableOptionEnum.java | 55 ++
.../calcite/sql/fun/IgniteSqlOperatorTable.java | 65 ++
.../calcite/sql/fun/SqlSystemRangeFunction.java | 60 ++
.../query/calcite/trait/CorrelationTrait.java | 122 ++++
.../query/calcite/trait/CorrelationTraitDef.java} | 45 +-
.../query/calcite/trait/DistributionFunction.java | 225 +++++++
.../query/calcite/trait/DistributionTrait.java | 178 ++++++
.../query/calcite/trait/DistributionTraitDef.java | 55 ++
.../query/calcite/trait/IgniteDistribution.java} | 28 +-
.../query/calcite/trait/IgniteDistributions.java | 123 ++++
.../query/calcite/trait/RelFactory.java} | 25 +-
.../query/calcite/trait/RewindabilityTrait.java | 102 +++
.../query/calcite/trait/RewindabilityTraitDef.java | 53 ++
.../processors/query/calcite/trait/TraitUtils.java | 536 ++++++++++++++++
.../query/calcite/trait/TraitsAwareIgniteRel.java | 156 +++++
.../query/calcite/type/IgniteTypeFactory.java | 239 +++++++
.../query/calcite/type/IgniteTypeSystem.java} | 35 +-
.../processors/query/calcite/util/Commons.java | 428 +++++++++++++
.../processors/query/calcite/util/HintUtils.java | 61 ++
.../query/calcite/util/IgniteResource.java | 46 ++
.../query/calcite/util/IndexConditions.java | 143 +++++
.../processors/query/calcite/util/RexUtils.java | 577 +++++++++++++++++
.../processors/query/calcite/util/TypeUtils.java | 186 ++++++
.../planner/AbstractAggregatePlannerTest.java | 73 +++
.../query/calcite/planner/AbstractPlannerTest.java | 697 +++++++++++++++++++++
.../planner/AggregateDistinctPlannerTest.java | 130 ++++
.../calcite/planner/AggregatePlannerTest.java | 305 +++++++++
.../CorrelatedNestedLoopJoinPlannerTest.java | 173 +++++
.../query/calcite/planner/ExceptPlannerTest.java | 329 ++++++++++
.../calcite/planner/HashAggregatePlannerTest.java | 128 ++++
.../calcite/planner/HashIndexSpoolPlannerTest.java | 232 +++++++
.../calcite/planner/JoinColocationPlannerTest.java | 204 ++++++
.../calcite/planner/SortAggregatePlannerTest.java | 151 +++++
.../planner/SortedIndexSpoolPlannerTest.java | 194 ++++++
.../query/calcite/planner/TableDmlPlannerTest.java | 174 +++++
.../query/calcite/planner/TableFunctionTest.java | 110 ++++
.../calcite/planner/TableSpoolPlannerTest.java | 140 +++++
.../query/calcite/sql/SqlDdlParserTest.java | 325 ++++++++++
.../ignite/cli/builtins/node/NodeManager.java | 52 +-
.../apache/ignite/cli/spec/NodeCommandSpec.java | 19 +-
.../apache/ignite/cli/IgniteCliInterfaceTest.java | 14 +-
.../processor/internal/Processor.java | 1 +
.../configuration/ConfigurationChangerTest.java | 17 +-
.../internal/util/ConfigurationUtilTest.java | 25 +-
.../sample/TraversableTreeNodeTest.java | 22 +-
.../ignite/configuration/ConfigurationValue.java | 2 +-
.../ignite/configuration/ConfigurationChanger.java | 76 +--
.../internal/DynamicConfiguration.java | 34 +-
.../configuration/internal/DynamicProperty.java | 26 +-
.../ignite/configuration/internal/SuperRoot.java | 13 +-
.../internal/asm/ConfigurationAsmGenerator.java | 30 +-
.../internal/util/ConfigurationUtil.java | 73 ++-
.../configuration/tree/ConfigurationSource.java | 6 +
.../ignite/configuration/tree/NamedListNode.java | 5 +-
modules/core/pom.xml | 12 +
.../apache/ignite/internal/util/ArrayUtils.java | 45 +-
.../ignite/internal/util/CollectionUtils.java | 77 +++
.../apache/ignite/internal/util/IgniteUtils.java | 43 ++
modules/metastorage-client/pom.xml | 6 +
.../client/ITMetaStorageServiceTest.java | 17 +-
modules/metastorage/pom.xml | 7 +-
.../internal/metastorage/MetaStorageManager.java | 18 +-
modules/network-annotation-processor/pom.xml | 8 +-
.../processor/ITAutoSerializableProcessorTest.java | 138 ----
.../ITTransferableObjectProcessorTest.java | 248 ++++++++
.../processor/internal/AllTypesMessage.java | 63 +-
.../processor/internal/AllTypesMessageImpl.java | 471 --------------
...derMessage.java => ConflictingTypeMessage.java} | 7 +-
...MessageFactory.java => ITTestMessageGroup.java} | 8 +-
.../internal/InvalidAnnotatedTypeMessage.java | 4 +-
...age.java => InvalidParameterGetterMessage.java} | 8 +-
...ge.java => InvalidReturnTypeGetterMessage.java} | 6 +-
...llTypesMessageFactory.java => SecondGroup.java} | 8 +-
.../processor/internal/TransitiveMessage.java | 33 +-
...Message.java => UnmarshallableTypeMessage.java} | 6 +-
... UnmarshallableTypeNonSerializableMessage.java} | 6 +-
.../processor/annotations/AutoSerializable.java | 72 ---
.../internal/AutoSerializableProcessor.java | 251 --------
.../network/processor/internal/MessageClass.java | 160 +++++
.../internal/MessageDeserializerGenerator.java | 212 -------
.../processor/internal/MessageGroupWrapper.java | 90 +++
.../processor/internal/ProcessingException.java | 42 +-
.../internal/SerializationFactoryGenerator.java | 69 --
.../internal/TransferableObjectProcessor.java | 258 ++++++++
.../network/processor/internal/TypeUtils.java | 52 +-
.../internal/messages/MessageBuilderGenerator.java | 91 +++
.../internal/messages/MessageFactoryGenerator.java | 81 +++
.../internal/messages/MessageImplGenerator.java | 230 +++++++
.../BaseMethodNameResolver.java | 53 +-
.../MessageCollectionItemTypeConverter.java | 32 +-
.../MessageDeserializerGenerator.java | 160 +++++
.../MessageReaderMethodResolver.java | 19 +-
.../MessageSerializerGenerator.java | 69 +-
.../MessageWriterMethodResolver.java | 20 +-
.../RegistryInitializerGenerator.java | 91 +++
.../SerializationFactoryGenerator.java | 104 +++
.../services/javax.annotation.processing.Processor | 2 +-
.../internal/SerializationOrderMessage.java} | 22 +-
.../processor/internal/SerializationOrderTest.java | 95 +++
.../processor/internal/TestMessageGroup.java} | 13 +-
.../org/apache/ignite/network/ClusterNode.java | 12 +-
.../org/apache/ignite/network/NetworkMessage.java | 25 +-
.../ignite/network/annotations/MessageGroup.java | 71 +++
.../ignite/network/annotations/Transferable.java | 98 +++
.../MessageSerializationRegistry.java | 51 +-
.../network/serialization/MessageWriter.java | 5 +-
.../org/apache/ignite/network/TestMessageImpl.java | 81 ---
.../internal/netty/ConnectionManagerTest.java | 30 +-
.../internal/recovery/RecoveryHandshakeTest.java | 36 +-
.../network/scalecube/ITNodeRestartsTest.java | 16 +-
.../scalecube/ITScaleCubeNetworkMessagingTest.java | 44 +-
.../network/MessageSerializationRegistryImpl.java | 101 +++
.../ignite/network/NetworkMessageTypes.java} | 46 +-
.../internal/direct/DirectMarshallingUtils.java | 12 +-
.../internal/direct/DirectMessageWriter.java | 28 +-
.../stream/DirectByteBufferStreamImplV1.java | 81 ++-
.../network/internal/netty/InboundDecoder.java | 9 +-
.../network/internal/netty/OutboundEncoder.java | 3 +-
.../recovery/RecoveryClientHandshakeManager.java | 19 +-
.../recovery/RecoveryServerHandshakeManager.java | 19 +-
.../recovery/message/HandshakeStartMessage.java | 29 +-
.../message/HandshakeStartResponseMessage.java | 41 +-
.../message/HandshakeStartResponseMessageImpl.java | 83 ---
.../scalecube/ScaleCubeClusterServiceFactory.java | 9 +-
.../ScaleCubeDirectMarshallerTransport.java | 21 +-
.../scalecube/message/ScaleCubeMessage.java | 21 +-
.../scalecube/message/ScaleCubeMessageImpl.java | 52 --
.../MessageSerializationRegistryImplTest.java} | 72 ++-
.../org/apache/ignite/network/TestMessage.java} | 13 +-
.../TestMessageSerializationRegistryImpl.java} | 15 +-
.../apache/ignite/network/TestMessageTypes.java} | 13 +-
.../ignite/network/internal/AllTypesMessage.java | 67 +-
.../network/internal/AllTypesMessageGenerator.java | 259 ++++----
.../network/internal/AllTypesMessageImpl.java | 496 ---------------
...ssageFactory.java => NestedMessageMessage.java} | 11 +-
.../network/internal/netty/InboundDecoderTest.java | 124 +++-
.../network/internal/netty/NettyServerTest.java | 70 +--
modules/raft-client/pom.xml | 8 +-
.../ignite/raft/client/message/ActionRequest.java | 31 +-
.../ignite/raft/client/message/ActionResponse.java | 21 +-
.../raft/client/message/AddLearnersRequest.java | 23 +-
.../raft/client/message/AddPeersRequest.java | 23 +-
.../raft/client/message/ChangePeersResponse.java | 23 +-
.../raft/client/message/GetLeaderRequest.java | 17 +-
.../raft/client/message/GetLeaderResponse.java | 17 +-
.../raft/client/message/GetPeersRequest.java | 23 +-
.../raft/client/message/GetPeersResponse.java | 23 +-
.../client/message/RaftClientMessageFactory.java | 93 ---
.../client/message/RaftClientMessageGroup.java | 96 +++
.../raft/client/message/RaftErrorResponse.java | 29 +-
.../raft/client/message/RemoveLearnersRequest.java | 23 +-
.../raft/client/message/RemovePeersRequest.java | 23 +-
.../raft/client/message/SnapshotRequest.java | 17 +-
.../client/message/TransferLeadershipRequest.java | 23 +-
.../client/message/impl/ActionRequestImpl.java | 78 ---
.../message/impl/AddLearnersRequestImpl.java | 68 --
.../message/impl/ChangePeersResponseImpl.java | 65 --
.../client/message/impl/GetLeaderRequestImpl.java | 48 --
.../client/message/impl/GetPeersRequestImpl.java | 63 --
.../client/message/impl/GetPeersResponseImpl.java | 64 --
.../message/impl/RaftClientMessageFactoryImpl.java | 109 ----
.../client/message/impl/RaftErrorResponseImpl.java | 79 ---
.../message/impl/RemoveLearnersRequestImpl.java | 66 --
.../message/impl/RemovePeersRequestImpl.java | 65 --
.../impl/TransferLeadershipRequestImpl.java | 66 --
.../client/service/impl/RaftGroupServiceImpl.java | 26 +-
.../raft/client/service/RaftGroupServiceTest.java | 5 +-
modules/raft/pom.xml | 6 +
.../raft/server/RaftCounterServerAbstractTest.java | 17 +-
.../java/org/apache/ignite/internal/raft/Loza.java | 7 +-
.../ignite/raft/server/impl/RaftServerImpl.java | 14 +-
.../runner/app/DynamicTableCreationTest.java | 30 +-
.../ignite/internal/runner/app/IgnitionTest.java | 28 +-
.../internal/runner/app/TableCreationTest.java | 25 +-
.../org/apache/ignite/app/IgniteCliRunner.java | 134 ++++
.../apache/ignite/internal/app/IgnitionImpl.java | 24 +-
modules/table/pom.xml | 8 +-
.../ignite/distributed/ITDistributedTableTest.java | 17 +-
.../internal/table/distributed/TableManager.java | 2 +-
.../ignite/internal/table/TableManagerTest.java | 3 +-
.../apache/ignite/internal/vault/VaultManager.java | 34 +
parent/pom.xml | 167 ++++-
pom.xml | 1 +
293 files changed, 24879 insertions(+), 4387 deletions(-)