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 9d29d0c WIP.
add db66f4b IGNITE-15175 Fixed javadoc in Rest module. Fixes #319
add 33403f6 IGNITE-15432 .NET: Fix tests for TeamCity project (#331)
add 551a9f0 IGNITE-15361 Thin 3.0: Add KeyValueBinaryView (#328)
add 7e726b8 IGNITE-15186 Implement basic JDBC client: Statement,
ResultSet (#284)
add 74eef32 IGNITE-15501 Improvements in ConfigurationExtension - support
for listeners and internal schema extensions (#334)
add f1c39fd IGNITE-15520 Fixed NamedListChange class type parameters.
(#341)
add 350fb95 IGNITE-15288 Full-featured RaftGroupService - Fixes #321.
add 83fcbbd IGNITE-15339 Fix broken access methods for column of temporal
types after row upgrade (#335)
add 1f1ca6c IGNITE-15188 JDBC driver for 3.0: Database metadata (#339)
add 403085d IGNITE-15404 Rework disctributed configuration flow. (#330)
add c7d44a5 IGNITE-15519: Make tuples serializable (#343)
add c065cbd IGNITE-15430 .NET: Add Table API (#342)
add 2bea2cc IGNITE-15519: Fix compilation due to competed commits.
add a250e8b IGNITE-15444 Implement MetaStorageManager component stop
(#332)
add 9ab3ae2 IGNITE-15438 Fix unexpectedly large allocations in
InternalTableImpl (#315)
add 2471da3 IGNITE-15187 JDBC driver for 3.0: ResultSet metadata (#345)
add 2c932e9 IGNITE-15439 Fix wrong item removal from collection (#333)
add 79c07d7 IGNITE-15532 Fix tuple equality comparison (#346)
add 9234711 IGNITE-15412 Introduce "direct" configuration properties
(#347)
add 1f75cb1 IGNITE-15362 Integration tests fixes. (#354)
add 3cdcfd3 IGNITE-15362 Fix compilation due to competed commits. (#354)
add f42fb60 IGNITE-15382 Decouple API and implementation for Tuple (#301)
add e2646a3 IGNITE-15341 Table API. Rename confusing method
getOrCreateTable (#316)
add 0c82a79 IGNITE-15548 Fix Table API classes hierarchy (#353)
add 720d5b0 Revert "IGNITE-15548 Fix Table API classes hierarchy (#353)"
(#361)
add a421688 IGNITE-15409 Adding NamedConfigurationTree#any to listen for
changes in any configuration (#336)
add 72d13b1 IGNITE-15531 .NET: Thin 3.0: Release procedure - Enable
packing - Use flexible MessagePack version
add 29e2828 Update DEVNOTES with release instructions
add 94c24ab Revert "Update DEVNOTES with release instructions"
add a166a9c Revert "IGNITE-15531 .NET: Thin 3.0: Release procedure"
add 3c9cd6a IGNITE-15548 Fix Table API classes hierarchy (#362)
add d590f4d IGNITE-15531 .NET: Set up binary and nuget packaging (#363)
add b40025b IGNITE-15579 Use test class and test method names as a part
of cluster node names (#359)
add 3812e3a IGNITE-15434 Reactive scan for table partitions.
add 472049d IGNITE-14679 Schema serialization. (#349)
add dab857a IGNITE-15508 Added loading via ServiceLoader for JDBC Driver
(#355)
add bc465f5 IGNITE-15543 Support injecting static variables with the
WorkDirectory extension (#357)
add c4df4de IGNITE-15646 ConcurrentHashMapStorage moved to test package.
(#367)
add ea7b7f4 IGNITE-15510 Use shared executor for raft group services.
Fixes #340
add 809e5d8 IGNITE-15661 Fix SystemPropertiesExtension state usage (#368)
add 6083f89 IGNITE-15108 Integrate with actual data layer in Ignite 3.0
(#295)
add f6af397 IGNITE-15545 JDBC Sql queries example. Fixes #358
add 0093c83 IGNITE-15670 .NET: Fix ClientSocketTests flakiness (#372)
add a970223 IGNITE-15668 Commented code without ticket link in
ignite-calcite (#371)
add 1b678f9 IGNITE-15406 Ignite, Ignition, and IgniteManager moved to
org.apache.ignite package. Fixes #370
add dbe7cf9 IGNITE-15191 Fixed bad wording. Fixes #374
add 85cee2b IGNITE-15663 Set default batch sized to 1. Fixes #369
add cee9f52 IGNITE-15027 Provide human-readable error when start
single-node cluster without hosting meta storage. Fixes #373
add 961ac5f IGNITE-15662 It is impossible to add a test-jar dependency to
the CLI module (#375)
add cb1a405 IGNITE-15538 Fixed NullPointerException during node start via
cli. Fixes #378
add 5a835d6 IGNITE-15686 Fix NPE in examples
add e7bb6de IGNITE-15685 - Renamed examples to make them consistent with
the updated API (#382)
add 15ef025 IGNITE-15379 Add Java client examples. Add tests
add a21454a IGNITE-15696 Fix NPE in StripeEntryHandler and logging bug in
StripeExceptionHandler. Fixes #385
add f370441 IGNITE-15351 Implemented concepts of storage engines and data
regions with basic integration into existing code. (#365)
add 5cd8c08 IGNITE-15684 - Fixed SqlJdbcExample. Fixes #381
add e56b90c IGNITE-15675 Added jul formatting to CLI module. Fixes #390
add 9c8fda5 IGNITE-15687 Fixed start more than one node via cli. Fixes
#391
add dd45a40 IGNITE-15491 Added setBaseline method and naive rebalance.
Fixes #379
add 2a6c557 IGNITE-15490 Created an example(s) that can allow to
demonstrate rebalancing. Fixes #390
add c0a3f32 IGNITE-15719 - Fixed multiple issues in the 'examples' module
(#392)
add bd7617c IGNITE-15396 TableManager#table(UUID) could return null value
even though the required table is already created. Fixes #15396
add 0083c45 IGNITE-15720 - Fixed examples to be able to run with a remote
node (#394)
add 8858465 Updated READMEs for alpha3 + minor formatting
add 8fdb8d2 IGNITE-14538 Implemented proper configuration of network
components (#294)
add 3501653 IGNITE-15749 Replace hamcrest-library with hamcrest (#397)
add fc684d2 IGNITE-15707 Ability to configure data regions for tables
(#387)
add f0a39da Merge branch 'main' into ignite-15212
No new revisions were added by this update.
Summary of changes:
.gitignore | 1 +
RELEASE.md | 14 +
assembly/README.md | 27 +-
assembly/assembly.xml | 2 +-
check-rules/checkstyle-disabled-modules.xml | 1 -
.../CheckUnusedDependenciesAndPluginsInParent.sh | 2 +-
docs/_docs/quick-start/getting-started-guide.adoc | 4 +-
examples/.gitignore | 2 +
examples/README.md | 17 +-
examples/config/ignite-config.json | 10 +-
examples/config/java.util.logging.properties | 23 +
examples/pom-standalone.xml | 6 +
examples/pom.xml | 24 +
.../ignite/example/rebalance/RebalanceExample.java | 210 +++
.../ignite/example/sql/jdbc/SqlJdbcExample.java | 282 +++
.../example/table/KeyValueBinaryViewExample.java | 114 --
.../ignite/example/table/KeyValueViewExample.java | 157 ++
.../ignite/example/table/RecordViewExample.java | 157 ++
.../apache/ignite/example/table/TableExample.java | 111 --
.../apache/ignite/example/ExampleTestUtils.java | 93 +
.../ignite/example/sql/jdbc/SqlExamplesTest.java | 98 +
.../ignite/example/table/TableExamplesTest.java | 101 +
.../ignite/internal/affinity/AffinityManager.java | 164 --
.../ignite/internal/affinity/AffinityUtils.java} | 35 +-
.../affinity/event/AffinityEventParameters.java | 64 -
.../internal/affinity/AffinityManagerTest.java | 297 ---
.../internal/affinity/AffinityServiceTest.java | 77 +
.../java/org/apache/ignite/{app => }/Ignite.java | 25 +-
.../java/org/apache/ignite/{app => }/Ignition.java | 3 +-
.../apache/ignite/{app => }/IgnitionManager.java | 2 +-
...a => ClusterMembershipConfigurationSchema.java} | 26 +-
.../InboundConfigurationSchema.java} | 42 +-
.../network/NetworkConfigurationSchema.java | 22 +-
...ema.java => NodeFinderConfigurationSchema.java} | 21 +-
.../schemas/network/NodeFinderType.java} | 11 +-
...chema.java => OutboundConfigurationSchema.java} | 25 +-
...hema.java => ScaleCubeConfigurationSchema.java} | 33 +-
.../store/DataRegionConfigurationSchema.java | 64 +
.../DataStorageConfigurationSchema.java} | 32 +-
...tor.java => PrimaryKeyConfigurationSchema.java} | 26 +-
.../schemas/table/TableConfigurationSchema.java | 15 +-
.../table/TableIndexConfigurationSchema.java | 2 +-
.../schemas/table/TableValidator.java | 2 +-
.../ignite/lang/TableAlreadyExistsException.java} | 11 +-
.../org/apache/ignite/{app => }/package-info.java | 2 +-
.../ignite/schema/builder/PrimaryIndexBuilder.java | 61 -
.../ColumnDefinition.java} | 11 +-
.../ignite/schema/{ => definition}/ColumnType.java | 2 +-
.../PrimaryKeyDefinition.java} | 21 +-
.../SchemaManagementMode.java} | 9 +-
.../{Column.java => definition/SchemaObject.java} | 36 +-
.../TableDefinition.java} | 24 +-
.../builder/ColumnDefinitionBuilder.java} | 20 +-
.../builder/HashIndexDefinitionBuilder.java} | 12 +-
.../builder/PartialIndexDefinitionBuilder.java} | 14 +-
.../builder/PrimaryKeyDefinitionBuilder.java} | 28 +-
.../builder/SchemaObjectBuilder.java | 4 +-
.../builder/SortedIndexDefinitionBuilder.java} | 26 +-
.../builder/TableSchemaBuilder.java} | 34 +-
.../index/ColumnarIndexDefinition.java} | 8 +-
.../index/HashIndexDefinition.java} | 4 +-
.../index/IndexColumnDefinition.java} | 6 +-
.../index/IndexDefinition.java} | 29 +-
.../index/PartialIndexDefinition.java} | 4 +-
.../schema/{ => definition/index}/SortOrder.java | 2 +-
.../index/SortedIndexColumnDefinition.java} | 4 +-
.../definition/index/SortedIndexDefinition.java} | 19 +-
.../index}/package-info.java | 4 +-
.../schema/{ => definition}/package-info.java | 2 +-
.../schema/modification/AlterColumnBuilder.java | 2 +-
.../modification/TableModificationBuilder.java | 12 +-
.../java/org/apache/ignite/table/KeyValueView.java | 15 +-
.../java/org/apache/ignite/table/RecordView.java | 358 +++-
.../main/java/org/apache/ignite/table/Table.java | 41 +-
.../java/org/apache/ignite/table/TableView.java | 371 ----
.../main/java/org/apache/ignite/table/Tuple.java | 111 +-
.../java/org/apache/ignite/table/TupleImpl.java | 117 +-
.../apache/ignite/table/manager/IgniteTables.java | 37 +-
modules/calcite/pom.xml | 2 +-
.../ExecutionService.java => QueryProcessor.java} | 29 +-
.../processors/query/calcite/SqlCursor.java} | 23 +-
.../query/calcite/SqlQueryProcessor.java | 16 +-
.../processors/query/calcite/SqlQueryType.java} | 52 +-
.../internal/processors/query/calcite/Stubs.java | 63 -
.../query/calcite/exec/ArrayRowHandler.java | 6 +
.../query/calcite/exec/ExchangeServiceImpl.java | 2 +-
.../query/calcite/exec/ExecutionContext.java | 15 +-
.../query/calcite/exec/ExecutionService.java | 4 +-
.../query/calcite/exec/ExecutionServiceImpl.java | 22 +-
.../query/calcite/exec/LogicalRelImplementor.java | 37 +-
.../processors/query/calcite/exec/RowHandler.java | 3 +
.../query/calcite/exec/exp/agg/Accumulators.java | 6 +-
.../query/calcite/exec/exp/agg/GroupKey.java | 8 +-
.../query/calcite/exec/rel/MinusNode.java | 2 +-
.../query/calcite/exec/rel/ModifyNode.java | 241 +++
.../query/calcite/exec/rel/TableScanNode.java | 270 +++
.../query/calcite/externalize/RelJson.java | 5 -
.../query/calcite/message/MessageServiceImpl.java | 4 +-
.../calcite/message/SqlQueryMessageGroup.java | 6 +-
.../query/calcite/prepare/IgniteSqlValidator.java | 58 +-
.../prepare/ddl/DdlSqlToCommandConverter.java | 2 -
.../calcite/rel/agg/IgniteMapHashAggregate.java | 6 +-
.../query/calcite/schema/ColumnDescriptor.java | 10 +-
.../query/calcite/schema/ColumnDescriptorImpl.java | 16 +-
.../query/calcite/schema/IgniteTable.java | 21 -
.../query/calcite/schema/IgniteTableImpl.java | 39 +-
.../query/calcite/schema/SchemaHolderImpl.java | 32 +-
.../query/calcite/schema/TableDescriptor.java | 58 +-
.../query/calcite/schema/TableDescriptorImpl.java | 153 +-
.../query/calcite/sql/IgniteSqlConformance.java} | 24 +-
.../query/calcite/trait/DistributionFunction.java | 10 -
.../processors/query/calcite/util/Commons.java | 31 +-
.../processors/query/calcite/util/TypeUtils.java | 3 +-
.../query/calcite/planner/AbstractPlannerTest.java | 41 +-
.../calcite/planner/SortAggregatePlannerTest.java | 23 +-
modules/cli/pom.xml | 30 +
.../org/apache/ignite/cli/ITConfigCommandTest.java | 72 +-
.../java/org/apache/ignite/cli/IgniteCliApp.java | 29 +
.../java/org/apache/ignite/cli/IgnitePaths.java | 7 +
.../cli/builtins/init/InitIgniteCommand.java | 19 +
.../ignite/cli/builtins/node/NodeManager.java | 21 +-
.../apache/ignite/cli/spec/NodeCommandSpec.java | 4 +-
.../resources/cli.java.util.logging.properties | 47 +
.../resources/ignite.java.util.logging.properties | 45 +
modules/cli/src/main/resources/logback.xml | 31 -
.../apache/ignite/cli/IgniteCliInterfaceTest.java | 5 +-
modules/cli/src/test/resources/logback-test.xml | 31 -
.../ignite/client/proto/query/ClientMessage.java} | 22 +-
.../client/proto/query/IgniteQueryErrorCode.java | 80 +
.../client/proto/query/JdbcQueryEventHandler.java | 113 ++
.../client/proto/query/JdbcStatementType.java} | 34 +-
.../ignite/client/proto/query/SqlStateCode.java | 81 +
.../proto/query/event/BatchExecuteRequest.java | 120 ++
.../proto/query/event/BatchExecuteResult.java | 94 +
.../proto/query/event/ClientMessageUtils.java | 52 +
.../client/proto/query/event/JdbcColumnMeta.java | 377 ++++
.../proto/query/event/JdbcMetaColumnsRequest.java | 102 +
.../proto/query/event/JdbcMetaColumnsResult.java | 118 ++
.../query/event/JdbcMetaPrimaryKeysRequest.java | 86 +
.../query/event/JdbcMetaPrimaryKeysResult.java | 114 ++
.../proto/query/event/JdbcMetaSchemasRequest.java | 70 +
.../proto/query/event/JdbcMetaSchemasResult.java | 94 +
.../proto/query/event/JdbcMetaTablesRequest.java | 121 ++
.../proto/query/event/JdbcMetaTablesResult.java | 99 +
.../proto/query/event/JdbcPrimaryKeyMeta.java | 167 ++
.../query/event/JdbcQueryMetadataRequest.java | 70 +
.../client/proto/query/event/JdbcTableMeta.java | 138 ++
.../ignite/client/proto/query/event/Query.java | 87 +
.../proto/query/event/QueryCloseRequest.java | 70 +
.../proto/query/event/QueryCloseResult.java} | 23 +-
.../proto/query/event/QueryExecuteRequest.java | 137 ++
.../proto/query/event/QueryExecuteResult.java | 117 ++
.../proto/query/event/QueryFetchRequest.java | 86 +
.../client/proto/query/event/QueryFetchResult.java | 123 ++
.../proto/query/event/QuerySingleResult.java | 189 ++
.../ignite/client/proto/query/event/Response.java | 134 ++
.../client/proto/query/event}/package-info.java | 5 +-
.../ignite/client/proto/query}/package-info.java | 5 +-
.../client/proto/ClientDataType.java | 8 +-
.../client/proto/ClientErrorCode.java | 2 +-
.../client/proto/ClientMessageCommon.java | 2 +-
.../client/proto/ClientMessageDecoder.java | 6 +-
.../client/proto/ClientMessagePacker.java | 170 +-
.../client/proto/ClientMessageUnpacker.java | 118 +-
.../client/proto/ClientMsgPackType.java | 5 +-
.../{ => internal}/client/proto/ClientOp.java | 32 +-
.../client/proto/ProtocolVersion.java | 2 +-
.../client/proto/ServerMessageType.java | 2 +-
.../ignite/internal/client/proto/TuplePart.java} | 22 +-
.../{ => internal}/client/proto/package-info.java | 2 +-
.../client/proto/ClientMessageDecoderTest.java | 2 +-
.../proto/ClientMessagePackerUnpackerTest.java | 82 +-
modules/client-handler/pom.xml | 5 +
.../ignite/client/handler/ITClientHandlerTest.java | 3 +-
.../ignite/client/handler/ClientContext.java | 2 +-
.../ignite/client/handler/ClientHandlerModule.java | 13 +-
.../handler/ClientInboundMessageHandler.java | 66 +-
.../client/handler/JdbcQueryEventHandlerImpl.java | 349 ++++
.../requests/sql/ClientSqlCloseRequest.java | 54 +
.../sql/ClientSqlColumnMetadataRequest.java | 54 +
.../requests/sql/ClientSqlExecuteBatchRequest.java | 54 +
.../requests/sql/ClientSqlExecuteRequest.java | 54 +
.../requests/sql/ClientSqlFetchRequest.java | 54 +
.../sql/ClientSqlPrimaryKeyMetadataRequest.java | 54 +
.../sql/ClientSqlQueryMetadataRequest.java | 54 +
.../sql/ClientSqlSchemasMetadataRequest.java | 54 +
.../sql/ClientSqlTableMetadataRequest.java | 54 +
.../handler/requests/sql/JdbcMetadataCatalog.java | 335 ++++
.../client/handler/requests/sql}/package-info.java | 4 +-
.../requests/table/ClientSchemasGetRequest.java | 4 +-
.../handler/requests/table/ClientTableCommon.java | 78 +-
.../requests/table/ClientTableDropRequest.java | 2 +-
.../requests/table/ClientTableGetRequest.java | 6 +-
.../requests/table/ClientTablesGetRequest.java | 4 +-
...est.java => ClientTupleContainsKeyRequest.java} | 11 +-
.../table/ClientTupleDeleteAllExactRequest.java | 6 +-
.../table/ClientTupleDeleteAllRequest.java | 7 +-
.../table/ClientTupleDeleteExactRequest.java | 6 +-
.../requests/table/ClientTupleDeleteRequest.java | 6 +-
.../requests/table/ClientTupleGetAllRequest.java | 6 +-
.../table/ClientTupleGetAndDeleteRequest.java | 7 +-
.../table/ClientTupleGetAndReplaceRequest.java | 7 +-
.../ClientTupleGetAndReplaceSchemalessRequest.java | 8 +-
.../table/ClientTupleGetAndUpsertRequest.java | 7 +-
.../ClientTupleGetAndUpsertSchemalessRequest.java | 8 +-
.../requests/table/ClientTupleGetRequest.java | 7 +-
.../table/ClientTupleInsertAllRequest.java | 6 +-
.../ClientTupleInsertAllSchemalessRequest.java | 8 +-
.../requests/table/ClientTupleInsertRequest.java | 6 +-
.../table/ClientTupleInsertSchemalessRequest.java | 8 +-
.../table/ClientTupleReplaceExactRequest.java | 10 +-
.../ClientTupleReplaceExactSchemalessRequest.java | 10 +-
.../requests/table/ClientTupleReplaceRequest.java | 6 +-
.../table/ClientTupleReplaceSchemalessRequest.java | 8 +-
.../table/ClientTupleUpsertAllRequest.java | 4 +-
.../ClientTupleUpsertAllSchemalessRequest.java | 6 +-
.../requests/table/ClientTupleUpsertRequest.java | 4 +-
.../table/ClientTupleUpsertSchemalessRequest.java | 6 +-
modules/client/pom.xml | 6 +
.../org/apache/ignite/client/IgniteClient.java | 2 +-
.../ignite/client/IgniteClientException.java | 2 +-
.../internal/client/PayloadInputChannel.java | 2 +-
.../internal/client/PayloadOutputChannel.java | 2 +-
.../ignite/internal/client/ProtocolContext.java | 2 +-
.../ignite/internal/client/TcpClientChannel.java | 12 +-
.../ignite/internal/client/TcpIgniteClient.java | 23 +
.../io/netty/NettyClientConnectionMultiplexer.java | 2 +-
.../client/query/JdbcClientQueryEventHandler.java | 135 ++
.../ignite/internal/client/table/ClientColumn.java | 2 +-
.../client/table/ClientKeyValueBinaryView.java} | 245 ++-
.../client/table/ClientRecordBinaryView.java | 319 ++++
.../ignite/internal/client/table/ClientTable.java | 441 ++---
.../ignite/internal/client/table/ClientTables.java | 18 +-
.../ignite/internal/client/table/ClientTuple.java | 99 +-
.../ignite/internal/jdbc/ConnectionProperties.java | 144 ++
.../internal/jdbc/ConnectionPropertiesImpl.java | 843 +++++++++
.../ignite/internal/jdbc/JdbcConnection.java | 792 ++++++++
.../ignite/internal/jdbc/JdbcDatabaseMetadata.java | 1531 +++++++++++++++
.../internal/jdbc/JdbcPreparedStatement.java | 529 ++++++
.../apache/ignite/internal/jdbc/JdbcResultSet.java | 1989 ++++++++++++++++++++
.../internal/jdbc/JdbcResultSetMetadata.java | 163 ++
.../apache/ignite/internal/jdbc/JdbcStatement.java | 657 +++++++
.../apache/ignite/internal/jdbc}/package-info.java | 4 +-
.../org/apache/ignite/jdbc/IgniteJdbcDriver.java | 128 ++
.../java/org/apache/ignite/jdbc}/package-info.java | 4 +-
.../resources/META-INF/services/java.sql.Driver | 1 +
.../ignite/client/AbstractClientTableTest.java | 77 +
.../apache/ignite/client/AbstractClientTest.java | 8 +-
.../client/ClientKeyValueBinaryViewTest.java | 286 +++
.../org/apache/ignite/client/ClientTableTest.java | 88 +-
.../org/apache/ignite/client/ClientTupleTest.java | 150 +-
.../java/org/apache/ignite/client/CustomTuple.java | 42 +-
.../org/apache/ignite/client/fakes/FakeCursor.java | 68 +
.../org/apache/ignite/client/fakes/FakeIgnite.java | 23 +-
.../client/fakes/FakeIgniteQueryProcessor.java} | 32 +-
.../ignite/client/fakes/FakeIgniteTables.java | 33 +-
.../ignite/client/fakes/FakeInternalTable.java | 31 +-
modules/configuration-annotation-processor/pom.xml | 8 +-
.../configuration/processor/ITProcessorTest.java | 25 +-
.../InvalidDirectAccessConfigurationSchema.java} | 32 +-
.../configuration/processor/Processor.java | 35 +-
.../ConfigurationListenOnlyException.java} | 17 +-
.../configuration/ConfigurationProperty.java | 10 +-
.../ignite/configuration/ConfigurationTree.java | 2 +-
.../ignite/configuration/ConfigurationValue.java | 3 +-
.../configuration/DirectConfigurationProperty.java | 42 +
.../configuration/NamedConfigurationTree.java | 21 +-
.../ignite/configuration/NamedListChange.java | 15 +-
.../configuration/annotation/DirectAccess.java | 44 +
.../notifications/ConfigurationListener.java | 1 -
.../ConfigurationNamedListListener.java | 22 +-
.../ConfigurationNotificationEvent.java | 26 +-
.../configuration/validation/ExceptKeys.java} | 17 +-
.../ignite/configuration/validation/OneOf.java} | 19 +-
.../validation/ValidationContext.java | 8 +-
modules/configuration/pom.xml | 9 +-
.../configuration/ConfigurationChanger.java | 102 +-
.../configuration/ConfigurationManager.java | 3 +-
.../internal/configuration/ConfigurationNode.java | 52 +-
.../configuration/ConfigurationRegistry.java | 28 +-
.../configuration/DirectDynamicConfiguration.java | 59 +
.../configuration/DirectDynamicProperty.java | 60 +
.../DirectNamedListConfiguration.java | 66 +
.../configuration/DynamicConfiguration.java | 33 +-
.../configuration/DynamicConfigurationChanger.java | 13 +
.../internal/configuration/DynamicProperty.java | 21 +-
.../configuration/NamedListConfiguration.java | 43 +-
.../asm/ConfigurationAsmGenerator.java | 202 +-
.../configuration/asm/SchemaClassesInfo.java | 25 +-
.../storage/ConfigurationStorage.java | 12 +-
.../internal/configuration/storage/Data.java | 6 +-
.../configuration/tree/ConfigurationVisitor.java | 8 +-
.../configuration/tree/ConverterToMapVisitor.java | 2 +-
.../internal/configuration/tree/NamedListNode.java | 37 +-
.../util/AnyNodeConfigurationVisitor.java | 2 +-
.../configuration/util/ConfigurationContainer.java | 49 +
.../util/ConfigurationNotificationEventImpl.java | 45 +-
.../util/ConfigurationNotificationsUtil.java | 512 ++++-
.../configuration/util/ConfigurationUtil.java | 66 +-
.../util/KeysTrackingConfigurationVisitor.java | 10 +-
.../validation/ExceptKeysValidator.java | 46 +
.../configuration/validation/OneOfValidator.java | 46 +
.../validation/ValidationContextImpl.java | 2 +-
.../configuration/ConfigurationChangerTest.java | 221 ++-
.../configuration/DirectPropertiesTest.java | 223 +++
.../configuration/hocon/HoconConverterTest.java | 4 +-
.../ConfigurationAnyListenerTest.java | 668 +++++++
.../notifications/ConfigurationListenerTest.java | 250 +++
.../ConfigurationListenerTestUtils.java | 208 ++
.../storage/TestConfigurationStorage.java | 42 +-
.../testframework/BasicConfigurationSchema.java} | 18 +-
.../testframework/ConfigurationExtension.java | 97 +-
.../testframework/ConfigurationExtensionTest.java | 72 +-
.../ExtendedConfigurationSchema.java} | 22 +-
.../testframework/InjectConfiguration.java | 13 +-
.../configuration/tree/NamedListNodeTest.java | 145 +-
.../tree/TraversableTreeNodeTest.java | 8 +-
.../configuration/util/ConfigurationUtilTest.java | 6 +-
.../validation/OneOfValidatorTest.java | 80 +
modules/core/pom.xml | 8 +-
.../org/apache/ignite/internal/manager/Event.java | 2 +-
.../ignite/internal/manager/EventParameters.java | 2 +-
.../apache/ignite/internal/manager/Producer.java | 2 +-
.../ignite/internal/util/CollectionUtils.java | 53 +-
.../ignite/internal/util/IgniteSpinBusyLock.java | 91 +
.../internal/util/IgniteSpinReadWriteLock.java | 406 ++++
.../apache/ignite/internal/util/IgniteUtils.java | 40 +-
.../internal/testframework/IgniteTestUtils.java | 15 +-
.../testframework/SystemPropertiesExtension.java | 180 +-
.../internal/testframework/WithSystemProperty.java | 22 +-
.../testframework/WorkDirectoryExtension.java | 121 +-
.../testframework/WorkDirectoryExtensionTest.java | 293 +++
.../ignite/internal/util/CollectionUtilsTest.java | 27 +
.../ITMetaStorageServicePersistenceTest.java | 5 +-
.../client/ITMetaStorageServiceTest.java | 39 +-
.../internal/metastorage/client/Condition.java | 2 +-
.../internal/metastorage/client/CursorImpl.java | 13 +-
.../ignite/internal/metastorage/client/Entry.java | 2 +-
.../metastorage/client/MetaStorageServiceImpl.java | 20 +-
.../internal/metastorage/client/Operation.java | 2 +-
.../internal/metastorage/server/Operation.java | 2 +-
.../server/raft/MetaStorageListener.java | 2 +-
.../internal/metastorage/MetaStorageManager.java | 487 ++++-
modules/network-api/pom.xml | 7 +-
.../ignite/network/ClusterServiceFactory.java | 9 +-
modules/network/pom.xml | 2 +-
.../network/netty/ITConnectionManagerTest.java | 16 +-
.../network/recovery/ITRecoveryHandshakeTest.java | 22 +-
.../network/scalecube/ITNodeRestartsTest.java | 25 +-
.../scalecube/ITScaleCubeNetworkMessagingTest.java | 59 +-
.../TestScaleCubeClusterServiceFactory.java | 3 +-
.../ignite/utils/ClusterServiceTestUtils.java | 50 +-
.../internal/network/netty/ConnectionManager.java | 22 +-
.../ignite/internal/network/netty/NettyServer.java | 68 +-
.../apache/ignite/network/NodeFinderFactory.java | 60 +
.../apache/ignite/network/StaticNodeFinder.java | 17 -
.../scalecube/ScaleCubeClusterServiceFactory.java | 35 +-
.../scalecube/ScaleCubeMessagingService.java | 2 +-
.../scalecube/ScaleCubeTopologyService.java | 22 +-
.../internal/network/netty/NettyServerTest.java | 29 +-
.../ignite/network/LocalPortRangeNodeFinder.java | 49 -
.../dotnet/Apache.Ignite.Benchmarks/Program.cs | 30 +-
.../Proto/WriteGuidBenchmarks.cs | 30 +-
.../Table/TupleGetBenchmarks.cs | 30 +-
.../dotnet/Apache.Ignite.Tests/IgniteTestsBase.cs | 15 +
.../dotnet/Apache.Ignite.Tests/JavaServer.cs | 143 +-
.../Apache.Ignite.Tests/ProjectFilesTests.cs | 1 +
.../{TablesTests.cs => CustomTestIgniteTuple.cs} | 36 +-
.../Apache.Ignite.Tests/Table/IgniteTupleTests.cs | 25 +
.../dotnet/Apache.Ignite.Tests/Table/TableTests.cs | 475 ++++-
.../Apache.Ignite.Tests/Table/TablesTests.cs | 25 +-
modules/platforms/dotnet/Apache.Ignite.sln | 1 +
.../dotnet/Apache.Ignite/Apache.Ignite.csproj | 3 +-
.../Internal/Buffers/PooledArrayBufferWriter.cs | 28 +
.../Apache.Ignite/Internal/ClientFailoverSocket.cs | 4 +-
.../Internal/Proto/ClientMessagePackType.cs | 5 +
.../{ClientMessagePackType.cs => IgniteUuid.cs} | 48 +-
.../Internal/Proto/MessagePackReaderExtensions.cs | 27 +
.../Internal/Proto/MessagePackWriterExtensions.cs | 13 +
.../dotnet/Apache.Ignite/Internal/Table/Schema.cs | 4 +
.../dotnet/Apache.Ignite/Internal/Table/Table.cs | 476 ++++-
.../dotnet/Apache.Ignite/Internal/Table/Tables.cs | 4 +-
.../dotnet/Apache.Ignite/Table/ITableView.cs | 145 +-
.../dotnet/Apache.Ignite/Table/IgniteTuple.cs | 23 +
.../dotnet/Apache_Ignite_logo_128x128.png | Bin 0 -> 18667 bytes
modules/platforms/dotnet/DEVNOTES.md | 8 +
modules/platforms/dotnet/Directory.Build.props | 20 +-
.../java/org/apache/ignite/raft/client/Peer.java | 1 +
.../apache/ignite/raft/client/RaftErrorCode.java | 70 -
.../raft/client/message/AddLearnersRequest.java | 40 -
.../raft/client/message/AddPeersRequest.java | 40 -
.../raft/client/message/ChangePeersResponse.java | 40 -
.../raft/client/message/GetLeaderRequest.java | 33 -
.../raft/client/message/GetLeaderResponse.java | 34 -
.../raft/client/message/GetPeersRequest.java | 36 -
.../raft/client/message/GetPeersResponse.java | 40 -
.../client/message/RaftClientMessageGroup.java | 96 -
.../raft/client/message/RaftErrorResponse.java | 46 -
.../raft/client/message/RemoveLearnersRequest.java | 40 -
.../raft/client/message/RemovePeersRequest.java | 40 -
.../raft/client/message/SnapshotRequest.java | 33 -
.../client/message/TransferLeadershipRequest.java | 39 -
.../raft/client/service/RaftGroupService.java | 36 +-
.../client/service/impl/RaftGroupServiceImpl.java | 456 -----
modules/raft/pom.xml | 6 +
.../apache/ignite/internal/raft/ITLozaTest.java | 150 ++
.../service/ITAbstractListenerSnapshotTest.java | 67 +-
.../ignite/raft/jraft/core/ITCliServiceTest.java | 13 +-
.../apache/ignite/raft/jraft/core/ITNodeTest.java | 184 +-
.../raft/server/ITJRaftCounterServerTest.java | 29 +-
.../raft/server/ITSimpleCounterServerTest.java | 32 +-
.../ignite/raft/server/RaftServerAbstractTest.java | 20 +-
.../java/org/apache/ignite/internal/raft/Loza.java | 128 +-
.../internal/raft/server/impl/JRaftServerImpl.java | 1 -
.../apache/ignite/raft/jraft/RaftMessageGroup.java | 17 +
.../apache/ignite/raft/jraft/core/NodeImpl.java | 13 +-
.../raft/jraft/disruptor/StripedDisruptor.java | 21 +-
.../apache/ignite/raft/jraft/entity/PeerId.java | 14 +-
.../apache/ignite/raft/jraft/error/RaftError.java | 2 +-
.../ignite/raft/jraft/option/NodeOptions.java | 3 +-
.../ignite/raft/jraft/option/RaftOptions.java | 23 -
.../ignite/raft/jraft/option/RpcOptions.java | 19 -
.../ignite/raft/jraft/rpc}/ActionRequest.java | 10 +-
.../ignite/raft/jraft/rpc}/ActionResponse.java | 10 +-
.../apache/ignite/raft/jraft/rpc/RpcRequests.java | 24 +-
.../ignite/raft/jraft/rpc/RpcResponseFactory.java | 21 +
.../raft/jraft/rpc/impl/AbstractClientService.java | 4 +-
.../impl/{client => }/ActionRequestProcessor.java | 63 +-
.../raft/jraft/rpc/impl/IgniteRpcServer.java | 16 +-
.../ignite/raft/jraft/rpc/impl}/RaftException.java | 32 +-
.../raft/jraft/rpc/impl/RaftGroupServiceImpl.java | 638 +++++++
.../rpc/impl/cli/AddLearnersRequestProcessor.java | 3 +-
.../rpc/impl/cli/AddPeerRequestProcessor.java | 3 +-
.../rpc/impl/cli/BaseCliRequestProcessor.java | 4 +-
.../rpc/impl/cli/ChangePeersRequestProcessor.java | 3 +-
.../rpc/impl/cli/GetLeaderRequestProcessor.java | 2 +-
.../rpc/impl/cli/GetPeersRequestProcessor.java | 3 +-
.../rpc/impl/cli/IgniteCliRpcRequestClosure.java | 93 +
.../impl/cli/RemoveLearnersRequestProcessor.java | 3 +-
.../rpc/impl/cli/RemovePeerRequestProcessor.java | 3 +-
.../impl/cli/ResetLearnersRequestProcessor.java | 3 +-
.../rpc/impl/cli/ResetPeerRequestProcessor.java | 3 +-
.../rpc/impl/cli/SnapshotRequestProcessor.java | 3 +-
.../impl/cli/TransferLeaderRequestProcessor.java | 3 +-
.../rpc/impl/client/GetLeaderRequestProcessor.java | 85 -
.../rpc/impl/client/SnapshotRequestProcessor.java | 71 -
.../raft/jraft/storage/impl/LogManagerImpl.java | 1 +
.../ignite/disruptor/StripedDisruptorTest.java | 154 ++
.../internal/raft/server/impl/RaftServerImpl.java | 32 +-
.../raft/jraft/core}/RaftGroupServiceTest.java | 375 +++-
.../apache/ignite/raft/jraft/core/TestCluster.java | 139 +-
.../ignite/raft/jraft/rpc/IgniteRpcTest.java | 13 +-
.../ignite/raft/jraft/rpc/TestIgniteRpcServer.java | 1 -
.../rpc/impl/cli/BaseCliRequestProcessorTest.java | 5 +-
.../java/org/apache/ignite/rest/ErrorResult.java | 4 +
.../java/org/apache/ignite/rest/RestModule.java | 1 +
.../apache/ignite/rest/netty/RestApiHandler.java | 4 +-
.../ignite/rest/netty/RestApiHttpRequest.java | 2 +
.../ignite/rest/netty/RestApiHttpResponse.java | 6 +
.../ignite/rest/netty/RestApiInitializer.java | 2 +
.../apache/ignite/rest/netty}/package-info.java | 4 +-
.../java/org/apache/ignite/rest}/package-info.java | 4 +-
.../rest/presentation/hocon}/package-info.java | 4 +-
.../ignite/rest/presentation}/package-info.java | 4 +-
.../java/org/apache/ignite/rest/routes/Route.java | 7 +-
.../java/org/apache/ignite/rest/routes/Router.java | 2 +-
.../apache/ignite/rest/routes}/package-info.java | 4 +-
.../ignite/internal/rocksdb/ColumnFamily.java | 7 +
modules/runner/pom.xml | 35 +-
.../calcite/AbstractBasicIntegrationTest.java | 212 +++
.../ignite/internal/calcite/ITAggregatesTest.java | 159 ++
.../ignite/internal/calcite/ITDataTypesTest.java | 74 +
.../ignite/internal/calcite/ITFunctionsTest.java | 205 ++
.../ignite/internal/calcite/ITIndexSpoolTest.java | 117 ++
.../ignite/internal/calcite/ITMetadataTest.java | 81 +
.../internal/calcite/ITMixedQueriesTest.java | 320 ++++
.../internal/calcite/ITOrToUnionRuleTest.java | 231 +++
.../calcite/ITProjectScanMergeRuleTest.java | 157 ++
.../internal/calcite/ITSecondaryIndexTest.java | 831 ++++++++
.../ignite/internal/calcite/ITSetOpTest.java | 282 +++
.../internal/calcite/ITSortAggregateTest.java | 99 +
.../ignite/internal/calcite/util/Commons.java} | 22 +-
.../ignite/internal/calcite/util/QueryChecker.java | 440 +++++
.../ITDistributedConfigurationPropertiesTest.java | 313 +++
.../ITDistributedConfigurationStorageTest.java | 23 +-
.../runner/app/AbstractSchemaChangeTest.java | 105 +-
.../internal/runner/app/ITBaselineChangesTest.java | 170 ++
.../runner/app/ITDynamicTableCreationTest.java | 155 +-
.../runner/app/ITIgniteNodeRestartTest.java | 96 +-
.../ignite/internal/runner/app/ITIgnitionTest.java | 172 +-
.../runner/app/ITLiveSchemaChangeKVViewTest.java | 46 +-
.../runner/app/ITLiveSchemaChangeTableTest.java | 126 +-
.../runner/app/ITSchemaChangeKVViewTest.java | 41 +-
.../runner/app/ITSchemaChangeTableViewTest.java | 47 +-
.../internal/runner/app/ITTableCreationTest.java | 133 +-
.../internal/runner/app/ITTablesApiTest.java | 320 ++++
.../runner/app/ITThinClientConnectionTest.java | 83 +-
.../runner/app/PlatformTestNodeRunner.java | 40 +-
.../runner/app/jdbc/AbstractJdbcSelfTest.java | 105 ++
.../app/jdbc/ITJdbcConnectionPropertiesTest.java} | 33 +-
.../runner/app/jdbc/ITJdbcConnectionSelfTest.java | 1297 +++++++++++++
.../runner/app/jdbc/ITJdbcMetadataSelfTest.java | 584 ++++++
.../runner/app/jdbc/ITJdbcResultSetSelfTest.java | 1094 +++++++++++
.../runner/app/jdbc/ITJdbcStatementSelfTest.java | 864 +++++++++
.../org/apache/ignite/app/IgniteCliRunner.java | 5 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 73 +-
.../apache/ignite/internal/app/IgnitionImpl.java | 13 +-
.../storage/DistributedConfigurationStorage.java | 64 +-
.../storage/LocalConfigurationStorage.java | 49 +-
...ite.app.Ignition => org.apache.ignite.Ignition} | 0
.../storage/ConfigurationStorageTest.java | 80 +
.../DistributedConfigurationStorageTest.java | 224 +++
.../storage/LocalConfigurationStorageTest.java} | 34 +-
modules/schema/pom.xml | 6 +
.../internal/schema/InvalidTypeException.java | 2 +-
.../apache/ignite/internal/schema/NativeTypes.java | 2 +-
.../ignite/internal/schema/SchemaDescriptor.java | 20 +-
.../ignite/internal/schema/SchemaManager.java | 408 ----
.../internal/schema}/SchemaMismatchException.java | 6 +-
.../ignite/internal/schema/SchemaRegistry.java | 11 +
.../apache/ignite/internal/schema/SchemaUtils.java | 147 ++
.../ignite/internal/schema/VarlenNativeType.java | 7 +
.../schema/builder/PrimaryKeyBuilderImpl.java | 119 --
.../schema/builder/SchemaTableBuilderImpl.java | 146 --
.../SchemaConfigurationConverter.java | 187 +-
.../configuration/SchemaDescriptorConverter.java | 28 +-
.../configuration/SchemaTableValidatorImpl.java | 65 -
.../schema/configuration/TableValidatorImpl.java | 141 ++
.../{ => definition}/AbstractSchemaObject.java | 6 +-
.../ColumnDefinitionImpl.java} | 34 +-
.../TableDefinitionImpl.java} | 72 +-
.../builder/AbstractIndexBuilder.java | 37 +-
.../builder/ColumnDefinitionBuilderImpl.java} | 32 +-
.../builder/HashIndexDefinitionBuilderImpl.java} | 20 +-
.../PartialIndexDefinitionBuilderImpl.java} | 34 +-
.../builder/PrimaryKeyDefinitionBuilderImpl.java | 83 +
.../builder/SortedIndexDefinitionBuilderImpl.java} | 44 +-
.../definition/builder/TableSchemaBuilderImpl.java | 147 ++
.../index/HashIndexDefinitionImpl.java} | 20 +-
.../index/IndexColumnDefinitionImpl.java} | 11 +-
.../index/PartialIndexDefinitionImpl.java} | 16 +-
.../index/PrimaryKeyDefinitionImpl.java} | 47 +-
.../index/SortedIndexColumnDefinitionImpl.java} | 23 +-
.../index/SortedIndexDefinitionImpl.java} | 31 +-
.../ignite/internal/schema/event/SchemaEvent.java | 35 -
.../schema/event/SchemaEventParameters.java | 60 -
.../schema/AbstractSchemaSerializer.java | 109 ++
.../marshaller/schema/SchemaSerializer.java} | 33 +-
.../marshaller/schema/SchemaSerializerImpl.java | 743 ++++++++
.../modification/AlterColumnBuilderImpl.java | 2 +-
.../modification/TableModificationBuilderImpl.java | 26 +-
.../schema/registry/UpgradingRowAdapter.java | 58 +-
.../org/apache/ignite/internal/schema/row/Row.java | 8 +-
.../internal/schema/row/TemporalTypesHelper.java | 2 +-
.../org/apache/ignite/schema/SchemaBuilders.java | 56 +-
.../benchmarks/SerializerBenchmarkTest.java | 3 +-
.../{ColumnTest.java => ColumnDefinitionTest.java} | 2 +-
.../ignite/internal/schema/NativeTypeTest.java | 2 +-
.../schema/RowAssemblerAdvancedSchemaTest.java | 10 +-
.../schema/RowAssemblerSimpleSchemaTest.java | 37 +-
.../org/apache/ignite/internal/schema/RowTest.java | 12 +-
.../internal/schema/SchemaConfigurationTest.java | 21 +-
.../internal/schema/SchemaDescriptorTest.java | 4 +-
.../ignite/internal/schema/TemporalTypesTest.java | 2 +-
.../apache/ignite/internal/schema/TestUtils.java | 4 +-
...rTest.java => ColumnDefinitionBuilderTest.java} | 14 +-
...st.java => HashIndexDefinitionBuilderTest.java} | 12 +-
...java => PartialIndexDefinitionBuilderTest.java} | 10 +-
.../schema/builder/PrimaryKeyBuilderTest.java | 46 -
.../PrimaryKeyDefinitionDefinitionBuilderTest.java | 79 +
....java => SortedIndexDefinitionBuilderTest.java} | 19 +-
...erTest.java => TableDefinitionBuilderTest.java} | 16 +-
.../SchemaConfigurationConverterTest.java | 160 +-
.../SchemaDescriptorConverterTest.java | 54 +-
.../configuration/TableValidatorImplTest.java | 140 ++
.../schema/marshaller/JavaSerializerTest.java | 19 +-
.../schema/registry/SchemaRegistryImplTest.java | 79 +-
.../schema/registry/UpgradingRowAdapterTest.java | 336 ++++
.../schema/serializer/AbstractSerializerTest.java | 164 ++
modules/storage-api/pom.xml | 11 +-
.../{Storage.java => PartitionStorage.java} | 17 +-
.../internal/storage/engine/DataRegion.java} | 18 +-
.../internal/storage/engine/StorageEngine.java | 55 +
.../internal/storage/engine/TableStorage.java} | 35 +-
...Test.java => AbstractPartitionStorageTest.java} | 62 +-
.../basic/ConcurrentHashMapPartitionStorage.java} | 74 +-
.../basic/ConcurrentHashMapStorageTest.java | 8 +-
modules/storage-rocksdb/pom.xml | 21 +-
.../storage/rocksdb/RocksDbDataRegion.java | 95 +
...DbStorage.java => RocksDbPartitionStorage.java} | 161 +-
.../storage/rocksdb/RocksDbStorageEngine.java | 61 +
.../storage/rocksdb/RocksDbTableStorage.java | 384 ++++
.../storage/rocksdb/RocksDbStorageTest.java | 57 +-
modules/table/pom.xml | 38 +
.../ignite/distributed/ITDistributedTableTest.java | 82 +-
.../distributed/ITInternalTableScanTest.java | 543 ++++++
.../ignite/distributed/ITTablePersistenceTest.java | 55 +-
.../schema/ExtendedTableConfigurationSchema.java} | 44 +-
.../schema/SchemaConfigurationSchema.java} | 22 +-
.../internal/table/AbstractRowTupleAdapter.java | 59 +-
.../ignite/internal/table/AbstractTableView.java | 20 +-
.../internal/table/IgniteTablesInternal.java | 13 +-
.../ignite/internal/table/InternalTable.java | 34 +-
...ryViewImpl.java => KeyValueBinaryViewImpl.java} | 15 +-
.../{KVViewImpl.java => KeyValueViewImpl.java} | 13 +-
.../internal/table/MutableRowTupleAdapter.java | 91 +-
.../{TableImpl.java => RecordBinaryViewImpl.java} | 60 +-
.../ignite/internal/table/RecordViewImpl.java | 18 -
.../apache/ignite/internal/table/TableImpl.java | 376 +---
.../org/apache/ignite/internal/table/TableRow.java | 6 +-
.../ignite/internal/table/TupleMarshallerImpl.java | 100 +-
.../internal/table/distributed/TableManager.java | 1211 +++++++-----
.../command/response/MultiRowsResponse.java | 12 +-
.../command/scan/ScanCloseCommand.java} | 32 +-
.../distributed/command/scan/ScanInitCommand.java | 59 +
.../command/scan/ScanRetrieveBatchCommand.java | 60 +
.../table/distributed/raft/PartitionListener.java | 161 +-
.../distributed/storage/InternalTableImpl.java | 382 +++-
.../internal/table/event/TableEventParameters.java | 11 +-
.../TupleMarshallerFixlenOnlyBenchmark.java | 7 +-
.../TupleMarshallerVarlenOnlyBenchmark.java | 7 +-
.../org/apache/ignite/internal/table/Example.java | 28 +-
....java => KeyValueBinaryViewOperationsTest.java} | 42 +-
.../internal/table/MutableRowTupleAdapterTest.java | 270 ++-
...st.java => RecordBinaryViewOperationsTest.java} | 42 +-
.../internal/table/StrictSchemaOperationsTest.java | 44 +-
.../ignite/internal/table/TableManagerTest.java | 278 +--
.../org/apache/ignite/internal/table/TxTest.java | 41 +-
.../raft/PartitionCommandListenerTest.java | 22 +-
.../table/impl/DummyInternalTableImpl.java | 32 +-
.../internal/table/impl/TestTupleBuilder.java | 44 +-
.../table/type/NumericTypesSerializerTest.java | 12 +-
.../org/apache/ignite/table/TupleImplTest.java | 141 +-
modules/vault/pom.xml | 2 +-
.../vault/persistence/PersistentVaultService.java | 2 +-
parent/pom.xml | 30 +-
636 files changed, 41253 insertions(+), 9657 deletions(-)
create mode 100644 examples/.gitignore
create mode 100644 examples/config/java.util.logging.properties
create mode 100644
examples/src/main/java/org/apache/ignite/example/rebalance/RebalanceExample.java
create mode 100644
examples/src/main/java/org/apache/ignite/example/sql/jdbc/SqlJdbcExample.java
delete mode 100644
examples/src/main/java/org/apache/ignite/example/table/KeyValueBinaryViewExample.java
create mode 100644
examples/src/main/java/org/apache/ignite/example/table/KeyValueViewExample.java
create mode 100644
examples/src/main/java/org/apache/ignite/example/table/RecordViewExample.java
delete mode 100644
examples/src/main/java/org/apache/ignite/example/table/TableExample.java
create mode 100644
examples/src/test/java/org/apache/ignite/example/ExampleTestUtils.java
create mode 100644
examples/src/test/java/org/apache/ignite/example/sql/jdbc/SqlExamplesTest.java
create mode 100644
examples/src/test/java/org/apache/ignite/example/table/TableExamplesTest.java
delete mode 100644
modules/affinity/src/main/java/org/apache/ignite/internal/affinity/AffinityManager.java
copy
modules/{configuration-api/src/main/java/org/apache/ignite/configuration/notifications/ConfigurationListener.java
=>
affinity/src/main/java/org/apache/ignite/internal/affinity/AffinityUtils.java}
(52%)
delete mode 100644
modules/affinity/src/main/java/org/apache/ignite/internal/affinity/event/AffinityEventParameters.java
delete mode 100644
modules/affinity/src/test/java/org/apache/ignite/internal/affinity/AffinityManagerTest.java
create mode 100644
modules/affinity/src/test/java/org/apache/ignite/internal/affinity/AffinityServiceTest.java
rename modules/api/src/main/java/org/apache/ignite/{app => }/Ignite.java (60%)
rename modules/api/src/main/java/org/apache/ignite/{app => }/Ignition.java
(98%)
rename modules/api/src/main/java/org/apache/ignite/{app =>
}/IgnitionManager.java (99%)
copy
modules/api/src/main/java/org/apache/ignite/configuration/schemas/network/{NetworkConfigurationSchema.java
=> ClusterMembershipConfigurationSchema.java} (62%)
copy
modules/api/src/main/java/org/apache/ignite/configuration/schemas/{table/TableConfigurationSchema.java
=> network/InboundConfigurationSchema.java} (59%)
copy
modules/api/src/main/java/org/apache/ignite/configuration/schemas/network/{NetworkConfigurationSchema.java
=> NodeFinderConfigurationSchema.java} (65%)
copy
modules/api/src/main/java/org/apache/ignite/{schema/builder/package-info.java
=> configuration/schemas/network/NodeFinderType.java} (80%)
copy
modules/api/src/main/java/org/apache/ignite/configuration/schemas/network/{NetworkConfigurationSchema.java
=> OutboundConfigurationSchema.java} (66%)
copy
modules/api/src/main/java/org/apache/ignite/configuration/schemas/network/{NetworkConfigurationSchema.java
=> ScaleCubeConfigurationSchema.java} (56%)
create mode 100644
modules/api/src/main/java/org/apache/ignite/configuration/schemas/store/DataRegionConfigurationSchema.java
copy
modules/api/src/main/java/org/apache/ignite/configuration/schemas/{network/NetworkConfigurationSchema.java
=> store/DataStorageConfigurationSchema.java} (55%)
copy
modules/api/src/main/java/org/apache/ignite/configuration/schemas/table/{TableValidator.java
=> PrimaryKeyConfigurationSchema.java} (62%)
copy
modules/{schema/src/main/java/org/apache/ignite/internal/schema/InvalidTypeException.java
=> api/src/main/java/org/apache/ignite/lang/TableAlreadyExistsException.java}
(72%)
copy modules/api/src/main/java/org/apache/ignite/{app => }/package-info.java
(96%)
delete mode 100644
modules/api/src/main/java/org/apache/ignite/schema/builder/PrimaryIndexBuilder.java
copy modules/api/src/main/java/org/apache/ignite/schema/{Column.java =>
definition/ColumnDefinition.java} (79%)
rename modules/api/src/main/java/org/apache/ignite/schema/{ =>
definition}/ColumnType.java (99%)
copy modules/api/src/main/java/org/apache/ignite/schema/{PrimaryIndex.java =>
definition/PrimaryKeyDefinition.java} (70%)
rename modules/api/src/main/java/org/apache/ignite/schema/{SchemaMode.java =>
definition/SchemaManagementMode.java} (91%)
copy modules/api/src/main/java/org/apache/ignite/schema/{Column.java =>
definition/SchemaObject.java} (59%)
rename modules/api/src/main/java/org/apache/ignite/schema/{SchemaTable.java =>
definition/TableDefinition.java} (74%)
rename
modules/api/src/main/java/org/apache/ignite/schema/{builder/TableColumnBuilder.java
=> definition/builder/ColumnDefinitionBuilder.java} (68%)
copy
modules/api/src/main/java/org/apache/ignite/schema/{builder/HashIndexBuilder.java
=> definition/builder/HashIndexDefinitionBuilder.java} (74%)
rename
modules/api/src/main/java/org/apache/ignite/schema/{builder/PartialIndexBuilder.java
=> definition/builder/PartialIndexDefinitionBuilder.java} (78%)
rename
modules/api/src/main/java/org/apache/ignite/schema/{builder/HashIndexBuilder.java
=> definition/builder/PrimaryKeyDefinitionBuilder.java} (61%)
copy modules/api/src/main/java/org/apache/ignite/schema/{ =>
definition}/builder/SchemaObjectBuilder.java (92%)
rename
modules/api/src/main/java/org/apache/ignite/schema/{builder/SortedIndexBuilder.java
=> definition/builder/SortedIndexDefinitionBuilder.java} (80%)
rename
modules/api/src/main/java/org/apache/ignite/schema/{builder/SchemaTableBuilder.java
=> definition/builder/TableSchemaBuilder.java} (55%)
copy modules/api/src/main/java/org/apache/ignite/schema/{ColumnarIndex.java =>
definition/index/ColumnarIndexDefinition.java} (82%)
rename modules/api/src/main/java/org/apache/ignite/schema/{HashIndex.java =>
definition/index/HashIndexDefinition.java} (88%)
rename modules/api/src/main/java/org/apache/ignite/schema/{IndexColumn.java =>
definition/index/IndexColumnDefinition.java} (88%)
rename modules/api/src/main/java/org/apache/ignite/schema/{SortedIndex.java =>
definition/index/IndexDefinition.java} (73%)
copy modules/api/src/main/java/org/apache/ignite/schema/{PartialIndex.java =>
definition/index/PartialIndexDefinition.java} (89%)
copy modules/api/src/main/java/org/apache/ignite/schema/{ =>
definition/index}/SortOrder.java (95%)
rename
modules/api/src/main/java/org/apache/ignite/schema/{SortedIndexColumn.java =>
definition/index/SortedIndexColumnDefinition.java} (88%)
rename
modules/api/src/main/java/org/apache/ignite/{table/KeyValueBinaryView.java =>
schema/definition/index/SortedIndexDefinition.java} (66%)
copy modules/api/src/main/java/org/apache/ignite/schema/{builder =>
definition/index}/package-info.java (89%)
rename modules/api/src/main/java/org/apache/ignite/schema/{ =>
definition}/package-info.java (95%)
delete mode 100644
modules/api/src/main/java/org/apache/ignite/table/TableView.java
copy
modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/{exec/ExecutionService.java
=> QueryProcessor.java} (63%)
rename modules/{api/src/main/java/org/apache/ignite/schema/TableIndex.java =>
calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/SqlCursor.java}
(66%)
copy
modules/{schema/src/main/java/org/apache/ignite/internal/schema/builder/AbstractIndexBuilder.java
=>
calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/SqlQueryType.java}
(50%)
create mode 100644
modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/ModifyNode.java
create mode 100644
modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/TableScanNode.java
copy modules/{api/src/main/java/org/apache/ignite/schema/PartialIndex.java =>
calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/sql/IgniteSqlConformance.java}
(55%)
create mode 100644
modules/cli/src/main/resources/cli.java.util.logging.properties
create mode 100644
modules/cli/src/main/resources/ignite.java.util.logging.properties
delete mode 100644 modules/cli/src/main/resources/logback.xml
delete mode 100644 modules/cli/src/test/resources/logback-test.xml
rename
modules/{api/src/main/java/org/apache/ignite/schema/builder/SchemaObjectBuilder.java
=>
client-common/src/main/java/org/apache/ignite/client/proto/query/ClientMessage.java}
(59%)
create mode 100644
modules/client-common/src/main/java/org/apache/ignite/client/proto/query/IgniteQueryErrorCode.java
create mode 100644
modules/client-common/src/main/java/org/apache/ignite/client/proto/query/JdbcQueryEventHandler.java
copy modules/{api/src/main/java/org/apache/ignite/schema/ColumnarIndex.java =>
client-common/src/main/java/org/apache/ignite/client/proto/query/JdbcStatementType.java}
(56%)
create mode 100644
modules/client-common/src/main/java/org/apache/ignite/client/proto/query/SqlStateCode.java
create mode 100644
modules/client-common/src/main/java/org/apache/ignite/client/proto/query/event/BatchExecuteRequest.java
create mode 100644
modules/client-common/src/main/java/org/apache/ignite/client/proto/query/event/BatchExecuteResult.java
create mode 100644
modules/client-common/src/main/java/org/apache/ignite/client/proto/query/event/ClientMessageUtils.java
create mode 100644
modules/client-common/src/main/java/org/apache/ignite/client/proto/query/event/JdbcColumnMeta.java
create mode 100644
modules/client-common/src/main/java/org/apache/ignite/client/proto/query/event/JdbcMetaColumnsRequest.java
create mode 100644
modules/client-common/src/main/java/org/apache/ignite/client/proto/query/event/JdbcMetaColumnsResult.java
create mode 100644
modules/client-common/src/main/java/org/apache/ignite/client/proto/query/event/JdbcMetaPrimaryKeysRequest.java
create mode 100644
modules/client-common/src/main/java/org/apache/ignite/client/proto/query/event/JdbcMetaPrimaryKeysResult.java
create mode 100644
modules/client-common/src/main/java/org/apache/ignite/client/proto/query/event/JdbcMetaSchemasRequest.java
create mode 100644
modules/client-common/src/main/java/org/apache/ignite/client/proto/query/event/JdbcMetaSchemasResult.java
create mode 100644
modules/client-common/src/main/java/org/apache/ignite/client/proto/query/event/JdbcMetaTablesRequest.java
create mode 100644
modules/client-common/src/main/java/org/apache/ignite/client/proto/query/event/JdbcMetaTablesResult.java
create mode 100644
modules/client-common/src/main/java/org/apache/ignite/client/proto/query/event/JdbcPrimaryKeyMeta.java
create mode 100644
modules/client-common/src/main/java/org/apache/ignite/client/proto/query/event/JdbcQueryMetadataRequest.java
create mode 100644
modules/client-common/src/main/java/org/apache/ignite/client/proto/query/event/JdbcTableMeta.java
create mode 100644
modules/client-common/src/main/java/org/apache/ignite/client/proto/query/event/Query.java
create mode 100644
modules/client-common/src/main/java/org/apache/ignite/client/proto/query/event/QueryCloseRequest.java
copy
modules/{schema/src/main/java/org/apache/ignite/internal/schema/IndexColumnImpl.java
=>
client-common/src/main/java/org/apache/ignite/client/proto/query/event/QueryCloseResult.java}
(67%)
create mode 100644
modules/client-common/src/main/java/org/apache/ignite/client/proto/query/event/QueryExecuteRequest.java
create mode 100644
modules/client-common/src/main/java/org/apache/ignite/client/proto/query/event/QueryExecuteResult.java
create mode 100644
modules/client-common/src/main/java/org/apache/ignite/client/proto/query/event/QueryFetchRequest.java
create mode 100644
modules/client-common/src/main/java/org/apache/ignite/client/proto/query/event/QueryFetchResult.java
create mode 100644
modules/client-common/src/main/java/org/apache/ignite/client/proto/query/event/QuerySingleResult.java
create mode 100644
modules/client-common/src/main/java/org/apache/ignite/client/proto/query/event/Response.java
copy modules/{api/src/main/java/org/apache/ignite/schema/builder =>
client-common/src/main/java/org/apache/ignite/client/proto/query/event}/package-info.java
(90%)
copy modules/{api/src/main/java/org/apache/ignite/app =>
client-common/src/main/java/org/apache/ignite/client/proto/query}/package-info.java
(84%)
rename modules/client-common/src/main/java/org/apache/ignite/{ =>
internal}/client/proto/ClientDataType.java (90%)
rename modules/client-common/src/main/java/org/apache/ignite/{ =>
internal}/client/proto/ClientErrorCode.java (95%)
rename modules/client-common/src/main/java/org/apache/ignite/{ =>
internal}/client/proto/ClientMessageCommon.java (95%)
rename modules/client-common/src/main/java/org/apache/ignite/{ =>
internal}/client/proto/ClientMessageDecoder.java (92%)
rename modules/client-common/src/main/java/org/apache/ignite/{ =>
internal}/client/proto/ClientMessagePacker.java (74%)
rename modules/client-common/src/main/java/org/apache/ignite/{ =>
internal}/client/proto/ClientMessageUnpacker.java (82%)
rename modules/client-common/src/main/java/org/apache/ignite/{ =>
internal}/client/proto/ClientMsgPackType.java (91%)
rename modules/client-common/src/main/java/org/apache/ignite/{ =>
internal}/client/proto/ClientOp.java (78%)
rename modules/client-common/src/main/java/org/apache/ignite/{ =>
internal}/client/proto/ProtocolVersion.java (98%)
rename modules/client-common/src/main/java/org/apache/ignite/{ =>
internal}/client/proto/ServerMessageType.java (95%)
rename
modules/{api/src/main/java/org/apache/ignite/schema/SchemaNamedObject.java =>
client-common/src/main/java/org/apache/ignite/internal/client/proto/TuplePart.java}
(75%)
rename modules/client-common/src/main/java/org/apache/ignite/{ =>
internal}/client/proto/package-info.java (94%)
rename modules/client-common/src/test/java/org/apache/ignite/{ =>
internal}/client/proto/ClientMessageDecoderTest.java (98%)
rename modules/client-common/src/test/java/org/apache/ignite/{ =>
internal}/client/proto/ClientMessagePackerUnpackerTest.java (78%)
create mode 100644
modules/client-handler/src/main/java/org/apache/ignite/client/handler/JdbcQueryEventHandlerImpl.java
create mode 100644
modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/sql/ClientSqlCloseRequest.java
create mode 100644
modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/sql/ClientSqlColumnMetadataRequest.java
create mode 100644
modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/sql/ClientSqlExecuteBatchRequest.java
create mode 100644
modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/sql/ClientSqlExecuteRequest.java
create mode 100644
modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/sql/ClientSqlFetchRequest.java
create mode 100644
modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/sql/ClientSqlPrimaryKeyMetadataRequest.java
create mode 100644
modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/sql/ClientSqlQueryMetadataRequest.java
create mode 100644
modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/sql/ClientSqlSchemasMetadataRequest.java
create mode 100644
modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/sql/ClientSqlTableMetadataRequest.java
create mode 100644
modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/sql/JdbcMetadataCatalog.java
copy modules/{api/src/main/java/org/apache/ignite/schema/builder =>
client-handler/src/main/java/org/apache/ignite/client/handler/requests/sql}/package-info.java
(90%)
copy
modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/table/{ClientTupleGetRequest.java
=> ClientTupleContainsKeyRequest.java} (81%)
create mode 100644
modules/client/src/main/java/org/apache/ignite/internal/client/query/JdbcClientQueryEventHandler.java
copy
modules/{table/src/main/java/org/apache/ignite/internal/table/KVBinaryViewImpl.java
=>
client/src/main/java/org/apache/ignite/internal/client/table/ClientKeyValueBinaryView.java}
(50%)
create mode 100644
modules/client/src/main/java/org/apache/ignite/internal/client/table/ClientRecordBinaryView.java
create mode 100644
modules/client/src/main/java/org/apache/ignite/internal/jdbc/ConnectionProperties.java
create mode 100644
modules/client/src/main/java/org/apache/ignite/internal/jdbc/ConnectionPropertiesImpl.java
create mode 100644
modules/client/src/main/java/org/apache/ignite/internal/jdbc/JdbcConnection.java
create mode 100644
modules/client/src/main/java/org/apache/ignite/internal/jdbc/JdbcDatabaseMetadata.java
create mode 100644
modules/client/src/main/java/org/apache/ignite/internal/jdbc/JdbcPreparedStatement.java
create mode 100644
modules/client/src/main/java/org/apache/ignite/internal/jdbc/JdbcResultSet.java
create mode 100644
modules/client/src/main/java/org/apache/ignite/internal/jdbc/JdbcResultSetMetadata.java
create mode 100644
modules/client/src/main/java/org/apache/ignite/internal/jdbc/JdbcStatement.java
copy modules/{api/src/main/java/org/apache/ignite/schema/builder =>
client/src/main/java/org/apache/ignite/internal/jdbc}/package-info.java (90%)
create mode 100644
modules/client/src/main/java/org/apache/ignite/jdbc/IgniteJdbcDriver.java
rename modules/{api/src/main/java/org/apache/ignite/schema/builder =>
client/src/main/java/org/apache/ignite/jdbc}/package-info.java (90%)
create mode 100644
modules/client/src/main/resources/META-INF/services/java.sql.Driver
create mode 100644
modules/client/src/test/java/org/apache/ignite/client/AbstractClientTableTest.java
create mode 100644
modules/client/src/test/java/org/apache/ignite/client/ClientKeyValueBinaryViewTest.java
create mode 100644
modules/client/src/test/java/org/apache/ignite/client/fakes/FakeCursor.java
rename modules/{api/src/main/java/org/apache/ignite/schema/ColumnarIndex.java
=>
client/src/test/java/org/apache/ignite/client/fakes/FakeIgniteQueryProcessor.java}
(60%)
copy modules/{platforms/dotnet/Apache.Ignite/Internal/Table/Schema.cs =>
configuration-annotation-processor/src/integrationTest/resources/org/apache/ignite/internal/configuration/processor/internal/InvalidDirectAccessConfigurationSchema.java}
(54%)
rename modules/{api/src/main/java/org/apache/ignite/schema/PartialIndex.java
=>
configuration-api/src/main/java/org/apache/ignite/configuration/ConfigurationListenOnlyException.java}
(69%)
create mode 100644
modules/configuration-api/src/main/java/org/apache/ignite/configuration/DirectConfigurationProperty.java
create mode 100644
modules/configuration-api/src/main/java/org/apache/ignite/configuration/annotation/DirectAccess.java
copy
modules/{api/src/main/java/org/apache/ignite/configuration/schemas/table/TableValidator.java
=>
configuration-api/src/main/java/org/apache/ignite/configuration/validation/ExceptKeys.java}
(75%)
copy
modules/{api/src/main/java/org/apache/ignite/configuration/schemas/table/TableValidator.java
=>
configuration-api/src/main/java/org/apache/ignite/configuration/validation/OneOf.java}
(72%)
create mode 100644
modules/configuration/src/main/java/org/apache/ignite/internal/configuration/DirectDynamicConfiguration.java
create mode 100644
modules/configuration/src/main/java/org/apache/ignite/internal/configuration/DirectDynamicProperty.java
create mode 100644
modules/configuration/src/main/java/org/apache/ignite/internal/configuration/DirectNamedListConfiguration.java
create mode 100644
modules/configuration/src/main/java/org/apache/ignite/internal/configuration/util/ConfigurationContainer.java
create mode 100644
modules/configuration/src/main/java/org/apache/ignite/internal/configuration/validation/ExceptKeysValidator.java
create mode 100644
modules/configuration/src/main/java/org/apache/ignite/internal/configuration/validation/OneOfValidator.java
create mode 100644
modules/configuration/src/test/java/org/apache/ignite/internal/configuration/DirectPropertiesTest.java
create mode 100644
modules/configuration/src/test/java/org/apache/ignite/internal/configuration/notifications/ConfigurationAnyListenerTest.java
create mode 100644
modules/configuration/src/test/java/org/apache/ignite/internal/configuration/notifications/ConfigurationListenerTestUtils.java
rename
modules/{affinity/src/main/java/org/apache/ignite/internal/affinity/event/AffinityEvent.java
=>
configuration/src/test/java/org/apache/ignite/internal/configuration/testframework/BasicConfigurationSchema.java}
(68%)
copy modules/{api/src/main/java/org/apache/ignite/schema/PrimaryIndex.java =>
configuration/src/test/java/org/apache/ignite/internal/configuration/testframework/ExtendedConfigurationSchema.java}
(64%)
create mode 100644
modules/configuration/src/test/java/org/apache/ignite/internal/configuration/validation/OneOfValidatorTest.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/util/IgniteSpinBusyLock.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/util/IgniteSpinReadWriteLock.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/testframework/WorkDirectoryExtensionTest.java
create mode 100644
modules/network/src/main/java/org/apache/ignite/network/NodeFinderFactory.java
delete mode 100644
modules/network/src/test/java/org/apache/ignite/network/LocalPortRangeNodeFinder.java
copy modules/platforms/dotnet/Apache.Ignite.Tests/Table/{TablesTests.cs =>
CustomTestIgniteTuple.cs} (53%)
copy
modules/platforms/dotnet/Apache.Ignite/Internal/Proto/{ClientMessagePackType.cs
=> IgniteUuid.cs} (58%)
create mode 100644 modules/platforms/dotnet/Apache_Ignite_logo_128x128.png
delete mode 100644
modules/raft-client/src/main/java/org/apache/ignite/raft/client/RaftErrorCode.java
delete mode 100644
modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/AddLearnersRequest.java
delete mode 100644
modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/AddPeersRequest.java
delete mode 100644
modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/ChangePeersResponse.java
delete mode 100644
modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/GetLeaderRequest.java
delete mode 100644
modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/GetLeaderResponse.java
delete mode 100644
modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/GetPeersRequest.java
delete mode 100644
modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/GetPeersResponse.java
delete mode 100644
modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/RaftClientMessageGroup.java
delete mode 100644
modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/RaftErrorResponse.java
delete mode 100644
modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/RemoveLearnersRequest.java
delete mode 100644
modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/RemovePeersRequest.java
delete mode 100644
modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/SnapshotRequest.java
delete mode 100644
modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/TransferLeadershipRequest.java
delete mode 100644
modules/raft-client/src/main/java/org/apache/ignite/raft/client/service/impl/RaftGroupServiceImpl.java
create mode 100644
modules/raft/src/integrationTest/java/org/apache/ignite/internal/raft/ITLozaTest.java
rename
modules/{raft-client/src/main/java/org/apache/ignite/raft/client/message =>
raft/src/main/java/org/apache/ignite/raft/jraft/rpc}/ActionRequest.java (80%)
rename
modules/{raft-client/src/main/java/org/apache/ignite/raft/client/message =>
raft/src/main/java/org/apache/ignite/raft/jraft/rpc}/ActionResponse.java (77%)
rename
modules/raft/src/main/java/org/apache/ignite/raft/jraft/rpc/impl/{client =>
}/ActionRequestProcessor.java (75%)
rename
modules/{raft-client/src/main/java/org/apache/ignite/raft/client/exception =>
raft/src/main/java/org/apache/ignite/raft/jraft/rpc/impl}/RaftException.java
(56%)
create mode 100644
modules/raft/src/main/java/org/apache/ignite/raft/jraft/rpc/impl/RaftGroupServiceImpl.java
create mode 100644
modules/raft/src/main/java/org/apache/ignite/raft/jraft/rpc/impl/cli/IgniteCliRpcRequestClosure.java
delete mode 100644
modules/raft/src/main/java/org/apache/ignite/raft/jraft/rpc/impl/client/GetLeaderRequestProcessor.java
delete mode 100644
modules/raft/src/main/java/org/apache/ignite/raft/jraft/rpc/impl/client/SnapshotRequestProcessor.java
create mode 100644
modules/raft/src/test/java/org/apache/ignite/disruptor/StripedDisruptorTest.java
rename
modules/{raft-client/src/test/java/org/apache/ignite/raft/client/service =>
raft/src/test/java/org/apache/ignite/raft/jraft/core}/RaftGroupServiceTest.java
(51%)
copy modules/{api/src/main/java/org/apache/ignite/app =>
rest/src/main/java/org/apache/ignite/rest/netty}/package-info.java (84%)
mode change 100644 => 100755
copy modules/{api/src/main/java/org/apache/ignite/app =>
rest/src/main/java/org/apache/ignite/rest}/package-info.java (86%)
mode change 100644 => 100755
copy modules/{api/src/main/java/org/apache/ignite/app =>
rest/src/main/java/org/apache/ignite/rest/presentation/hocon}/package-info.java
(87%)
mode change 100644 => 100755
copy modules/{api/src/main/java/org/apache/ignite/app =>
rest/src/main/java/org/apache/ignite/rest/presentation}/package-info.java (84%)
mode change 100644 => 100755
rename modules/{api/src/main/java/org/apache/ignite/app =>
rest/src/main/java/org/apache/ignite/rest/routes}/package-info.java (86%)
mode change 100644 => 100755
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/AbstractBasicIntegrationTest.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/ITAggregatesTest.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/ITDataTypesTest.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/ITFunctionsTest.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/ITIndexSpoolTest.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/ITMetadataTest.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/ITMixedQueriesTest.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/ITOrToUnionRuleTest.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/ITProjectScanMergeRuleTest.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/ITSecondaryIndexTest.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/ITSetOpTest.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/ITSortAggregateTest.java
copy modules/{api/src/main/java/org/apache/ignite/schema/PrimaryIndex.java =>
runner/src/integrationTest/java/org/apache/ignite/internal/calcite/util/Commons.java}
(69%)
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/util/QueryChecker.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/configuration/ITDistributedConfigurationPropertiesTest.java
rename modules/runner/src/integrationTest/java/org/apache/ignite/internal/{ =>
configuration}/storage/ITDistributedConfigurationStorageTest.java (91%)
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/ITBaselineChangesTest.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/ITTablesApiTest.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/AbstractJdbcSelfTest.java
copy
modules/{schema/src/test/java/org/apache/ignite/internal/schema/builder/SortedIndexBuilderTest.java
=>
runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ITJdbcConnectionPropertiesTest.java}
(52%)
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ITJdbcConnectionSelfTest.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ITJdbcMetadataSelfTest.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ITJdbcResultSetSelfTest.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ITJdbcStatementSelfTest.java
rename modules/runner/src/main/java/org/apache/ignite/internal/{ =>
configuration}/storage/DistributedConfigurationStorage.java (87%)
rename modules/runner/src/main/java/org/apache/ignite/internal/{ =>
configuration}/storage/LocalConfigurationStorage.java (74%)
rename
modules/runner/src/main/resources/META-INF/services/{org.apache.ignite.app.Ignition
=> org.apache.ignite.Ignition} (100%)
create mode 100644
modules/runner/src/test/java/org/apache/ignite/internal/configuration/storage/ConfigurationStorageTest.java
create mode 100644
modules/runner/src/test/java/org/apache/ignite/internal/configuration/storage/DistributedConfigurationStorageTest.java
copy
modules/{storage-rocksdb/src/test/java/org/apache/ignite/internal/storage/rocksdb/RocksDbStorageTest.java
=>
runner/src/test/java/org/apache/ignite/internal/configuration/storage/LocalConfigurationStorageTest.java}
(51%)
delete mode 100644
modules/schema/src/main/java/org/apache/ignite/internal/schema/SchemaManager.java
rename modules/{table/src/main/java/org/apache/ignite/internal/table =>
schema/src/main/java/org/apache/ignite/internal/schema}/SchemaMismatchException.java
(87%)
create mode 100644
modules/schema/src/main/java/org/apache/ignite/internal/schema/SchemaUtils.java
delete mode 100644
modules/schema/src/main/java/org/apache/ignite/internal/schema/builder/PrimaryKeyBuilderImpl.java
delete mode 100644
modules/schema/src/main/java/org/apache/ignite/internal/schema/builder/SchemaTableBuilderImpl.java
delete mode 100644
modules/schema/src/main/java/org/apache/ignite/internal/schema/configuration/SchemaTableValidatorImpl.java
create mode 100644
modules/schema/src/main/java/org/apache/ignite/internal/schema/configuration/TableValidatorImpl.java
rename modules/schema/src/main/java/org/apache/ignite/internal/schema/{ =>
definition}/AbstractSchemaObject.java (88%)
rename
modules/schema/src/main/java/org/apache/ignite/internal/schema/{ColumnImpl.java
=> definition/ColumnDefinitionImpl.java} (67%)
rename
modules/schema/src/main/java/org/apache/ignite/internal/schema/{SchemaTableImpl.java
=> definition/TableDefinitionImpl.java} (59%)
rename modules/schema/src/main/java/org/apache/ignite/internal/schema/{ =>
definition}/builder/AbstractIndexBuilder.java (65%)
rename
modules/schema/src/main/java/org/apache/ignite/internal/schema/{builder/TableColumnBuilderImpl.java
=> definition/builder/ColumnDefinitionBuilderImpl.java} (59%)
rename
modules/schema/src/main/java/org/apache/ignite/internal/schema/{builder/HashIndexBuilderImpl.java
=> definition/builder/HashIndexDefinitionBuilderImpl.java} (63%)
rename
modules/schema/src/main/java/org/apache/ignite/internal/schema/{builder/PartialIndexBuilderImpl.java
=> definition/builder/PartialIndexDefinitionBuilderImpl.java} (67%)
create mode 100644
modules/schema/src/main/java/org/apache/ignite/internal/schema/definition/builder/PrimaryKeyDefinitionBuilderImpl.java
rename
modules/schema/src/main/java/org/apache/ignite/internal/schema/{builder/SortedIndexBuilderImpl.java
=> definition/builder/SortedIndexDefinitionBuilderImpl.java} (69%)
create mode 100644
modules/schema/src/main/java/org/apache/ignite/internal/schema/definition/builder/TableSchemaBuilderImpl.java
rename
modules/schema/src/main/java/org/apache/ignite/internal/schema/{HashIndexImpl.java
=> definition/index/HashIndexDefinitionImpl.java} (66%)
rename
modules/schema/src/main/java/org/apache/ignite/internal/schema/{IndexColumnImpl.java
=> definition/index/IndexColumnDefinitionImpl.java} (70%)
rename
modules/schema/src/main/java/org/apache/ignite/internal/schema/{PartialIndexImpl.java
=> definition/index/PartialIndexDefinitionImpl.java} (71%)
rename
modules/schema/src/main/java/org/apache/ignite/internal/schema/{PrimaryIndexImpl.java
=> definition/index/PrimaryKeyDefinitionImpl.java} (55%)
rename
modules/schema/src/main/java/org/apache/ignite/internal/schema/{SortedIndexColumnImpl.java
=> definition/index/SortedIndexColumnDefinitionImpl.java} (67%)
rename
modules/schema/src/main/java/org/apache/ignite/internal/schema/{SortedIndexImpl.java
=> definition/index/SortedIndexDefinitionImpl.java} (64%)
delete mode 100644
modules/schema/src/main/java/org/apache/ignite/internal/schema/event/SchemaEvent.java
delete mode 100644
modules/schema/src/main/java/org/apache/ignite/internal/schema/event/SchemaEventParameters.java
create mode 100644
modules/schema/src/main/java/org/apache/ignite/internal/schema/marshaller/schema/AbstractSchemaSerializer.java
copy
modules/{configuration-api/src/main/java/org/apache/ignite/configuration/ConfigurationProperty.java
=>
schema/src/main/java/org/apache/ignite/internal/schema/marshaller/schema/SchemaSerializer.java}
(53%)
create mode 100644
modules/schema/src/main/java/org/apache/ignite/internal/schema/marshaller/schema/SchemaSerializerImpl.java
rename
modules/schema/src/test/java/org/apache/ignite/internal/schema/{ColumnTest.java
=> ColumnDefinitionTest.java} (98%)
rename
modules/schema/src/test/java/org/apache/ignite/internal/schema/builder/{TableColumnBuilderTest.java
=> ColumnDefinitionBuilderTest.java} (73%)
rename
modules/schema/src/test/java/org/apache/ignite/internal/schema/builder/{HashIndexBuilderTest.java
=> HashIndexDefinitionBuilderTest.java} (80%)
rename
modules/schema/src/test/java/org/apache/ignite/internal/schema/builder/{PartialIndexBuilderTest.java
=> PartialIndexDefinitionBuilderTest.java} (79%)
delete mode 100644
modules/schema/src/test/java/org/apache/ignite/internal/schema/builder/PrimaryKeyBuilderTest.java
create mode 100644
modules/schema/src/test/java/org/apache/ignite/internal/schema/builder/PrimaryKeyDefinitionDefinitionBuilderTest.java
rename
modules/schema/src/test/java/org/apache/ignite/internal/schema/builder/{SortedIndexBuilderTest.java
=> SortedIndexDefinitionBuilderTest.java} (67%)
rename
modules/schema/src/test/java/org/apache/ignite/internal/schema/builder/{SchemaTableBuilderTest.java
=> TableDefinitionBuilderTest.java} (77%)
create mode 100644
modules/schema/src/test/java/org/apache/ignite/internal/schema/configuration/TableValidatorImplTest.java
create mode 100644
modules/schema/src/test/java/org/apache/ignite/internal/schema/registry/UpgradingRowAdapterTest.java
create mode 100644
modules/schema/src/test/java/org/apache/ignite/internal/schema/serializer/AbstractSerializerTest.java
rename
modules/storage-api/src/main/java/org/apache/ignite/internal/storage/{Storage.java
=> PartitionStorage.java} (89%)
rename modules/{api/src/main/java/org/apache/ignite/schema/SortOrder.java =>
storage-api/src/main/java/org/apache/ignite/internal/storage/engine/DataRegion.java}
(71%)
create mode 100644
modules/storage-api/src/main/java/org/apache/ignite/internal/storage/engine/StorageEngine.java
rename modules/{api/src/main/java/org/apache/ignite/schema/Column.java =>
storage-api/src/main/java/org/apache/ignite/internal/storage/engine/TableStorage.java}
(55%)
rename
modules/storage-api/src/test/java/org/apache/ignite/internal/storage/{AbstractStorageTest.java
=> AbstractPartitionStorageTest.java} (89%)
rename
modules/storage-api/src/{main/java/org/apache/ignite/internal/storage/basic/ConcurrentHashMapStorage.java
=>
test/java/org/apache/ignite/internal/storage/basic/ConcurrentHashMapPartitionStorage.java}
(69%)
create mode 100644
modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/RocksDbDataRegion.java
rename
modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/{RocksDbStorage.java
=> RocksDbPartitionStorage.java} (72%)
create mode 100644
modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/RocksDbStorageEngine.java
create mode 100644
modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/RocksDbTableStorage.java
create mode 100644
modules/table/src/integrationTest/java/org/apache/ignite/distributed/ITInternalTableScanTest.java
copy
modules/{api/src/main/java/org/apache/ignite/configuration/schemas/table/TableIndexConfigurationSchema.java
=>
table/src/main/java/org/apache/ignite/internal/configuration/schema/ExtendedTableConfigurationSchema.java}
(52%)
rename modules/{api/src/main/java/org/apache/ignite/schema/PrimaryIndex.java
=>
table/src/main/java/org/apache/ignite/internal/configuration/schema/SchemaConfigurationSchema.java}
(67%)
rename
modules/table/src/main/java/org/apache/ignite/internal/table/{KVBinaryViewImpl.java
=> KeyValueBinaryViewImpl.java} (94%)
rename
modules/table/src/main/java/org/apache/ignite/internal/table/{KVViewImpl.java
=> KeyValueViewImpl.java} (94%)
copy
modules/table/src/main/java/org/apache/ignite/internal/table/{TableImpl.java =>
RecordBinaryViewImpl.java} (86%)
copy
modules/{configuration-api/src/main/java/org/apache/ignite/configuration/notifications/ConfigurationListener.java
=>
table/src/main/java/org/apache/ignite/internal/table/distributed/command/scan/ScanCloseCommand.java}
(53%)
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/scan/ScanInitCommand.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/scan/ScanRetrieveBatchCommand.java
rename
modules/table/src/test/java/org/apache/ignite/internal/table/{KVBinaryViewOperationsTest.java
=> KeyValueBinaryViewOperationsTest.java} (89%)
rename
modules/table/src/test/java/org/apache/ignite/internal/table/{TableBinaryViewOperationsTest.java
=> RecordBinaryViewOperationsTest.java} (90%)
