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/09 16:05:41 UTC
[ignite-3] branch ignite-14484 updated (ed0fb05 -> f8e0ff2)
This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-14484
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.
discard ed0fb05 Fix todos.
discard 5bc9e14 IGNITE-14484: Implement RecordView.
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 8690290 Merge branch 'main' into ignite-15783
add 459a0b5 Styles.
add 2f9a4ec IGNITE-14484: Implement RecordView.
add f8e0ff2 Fix todos.
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (ed0fb05)
\
N -- N -- N refs/heads/ignite-14484 (f8e0ff2)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
DEVNOTES.md | 7 +
.../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 | 12 +-
.../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 +
.../client/ItMetaStorageServiceTest.java | 19 +
.../internal/metastorage/client/CursorImpl.java | 18 +-
.../server/raft/MetaStorageListener.java | 32 +-
.../raft/server/ItJraftCounterServerTest.java | 87 +-
.../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 | 91 ++-
.../raft/jraft/core/RaftGroupServiceTest.java | 1 +
.../ignite/internal/calcite/util/Commons.java | 4 +
.../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 | 100 +--
.../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 | 4 +-
.../internal/schema/marshaller/Serializer.java | 11 +-
.../schema/marshaller/SerializerFactory.java | 6 +
.../marshaller/asm/ColumnAccessCodeGenerator.java | 13 +-
.../marshaller/asm/MarshallerCodeGenerator.java | 17 +-
.../schema/marshaller/reflection/Marshaller.java | 86 +-
.../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 +
.../internal/schema/SchemaConfigurationTest.java | 9 +-
.../internal/schema/SchemaDescriptorTest.java | 6 +-
.../ignite/internal/schema/TemporalTypesTest.java | 6 +
.../configuration/TableValidatorImplTest.java | 3 +-
.../schema/marshaller/JavaSerializerTest.java | 169 ++--
.../marshaller/reflection/FieldAccessorTest.java | 14 +-
.../schema/registry/SchemaRegistryImplTest.java | 3 +
.../distributed/ItInternalTableScanTest.java | 12 +-
.../table/distributed/raft/PartitionListener.java | 4 +-
.../distributed/storage/InternalTableImpl.java | 7 -
350 files changed, 5107 insertions(+), 7828 deletions(-)
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%)