This is an automated email from the ASF dual-hosted git repository.
tkalkirill pushed a change to branch ignite-28331
in repository https://gitbox.apache.org/repos/asf/ignite.git
from e75e6dbfd54 Merge branch 'master' into ignite-28331
add c8a6958d49d IGNITE-27938 Java thin: Add ability to configure cache
partitions count - Fixes #12783.
add 59db10bf73a IGNITE-28219 Control utility: Add event management
commands - Fixes #12887.
add 5efb94234db IGNITE-28251 Supplementing the documentation regarding
maintenance mode scheduling (#12899)
add 11faa99f654 IGNITE-28260 Remove PartitionReservationsMap (#12941)
add 091b0580101 IGNITE-27940 SQL Calcite: Refactor
IgniteSqlCallRewriteTable usage - Fixes #12785.
add fa2c7c606eb IGNITE-28276 Remove TxLockList (#12945)
add d32b88ebc53 IGNITE-28274 JDBC connection parameter 'keepBinary' need
to be described (#12903)
add 918de0de649 IGNITE-28364 Finalize migration of GridCacheMessage
(#12940)
add d2acf963208 IGNITE-27929 Add parent process listener to
IgniteNodeRunner (#12933)
add ffaea42d2e9 IGNITE-27716 Add group name to DumpReader logs (#12840)
add 03a96c25cb0 IGNITE-28348 Fixed NullPointerException while executing
putAllConflict/removeAllConflict requests during cache startup (#12943)
add 5a949f374bd IGNITE-28307 Message Id deduplication (#12929)
add f456f590ad4 IGNITE-28387 Deprecate lazy flag of SqlFieldsQuery in
platforms (#12949)
add 298a2552630 IGNITE-28353 Replace idxNames and idxDefs with a map in
IndexQueryResultMeta (#12950)
add caa5697ddd6 IGNITE-28256 Remove IntLongMap (#12909)
add e2384f8dac4 IGNITE-28396 Remove NodeSpecificData (#12956)
add 8d1c533df89 IGNITE-28299 Fix local runs with VPN on MacOS (#12915)
add 8a26b182415 IGNITE-27899 : Make TcpDiscoveryNode implement message v2
(#12955)
add ee2df95b537 IGNITE-28264 Extract enum from message class, use
serializer to encode and decode the enum (#12916)
add ca400bb025e IGNITE-27818 PerfStat: Add cache store operations (#12954)
add 9eb86031c34 IGNITE-28051 Use MessageSerializer for
ServiceChangeBatchRequest, ServiceClusterDeploymentResultBatch (#12895)
add 4aeb48d71c6 Merge branch 'master' into ignite-28331
add 1858e222559 IGNITE-27968 Use message serializer for
ExchangeFailureMessage (#12963)
add 5dddf25ab99 Merge branch 'master' into ignite-28331
add 5e29a5bcdbd IGNITE-28331 wip
add a785811d4cf Merge branch 'ignite-28331-v2' into ignite-28331
No new revisions were added by this update.
Summary of changes:
docs/_docs/SQL/JDBC/jdbc-driver.adoc | 58 +++
docs/_docs/events/listening-to-events.adoc | 4 +-
docs/_docs/maintenance-mode.adoc | 2 +-
docs/_docs/tools/control-script.adoc | 54 ++-
.../query/calcite/CalciteQueryProcessor.java | 6 +-
.../query/calcite/exec/ArrayRowHandler.java | 7 +-
.../query/calcite/exec/IndexFirstLastScan.java | 14 +-
.../processors/query/calcite/exec/IndexScan.java | 69 +--
.../calcite/exec/IndexWrappedKeyFirstLastScan.java | 64 +++
.../query/calcite/exec/IndexWrappedKeyScan.java | 101 +++++
.../processors/query/calcite/exec/RowHandler.java | 4 -
.../query/calcite/message/CalciteErrorMessage.java | 4 -
.../query/calcite/message/CalciteMessage.java | 5 -
.../calcite/message/CalciteMessageFactory.java | 9 +-
.../query/calcite/message/MessageType.java | 25 +-
.../calcite/prepare/IgniteSqlCallRewriteTable.java | 34 +-
...pareService.java => IgniteSqlNodeRewriter.java} | 12 +-
.../query/calcite/prepare/IgniteSqlValidator.java | 31 +-
.../query/calcite/schema/CacheIndexImpl.java | 115 ++---
...ndexImpl.java => CacheWrappedKeyIndexImpl.java} | 102 ++---
.../query/calcite/schema/SchemaHolderImpl.java | 60 ++-
.../exec/rel/AbstractSetOpExecutionTest.java | 7 +-
.../query/calcite/exec/rel/BaseAggregateTest.java | 7 +-
.../rel/HashAggregateSingleGroupExecutionTest.java | 7 +-
.../OperatorsExtensionIntegrationTest.java | 22 +-
.../internal/MessageSerializerGenerator.java | 2 +-
.../junits/IgniteCompatibilityNodeRunner.java | 4 +
.../commandline/CommandHandlerParsingTest.java | 4 +-
.../testsuites/IgniteControlUtilityTestSuite2.java | 3 +
.../ignite/util/GridCommandHandlerEventTest.java | 206 +++++++++
.../apache/ignite/IgniteJdbcThinDataSource.java | 4 +
.../apache/ignite/cache/query/SqlFieldsQuery.java | 4 +-
.../ignite/client/ClientAffinityConfiguration.java | 88 ++++
.../ignite/client/ClientCacheConfiguration.java | 25 ++
.../java/org/apache/ignite/dump/DumpReader.java | 25 +-
.../ignite/internal/ClusterMetricsSnapshot.java | 3 +
.../org/apache/ignite/internal/ExchangeInfo.java | 4 -
.../org/apache/ignite/internal/GridComponent.java | 5 +-
.../ignite/internal/GridJobCancelRequest.java | 4 -
.../ignite/internal/GridJobExecuteRequest.java | 4 -
.../ignite/internal/GridJobExecuteResponse.java | 4 -
.../ignite/internal/GridJobSiblingsRequest.java | 4 -
.../ignite/internal/GridJobSiblingsResponse.java | 4 -
.../ignite/internal/GridTaskCancelRequest.java | 4 -
.../ignite/internal/GridTaskSessionRequest.java | 4 -
.../ignite/internal/IgniteDiagnosticRequest.java | 4 -
.../ignite/internal/IgniteDiagnosticResponse.java | 4 -
.../org/apache/ignite/internal/TxEntriesInfo.java | 4 -
.../java/org/apache/ignite/internal/TxInfo.java | 4 -
.../cache/query/index/IndexQueryResultMeta.java | 46 +-
.../query/index/sorted/IndexKeyDefinition.java | 5 -
.../query/index/sorted/IndexKeyTypeSettings.java | 5 -
.../ignite/internal/client/thin/ClientUtils.java | 29 +-
.../client/thin/ProtocolBitmaskFeature.java | 5 +-
.../internal/management/IgniteCommandRegistry.java | 4 +-
.../EventCommand.java} | 15 +-
.../EventCommandArg.java} | 18 +-
.../EventDisableCommand.java} | 33 +-
.../EventEnableCommand.java} | 33 +-
.../EventListCommand.java} | 42 +-
.../EventListCommandArg.java} | 18 +-
.../internal/management/event/EventListTask.java | 103 +++++
.../management/event/EventManagementTask.java | 105 +++++
.../managers/checkpoint/GridCheckpointRequest.java | 4 -
.../managers/communication/CompressedMessage.java | 8 -
.../managers/communication/ErrorMessage.java | 4 -
.../managers/communication/GridIoMessage.java | 4 -
.../communication/GridIoMessageFactory.java | 361 ++++++++-------
.../communication/GridIoSecurityAwareMessage.java | 7 -
.../managers/communication/GridIoUserMessage.java | 4 -
.../communication/IgniteIoTestMessage.java | 4 -
.../communication/IgniteMessageFactoryImpl.java | 8 +
.../communication/SessionChannelMessage.java | 7 -
.../deployment/GridDeploymentInfoBean.java | 4 -
.../managers/deployment/GridDeploymentRequest.java | 4 -
.../deployment/GridDeploymentResponse.java | 4 -
.../discovery/DiscoveryMessageFactory.java | 231 +++++-----
.../managers/discovery/GridDiscoveryManager.java | 13 +-
.../SecurityAwareCustomMessageWrapper.java | 4 -
.../encryption/ChangeCacheEncryptionRequest.java | 4 -
.../encryption/GenerateEncryptionKeyRequest.java | 4 -
.../encryption/GenerateEncryptionKeyResponse.java | 4 -
.../encryption/MasterKeyChangeRequest.java | 4 -
.../eventstorage/GridEventStorageManager.java | 85 +++-
.../eventstorage/GridEventStorageMessage.java | 4 -
.../internal/processors/authentication/User.java | 4 -
.../authentication/UserAcceptedMessage.java | 4 -
.../UserAuthenticateRequestMessage.java | 4 -
.../UserAuthenticateResponseMessage.java | 4 -
.../authentication/UserManagementOperation.java | 5 -
.../UserManagementOperationFinishedMessage.java | 4 -
.../authentication/UserProposedMessage.java | 4 -
.../cache/CacheAffinityChangeMessage.java | 4 -
.../cache/CacheEntryPredicateAdapter.java | 109 +----
...eployable.java => CacheEntryPredicateType.java} | 29 +-
.../processors/cache/CacheEvictionEntry.java | 5 -
.../processors/cache/CacheInvokeDirectResult.java | 4 -
.../cache/CacheStatisticsClearMessage.java | 5 -
.../cache/CacheStatisticsModeChangeMessage.java | 4 -
.../cache/ClientCacheChangeDiscoveryMessage.java | 4 -
.../ClientCacheChangeDummyDiscoveryMessage.java | 4 -
.../processors/cache/DynamicCacheChangeBatch.java | 4 -
.../processors/cache/ExchangeFailureMessage.java | 34 +-
.../processors/cache/GridCacheContext.java | 6 +-
.../processors/cache/GridCacheEntryInfo.java | 5 -
.../processors/cache/GridCacheGroupIdMessage.java | 52 ---
.../processors/cache/GridCacheIdMessage.java | 52 ---
.../processors/cache/GridCacheIoManager.java | 5 +-
.../processors/cache/GridCacheMessage.java | 78 +---
.../cache/GridCachePartitionExchangeManager.java | 10 +-
.../internal/processors/cache/GridCacheReturn.java | 4 -
.../internal/processors/cache/GridCacheUtils.java | 40 +-
.../GridChangeGlobalStateMessageResponse.java | 4 -
...TimeoutOnPartitionMapExchangeChangeMessage.java | 4 -
.../processors/cache/WalStateAckMessage.java | 4 -
.../processors/cache/WalStateFinishMessage.java | 4 -
.../processors/cache/WalStateProposeMessage.java | 4 -
.../cache/binary/BinaryMetadataVersionInfo.java | 7 -
.../binary/MetadataRemoveAcceptedMessage.java | 4 -
.../binary/MetadataRemoveProposedMessage.java | 4 -
.../cache/binary/MetadataRequestMessage.java | 5 -
.../cache/binary/MetadataResponseMessage.java | 5 -
.../binary/MetadataUpdateAcceptedMessage.java | 4 -
.../distributed/GridCacheTtlUpdateRequest.java | 4 -
.../distributed/GridCacheTxRecoveryRequest.java | 4 -
.../distributed/GridCacheTxRecoveryResponse.java | 37 +-
.../distributed/GridDistributedLockRequest.java | 4 -
.../distributed/GridDistributedLockResponse.java | 44 +-
.../GridDistributedTxFinishRequest.java | 4 -
.../GridDistributedTxFinishResponse.java | 4 -
.../GridDistributedTxPrepareRequest.java | 4 -
.../GridDistributedTxPrepareResponse.java | 26 --
.../cache/distributed/GridNearUnlockRequest.java | 4 -
.../dht/GridDhtAffinityAssignmentRequest.java | 4 -
.../dht/GridDhtAffinityAssignmentResponse.java | 4 -
.../cache/distributed/dht/GridDhtCacheAdapter.java | 3 +-
.../cache/distributed/dht/GridDhtLockRequest.java | 4 -
.../cache/distributed/dht/GridDhtLockResponse.java | 37 +-
.../distributed/dht/GridDhtTxFinishRequest.java | 4 -
.../distributed/dht/GridDhtTxFinishResponse.java | 4 -
.../dht/GridDhtTxOnePhaseCommitAckRequest.java | 4 -
.../distributed/dht/GridDhtTxPrepareRequest.java | 4 -
.../distributed/dht/GridDhtTxPrepareResponse.java | 37 +-
.../distributed/dht/GridDhtUnlockRequest.java | 4 -
.../dht/PartitionUpdateCountersMessage.java | 4 -
.../dht/TransactionAttributesAwareRequest.java | 7 -
.../AtomicApplicationAttributesAwareRequest.java | 7 -
.../GridDhtAtomicDeferredUpdateResponse.java | 15 +-
.../dht/atomic/GridDhtAtomicNearResponse.java | 44 +-
.../atomic/GridDhtAtomicSingleUpdateRequest.java | 4 -
.../dht/atomic/GridDhtAtomicUpdateRequest.java | 4 -
.../dht/atomic/GridDhtAtomicUpdateResponse.java | 36 +-
.../atomic/GridNearAtomicCheckUpdateRequest.java | 4 -
.../atomic/GridNearAtomicFullUpdateRequest.java | 4 -
.../GridNearAtomicSingleUpdateFilterRequest.java | 4 -
.../GridNearAtomicSingleUpdateInvokeRequest.java | 4 -
.../atomic/GridNearAtomicSingleUpdateRequest.java | 4 -
.../dht/atomic/GridNearAtomicUpdateResponse.java | 26 +-
.../distributed/dht/atomic/NearCacheUpdates.java | 4 -
.../cache/distributed/dht/atomic/UpdateErrors.java | 4 -
.../dht/preloader/CacheGroupAffinityMessage.java | 4 -
.../preloader/CachePartitionFullCountersMap.java | 7 -
.../CachePartitionPartialCountersMap.java | 7 -
.../dht/preloader/GridDhtForceKeysRequest.java | 4 -
.../dht/preloader/GridDhtForceKeysResponse.java | 75 +---
.../preloader/GridDhtPartitionDemandMessage.java | 4 -
.../dht/preloader/GridDhtPartitionExchangeId.java | 4 -
.../dht/preloader/GridDhtPartitionFullMap.java | 7 -
.../dht/preloader/GridDhtPartitionMap.java | 7 -
.../preloader/GridDhtPartitionSupplyMessage.java | 4 -
.../preloader/GridDhtPartitionsExchangeFuture.java | 10 +-
.../preloader/GridDhtPartitionsFullMessage.java | 10 +-
.../preloader/GridDhtPartitionsSingleMessage.java | 23 +-
.../preloader/GridDhtPartitionsSingleRequest.java | 4 -
.../dht/preloader/GroupPartitionIdPair.java | 7 -
.../preloader/IgniteDhtDemandedPartitionsMap.java | 7 -
.../preloader/IgniteDhtPartitionCountersMap.java | 7 -
.../IgniteDhtPartitionHistorySuppliersMap.java | 15 +-
.../preloader/IgniteDhtPartitionsToReloadMap.java | 7 -
.../distributed/dht/preloader/IntLongMap.java | 60 ---
.../dht/preloader/PartitionReservationsMap.java | 68 ---
.../dht/preloader/latch/LatchAckMessage.java | 5 -
.../distributed/near/CacheVersionedValue.java | 4 -
.../cache/distributed/near/GridNearGetRequest.java | 4 -
.../distributed/near/GridNearGetResponse.java | 54 +--
.../distributed/near/GridNearLockRequest.java | 4 -
.../distributed/near/GridNearLockResponse.java | 79 +---
.../distributed/near/GridNearSingleGetRequest.java | 4 -
.../near/GridNearSingleGetResponse.java | 54 +--
.../distributed/near/GridNearTxFinishRequest.java | 4 -
.../distributed/near/GridNearTxFinishResponse.java | 44 +-
.../distributed/near/GridNearTxPrepareRequest.java | 4 -
.../near/GridNearTxPrepareResponse.java | 109 +----
.../snapshot/DataStreamerUpdatesHandlerResult.java | 4 -
.../snapshot/IncrementalSnapshotAwareMessage.java | 7 -
.../snapshot/IncrementalSnapshotVerifyResult.java | 4 -
.../snapshot/SnapshotCheckHandlersResponse.java | 4 -
.../SnapshotCheckPartitionHashesResponse.java | 4 -
.../snapshot/SnapshotCheckProcessRequest.java | 4 -
.../snapshot/SnapshotCheckResponse.java | 4 -
.../snapshot/SnapshotFilesFailureMessage.java | 7 -
.../snapshot/SnapshotFilesRequestMessage.java | 7 -
.../snapshot/SnapshotHandlerResult.java | 4 -
.../snapshot/SnapshotMetadataResponse.java | 4 -
.../snapshot/SnapshotOperationEndRequest.java | 4 -
.../snapshot/SnapshotOperationRequest.java | 4 -
.../snapshot/SnapshotOperationResponse.java | 4 -
.../SnapshotPartitionsVerifyHandlerResponse.java | 4 -
.../snapshot/SnapshotRestoreOperationResponse.java | 5 -
.../snapshot/SnapshotRestoreStartRequest.java | 4 -
.../snapshot/SnapshotStartDiscoveryMessage.java | 4 -
.../cache/query/GridCacheQueryRequest.java | 4 -
.../cache/query/GridCacheQueryResponse.java | 45 +-
.../processors/cache/query/GridCacheSqlQuery.java | 5 -
.../continuous/CacheContinuousQueryBatchAck.java | 24 +-
.../continuous/CacheContinuousQueryEntry.java | 4 -
.../continuous/CacheContinuousQueryManager.java | 2 +-
.../cache/store/GridCacheStoreManagerAdapter.java | 64 +++
.../cache/transactions/IgniteTxEntry.java | 4 -
.../processors/cache/transactions/IgniteTxKey.java | 4 -
.../cache/transactions/TxDeadlockDetection.java | 24 +-
.../cache/transactions/TxEntryValueHolder.java | 4 -
.../processors/cache/transactions/TxLock.java | 5 -
.../processors/cache/transactions/TxLockList.java | 73 ---
.../cache/transactions/TxLocksRequest.java | 4 -
.../cache/transactions/TxLocksResponse.java | 23 +-
.../cache/version/GridCacheRawVersionedEntry.java | 4 -
.../processors/cache/version/GridCacheVersion.java | 4 -
.../cache/version/GridCacheVersionEx.java | 4 -
.../processors/cluster/CacheMetricsMessage.java | 8 -
.../cluster/ChangeGlobalStateFinishMessage.java | 4 -
.../cluster/ChangeGlobalStateMessage.java | 4 -
.../cluster/ClusterMetricsUpdateMessage.java | 7 -
.../processors/cluster/NodeFullMetricsMessage.java | 7 -
.../processors/cluster/NodeMetricsMessage.java | 8 -
.../ContinuousRoutineStartResultMessage.java | 4 -
.../continuous/GridContinuousMessage.java | 4 -
.../continuous/StopRoutineAckDiscoveryMessage.java | 4 -
.../continuous/StopRoutineDiscoveryMessage.java | 4 -
.../processors/datastreamer/DataStreamerEntry.java | 4 -
.../datastreamer/DataStreamerRequest.java | 4 -
.../datastreamer/DataStreamerResponse.java | 4 -
.../marshaller/MappingAcceptedMessage.java | 4 -
.../marshaller/MappingProposedMessage.java | 4 -
.../marshaller/MarshallerMappingItem.java | 4 -
.../marshaller/MissingMappingRequestMessage.java | 5 -
.../marshaller/MissingMappingResponseMessage.java | 5 -
.../DistributedMetaStorageCasAckMessage.java | 4 -
.../DistributedMetaStorageCasMessage.java | 4 -
.../DistributedMetaStorageUpdateAckMessage.java | 4 -
.../DistributedMetaStorageUpdateMessage.java | 4 -
.../internal/processors/odbc/ClientMessage.java | 5 -
.../performancestatistics/OperationType.java | 24 +-
.../platform/client/ClientBitmaskFeature.java | 5 +-
.../cache/ClientCacheConfigurationSerializer.java | 21 +
.../cache/ClientCachePutAllConflictRequest.java | 2 +-
.../cache/ClientCacheRemoveAllConflictRequest.java | 2 +-
.../platform/client/cache/ClientCacheRequest.java | 14 +-
.../internal/processors/query/QueryField.java | 4 -
.../twostep/messages/GridQueryCancelRequest.java | 4 -
.../h2/twostep/messages/GridQueryFailResponse.java | 4 -
.../twostep/messages/GridQueryNextPageRequest.java | 4 -
.../messages/GridQueryNextPageResponse.java | 5 -
.../query/messages/GridQueryKillRequest.java | 7 -
.../query/messages/GridQueryKillResponse.java | 7 -
.../message/SchemaFinishDiscoveryMessage.java | 4 -
.../message/SchemaOperationStatusMessage.java | 4 -
.../message/SchemaProposeDiscoveryMessage.java | 4 -
.../operation/SchemaAddQueryEntityOperation.java | 4 -
.../SchemaAlterTableAddColumnOperation.java | 4 -
.../SchemaAlterTableDropColumnOperation.java | 4 -
.../operation/SchemaIndexCreateOperation.java | 4 -
.../schema/operation/SchemaIndexDropOperation.java | 4 -
.../query/stat/messages/StatisticsColumnData.java | 8 -
.../stat/messages/StatisticsDecimalMessage.java | 7 -
.../query/stat/messages/StatisticsKeyMessage.java | 7 -
.../query/stat/messages/StatisticsObjectData.java | 8 -
.../query/stat/messages/StatisticsRequest.java | 8 -
.../query/stat/messages/StatisticsResponse.java | 8 -
.../rest/handlers/task/GridTaskResultRequest.java | 4 -
.../rest/handlers/task/GridTaskResultResponse.java | 5 -
.../service/ServiceChangeAbstractRequest.java | 19 +-
.../service/ServiceChangeBatchRequest.java | 18 +-
.../service/ServiceClusterDeploymentResult.java | 19 +-
.../ServiceClusterDeploymentResultBatch.java | 21 +-
.../service/ServiceDeploymentProcessId.java | 4 -
.../service/ServiceDeploymentRequest.java | 36 +-
.../service/ServiceSingleNodeDeploymentResult.java | 4 -
.../ServiceSingleNodeDeploymentResultBatch.java | 4 -
.../service/ServiceUndeploymentRequest.java | 8 +-
.../ignite/internal/util/GridByteArrayList.java | 4 -
.../internal/util/GridPartitionStateMap.java | 7 -
.../apache/ignite/internal/util/IgniteUtils.java | 9 +
.../internal/util/distributed/FullMessage.java | 4 -
.../internal/util/distributed/InitMessage.java | 4 -
.../util/distributed/SingleNodeMessage.java | 8 -
.../apache/ignite/lang/IgniteProductVersion.java | 30 +-
.../plugin/extensions/communication/Message.java | 45 +-
.../extensions/communication/MessageFactory.java | 35 ++
.../collision/jobstealing/JobStealingRequest.java | 4 -
.../TcpConnectionRequestDiscoveryMessage.java | 4 -
.../TcpInverseConnectionResponseMessage.java | 4 -
.../tcp/messages/HandshakeMessage.java | 5 -
.../tcp/messages/HandshakeWaitMessage.java | 7 -
.../communication/tcp/messages/NodeIdMessage.java | 5 -
.../tcp/messages/RecoveryLastReceivedMessage.java | 5 -
.../ignite/spi/discovery/tcp/ClientImpl.java | 2 +-
.../ignite/spi/discovery/tcp/ServerImpl.java | 34 +-
.../ignite/spi/discovery/tcp/TcpDiscoveryImpl.java | 26 +-
.../tcp/internal/DiscoveryDataPacket.java | 35 +-
.../discovery/tcp/internal/TcpDiscoveryNode.java | 82 +++-
.../discovery/tcp/messages/InetAddressMessage.java | 4 -
.../tcp/messages/InetSocketAddressMessage.java | 4 -
.../discovery/tcp/messages/NodeSpecificData.java | 84 ----
.../messages/TcpDiscoveryAuthFailedMessage.java | 4 -
.../messages/TcpDiscoveryCacheMetricsMessage.java | 4 -
.../messages/TcpDiscoveryCheckFailedMessage.java | 4 -
.../messages/TcpDiscoveryClientAckResponse.java | 4 -
.../TcpDiscoveryClientMetricsUpdateMessage.java | 4 -
.../TcpDiscoveryClientNodesMetricsMessage.java | 4 -
.../messages/TcpDiscoveryClientPingRequest.java | 4 -
.../messages/TcpDiscoveryClientPingResponse.java | 4 -
.../TcpDiscoveryClientReconnectMessage.java | 4 -
.../messages/TcpDiscoveryCollectionMessage.java | 4 -
.../TcpDiscoveryConnectionCheckMessage.java | 4 -
.../messages/TcpDiscoveryCustomEventMessage.java | 4 -
.../tcp/messages/TcpDiscoveryDiscardMessage.java | 4 -
.../messages/TcpDiscoveryDuplicateIdMessage.java | 4 -
.../tcp/messages/TcpDiscoveryHandshakeRequest.java | 4 -
.../messages/TcpDiscoveryHandshakeResponse.java | 4 -
.../messages/TcpDiscoveryJoinRequestMessage.java | 27 +-
.../TcpDiscoveryLoopbackProblemMessage.java | 4 -
.../messages/TcpDiscoveryMetricsUpdateMessage.java | 4 -
.../TcpDiscoveryNodeAddFinishedMessage.java | 7 +-
.../tcp/messages/TcpDiscoveryNodeAddedMessage.java | 65 +--
.../messages/TcpDiscoveryNodeFailedMessage.java | 4 -
.../TcpDiscoveryNodeFullMetricsMessage.java | 4 -
.../tcp/messages/TcpDiscoveryNodeLeftMessage.java | 4 -
.../messages/TcpDiscoveryNodeMetricsMessage.java | 4 -
.../tcp/messages/TcpDiscoveryPingRequest.java | 4 -
.../tcp/messages/TcpDiscoveryPingResponse.java | 4 -
.../TcpDiscoveryRingLatencyCheckMessage.java | 4 -
.../TcpDiscoveryServerOnlyCustomEventMessage.java | 4 -
.../messages/TcpDiscoveryStatusCheckMessage.java | 4 -
.../main/resources/META-INF/classnames.properties | 1 -
...idEventStorageRuntimeConfigurationSelfTest.java | 13 +-
.../client/thin/CacheConfigurationTest.java | 159 +++++++
.../internal/client/thin/FunctionalTest.java | 93 ----
.../direct/TestNestedContainersMessage.java | 4 -
.../GridManagerLocalMessageListenerSelfTest.java | 12 +-
.../CacheEntryPredicateAdapterMessageTest.java | 123 -----
.../communication/CompressedMessageTest.java | 10 +-
.../affinity/GridAffinityAssignmentV2Test.java | 9 +-
.../rebalancing/GridCacheRebalanceOrderTest.java | 4 +-
.../snapshot/dump/IgniteCacheDumpSelf2Test.java | 189 ++++++++
.../PerformanceStatisticsSelfTest.java | 87 ++++
.../util/distributed/MessagesPluginProvider.java | 4 +-
.../util/distributed/TestIntegerMessage.java | 4 -
.../internal/util/distributed/TestUuidMessage.java | 4 -
.../nio/IgniteExceptionInNioWorkerSelfTest.java | 2 +-
.../TcpCommunicationSpiSslVolatilePayloadTest.java | 10 +-
.../loadtests/communication/GridTestMessage.java | 4 -
.../GridAbstractCommunicationSelfTest.java | 12 +-
.../communication/GridCacheMessageSelfTest.java | 494 +--------------------
.../ignite/spi/communication/GridTestMessage.java | 114 +----
.../ignite/spi/communication/TestBadMessage.java} | 50 +--
.../ignite/spi/communication/TestMessage.java} | 37 +-
.../ignite/spi/communication/TestMessage1.java} | 49 +-
.../ignite/spi/communication/TestMessage2.java} | 69 +--
.../communication/TestVolatilePayloadMessage.java | 85 +---
.../CommunicationConnectionPoolMetricsTest.java | 24 +-
.../tcp/GridTcpCommunicationSpiAbstractTest.java | 9 +-
...pCommunicationSpiConcurrentConnectSelfTest.java | 10 +-
.../tcp/GridTcpCommunicationSpiConfigSelfTest.java | 5 +-
...idTcpCommunicationSpiMultithreadedSelfTest.java | 5 +-
...GridTcpCommunicationSpiRecoveryAckSelfTest.java | 10 +-
.../GridTcpCommunicationSpiRecoverySelfTest.java | 5 +-
...TcpCommunicationRecoveryAckClosureSelfTest.java | 10 +-
.../tcp/TcpCommunicationStatisticsTest.java | 8 +-
.../TcpDiscoveryDeadNodeAddressResolvingTest.java | 7 +-
.../spi/discovery/tcp/TcpDiscoverySelfTest.java | 52 ++-
.../junits/multijvm/IgniteNodeRunner.java | 39 ++
.../junits/multijvm/IgniteProcessProxy.java | 2 +-
.../ignite/testsuites/IgniteBasicTestSuite.java | 2 -
...ridCommandHandlerClusterByClassTest_help.output | 18 +
...andHandlerClusterByClassWithSSLTest_help.output | 18 +
.../internal/processors/query/h2/QueryTable.java | 4 -
.../query/h2/twostep/msg/GridH2Array.java | 4 -
.../query/h2/twostep/msg/GridH2Boolean.java | 4 -
.../query/h2/twostep/msg/GridH2Byte.java | 4 -
.../query/h2/twostep/msg/GridH2Bytes.java | 4 -
.../query/h2/twostep/msg/GridH2CacheObject.java | 4 -
.../query/h2/twostep/msg/GridH2Date.java | 4 -
.../query/h2/twostep/msg/GridH2Decimal.java | 4 -
.../query/h2/twostep/msg/GridH2DmlRequest.java | 4 -
.../query/h2/twostep/msg/GridH2DmlResponse.java | 5 -
.../query/h2/twostep/msg/GridH2Double.java | 4 -
.../query/h2/twostep/msg/GridH2Float.java | 4 -
.../query/h2/twostep/msg/GridH2Geometry.java | 4 -
.../h2/twostep/msg/GridH2IndexRangeRequest.java | 4 -
.../h2/twostep/msg/GridH2IndexRangeResponse.java | 4 -
.../query/h2/twostep/msg/GridH2Integer.java | 4 -
.../query/h2/twostep/msg/GridH2JavaObject.java | 4 -
.../query/h2/twostep/msg/GridH2Long.java | 4 -
.../query/h2/twostep/msg/GridH2Null.java | 4 -
.../query/h2/twostep/msg/GridH2QueryRequest.java | 4 -
.../query/h2/twostep/msg/GridH2RowMessage.java | 4 -
.../query/h2/twostep/msg/GridH2RowRange.java | 5 -
.../query/h2/twostep/msg/GridH2RowRangeBounds.java | 4 -
.../query/h2/twostep/msg/GridH2Short.java | 4 -
.../query/h2/twostep/msg/GridH2String.java | 4 -
.../query/h2/twostep/msg/GridH2Time.java | 4 -
.../query/h2/twostep/msg/GridH2Timestamp.java | 4 -
.../query/h2/twostep/msg/GridH2Uuid.java | 4 -
.../h2/twostep/msg/GridH2ValueMessageFactory.java | 56 +--
.../org/apache/ignite/client/ClientTestSuite.java | 2 +
.../include/ignite/cache/query/query_sql_fields.h | 6 +-
.../thin-client-test/src/sql_fields_query_test.cpp | 2 +-
.../ignite/thin/cache/query/query_sql_fields.h | 4 +-
.../Cache/Query/CacheQueriesTest.cs | 2 +
.../Query/Linq/CacheLinqTest.Introspection.cs | 16 +-
.../Cache/Query/Linq/CacheLinqTest.Misc.cs | 3 +-
.../Client/Cache/SqlQueryTest.cs | 2 +
.../Cache/Query/SqlFieldsQuery.cs | 9 +-
.../Impl/Client/Cache/CacheClient.cs | 2 +
.../Impl/CacheFieldsQueryExecutor.cs | 2 +
.../dotnet/Apache.Ignite.Linq/QueryOptions.cs | 4 +
427 files changed, 3063 insertions(+), 4646 deletions(-)
create mode 100644
modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/IndexWrappedKeyFirstLastScan.java
create mode 100644
modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/IndexWrappedKeyScan.java
copy
modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/{PrepareService.java
=> IgniteSqlNodeRewriter.java} (79%)
copy
modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/{SystemViewIndexImpl.java
=> CacheWrappedKeyIndexImpl.java} (55%)
create mode 100644
modules/control-utility/src/test/java/org/apache/ignite/util/GridCommandHandlerEventTest.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/client/ClientAffinityConfiguration.java
copy
modules/core/src/main/java/org/apache/ignite/internal/management/{persistence/PersistenceCleanCommand.java
=> event/EventCommand.java} (71%)
copy
modules/core/src/main/java/org/apache/ignite/internal/management/{cache/CacheResetLostPartitionsCommandArg.java
=> event/EventCommandArg.java} (75%)
copy
modules/core/src/main/java/org/apache/ignite/internal/management/{metric/MetricConfigureHitrateCommand.java
=> event/EventDisableCommand.java} (59%)
copy
modules/core/src/main/java/org/apache/ignite/internal/management/{metric/MetricConfigureHitrateCommand.java
=> event/EventEnableCommand.java} (58%)
copy
modules/core/src/main/java/org/apache/ignite/internal/management/{consistency/ConsistencyStatusCommand.java
=> event/EventListCommand.java} (56%)
copy
modules/core/src/main/java/org/apache/ignite/internal/management/{cache/CacheClearCommandArg.java
=> event/EventListCommandArg.java} (75%)
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/management/event/EventListTask.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/management/event/EventManagementTask.java
copy
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/{GridCacheDeployable.java
=> CacheEntryPredicateType.java} (68%)
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/IntLongMap.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/PartitionReservationsMap.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/TxLockList.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/messages/NodeSpecificData.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/client/thin/CacheConfigurationTest.java
delete mode 100644
modules/core/src/test/java/org/apache/ignite/internal/managers/communication/CacheEntryPredicateAdapterMessageTest.java
copy
modules/core/src/{main/java/org/apache/ignite/spi/collision/jobstealing/JobStealingRequest.java
=> test/java/org/apache/ignite/spi/communication/TestBadMessage.java} (62%)
copy
modules/{extdata/p2p/src/main/java/org/apache/ignite/tests/p2p/P2PTestPredicate.java
=> core/src/test/java/org/apache/ignite/spi/communication/TestMessage.java}
(60%)
copy
modules/core/src/{main/java/org/apache/ignite/internal/processors/query/h2/twostep/messages/GridQueryCancelRequest.java
=> test/java/org/apache/ignite/spi/communication/TestMessage1.java} (59%)
copy
modules/core/src/{main/java/org/apache/ignite/spi/communication/tcp/messages/NodeIdMessage.java
=> test/java/org/apache/ignite/spi/communication/TestMessage2.java} (56%)
