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%)