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/11/15 09:26:52 UTC
[ignite-3] branch ignite-15212 updated (0796182 -> 2a43d41)
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 0796182 Styles
add 977f637 IGNITE-15371 Set GoogleStyle as default in IDEA (#429)
add d1ffceb Fix IDEA codestyle settings (#428)
add d0de3a4 IGNITE-15876 Fix the code style javadocs issues for the modules / Part 1 (#430)
add d71b5e2 IGNITE-15776 Fix code style issue for sql components (#427)
add 392717b IGNITE-15581 Added proper handling of errors in user's state machines. Fixes #418
add 9905bfe IGNITE-15874 Add idea/intellij-java-google-style.xml import instruction to idea into DEVNOTES. Fixes #432
add e3c2d46 IGNITE-15881 Use direct properties in the TableManager. Fixes #431
add 4272626 IGNITE-15877 Fix the code style javadocs issues for the modules (step #2). Fixes #438
add 9fad62c IGNITE-15883 VariableDeclarationUsageDistance rule is removed from checkstyle rules. Fixes #437
add af9d4d0 IGNITE-15875 Enabled javadoc checking for Google code style, got rid of SummaryJavadoc, MissingJavadocMethod and MissingJavadocType (#440)
add 8789a58 IGNITE-15892 Fixed the default charset that is used by calcite engine. Fixes #436
add 6ee89ad IGNITE-15234 Implement ByteBuf-based message packer and unpacker (#434)
add ba18299 IGNITE-15783 Mapper API and initial implementation. (#424)
add af06c65 IGNITE-14484 Implement RecordView API. (#435)
add bb7e13c IGNITE-15900 Disable javadoc style checks for test methods. (#442)
add d3149c5 IGNITE-15060 IGNITE-15060 Added support of node working directory to CLI. #210
add 319fe9e Merge branch 'main' into ignite-15212
add 5987ac9 Minors.
add 2a43d41 Refactoring.
No new revisions were added by this update.
Summary of changes:
.idea/codeStyles/codeStyleConfig.xml | 5 +
DEVNOTES.md | 7 +
check-rules/checkstyle-rules.xml | 39 +-
.../ignite/example/rebalance/RebalanceExample.java | 6 +
.../ignite/example/sql/jdbc/SqlJdbcExample.java | 6 +
.../ignite/example/table/KeyValueViewExample.java | 6 +
.../ignite/example/table/RecordViewExample.java | 6 +
.../ignite/example/sql/jdbc/SqlExamplesTest.java | 12 +-
.../ignite/example/table/TableExamplesTest.java | 12 +-
idea/intellij-java-google-style.xml | 5 +-
.../affinity/RendezvousAffinityFunction.java | 12 +-
.../internal/affinity/AffinityServiceTest.java | 6 -
.../src/main/java/org/apache/ignite/Ignite.java | 2 +-
.../network/InboundConfigurationSchema.java | 2 +-
.../network/OutboundConfigurationSchema.java | 2 +-
.../query/sql/async/AsyncMultiResultSet.java | 50 --
.../query/sql/reactive/ReactiveMultiResultSet.java | 27 -
.../ignite/{query => }/sql/ColumnMetadata.java | 8 +-
.../apache/ignite/{query => }/sql/IgniteSql.java | 2 +-
.../ignite/{query => }/sql/MultiResultSet.java | 2 +-
.../apache/ignite/{query => }/sql/ResultSet.java | 8 +-
.../ignite/{query => }/sql/ResultSetMetadata.java | 12 +-
.../org/apache/ignite/{query => }/sql/Session.java | 27 +-
.../ignite/{query => }/sql/SqlException.java | 2 +-
.../org/apache/ignite/{query => }/sql/SqlRow.java | 2 +-
.../apache/ignite/{query => }/sql/Statement.java | 24 +-
.../{query => }/sql/async/AsyncResultSet.java | 8 +-
.../ignite/{query => }/sql/async/AsyncSession.java | 18 +-
.../sql/reactive/ReactiveResultSet.java | 6 +-
.../{query => }/sql/reactive/ReactiveSession.java | 18 +-
.../apache/ignite/table/IgniteTableStatistics.java | 9 +-
.../java/org/apache/ignite/table/KeyValueView.java | 3 +-
.../java/org/apache/ignite/table/RecordView.java | 1 +
.../main/java/org/apache/ignite/table/Table.java | 6 +-
.../ignite/table/mapper/DefaultColumnMapper.java} | 42 +-
.../apache/ignite/table/mapper/IdentityMapper.java | 63 ++
.../org/apache/ignite/table/mapper/Mapper.java | 82 +-
.../apache/ignite/table/mapper/MapperBuilder.java | 129 +++
.../org/apache/ignite/table/mapper/Mappers.java | 94 ---
.../org/apache/ignite/tx/IgniteTransactions.java | 1 +
.../java/org/apache/ignite/tx/Transaction.java | 17 +
.../query/calcite/ResultFieldMetadata.java | 21 +-
.../query/calcite/ResultSetMetadata.java | 2 +-
.../processors/query/calcite/SqlCursor.java | 4 +-
.../query/calcite/SqlQueryProcessor.java | 77 +-
.../processors/query/calcite/SqlQueryType.java | 2 +
.../internal/processors/query/calcite/Stubs.java | 5 +-
.../query/calcite/exec/AbstractIndexScan.java | 22 +-
.../query/calcite/exec/ArrayRowHandler.java | 6 -
.../calcite/exec/ClosableIteratorsHolder.java | 54 +-
.../query/calcite/exec/ExchangeService.java | 9 +-
.../query/calcite/exec/ExchangeServiceImpl.java | 29 +-
.../calcite/exec/ExecutionCancelledException.java | 3 +-
.../query/calcite/exec/ExecutionContext.java | 64 +-
.../query/calcite/exec/ExecutionService.java | 3 +-
.../query/calcite/exec/ExecutionServiceImpl.java | 519 +++++-------
.../query/calcite/exec/LogicalRelImplementor.java | 29 +-
.../query/calcite/exec/MailboxRegistry.java | 3 +-
.../query/calcite/exec/MailboxRegistryImpl.java | 41 +-
.../query/calcite/exec/PlannerHelper.java | 17 +-
.../query/calcite/exec/QueryTaskExecutor.java | 3 +-
.../query/calcite/exec/QueryTaskExecutorImpl.java | 23 +-
.../processors/query/calcite/exec/RowHandler.java | 34 +-
.../query/calcite/exec/RuntimeHashIndex.java | 24 +-
.../query/calcite/exec/RuntimeTreeIndex.java | 26 +-
.../query/calcite/exec/TableFunctionScan.java | 12 +-
.../query/calcite/exec/exp/ConverterUtils.java | 65 +-
.../query/calcite/exec/exp/ExpressionFactory.java | 3 -
.../calcite/exec/exp/ExpressionFactoryImpl.java | 123 +--
.../calcite/exec/exp/IgniteBuiltInMethod.java | 12 -
.../query/calcite/exec/exp/IgniteSqlFunctions.java | 15 +-
.../exec/exp/ReflectiveCallNotNullImplementor.java | 6 -
.../query/calcite/exec/exp/RexImpTable.java | 294 +------
.../query/calcite/exec/exp/RexToLixTranslator.java | 167 ++--
.../processors/query/calcite/exec/exp/Scalar.java | 6 +-
.../query/calcite/exec/exp/agg/Accumulator.java | 17 +-
.../calcite/exec/exp/agg/AccumulatorWrapper.java | 15 +-
.../query/calcite/exec/exp/agg/Accumulators.java | 273 +------
.../calcite/exec/exp/agg/AccumulatorsFactory.java | 93 +--
.../query/calcite/exec/exp/agg/AggregateType.java | 3 +-
.../query/calcite/exec/exp/agg/GroupKey.java | 39 +-
.../query/calcite/exec/rel/AbstractNode.java | 62 +-
.../query/calcite/exec/rel/AbstractSetOpNode.java | 84 +-
.../exec/rel/CorrelatedNestedLoopJoinNode.java | 99 +--
.../query/calcite/exec/rel/FilterNode.java | 28 +-
.../query/calcite/exec/rel/HashAggregateNode.java | 77 +-
.../processors/query/calcite/exec/rel/Inbox.java | 148 +---
.../query/calcite/exec/rel/IndexSpoolNode.java | 29 +-
.../query/calcite/exec/rel/IntersectNode.java | 9 -
.../processors/query/calcite/exec/rel/Mailbox.java | 9 +-
.../query/calcite/exec/rel/MergeJoinNode.java | 152 +---
.../query/calcite/exec/rel/MinusNode.java | 9 -
.../query/calcite/exec/rel/ModifyNode.java | 56 +-
.../query/calcite/exec/rel/NestedLoopJoinNode.java | 161 +---
.../processors/query/calcite/exec/rel/Node.java | 2 +
.../processors/query/calcite/exec/rel/Outbox.java | 75 +-
.../query/calcite/exec/rel/ProjectNode.java | 10 +-
.../query/calcite/exec/rel/RootNode.java | 45 +-
.../query/calcite/exec/rel/ScanNode.java | 19 +-
.../query/calcite/exec/rel/SingleNode.java | 8 +-
.../query/calcite/exec/rel/SortAggregateNode.java | 78 +-
.../query/calcite/exec/rel/SortNode.java | 9 +-
.../query/calcite/exec/rel/TableScanNode.java | 41 +-
.../query/calcite/exec/rel/TableSpoolNode.java | 15 +-
.../query/calcite/exec/rel/UnionAllNode.java | 16 +-
.../query/calcite/externalize/RelInputEx.java | 6 +-
.../query/calcite/externalize/RelJson.java | 177 +----
.../query/calcite/externalize/RelJsonReader.java | 57 +-
.../query/calcite/externalize/RelJsonWriter.java | 36 +-
.../query/calcite/message/ErrorMessage.java | 9 +-
.../message/ExecutionContextAwareMessage.java | 4 +-
.../query/calcite/message/InboxCloseMessage.java | 9 +-
.../query/calcite/message/MessageListener.java | 5 +-
.../query/calcite/message/MessageService.java | 3 +-
.../query/calcite/message/MessageServiceImpl.java | 24 +-
.../query/calcite/message/OutboxCloseMessage.java | 9 +-
.../message/QueryBatchAcknowledgeMessage.java | 7 +-
.../query/calcite/message/QueryBatchMessage.java | 11 +-
.../query/calcite/message/QueryStartRequest.java | 12 +-
.../query/calcite/message/QueryStartResponse.java | 9 +-
.../query/calcite/metadata/AffinityService.java | 3 +-
.../query/calcite/metadata/ColocationGroup.java | 55 +-
.../metadata/ColocationMappingException.java | 5 +-
.../calcite/metadata/FragmentDescription.java | 31 +-
.../query/calcite/metadata/FragmentMapping.java | 48 +-
.../calcite/metadata/FragmentMappingException.java | 15 +-
.../query/calcite/metadata/IgniteMdCollation.java | 153 ++--
.../calcite/metadata/IgniteMdCumulativeCost.java | 18 +-
.../calcite/metadata/IgniteMdDistinctRowCount.java | 3 +-
.../calcite/metadata/IgniteMdDistribution.java | 10 +-
.../calcite/metadata/IgniteMdFragmentMapping.java | 29 +-
.../metadata/IgniteMdNonCumulativeCost.java | 12 +-
.../metadata/IgniteMdPercentageOriginalRows.java | 20 +-
.../query/calcite/metadata/IgniteMdPredicates.java | 9 +-
.../query/calcite/metadata/IgniteMdRowCount.java | 10 +-
.../calcite/metadata/IgniteMdSelectivity.java | 18 +-
.../query/calcite/metadata/IgniteMetadata.java | 6 +-
.../query/calcite/metadata/MappingServiceImpl.java | 6 +-
.../calcite/metadata/NodeMappingException.java | 10 +-
.../query/calcite/metadata/RelMetadataQueryEx.java | 11 +-
.../query/calcite/metadata/RemoteException.java | 20 +-
.../query/calcite/metadata/cost/IgniteCost.java | 22 +-
.../calcite/prepare/AbstractMultiStepPlan.java | 48 +-
.../processors/query/calcite/prepare/CacheKey.java | 16 +-
.../processors/query/calcite/prepare/Cloner.java | 18 +-
.../processors/query/calcite/prepare/DdlPlan.java | 12 +-
.../query/calcite/prepare/ExecutionPlan.java | 8 +-
.../query/calcite/prepare/ExplainPlan.java | 9 +-
.../query/calcite/prepare/FieldsMetadata.java | 7 +-
.../query/calcite/prepare/FieldsMetadataImpl.java | 12 +-
.../processors/query/calcite/prepare/Fragment.java | 56 +-
.../query/calcite/prepare/FragmentPlan.java | 12 +-
.../query/calcite/prepare/FragmentSplitter.java | 39 +-
.../query/calcite/prepare/IdGenerator.java | 12 +-
.../query/calcite/prepare/IgnitePlanner.java | 85 +-
.../query/calcite/prepare/IgnitePrograms.java | 3 +-
.../query/calcite/prepare/IgniteRelShuttle.java | 3 +-
.../query/calcite/prepare/IgniteSqlValidator.java | 30 +-
.../query/calcite/prepare/MultiStepDmlPlan.java | 3 +-
.../query/calcite/prepare/MultiStepPlan.java | 15 +-
.../query/calcite/prepare/MultiStepQueryPlan.java | 3 +
.../query/calcite/prepare/PlannerHelper.java | 12 +-
.../query/calcite/prepare/PlannerPhase.java | 11 +-
.../query/calcite/prepare/PlanningContext.java | 116 +--
.../query/calcite/prepare/QueryPlan.java | 7 +-
.../query/calcite/prepare/QueryPlanCache.java | 6 +-
.../query/calcite/prepare/QueryPlanFactory.java | 5 +-
.../query/calcite/prepare/QueryTemplate.java | 24 +-
.../calcite/prepare/ResultFieldMetadataImpl.java | 24 +-
.../calcite/prepare/ResultSetMetadataInternal.java | 3 +-
.../processors/query/calcite/prepare/Splitter.java | 27 +-
.../query/calcite/prepare/ValidationResult.java | 20 +-
.../calcite/prepare/ddl/ColumnDefinition.java | 21 +-
.../calcite/prepare/ddl/CreateTableCommand.java | 56 +-
.../prepare/ddl/DdlSqlToCommandConverter.java | 33 +-
.../calcite/prepare/ddl/DropTableCommand.java | 12 +-
.../query/calcite/rel/AbstractIgniteJoin.java | 9 +-
.../query/calcite/rel/AbstractIgniteSpool.java | 3 +-
.../query/calcite/rel/AbstractIndexScan.java | 25 +-
.../query/calcite/rel/IgniteAggregate.java | 12 +-
.../query/calcite/rel/IgniteConvention.java | 6 -
.../rel/IgniteCorrelatedNestedLoopJoin.java | 6 +-
.../query/calcite/rel/IgniteExchange.java | 11 +-
.../processors/query/calcite/rel/IgniteFilter.java | 43 +-
.../query/calcite/rel/IgniteHashIndexSpool.java | 18 +-
.../query/calcite/rel/IgniteIndexScan.java | 25 +-
.../processors/query/calcite/rel/IgniteLimit.java | 67 +-
.../query/calcite/rel/IgniteMergeJoin.java | 100 +--
.../query/calcite/rel/IgniteNestedLoopJoin.java | 34 +-
.../query/calcite/rel/IgniteProject.java | 87 +-
.../query/calcite/rel/IgniteReceiver.java | 29 +-
.../processors/query/calcite/rel/IgniteRel.java | 8 +-
.../query/calcite/rel/IgniteRelVisitor.java | 54 +-
.../processors/query/calcite/rel/IgniteSender.java | 22 +-
.../processors/query/calcite/rel/IgniteSort.java | 35 +-
.../query/calcite/rel/IgniteSortedIndexSpool.java | 18 +-
.../query/calcite/rel/IgniteTableModify.java | 3 +-
.../query/calcite/rel/IgniteTableScan.java | 41 +-
.../query/calcite/rel/IgniteTableSpool.java | 6 +-
.../query/calcite/rel/IgniteTrimExchange.java | 15 +-
.../query/calcite/rel/IgniteUnionAll.java | 55 +-
.../processors/query/calcite/rel/IgniteValues.java | 17 +-
.../rel/ProjectableFilterableTableScan.java | 21 +-
.../query/calcite/rel/SourceAwareIgniteRel.java | 8 +-
.../calcite/rel/agg/IgniteHashAggregateBase.java | 3 +-
.../calcite/rel/agg/IgniteMapAggregateBase.java | 3 +-
.../calcite/rel/agg/IgniteMapHashAggregate.java | 12 +-
.../calcite/rel/agg/IgniteMapSortAggregate.java | 9 +-
.../calcite/rel/agg/IgniteReduceAggregateBase.java | 27 +-
.../calcite/rel/agg/IgniteReduceHashAggregate.java | 9 +-
.../calcite/rel/agg/IgniteReduceSortAggregate.java | 9 +-
.../calcite/rel/agg/IgniteSingleAggregateBase.java | 3 +-
.../calcite/rel/agg/IgniteSingleHashAggregate.java | 3 +-
.../calcite/rel/agg/IgniteSingleSortAggregate.java | 11 +-
.../calcite/rel/agg/IgniteSortAggregateBase.java | 3 +-
.../rel/logical/IgniteLogicalIndexScan.java | 13 +-
.../rel/logical/IgniteLogicalTableScan.java | 5 +-
.../query/calcite/rel/set/IgniteIntersect.java | 3 -
.../query/calcite/rel/set/IgniteMapIntersect.java | 6 +-
.../query/calcite/rel/set/IgniteMapMinus.java | 6 +-
.../query/calcite/rel/set/IgniteMinus.java | 3 +-
.../query/calcite/rel/set/IgniteMinusBase.java | 33 +-
.../calcite/rel/set/IgniteReduceIntersect.java | 22 +-
.../query/calcite/rel/set/IgniteReduceMinus.java | 22 +-
.../calcite/rel/set/IgniteSingleIntersect.java | 3 +-
.../query/calcite/rel/set/IgniteSingleMinus.java | 3 +-
.../calcite/rule/AbstractIgniteConverterRule.java | 9 +-
.../calcite/rule/CorrelateToNestedLoopRule.java | 18 +-
.../calcite/rule/CorrelatedNestedLoopJoinRule.java | 27 +-
.../query/calcite/rule/FilterConverterRule.java | 9 +-
.../rule/FilterSpoolMergeToHashIndexSpoolRule.java | 9 +-
.../FilterSpoolMergeToSortedIndexSpoolRule.java | 38 +-
.../calcite/rule/HashAggregateConverterRule.java | 24 +-
.../calcite/rule/LogicalScanConverterRule.java | 6 +-
.../query/calcite/rule/MergeJoinConverterRule.java | 3 -
.../query/calcite/rule/MinusConverterRule.java | 21 -
.../calcite/rule/NestedLoopJoinConverterRule.java | 3 -
.../query/calcite/rule/ProjectConverterRule.java | 9 +-
.../query/calcite/rule/SetOpConverterRule.java | 51 --
.../calcite/rule/SortAggregateConverterRule.java | 24 +-
.../query/calcite/rule/SortConverterRule.java | 8 +-
.../rule/TableFunctionScanConverterRule.java | 3 -
.../calcite/rule/TableModifyConverterRule.java | 6 +-
.../query/calcite/rule/UnionConverterRule.java | 12 +-
.../query/calcite/rule/ValuesConverterRule.java | 6 +-
.../calcite/rule/logical/ExposeIndexRule.java | 12 +-
.../calcite/rule/logical/FilterScanMergeRule.java | 3 -
.../calcite/rule/logical/LogicalOrToUnionRule.java | 34 +-
.../calcite/rule/logical/ProjectScanMergeRule.java | 6 +-
.../query/calcite/schema/ColumnDescriptor.java | 24 +-
.../query/calcite/schema/ColumnDescriptorImpl.java | 16 +-
.../query/calcite/schema/IgniteIndex.java | 22 +-
.../query/calcite/schema/IgniteSchema.java | 13 +-
.../query/calcite/schema/IgniteTable.java | 6 +-
.../query/calcite/schema/IgniteTableImpl.java | 64 +-
.../query/calcite/schema/SchemaHolder.java | 5 +-
.../query/calcite/schema/SchemaHolderImpl.java | 63 +-
.../query/calcite/schema/TableDescriptor.java | 5 +-
.../query/calcite/schema/TableDescriptorImpl.java | 33 +-
.../query/calcite/sql/IgniteSqlCreateTable.java | 23 +-
.../calcite/sql/IgniteSqlCreateTableOption.java | 37 +-
.../calcite/sql/fun/IgniteSqlOperatorTable.java | 6 -
.../query/calcite/trait/AffinityAdapter.java | 15 +-
.../processors/query/calcite/trait/AllNodes.java | 9 +-
.../query/calcite/trait/CorrelationTrait.java | 69 +-
.../query/calcite/trait/CorrelationTraitDef.java | 6 +-
.../query/calcite/trait/Destination.java | 4 +-
.../query/calcite/trait/DistributionFunction.java | 80 +-
.../query/calcite/trait/DistributionTrait.java | 93 ++-
.../query/calcite/trait/DistributionTraitDef.java | 9 +-
.../query/calcite/trait/IgniteDistribution.java | 2 +-
.../query/calcite/trait/IgniteDistributions.java | 38 +-
.../query/calcite/trait/Partitioned.java | 12 +-
.../processors/query/calcite/trait/RandomNode.java | 12 +-
.../processors/query/calcite/trait/RelFactory.java | 3 +-
.../query/calcite/trait/RewindabilityTrait.java | 21 +-
.../query/calcite/trait/RewindabilityTraitDef.java | 6 +-
.../processors/query/calcite/trait/TraitUtils.java | 284 ++++---
.../query/calcite/trait/TraitsAwareIgniteRel.java | 3 +-
.../query/calcite/type/IgniteTypeFactory.java | 23 +-
.../query/calcite/type/IgniteTypeSystem.java | 3 -
.../processors/query/calcite/util/Commons.java | 281 ++++---
.../query/calcite/util/FilteringIterator.java | 11 +-
.../processors/query/calcite/util/HintUtils.java | 23 +-
.../query/calcite/util/IgniteMethod.java | 25 +-
.../query/calcite/util/IgniteResource.java | 17 +-
.../query/calcite/util/IndexConditions.java | 36 +-
.../query/calcite/util/NodeLeaveHandler.java | 8 +
.../processors/query/calcite/util/Primitives.java | 34 +-
.../processors/query/calcite/util/RexUtils.java | 334 ++++----
.../query/calcite/util/TransformingIterator.java | 8 +
.../processors/query/calcite/util/TypeUtils.java | 143 ++--
.../query/calcite/StopCalciteModuleTest.java | 83 +-
.../query/calcite/exec/RuntimeTreeIndexTest.java | 27 +-
.../calcite/exec/rel/AbstractExecutionTest.java | 129 +--
.../exec/rel/AbstractSetOpExecutionTest.java | 24 +-
.../query/calcite/exec/rel/BaseAggregateTest.java | 221 +++---
.../query/calcite/exec/rel/ExecutionTest.java | 305 ++++----
.../exec/rel/HashAggregateExecutionTest.java | 37 +-
.../rel/HashAggregateSingleGroupExecutionTest.java | 173 ++--
.../exec/rel/HashIndexSpoolExecutionTest.java | 27 +-
.../calcite/exec/rel/MergeJoinExecutionTest.java | 24 +-
.../exec/rel/NestedLoopJoinExecutionTest.java | 24 +-
.../exec/rel/SortAggregateExecutionTest.java | 51 +-
.../calcite/exec/rel/TableSpoolExecutionTest.java | 12 +-
.../exec/rel/TreeIndexSpoolExecutionTest.java | 30 +-
.../planner/AbstractAggregatePlannerTest.java | 8 +-
.../query/calcite/planner/AbstractPlannerTest.java | 421 +++++-----
.../planner/AggregateDistinctPlannerTest.java | 30 +-
.../calcite/planner/AggregatePlannerTest.java | 39 +-
.../CorrelatedNestedLoopJoinPlannerTest.java | 6 +-
.../calcite/planner/HashAggregatePlannerTest.java | 9 +-
.../calcite/planner/HashIndexSpoolPlannerTest.java | 9 +-
.../query/calcite/planner/PlannerTest.java | 871 +++++++++++----------
.../query/calcite/planner/SetOpPlannerTest.java | 72 +-
.../calcite/planner/SortAggregatePlannerTest.java | 12 +-
.../planner/SortedIndexSpoolPlannerTest.java | 9 +-
.../query/calcite/planner/TableDmlPlannerTest.java | 15 +
.../calcite/planner/TableFunctionPlannerTest.java | 16 +-
.../calcite/planner/TableSpoolPlannerTest.java | 6 +
.../org/apache/ignite/cli/ItConfigCommandTest.java | 14 +-
.../apache/ignite/cli/CliPathsConfigLoader.java | 4 +-
.../java/org/apache/ignite/cli/IgniteCliApp.java | 5 +
.../org/apache/ignite/cli/IgniteCliException.java | 8 +-
.../java/org/apache/ignite/cli/IgnitePaths.java | 32 +-
.../org/apache/ignite/cli/InteractiveWrapper.java | 7 +-
.../src/main/java/org/apache/ignite/cli/Table.java | 20 +-
.../ignite/cli/builtins/SystemPathResolver.java | 6 +-
.../cli/builtins/config/ConfigurationClient.java | 2 +-
.../cli/builtins/module/MavenArtifactResolver.java | 6 +-
.../cli/builtins/module/MavenCoordinates.java | 6 +-
.../ignite/cli/builtins/module/ModuleRegistry.java | 10 +-
.../ignite/cli/builtins/module/ResolveResult.java | 2 +
.../ignite/cli/builtins/node/NodeManager.java | 58 +-
.../org/apache/ignite/cli/spec/CommandSpec.java | 2 +-
.../apache/ignite/cli/spec/ConfigCommandSpec.java | 4 +
.../apache/ignite/cli/spec/NodeCommandSpec.java | 5 +-
.../org/apache/ignite/cli/spec/SpecAdapter.java | 7 +-
.../java/org/apache/ignite/cli/ui/Spinner.java | 8 +-
.../org/apache/ignite/cli/ui/TerminalFactory.java | 2 +-
.../org/apache/ignite/cli/AbstractCliTest.java | 2 +-
.../apache/ignite/cli/IgniteCliInterfaceTest.java | 123 +--
.../cli/builtins/init/InitIgniteCommandTest.java | 29 +-
.../cli/builtins/module/ModuleMangerTest.java | 32 +-
.../org/apache/ignite/cli/ui/ProgressBarTest.java | 22 +-
.../java/org/apache/ignite/cli/ui/SpinnerTest.java | 22 +-
modules/client-common/pom.xml | 19 +
.../internal/client/proto/ClientMessagePacker.java | 773 ++++++++++--------
.../client/proto/ClientMessageUnpacker.java | 792 ++++++++++++++-----
.../internal/client/proto/ProtocolVersion.java | 11 +-
.../client/proto/ClientMessagePackerBenchmark.java | 95 +++
.../client/proto/ClientMessagePackerTest.java | 185 +++++
.../proto/ClientMessagePackerUnpackerTest.java | 6 +-
.../client/proto/ClientMessageUnpackerTest.java | 194 +++++
.../ignite/client/handler/ItClientHandlerTest.java | 2 +-
.../handler/ClientInboundMessageHandler.java | 23 +-
.../requests/table/ClientSchemasGetRequest.java | 3 +-
.../handler/requests/table/ClientTableCommon.java | 6 +-
.../ignite/internal/client/ClientChannel.java | 2 +
.../client/ClientChannelConfiguration.java | 4 +
.../ignite/internal/client/HostAndPortRange.java | 6 +
.../internal/client/ProtocolBitmaskFeature.java | 15 +-
.../ignite/internal/client/ProtocolContext.java | 6 +
.../ignite/internal/client/ReliableChannel.java | 14 +-
.../ignite/internal/client/TcpClientChannel.java | 10 +-
.../ignite/internal/client/TcpIgniteClient.java | 2 +-
.../client/io/netty/NettyClientConnection.java | 2 +-
.../io/netty/NettyClientConnectionMultiplexer.java | 8 +-
.../client/query/JdbcClientQueryEventHandler.java | 2 +
.../ignite/internal/client/table/ClientSchema.java | 6 +
.../ignite/internal/client/table/ClientTable.java | 80 +-
.../ignite/internal/client/table/ClientTables.java | 3 -
.../apache/ignite/client/AbstractClientTest.java | 29 +
.../java/org/apache/ignite/client/CustomTuple.java | 125 +--
.../org/apache/ignite/client/fakes/FakeCursor.java | 4 +-
.../org/apache/ignite/client/fakes/FakeIgnite.java | 5 +-
.../client/fakes/FakeIgniteQueryProcessor.java | 3 +
.../ignite/client/fakes/FakeIgniteTables.java | 9 -
.../ignite/client/fakes/FakeSchemaRegistry.java | 2 +-
.../configuration/tree/TraversableTreeNode.java | 8 +-
.../util/ConfigurationNotificationsUtil.java | 2 +-
.../configuration/util/ConfigurationUtil.java | 8 +-
.../configuration/util/KeyNotFoundException.java | 4 +-
.../util/KeysTrackingConfigurationVisitor.java | 4 +
.../validation/ImmutableValidator.java | 3 +
.../validation/ValidationContextImpl.java | 12 +-
.../configuration/validation/ValidationUtil.java | 7 +-
.../configuration/ConfigurationChangerTest.java | 53 +-
.../configuration/ConfigurationRegistryTest.java | 12 +-
.../configuration/DirectPropertiesTest.java | 49 +-
.../asm/ConfigurationAsmGeneratorTest.java | 39 -
.../configuration/hocon/HoconConverterTest.java | 86 +-
.../ConfigurationAnyListenerTest.java | 40 +-
.../notifications/ConfigurationListenerTest.java | 47 +-
.../ConfigurationListenerTestUtils.java | 12 +
.../sample/BaselineConfigurationSchema.java | 2 +-
.../internal/configuration/sample/UsageTest.java | 6 -
.../testframework/BasicConfigurationSchema.java | 3 -
.../testframework/ExtendedConfigurationSchema.java | 3 -
.../configuration/tree/ConfigurationArrayTest.java | 60 +-
.../tree/ConstructableTreeNodeTest.java | 43 +-
.../configuration/tree/NamedListNodeTest.java | 10 +-
.../tree/TraversableTreeNodeTest.java | 39 +-
.../configuration/util/ConfigurationUtilTest.java | 76 +-
.../validation/OneOfValidatorTest.java | 4 +-
.../validation/ValidationUtilTest.java | 68 +-
.../ItMetaStorageServicePersistenceTest.java | 20 +-
.../client/ItMetaStorageServiceTest.java | 30 +-
.../internal/metastorage/client/CursorImpl.java | 28 +-
.../ignite/internal/metastorage/client/Entry.java | 4 +-
.../metastorage/client/MetaStorageServiceImpl.java | 24 +-
.../internal/metastorage/client/Operation.java | 4 +-
.../metastorage/common/command/GetAllCommand.java | 8 +-
.../common/command/GetAndPutAllCommand.java | 6 +-
.../common/command/GetAndPutCommand.java | 6 +-
.../common/command/GetAndRemoveAllCommand.java | 4 +-
.../common/command/GetAndRemoveCommand.java | 4 +-
.../metastorage/common/command/GetCommand.java | 8 +-
.../metastorage/common/command/PutAllCommand.java | 6 +-
.../metastorage/common/command/PutCommand.java | 6 +-
.../metastorage/common/command/RangeCommand.java | 14 +-
.../common/command/RemoveAllCommand.java | 4 +-
.../metastorage/common/command/RemoveCommand.java | 4 +-
.../common/command/SingleEntryResponse.java | 2 +-
.../common/command/WatchExactKeysCommand.java | 10 +-
.../common/command/WatchRangeKeysCommand.java | 14 +-
.../common/command/cursor/CursorCloseCommand.java | 4 +-
.../command/cursor/CursorHasNextCommand.java | 4 +-
.../common/command/cursor/CursorNextCommand.java | 4 +-
.../common/command/cursor/CursorsCloseCommand.java | 4 +-
.../ignite/internal/metastorage/server/Entry.java | 4 +-
.../server/persistence/RocksDbKeyValueStorage.java | 11 +-
.../server/raft/MetaStorageListener.java | 48 +-
.../server/AbstractKeyValueStorageTest.java | 20 +-
.../server/RocksDbKeyValueStorageTest.java | 3 -
.../server/SimpleInMemoryKeyValueStorage.java | 70 +-
.../internal/metastorage/MetaStorageManager.java | 48 +-
.../metastorage/watch/AggregatedWatch.java | 6 +-
.../internal/metastorage/watch/KeyCriterion.java | 8 +-
.../metastorage/watch/WatchAggregator.java | 4 +-
.../internal/metastorage/WatchAggregatorTest.java | 44 +-
.../ItTransferableObjectProcessorTest.java | 5 +-
.../internal/network/processor/MessageClass.java | 47 +-
.../network/processor/MessageGroupWrapper.java | 24 +-
.../network/processor/ProcessingException.java | 14 +-
.../processor/TransferableObjectProcessor.java | 6 +-
.../internal/network/processor/TypeUtils.java | 12 +-
.../messages/MessageBuilderGenerator.java | 10 +-
.../messages/MessageFactoryGenerator.java | 10 +-
.../processor/messages/MessageImplGenerator.java | 10 +-
.../serialization/BaseMethodNameResolver.java | 8 +-
.../MessageCollectionItemTypeConverter.java | 8 +-
.../MessageDeserializerGenerator.java | 10 +-
.../serialization/MessageReaderMethodResolver.java | 12 +-
.../serialization/MessageSerializerGenerator.java | 10 +-
.../serialization/MessageWriterMethodResolver.java | 12 +-
.../RegistryInitializerGenerator.java | 10 +-
.../SerializationFactoryGenerator.java | 10 +-
.../apache/ignite/network/MessagingService.java | 4 +-
.../network/netty/ItConnectionManagerTest.java | 2 +-
.../network/recovery/ItRecoveryHandshakeTest.java | 6 +-
.../network/direct/DirectMessageReader.java | 6 +-
.../network/direct/DirectMessageWriter.java | 17 +-
.../network/direct/state/DirectMessageState.java | 4 +
.../direct/stream/DirectByteBufferStream.java | 220 ++++--
.../stream/DirectByteBufferStreamImplV1.java | 174 ++--
.../network/handshake/HandshakeManager.java | 2 +
.../internal/network/netty/ConnectionManager.java | 10 +
.../ignite/internal/network/netty/NettyClient.java | 6 +
.../ignite/internal/network/netty/NettySender.java | 8 +
.../ignite/internal/network/netty/NettyServer.java | 10 +-
.../recovery/RecoveryClientHandshakeManager.java | 8 +-
.../recovery/RecoveryServerHandshakeManager.java | 8 +-
.../recovery/message/HandshakeStartMessage.java | 8 +-
.../message/HandshakeStartResponseMessage.java | 16 +-
.../ignite/internal/network/AllTypesMessage.java | 3 +
.../internal/network/NestedMessageMessage.java | 3 +
.../netty/IoExceptionSuppressingHandlerTest.java | 8 +-
.../internal/network/netty/NettyClientTest.java | 15 +-
.../internal/network/netty/NettyServerTest.java | 6 +-
.../internal/network/processor/EmptyMessage.java | 2 +-
.../network/processor/EmptyMessageTest.java | 5 +-
.../network/processor/InheritedMessage.java | 6 +-
.../network/processor/InheritedMessageTest.java | 8 +-
.../network/processor/NetworkMessage1.java | 5 +-
.../network/processor/NetworkMessage2.java | 6 +-
.../processor/SerializationOrderMessage.java | 18 +-
.../network/processor/SerializationOrderTest.java | 8 +-
.../MessageSerializationRegistryImplTest.java | 16 +-
.../org/apache/ignite/network/TestMessage.java | 3 +
.../apache/ignite/network/TestMessageTypes.java | 24 +-
.../dotnet/Apache.Ignite.Tests/Table/TableTests.cs | 43 +-
modules/platforms/dotnet/DEVNOTES.md | 3 +-
.../java/org/apache/ignite/raft/client/Peer.java | 10 +-
.../ignite/raft/client/service/CommandClosure.java | 2 +-
.../raft/client/service/RaftGroupService.java | 10 +-
.../apache/ignite/internal/raft/ItLozaTest.java | 10 +-
.../service/ItAbstractListenerSnapshotTest.java | 20 +-
.../apache/ignite/raft/server/CounterListener.java | 2 +-
.../ignite/raft/server/CounterSnapshotFile.java | 7 +-
.../ignite/raft/server/IncrementAndGetCommand.java | 4 +-
.../raft/server/ItJraftCounterServerTest.java | 116 ++-
.../raft/server/ItSimpleCounterServerTest.java | 13 +-
.../ignite/raft/server/RaftServerAbstractTest.java | 11 +-
.../ignite/internal/raft/server/RaftServer.java | 2 +-
.../internal/raft/server/impl/JraftServerImpl.java | 12 +-
.../apache/ignite/raft/jraft/RaftMessageGroup.java | 81 +-
.../apache/ignite/raft/jraft/rpc/RpcRequests.java | 9 +
.../jraft/rpc/impl/ActionRequestProcessor.java | 53 +-
.../raft/jraft/rpc/impl/RaftGroupServiceImpl.java | 24 +
...aftException.java => SMCompactedThrowable.java} | 37 +-
.../raft/jraft/rpc/impl/SMFullThrowable.java} | 26 +-
.../rpc/impl/{FutureImpl.java => SMThrowable.java} | 9 +-
.../internal/raft/server/impl/RaftServerImpl.java | 125 ++-
.../raft/jraft/core/RaftGroupServiceTest.java | 1 +
.../ignite/rest/netty/RestApiHttpResponseTest.java | 3 -
.../ConfigurationPresentationTest.java | 36 +-
.../org/apache/ignite/rest/routes/RouteTest.java | 20 +-
.../ignite/internal/rocksdb/ColumnFamily.java | 4 +
modules/runner/pom.xml | 5 +
.../calcite/AbstractBasicIntegrationTest.java | 31 +-
.../ignite/internal/calcite/ItAggregatesTest.java | 19 +-
.../ignite/internal/calcite/ItDataTypesTest.java | 2 +-
.../ignite/internal/calcite/ItFunctionsTest.java | 28 +-
.../ignite/internal/calcite/ItIndexSpoolTest.java | 7 +-
.../ignite/internal/calcite/ItMetadataTest.java | 24 +-
.../internal/calcite/ItMixedQueriesTest.java | 54 +-
.../internal/calcite/ItOrToUnionRuleTest.java | 20 +-
.../calcite/ItProjectScanMergeRuleTest.java | 5 +-
.../internal/calcite/ItSecondaryIndexTest.java | 245 ++----
.../ignite/internal/calcite/ItSetOpTest.java | 41 +-
.../internal/calcite/ItSortAggregateTest.java | 8 +-
.../ignite/internal/calcite/util/Commons.java | 4 +
.../ignite/internal/calcite/util/QueryChecker.java | 92 +--
.../ItDistributedConfigurationPropertiesTest.java | 50 +-
.../ItDistributedConfigurationStorageTest.java | 33 +-
.../runner/app/AbstractSchemaChangeTest.java | 26 +-
.../internal/runner/app/IgniteCliRunnerTest.java} | 37 +-
.../internal/runner/app/ItBaselineChangesTest.java | 18 +-
.../runner/app/ItDynamicTableCreationTest.java | 16 +-
.../ignite/internal/runner/app/ItIgnitionTest.java | 10 +-
.../runner/app/ItLiveSchemaChangeKvViewTest.java | 2 +-
.../runner/app/ItLiveSchemaChangeTableTest.java | 2 +-
.../internal/runner/app/ItTableCreationTest.java | 10 +-
.../internal/runner/app/ItTablesApiTest.java | 8 +-
.../runner/app/ItThinClientConnectionTest.java | 13 +-
.../runner/app/PlatformTestNodeRunner.java | 8 +-
.../runner/app/jdbc/AbstractJdbcSelfTest.java | 3 +
.../app/jdbc/ItJdbcConnectionPropertiesTest.java | 2 +-
.../runner/app/jdbc/ItJdbcConnectionSelfTest.java | 101 +--
.../runner/app/jdbc/ItJdbcMetadataSelfTest.java | 36 -
.../runner/app/jdbc/ItJdbcResultSetSelfTest.java | 59 +-
.../runner/app/jdbc/ItJdbcStatementSelfTest.java | 87 --
.../org/apache/ignite/app/IgniteCliRunner.java | 157 ++--
.../org/apache/ignite/internal/app/IgniteImpl.java | 22 +-
.../apache/ignite/internal/app/IgnitionImpl.java | 12 -
.../org/apache/ignite/utils/IgniteProperties.java | 4 +-
.../storage/ConfigurationStorageTest.java | 5 +-
.../DistributedConfigurationStorageTest.java | 15 +-
.../storage/LocalConfigurationStorageTest.java | 7 +-
modules/schema/pom.xml | 18 +
.../ignite/internal/schema/AssemblyException.java | 4 +
.../apache/ignite/internal/schema/BinaryRow.java | 26 +-
.../ignite/internal/schema/BitmaskNativeType.java | 5 +-
.../ignite/internal/schema/ByteBufferRow.java | 2 +
.../org/apache/ignite/internal/schema/Column.java | 18 +-
.../org/apache/ignite/internal/schema/Columns.java | 44 +-
.../ignite/internal/schema/DecimalNativeType.java | 4 +-
.../internal/schema/InvalidTypeException.java | 2 +
.../apache/ignite/internal/schema/NativeType.java | 10 +-
.../ignite/internal/schema/NativeTypeSpec.java | 2 +-
.../apache/ignite/internal/schema/NativeTypes.java | 102 +--
.../ignite/internal/schema/NumberNativeType.java | 5 +-
.../ignite/internal/schema/SchemaDescriptor.java | 22 +
.../schema/SchemaModificationException.java | 2 +-
.../ignite/internal/schema/SchemaRegistry.java | 5 +-
.../ignite/internal/schema/VarlenNativeType.java | 4 +-
.../SchemaConfigurationConverter.java | 3 +
.../configuration/SchemaDescriptorConverter.java | 2 +
.../schema/definition/TableDefinitionImpl.java | 4 +
.../builder/PrimaryKeyDefinitionBuilderImpl.java | 2 +-
.../builder/SortedIndexDefinitionBuilderImpl.java | 5 +-
.../internal/schema/mapping/ColumnMapperImpl.java | 5 +
.../internal/schema/mapping/ColumnMapping.java | 6 +
.../internal/schema/marshaller/BinaryMode.java | 20 +-
.../internal/schema/marshaller/KvMarshaller.java | 27 +-
...tionException.java => MarshallerException.java} | 8 +-
.../schema/marshaller/MarshallerFactory.java | 72 ++
.../internal/schema/marshaller/MarshallerUtil.java | 36 +-
.../schema/marshaller/RecordMarshaller.java} | 40 +-
.../internal/schema/marshaller/Serializer.java | 30 +-
.../schema/marshaller/SerializerFactory.java | 10 +
.../marshaller/asm/AsmSerializerGenerator.java | 10 +-
.../marshaller/asm/ColumnAccessCodeGenerator.java | 51 +-
.../marshaller/asm/MarshallerCodeGenerator.java | 17 +-
.../marshaller/reflection/FieldAccessor.java | 426 ++++++----
.../marshaller/reflection/JavaSerializer.java | 12 +-
.../reflection/JavaSerializerFactory.java | 2 +
.../{JavaSerializer.java => KvMarshallerImpl.java} | 79 +-
.../schema/marshaller/reflection/Marshaller.java | 204 +++--
...vaSerializer.java => RecordMarshallerImpl.java} | 114 +--
...ctory.java => ReflectionMarshallerFactory.java} | 20 +-
.../schema/AbstractSchemaSerializer.java | 8 +-
.../schema/marshaller/schema/SchemaSerializer.java | 2 +
.../schema/registry/SchemaRegistryImpl.java | 3 +
.../schema/registry/UpgradingRowAdapter.java | 2 +
.../internal/schema/row/ExpandableByteBuf.java | 8 +-
.../org/apache/ignite/internal/schema/row/Row.java | 21 +-
.../ignite/internal/schema/row/RowAssembler.java | 421 +++++-----
.../internal/schema/row/TemporalTypesHelper.java | 3 +
.../ignite/internal/schema/row/VarTableFormat.java | 94 +--
.../java/org/apache/ignite/internal/util/Pair.java | 4 +-
.../benchmarks/SerializerBenchmarkTest.java | 61 +-
.../internal/schema/ColumnDefinitionTest.java | 6 +-
.../apache/ignite/internal/schema/ColumnsTest.java | 60 +-
.../internal/schema/ExpandableByteBufTest.java | 18 +-
.../ignite/internal/schema/NativeTypeTest.java | 68 +-
.../schema/RowAssemblerAdvancedSchemaTest.java | 2 +
.../schema/RowAssemblerSimpleSchemaTest.java | 2 +
.../org/apache/ignite/internal/schema/RowTest.java | 2 +-
.../internal/schema/SchemaConfigurationTest.java | 9 +-
.../internal/schema/SchemaDescriptorTest.java | 6 +-
.../{TestUtils.java => SchemaTestUtils.java} | 4 +-
.../ignite/internal/schema/TemporalTypesTest.java | 6 +
.../configuration/TableValidatorImplTest.java | 3 +-
.../schema/marshaller/JavaSerializerTest.java | 486 ++++--------
...vaSerializerTest.java => KvMarshallerTest.java} | 583 +++++++-------
.../internal/schema/marshaller/MapperTest.java | 75 ++
.../schema/marshaller/RecordMarshallerTest.java | 597 ++++++++++++++
.../marshaller/reflection/FieldAccessorTest.java | 335 +++-----
.../schema/registry/SchemaRegistryImplTest.java | 3 +
.../schema/registry/UpgradingRowAdapterTest.java | 4 +-
.../schema/testobjects/TestObjectWithAllTypes.java | 370 +++++++++
.../TestObjectWithNoDefaultConstructor.java} | 51 +-
.../TestObjectWithPrivateConstructor.java} | 55 +-
.../schema/testobjects/TestSimpleObject.java | 72 ++
modules/sql/src/test/java/IgniteSqlTest.java | 107 +--
modules/sql/src/test/java/TestRow.java | 4 +-
.../apache/ignite/internal/storage/DataRow.java | 4 +
.../ignite/internal/storage/InvokeClosure.java | 7 +
.../apache/ignite/internal/storage/SearchRow.java | 4 +
.../ignite/internal/storage/StorageException.java | 6 +
.../storage/basic/GetAndRemoveInvokeClosure.java | 2 +
.../storage/basic/GetAndReplaceInvokeClosure.java | 2 +
.../internal/storage/basic/SimpleDataRow.java | 2 +
.../storage/basic/SimpleWriteInvokeClosure.java | 2 +
.../storage/rocksdb/RocksDbDataRegion.java | 2 +
.../storage/rocksdb/RocksDbPartitionStorage.java | 4 +-
.../storage/rocksdb/RocksDbTableStorage.java | 5 +-
.../storage/rocksdb/RocksDbStorageTest.java | 12 +-
modules/table/pom.xml | 7 +
.../ignite/distributed/ItDistributedTableTest.java | 10 +-
.../distributed/ItInternalTableScanTest.java | 34 +-
.../ignite/distributed/ItTablePersistenceTest.java | 15 -
.../schema/marshaller/TupleMarshallerImpl.java | 9 +-
.../ignite/internal/table/AbstractTableView.java | 6 +-
.../internal/table/KeyValueBinaryViewImpl.java | 3 +-
.../ignite/internal/table/KeyValueViewImpl.java | 303 +++----
.../internal/table/RecordBinaryViewImpl.java | 6 +-
.../ignite/internal/table/RecordViewImpl.java | 240 ++++--
.../apache/ignite/internal/table/TableImpl.java | 2 +
.../internal/table/distributed/TableManager.java | 86 +-
.../command/response/MultiRowsResponse.java | 2 +-
.../command/response/SingleRowResponse.java | 2 +-
.../distributed/command/scan/ScanCloseCommand.java | 2 +-
.../distributed/command/scan/ScanInitCommand.java | 6 +-
.../command/scan/ScanRetrieveBatchCommand.java | 6 +-
.../table/distributed/raft/PartitionListener.java | 10 +-
.../distributed/storage/InternalTableImpl.java | 18 +-
.../internal/table/event/TableEventParameters.java | 6 +
.../TupleMarshallerFixlenOnlyBenchmark.java | 2 +-
.../TupleMarshallerVarlenOnlyBenchmark.java | 2 +-
.../org/apache/ignite/internal/table/Example.java | 20 +-
.../table/KeyValueBinaryViewOperationsTest.java | 40 +-
...=> KeyValueViewOperationsSimpleSchemaTest.java} | 137 ++--
.../internal/table/KeyValueViewOperationsTest.java | 416 ++++++++++
.../internal/table/MutableRowTupleAdapterTest.java | 3 +-
.../table/RecordBinaryViewOperationsTest.java | 45 +-
.../internal/table/RecordViewOperationsTest.java | 340 ++++++++
.../internal/table/StrictSchemaOperationsTest.java | 25 +-
.../ignite/internal/table/TableManagerTest.java | 115 +--
.../org/apache/ignite/internal/table/TxTest.java | 30 +-
.../raft/PartitionCommandListenerTest.java | 22 +
.../table/impl/DummyInternalTableImpl.java | 6 +-
.../table/type/NumericTypesSerializerTest.java | 48 +-
.../apache/ignite/internal/tx/LockException.java | 4 +
.../org/apache/ignite/internal/tx/LockManager.java | 16 +-
.../org/apache/ignite/internal/tx/Timestamp.java | 18 +-
.../java/org/apache/ignite/internal/tx/Waiter.java | 4 +-
.../ignite/internal/tx/impl/HeapLockManager.java | 35 +-
.../internal/tx/AbstractLockManagerTest.java | 2 +
.../ignite/internal/tx/HeapLockManagerTest.java | 2 +-
.../ItPersistencePropertiesVaultServiceTest.java | 6 -
.../persistence/ItPersistentVaultServiceTest.java | 3 -
.../apache/ignite/internal/vault/VaultEntry.java | 4 +-
.../apache/ignite/internal/vault/VaultManager.java | 12 +-
.../vault/persistence/PersistentVaultService.java | 15 -
.../vault/persistence/RocksIteratorAdapter.java | 10 +-
.../ignite/internal/vault/VaultManagerTest.java | 8 +-
.../ignite/internal/vault/VaultServiceTest.java | 7 +-
parent/pom.xml | 7 +
701 files changed, 12626 insertions(+), 13396 deletions(-)
create mode 100644 .idea/codeStyles/codeStyleConfig.xml
delete mode 100644 modules/api/src/main/java/org/apache/ignite/query/sql/async/AsyncMultiResultSet.java
delete mode 100644 modules/api/src/main/java/org/apache/ignite/query/sql/reactive/ReactiveMultiResultSet.java
rename modules/api/src/main/java/org/apache/ignite/{query => }/sql/ColumnMetadata.java (90%)
rename modules/api/src/main/java/org/apache/ignite/{query => }/sql/IgniteSql.java (97%)
rename modules/api/src/main/java/org/apache/ignite/{query => }/sql/MultiResultSet.java (96%)
rename modules/api/src/main/java/org/apache/ignite/{query => }/sql/ResultSet.java (87%)
rename modules/api/src/main/java/org/apache/ignite/{query => }/sql/ResultSetMetadata.java (84%)
rename modules/api/src/main/java/org/apache/ignite/{query => }/sql/Session.java (76%)
rename modules/api/src/main/java/org/apache/ignite/{query => }/sql/SqlException.java (98%)
rename modules/api/src/main/java/org/apache/ignite/{query => }/sql/SqlRow.java (97%)
rename modules/api/src/main/java/org/apache/ignite/{query => }/sql/Statement.java (76%)
rename modules/api/src/main/java/org/apache/ignite/{query => }/sql/async/AsyncResultSet.java (88%)
rename modules/api/src/main/java/org/apache/ignite/{query => }/sql/async/AsyncSession.java (73%)
rename modules/api/src/main/java/org/apache/ignite/{query => }/sql/reactive/ReactiveResultSet.java (92%)
rename modules/api/src/main/java/org/apache/ignite/{query => }/sql/reactive/ReactiveSession.java (72%)
copy modules/{metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/AbstractCondition.java => api/src/main/java/org/apache/ignite/table/mapper/DefaultColumnMapper.java} (51%)
create mode 100644 modules/api/src/main/java/org/apache/ignite/table/mapper/IdentityMapper.java
create mode 100644 modules/api/src/main/java/org/apache/ignite/table/mapper/MapperBuilder.java
delete mode 100644 modules/api/src/main/java/org/apache/ignite/table/mapper/Mappers.java
create mode 100644 modules/client-common/src/test/java/org/apache/ignite/internal/client/proto/ClientMessagePackerBenchmark.java
create mode 100644 modules/client-common/src/test/java/org/apache/ignite/internal/client/proto/ClientMessagePackerTest.java
create mode 100644 modules/client-common/src/test/java/org/apache/ignite/internal/client/proto/ClientMessageUnpackerTest.java
copy modules/raft/src/main/java/org/apache/ignite/raft/jraft/rpc/impl/{RaftException.java => SMCompactedThrowable.java} (54%)
copy modules/raft/src/{integrationTest/java/org/apache/ignite/raft/server/IncrementAndGetCommand.java => main/java/org/apache/ignite/raft/jraft/rpc/impl/SMFullThrowable.java} (65%)
copy modules/raft/src/main/java/org/apache/ignite/raft/jraft/rpc/impl/{FutureImpl.java => SMThrowable.java} (84%)
copy modules/{metastorage-server/src/test/java/org/apache/ignite/internal/metastorage/server/RocksDbKeyValueStorageTest.java => runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/IgniteCliRunnerTest.java} (52%)
rename modules/{table => schema}/src/main/java/org/apache/ignite/internal/schema/marshaller/KvMarshaller.java (68%)
rename modules/schema/src/main/java/org/apache/ignite/internal/schema/marshaller/{SerializationException.java => MarshallerException.java} (82%)
create mode 100644 modules/schema/src/main/java/org/apache/ignite/internal/schema/marshaller/MarshallerFactory.java
rename modules/{table/src/main/java/org/apache/ignite/internal/schema/marshaller/RecordSerializer.java => schema/src/main/java/org/apache/ignite/internal/schema/marshaller/RecordMarshaller.java} (51%)
copy modules/schema/src/main/java/org/apache/ignite/internal/schema/marshaller/reflection/{JavaSerializer.java => KvMarshallerImpl.java} (74%)
copy modules/schema/src/main/java/org/apache/ignite/internal/schema/marshaller/reflection/{JavaSerializer.java => RecordMarshallerImpl.java} (62%)
copy modules/schema/src/main/java/org/apache/ignite/internal/schema/marshaller/reflection/{JavaSerializerFactory.java => ReflectionMarshallerFactory.java} (56%)
rename modules/schema/src/test/java/org/apache/ignite/internal/schema/{TestUtils.java => SchemaTestUtils.java} (98%)
copy modules/schema/src/test/java/org/apache/ignite/internal/schema/marshaller/{JavaSerializerTest.java => KvMarshallerTest.java} (52%)
create mode 100644 modules/schema/src/test/java/org/apache/ignite/internal/schema/marshaller/MapperTest.java
create mode 100644 modules/schema/src/test/java/org/apache/ignite/internal/schema/marshaller/RecordMarshallerTest.java
create mode 100644 modules/schema/src/test/java/org/apache/ignite/internal/schema/testobjects/TestObjectWithAllTypes.java
copy modules/{configuration/src/main/java/org/apache/ignite/internal/configuration/validation/MemberKey.java => schema/src/test/java/org/apache/ignite/internal/schema/testobjects/TestObjectWithNoDefaultConstructor.java} (55%)
copy modules/{configuration/src/main/java/org/apache/ignite/internal/configuration/validation/MemberKey.java => schema/src/test/java/org/apache/ignite/internal/schema/testobjects/TestObjectWithPrivateConstructor.java} (53%)
create mode 100644 modules/schema/src/test/java/org/apache/ignite/internal/schema/testobjects/TestSimpleObject.java
rename modules/table/src/test/java/org/apache/ignite/internal/table/{KeyValueOperationsTest.java => KeyValueViewOperationsSimpleSchemaTest.java} (72%)
create mode 100644 modules/table/src/test/java/org/apache/ignite/internal/table/KeyValueViewOperationsTest.java
create mode 100644 modules/table/src/test/java/org/apache/ignite/internal/table/RecordViewOperationsTest.java