ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From voze...@apache.org
Subject [32/50] ignite git commit: Merge branch 'gridgain-7.5.26' of https://github.com/gridgain/apache-ignite into gridgain-7.5.26
Date Mon, 20 Jun 2016 12:53:12 GMT
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-3341
Commit: fb23e00df7a693088acc2b7d29564fc0e29ba3be
Parents: 377b387 2c18b6e
Author: Denis Magda <dmagda@gridgain.com>
Authored: Wed Jun 15 17:18:39 2016 +0300
Committer: Denis Magda <dmagda@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
----------------------------------------------------------------------


Mime
View raw message