You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vo...@apache.org on 2016/06/17 08:54:41 UTC
[32/41] ignite git commit: Merge branch 'gridgain-7.5.26' of
https://github.com/gridgain/apache-ignite into gridgain-7.5.26
Merge branch 'gridgain-7.5.26' of https://github.com/gridgain/apache-ignite into gridgain-7.5.26
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/fb23e00d
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/fb23e00d
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/fb23e00d
Branch: refs/heads/ignite-3331
Commit: fb23e00df7a693088acc2b7d29564fc0e29ba3be
Parents: 377b387 2c18b6e
Author: Denis Magda <dm...@gridgain.com>
Authored: Wed Jun 15 17:18:39 2016 +0300
Committer: Denis Magda <dm...@gridgain.com>
Committed: Wed Jun 15 17:18:39 2016 +0300
----------------------------------------------------------------------
modules/cassandra/README.txt | 32 +
modules/cassandra/licenses/apache-2.0.txt | 202 +++++
modules/cassandra/pom.xml | 340 +++++++
.../store/cassandra/CassandraCacheStore.java | 409 +++++++++
.../cassandra/CassandraCacheStoreFactory.java | 200 +++++
.../store/cassandra/common/CassandraHelper.java | 133 +++
.../cassandra/common/PropertyMappingHelper.java | 220 +++++
.../store/cassandra/common/RandomSleeper.java | 104 +++
.../store/cassandra/common/SystemHelper.java | 46 +
.../store/cassandra/datasource/Credentials.java | 37 +
.../store/cassandra/datasource/DataSource.java | 550 ++++++++++++
.../cassandra/datasource/PlainCredentials.java | 50 ++
.../persistence/KeyPersistenceSettings.java | 274 ++++++
.../KeyValuePersistenceSettings.java | 478 ++++++++++
.../persistence/PersistenceController.java | 421 +++++++++
.../persistence/PersistenceSettings.java | 335 +++++++
.../persistence/PersistenceStrategy.java | 62 ++
.../store/cassandra/persistence/PojoField.java | 219 +++++
.../cassandra/persistence/PojoKeyField.java | 91 ++
.../cassandra/persistence/PojoValueField.java | 152 ++++
.../persistence/ValuePersistenceSettings.java | 107 +++
.../cassandra/serializer/JavaSerializer.java | 81 ++
.../cassandra/serializer/KryoSerializer.java | 93 ++
.../store/cassandra/serializer/Serializer.java | 43 +
.../session/BatchExecutionAssistant.java | 95 ++
.../cassandra/session/BatchLoaderAssistant.java | 47 +
.../cassandra/session/CassandraSession.java | 60 ++
.../cassandra/session/CassandraSessionImpl.java | 832 +++++++++++++++++
.../cassandra/session/ExecutionAssistant.java | 77 ++
.../session/GenericBatchExecutionAssistant.java | 67 ++
.../session/LoadCacheCustomQueryWorker.java | 105 +++
.../cassandra/session/pool/SessionPool.java | 173 ++++
.../cassandra/session/pool/SessionWrapper.java | 71 ++
.../store/cassandra/utils/DDLGenerator.java | 64 ++
.../aws/cassandra/cassandra-bootstrap.sh | 373 ++++++++
.../bootstrap/aws/cassandra/cassandra-env.sh | 283 ++++++
.../bootstrap/aws/cassandra/cassandra-start.sh | 550 ++++++++++++
.../aws/cassandra/cassandra-template.yaml | 889 +++++++++++++++++++
.../bootstrap/aws/ignite/ignite-bootstrap.sh | 384 ++++++++
.../ignite/ignite-cassandra-server-template.xml | 177 ++++
.../src/test/bootstrap/aws/ignite/ignite-env.sh | 25 +
.../test/bootstrap/aws/ignite/ignite-start.sh | 637 +++++++++++++
.../src/test/bootstrap/aws/logs-collector.sh | 102 +++
.../tests/ignite-cassandra-client-template.xml | 173 ++++
.../test/bootstrap/aws/tests/tests-bootstrap.sh | 379 ++++++++
.../test/bootstrap/aws/tests/tests-report.sh | 590 ++++++++++++
.../src/test/bootstrap/aws/tests/tests-run.sh | 715 +++++++++++++++
.../CassandraDirectPersistenceLoadTest.java | 107 +++
.../tests/CassandraDirectPersistenceTest.java | 371 ++++++++
.../apache/ignite/tests/DDLGeneratorTest.java | 43 +
.../tests/IgnitePersistentStoreLoadTest.java | 111 +++
.../ignite/tests/IgnitePersistentStoreTest.java | 369 ++++++++
.../org/apache/ignite/tests/load/Generator.java | 27 +
.../apache/ignite/tests/load/IntGenerator.java | 33 +
.../ignite/tests/load/LoadTestDriver.java | 238 +++++
.../apache/ignite/tests/load/LongGenerator.java | 28 +
.../ignite/tests/load/PersonGenerator.java | 43 +
.../ignite/tests/load/PersonIdGenerator.java | 31 +
.../ignite/tests/load/StringGenerator.java | 28 +
.../org/apache/ignite/tests/load/Worker.java | 429 +++++++++
.../tests/load/cassandra/BulkReadWorker.java | 63 ++
.../tests/load/cassandra/BulkWriteWorker.java | 52 ++
.../ignite/tests/load/cassandra/ReadWorker.java | 51 ++
.../tests/load/cassandra/WriteWorker.java | 51 ++
.../tests/load/ignite/BulkReadWorker.java | 52 ++
.../tests/load/ignite/BulkWriteWorker.java | 52 ++
.../ignite/tests/load/ignite/ReadWorker.java | 51 ++
.../ignite/tests/load/ignite/WriteWorker.java | 51 ++
.../org/apache/ignite/tests/pojos/Person.java | 246 +++++
.../org/apache/ignite/tests/pojos/PersonId.java | 110 +++
.../ignite/tests/utils/CacheStoreHelper.java | 64 ++
.../tests/utils/CassandraAdminCredentials.java | 36 +
.../ignite/tests/utils/CassandraHelper.java | 358 ++++++++
.../tests/utils/CassandraLifeCycleBean.java | 149 ++++
.../utils/CassandraRegularCredentials.java | 36 +
.../ignite/tests/utils/TestCacheSession.java | 91 ++
.../apache/ignite/tests/utils/TestsHelper.java | 375 ++++++++
.../src/test/resources/log4j.properties | 119 +++
.../tests/cassandra/connection-settings.xml | 48 +
.../tests/cassandra/connection.properties | 17 +
.../tests/cassandra/credentials.properties | 22 +
.../tests/cassandra/embedded-cassandra.yaml | 119 +++
.../ignite/tests/cassandra/keyspaces.properties | 17 +
.../tests/persistence/blob/ignite-config.xml | 100 +++
.../persistence/blob/persistence-settings-1.xml | 21 +
.../persistence/blob/persistence-settings-2.xml | 21 +
.../persistence/blob/persistence-settings-3.xml | 29 +
.../tests/persistence/pojo/ignite-config.xml | 119 +++
.../persistence/pojo/persistence-settings-1.xml | 21 +
.../persistence/pojo/persistence-settings-2.xml | 21 +
.../persistence/pojo/persistence-settings-3.xml | 173 ++++
.../persistence/primitive/ignite-config.xml | 100 +++
.../primitive/ignite-remote-client-config.xml | 95 ++
.../primitive/ignite-remote-server-config.xml | 106 +++
.../primitive/persistence-settings-1.xml | 21 +
.../primitive/persistence-settings-2.xml | 21 +
.../src/test/resources/tests.properties | 50 ++
.../src/test/scripts/cassandra-load-tests.bat | 41 +
.../src/test/scripts/cassandra-load-tests.sh | 39 +
.../src/test/scripts/ignite-load-tests.bat | 41 +
.../src/test/scripts/ignite-load-tests.sh | 39 +
modules/cassandra/src/test/scripts/jvm-opt.sh | 21 +
modules/cassandra/src/test/scripts/jvm-opts.bat | 24 +
.../configuration/FileSystemConfiguration.java | 18 +-
.../ignite/internal/MarshallerContextImpl.java | 51 +-
.../ignite/internal/binary/BinaryContext.java | 43 +-
.../processors/cache/GridCacheAdapter.java | 46 +-
.../processors/cache/GridCacheEntryEx.java | 9 +-
.../processors/cache/GridCacheMapEntry.java | 100 +--
.../processors/cache/GridCacheUtils.java | 3 +
.../binary/CacheObjectBinaryProcessorImpl.java | 29 +-
.../distributed/dht/GridDhtCacheAdapter.java | 10 +-
.../distributed/dht/GridDhtLockFuture.java | 18 +-
.../dht/GridDhtTransactionalCacheAdapter.java | 2 -
.../distributed/dht/GridDhtTxPrepareFuture.java | 19 +-
.../dht/GridPartitionedGetFuture.java | 2 -
.../dht/GridPartitionedSingleGetFuture.java | 2 -
.../dht/atomic/GridDhtAtomicCache.java | 8 -
.../dht/colocated/GridDhtColocatedCache.java | 4 +-
.../dht/preloader/GridDhtForceKeysFuture.java | 3 +-
.../dht/preloader/GridDhtPartitionDemander.java | 3 +-
.../distributed/near/GridNearGetFuture.java | 4 -
.../cache/distributed/near/GridNearTxLocal.java | 7 +-
.../local/atomic/GridLocalAtomicCache.java | 8 -
.../continuous/CacheContinuousQueryEntry.java | 16 +
.../continuous/CacheContinuousQueryHandler.java | 2 +-
.../continuous/CacheContinuousQueryManager.java | 135 +++
.../cache/transactions/IgniteTxAdapter.java | 2 -
.../cache/transactions/IgniteTxEntry.java | 24 +-
.../cache/transactions/IgniteTxHandler.java | 46 +
.../transactions/IgniteTxLocalAdapter.java | 34 +-
.../cacheobject/IgniteCacheObjectProcessor.java | 7 +
.../IgniteCacheObjectProcessorImpl.java | 5 +
.../continuous/GridContinuousProcessor.java | 217 +++--
.../datastreamer/DataStreamerImpl.java | 3 +-
.../processors/igfs/IgfsCreateResult.java | 66 ++
.../processors/igfs/IgfsDataManager.java | 166 +---
.../internal/processors/igfs/IgfsImpl.java | 53 +-
.../processors/igfs/IgfsMetaManager.java | 633 ++++++-------
.../IgfsSecondaryFileSystemCreateContext.java | 111 +++
.../IgfsSecondaryOutputStreamDescriptor.java | 59 --
.../igfs/data/IgfsDataPutProcessor.java | 99 +++
.../meta/IgfsMetaDirectoryCreateProcessor.java | 40 +-
...IgfsMetaDirectoryListingRenameProcessor.java | 133 +++
.../igfs/meta/IgfsMetaFileCreateProcessor.java | 46 +-
.../service/GridServiceProcessor.java | 391 ++++----
.../processors/task/GridTaskWorker.java | 44 +-
.../ignite/spi/discovery/tcp/ServerImpl.java | 4 +-
...eClientReconnectContinuousProcessorTest.java | 60 +-
.../ignite/internal/binary/AffinityKey.java | 69 ++
.../binary/GridBinaryAffinityKeySelfTest.java | 15 +
...aultBinaryMappersBinaryMetaDataSelfTest.java | 17 +
.../cache/CacheAffinityCallSelfTest.java | 45 +-
.../processors/cache/GridCacheTestEntryEx.java | 5 +-
.../cache/IgniteCacheAbstractTest.java | 2 +-
...gniteCacheInvokeReadThroughAbstractTest.java | 382 ++++++++
...iteCacheInvokeReadThroughSingleNodeTest.java | 106 +++
.../cache/IgniteCacheInvokeReadThroughTest.java | 182 ++--
.../IgniteCacheReadThroughStoreCallTest.java | 288 ++++++
.../IgniteCacheLoaderWriterAbstractTest.java | 10 +
...ridCacheContinuousQueryAbstractSelfTest.java | 2 +-
...niteCacheContinuousQueryBackupQueueTest.java | 135 +++
.../IgniteNoCustomEventsOnNodeStart.java | 80 ++
.../igfs/IgfsMetaManagerSelfTest.java | 4 +-
.../service/GridServiceClientNodeTest.java | 102 ++-
.../testsuites/IgniteCacheTestSuite2.java | 3 +
.../testsuites/IgniteCacheTestSuite4.java | 4 +
.../processors/query/h2/sql/GridSqlConst.java | 5 +
.../processors/query/h2/sql/GridSqlJoin.java | 17 +-
.../processors/query/h2/sql/GridSqlType.java | 5 +
.../query/IgniteSqlSplitterSelfTest.java | 75 ++
.../IgniteCacheQuerySelfTestSuite3.java | 2 +
.../org/apache/ignite/spark/IgniteContext.scala | 4 +-
.../org/apache/ignite/spark/IgniteRDD.scala | 25 +-
.../apache/ignite/spark/JavaIgniteContext.scala | 4 +-
.../org/apache/ignite/spark/JavaIgniteRDD.scala | 2 +
.../ignite/spark/impl/IgniteAbstractRDD.scala | 15 +-
.../apache/ignite/spark/impl/IgniteSqlRDD.scala | 5 +-
.../spark/impl/JavaIgniteAbstractRDD.scala | 34 -
.../org/apache/ignite/spark/IgniteRDDSpec.scala | 25 +-
pom.xml | 9 +
181 files changed, 20033 insertions(+), 1168 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/fb23e00d/modules/indexing/src/test/java/org/apache/ignite/testsuites/IgniteCacheQuerySelfTestSuite3.java
----------------------------------------------------------------------