ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From akuznet...@apache.org
Subject [9/9] ignite git commit: IGNITE-1371 Implemented Cassandra cache store.
Date Wed, 18 May 2016 09:50:06 GMT
IGNITE-1371 Implemented Cassandra cache store.


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/b33eb027
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/b33eb027
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/b33eb027

Branch: refs/heads/ignite-1.6
Commit: b33eb0273236b71c1a508abc5adca9e2c54d0306
Parents: 71315a6
Author: Igor <irudyak@gmail.com>
Authored: Wed May 18 16:49:46 2016 +0700
Committer: Alexey Kuznetsov <akuznetsov@apache.org>
Committed: Wed May 18 16:49:48 2016 +0700

----------------------------------------------------------------------
 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 +++++
 .../cassandra/bean/CassandraLifeCycleBean.java  | 149 ++++
 .../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 ++++++++
 .../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 +
 pom.xml                                         |   9 +
 104 files changed, 16747 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/b33eb027/modules/cassandra/README.txt
----------------------------------------------------------------------
diff --git a/modules/cassandra/README.txt b/modules/cassandra/README.txt
new file mode 100644
index 0000000..cc2134d
--- /dev/null
+++ b/modules/cassandra/README.txt
@@ -0,0 +1,32 @@
+Apache Ignite Cassandra Module
+------------------------
+
+Apache Ignite Cassandra module provides CacheStore implementation backed by Cassandra database.
+
+To enable Cassandra module when starting a standalone node, move 'optional/ignite-cassandra' folder to
+'libs' folder before running 'ignite.{sh|bat}' script. The content of the module folder will
+be added to classpath in this case.
+
+Importing Cassandra Module In Maven Project
+-------------------------------------
+
+If you are using Maven to manage dependencies of your project, you can add Cassandra module
+dependency like this (replace '${ignite.version}' with actual Ignite version you are
+interested in):
+
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
+                        http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    ...
+    <dependencies>
+        ...
+        <dependency>
+            <groupId>org.apache.ignite</groupId>
+            <artifactId>ignite-cassandra</artifactId>
+            <version>${ignite.version}</version>
+        </dependency>
+        ...
+    </dependencies>
+    ...
+</project>

http://git-wip-us.apache.org/repos/asf/ignite/blob/b33eb027/modules/cassandra/licenses/apache-2.0.txt
----------------------------------------------------------------------
diff --git a/modules/cassandra/licenses/apache-2.0.txt b/modules/cassandra/licenses/apache-2.0.txt
new file mode 100644
index 0000000..d645695
--- /dev/null
+++ b/modules/cassandra/licenses/apache-2.0.txt
@@ -0,0 +1,202 @@
+
+                                 Apache License
+                           Version 2.0, January 2004
+                        http://www.apache.org/licenses/
+
+   TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
+
+   1. Definitions.
+
+      "License" shall mean the terms and conditions for use, reproduction,
+      and distribution as defined by Sections 1 through 9 of this document.
+
+      "Licensor" shall mean the copyright owner or entity authorized by
+      the copyright owner that is granting the License.
+
+      "Legal Entity" shall mean the union of the acting entity and all
+      other entities that control, are controlled by, or are under common
+      control with that entity. For the purposes of this definition,
+      "control" means (i) the power, direct or indirect, to cause the
+      direction or management of such entity, whether by contract or
+      otherwise, or (ii) ownership of fifty percent (50%) or more of the
+      outstanding shares, or (iii) beneficial ownership of such entity.
+
+      "You" (or "Your") shall mean an individual or Legal Entity
+      exercising permissions granted by this License.
+
+      "Source" form shall mean the preferred form for making modifications,
+      including but not limited to software source code, documentation
+      source, and configuration files.
+
+      "Object" form shall mean any form resulting from mechanical
+      transformation or translation of a Source form, including but
+      not limited to compiled object code, generated documentation,
+      and conversions to other media types.
+
+      "Work" shall mean the work of authorship, whether in Source or
+      Object form, made available under the License, as indicated by a
+      copyright notice that is included in or attached to the work
+      (an example is provided in the Appendix below).
+
+      "Derivative Works" shall mean any work, whether in Source or Object
+      form, that is based on (or derived from) the Work and for which the
+      editorial revisions, annotations, elaborations, or other modifications
+      represent, as a whole, an original work of authorship. For the purposes
+      of this License, Derivative Works shall not include works that remain
+      separable from, or merely link (or bind by name) to the interfaces of,
+      the Work and Derivative Works thereof.
+
+      "Contribution" shall mean any work of authorship, including
+      the original version of the Work and any modifications or additions
+      to that Work or Derivative Works thereof, that is intentionally
+      submitted to Licensor for inclusion in the Work by the copyright owner
+      or by an individual or Legal Entity authorized to submit on behalf of
+      the copyright owner. For the purposes of this definition, "submitted"
+      means any form of electronic, verbal, or written communication sent
+      to the Licensor or its representatives, including but not limited to
+      communication on electronic mailing lists, source code control systems,
+      and issue tracking systems that are managed by, or on behalf of, the
+      Licensor for the purpose of discussing and improving the Work, but
+      excluding communication that is conspicuously marked or otherwise
+      designated in writing by the copyright owner as "Not a Contribution."
+
+      "Contributor" shall mean Licensor and any individual or Legal Entity
+      on behalf of whom a Contribution has been received by Licensor and
+      subsequently incorporated within the Work.
+
+   2. Grant of Copyright License. Subject to the terms and conditions of
+      this License, each Contributor hereby grants to You a perpetual,
+      worldwide, non-exclusive, no-charge, royalty-free, irrevocable
+      copyright license to reproduce, prepare Derivative Works of,
+      publicly display, publicly perform, sublicense, and distribute the
+      Work and such Derivative Works in Source or Object form.
+
+   3. Grant of Patent License. Subject to the terms and conditions of
+      this License, each Contributor hereby grants to You a perpetual,
+      worldwide, non-exclusive, no-charge, royalty-free, irrevocable
+      (except as stated in this section) patent license to make, have made,
+      use, offer to sell, sell, import, and otherwise transfer the Work,
+      where such license applies only to those patent claims licensable
+      by such Contributor that are necessarily infringed by their
+      Contribution(s) alone or by combination of their Contribution(s)
+      with the Work to which such Contribution(s) was submitted. If You
+      institute patent litigation against any entity (including a
+      cross-claim or counterclaim in a lawsuit) alleging that the Work
+      or a Contribution incorporated within the Work constitutes direct
+      or contributory patent infringement, then any patent licenses
+      granted to You under this License for that Work shall terminate
+      as of the date such litigation is filed.
+
+   4. Redistribution. You may reproduce and distribute copies of the
+      Work or Derivative Works thereof in any medium, with or without
+      modifications, and in Source or Object form, provided that You
+      meet the following conditions:
+
+      (a) You must give any other recipients of the Work or
+          Derivative Works a copy of this License; and
+
+      (b) You must cause any modified files to carry prominent notices
+          stating that You changed the files; and
+
+      (c) You must retain, in the Source form of any Derivative Works
+          that You distribute, all copyright, patent, trademark, and
+          attribution notices from the Source form of the Work,
+          excluding those notices that do not pertain to any part of
+          the Derivative Works; and
+
+      (d) If the Work includes a "NOTICE" text file as part of its
+          distribution, then any Derivative Works that You distribute must
+          include a readable copy of the attribution notices contained
+          within such NOTICE file, excluding those notices that do not
+          pertain to any part of the Derivative Works, in at least one
+          of the following places: within a NOTICE text file distributed
+          as part of the Derivative Works; within the Source form or
+          documentation, if provided along with the Derivative Works; or,
+          within a display generated by the Derivative Works, if and
+          wherever such third-party notices normally appear. The contents
+          of the NOTICE file are for informational purposes only and
+          do not modify the License. You may add Your own attribution
+          notices within Derivative Works that You distribute, alongside
+          or as an addendum to the NOTICE text from the Work, provided
+          that such additional attribution notices cannot be construed
+          as modifying the License.
+
+      You may add Your own copyright statement to Your modifications and
+      may provide additional or different license terms and conditions
+      for use, reproduction, or distribution of Your modifications, or
+      for any such Derivative Works as a whole, provided Your use,
+      reproduction, and distribution of the Work otherwise complies with
+      the conditions stated in this License.
+
+   5. Submission of Contributions. Unless You explicitly state otherwise,
+      any Contribution intentionally submitted for inclusion in the Work
+      by You to the Licensor shall be under the terms and conditions of
+      this License, without any additional terms or conditions.
+      Notwithstanding the above, nothing herein shall supersede or modify
+      the terms of any separate license agreement you may have executed
+      with Licensor regarding such Contributions.
+
+   6. Trademarks. This License does not grant permission to use the trade
+      names, trademarks, service marks, or product names of the Licensor,
+      except as required for reasonable and customary use in describing the
+      origin of the Work and reproducing the content of the NOTICE file.
+
+   7. Disclaimer of Warranty. Unless required by applicable law or
+      agreed to in writing, Licensor provides the Work (and each
+      Contributor provides its Contributions) on an "AS IS" BASIS,
+      WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+      implied, including, without limitation, any warranties or conditions
+      of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A
+      PARTICULAR PURPOSE. You are solely responsible for determining the
+      appropriateness of using or redistributing the Work and assume any
+      risks associated with Your exercise of permissions under this License.
+
+   8. Limitation of Liability. In no event and under no legal theory,
+      whether in tort (including negligence), contract, or otherwise,
+      unless required by applicable law (such as deliberate and grossly
+      negligent acts) or agreed to in writing, shall any Contributor be
+      liable to You for damages, including any direct, indirect, special,
+      incidental, or consequential damages of any character arising as a
+      result of this License or out of the use or inability to use the
+      Work (including but not limited to damages for loss of goodwill,
+      work stoppage, computer failure or malfunction, or any and all
+      other commercial damages or losses), even if such Contributor
+      has been advised of the possibility of such damages.
+
+   9. Accepting Warranty or Additional Liability. While redistributing
+      the Work or Derivative Works thereof, You may choose to offer,
+      and charge a fee for, acceptance of support, warranty, indemnity,
+      or other liability obligations and/or rights consistent with this
+      License. However, in accepting such obligations, You may act only
+      on Your own behalf and on Your sole responsibility, not on behalf
+      of any other Contributor, and only if You agree to indemnify,
+      defend, and hold each Contributor harmless for any liability
+      incurred by, or claims asserted against, such Contributor by reason
+      of your accepting any such warranty or additional liability.
+
+   END OF TERMS AND CONDITIONS
+
+   APPENDIX: How to apply the Apache License to your work.
+
+      To apply the Apache License to your work, attach the following
+      boilerplate notice, with the fields enclosed by brackets "[]"
+      replaced with your own identifying information. (Don't include
+      the brackets!)  The text should be enclosed in the appropriate
+      comment syntax for the file format. We also recommend that a
+      file or class name and description of purpose be included on the
+      same "printed page" as the copyright notice for easier
+      identification within third-party archives.
+
+   Copyright [yyyy] [name of copyright owner]
+
+   Licensed under the Apache License, Version 2.0 (the "License");
+   you may not use this file except in compliance with the License.
+   You may obtain a copy of the License at
+
+       http://www.apache.org/licenses/LICENSE-2.0
+
+   Unless required by applicable law or agreed to in writing, software
+   distributed under the License is distributed on an "AS IS" BASIS,
+   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+   See the License for the specific language governing permissions and
+   limitations under the License.

http://git-wip-us.apache.org/repos/asf/ignite/blob/b33eb027/modules/cassandra/pom.xml
----------------------------------------------------------------------
diff --git a/modules/cassandra/pom.xml b/modules/cassandra/pom.xml
new file mode 100644
index 0000000..d2a7f25
--- /dev/null
+++ b/modules/cassandra/pom.xml
@@ -0,0 +1,340 @@
+<?xml version="1.0" encoding="UTF-8"?>
+
+<!--
+  Licensed to the Apache Software Foundation (ASF) under one or more
+  contributor license agreements.  See the NOTICE file distributed with
+  this work for additional information regarding copyright ownership.
+  The ASF licenses this file to You under the Apache License, Version 2.0
+  (the "License"); you may not use this file except in compliance with
+  the License.  You may obtain a copy of the License at
+
+       http://www.apache.org/licenses/LICENSE-2.0
+
+  Unless required by applicable law or agreed to in writing, software
+  distributed under the License is distributed on an "AS IS" BASIS,
+  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+  See the License for the specific language governing permissions and
+  limitations under the License.
+-->
+
+<!--
+    POM file.
+-->
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <parent>
+        <groupId>org.apache.ignite</groupId>
+        <artifactId>ignite-parent</artifactId>
+        <version>1</version>
+        <relativePath>../../parent</relativePath>
+    </parent>
+
+    <artifactId>ignite-cassandra</artifactId>
+    <version>1.6.0-SNAPSHOT</version>
+    <url>http://ignite.apache.org</url>
+
+    <properties>
+        <commons-beanutils.version>1.8.3</commons-beanutils.version>
+        <cassandra-driver.version>3.0.0</cassandra-driver.version>
+        <cassandra-all.version>3.3</cassandra-all.version>
+        <kryo.version>3.0.3</kryo.version>
+        <reflectasm.version>1.10.1</reflectasm.version>
+        <minlog.version>1.3.0</minlog.version>
+        <asm.version>5.0.3</asm.version>
+        <objenesis.version>2.1</objenesis.version>
+        <netty-handler.version>4.0.27.Final</netty-handler.version>
+        <netty-buffer.version>4.0.27.Final</netty-buffer.version>
+        <netty-common.version>4.0.27.Final</netty-common.version>
+        <netty-transport.version>4.0.27.Final</netty-transport.version>
+        <netty-codec.version>4.0.27.Final</netty-codec.version>
+        <guava.version>19.0</guava.version>
+        <metrics-core.version>3.0.2</metrics-core.version>
+    </properties>
+
+    <dependencies>
+        <!-- Apache commons -->
+        <dependency>
+            <groupId>commons-beanutils</groupId>
+            <artifactId>commons-beanutils</artifactId>
+            <version>${commons-beanutils.version}</version>
+        </dependency>
+
+        <!-- Kryo and required dependencies -->
+        <dependency>
+            <groupId>com.esotericsoftware</groupId>
+            <artifactId>kryo</artifactId>
+            <version>${kryo.version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>com.esotericsoftware</groupId>
+            <artifactId>reflectasm</artifactId>
+            <version>${reflectasm.version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>com.esotericsoftware</groupId>
+            <artifactId>minlog</artifactId>
+            <version>${minlog.version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.ow2.asm</groupId>
+            <artifactId>asm</artifactId>
+            <version>${asm.version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.objenesis</groupId>
+            <artifactId>objenesis</artifactId>
+            <version>${objenesis.version}</version>
+        </dependency>
+
+        <!-- Ignite -->
+        <dependency>
+            <groupId>org.apache.ignite</groupId>
+            <artifactId>ignite-core</artifactId>
+            <version>${project.version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.apache.ignite</groupId>
+            <artifactId>ignite-spring</artifactId>
+            <version>${project.version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.apache.ignite</groupId>
+            <artifactId>ignite-log4j</artifactId>
+            <version>${project.version}</version>
+            <scope>test</scope>
+        </dependency>
+
+        <!-- Cassandra and required dependencies -->
+        <dependency>
+            <groupId>com.datastax.cassandra</groupId>
+            <artifactId>cassandra-driver-core</artifactId>
+            <version>${cassandra-driver.version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>io.netty</groupId>
+            <artifactId>netty-handler</artifactId>
+            <version>${netty-handler.version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>io.netty</groupId>
+            <artifactId>netty-buffer</artifactId>
+            <version>${netty-buffer.version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>io.netty</groupId>
+            <artifactId>netty-common</artifactId>
+            <version>${netty-common.version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>io.netty</groupId>
+            <artifactId>netty-transport</artifactId>
+            <version>${netty-transport.version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>io.netty</groupId>
+            <artifactId>netty-codec</artifactId>
+            <version>${netty-codec.version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>com.google.guava</groupId>
+            <artifactId>guava</artifactId>
+            <version>${guava.version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>com.codahale.metrics</groupId>
+            <artifactId>metrics-core</artifactId>
+            <version>${metrics-core.version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.apache.cassandra</groupId>
+            <artifactId>cassandra-all</artifactId>
+            <version>${cassandra-all.version}</version>
+            <scope>provided</scope>
+            <exclusions>
+                <exclusion>
+                    <artifactId>log4j-over-slf4j</artifactId>
+                    <groupId>org.slf4j</groupId>
+                </exclusion>
+            </exclusions>
+        </dependency>
+
+        <!-- Apache log4j -->
+        <dependency>
+            <groupId>log4j</groupId>
+            <artifactId>log4j</artifactId>
+            <scope>test</scope>
+        </dependency>
+
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <version>3.2</version>
+                <configuration>
+                    <source>1.7</source>
+                    <target>1.7</target>
+                    <compilerVersion>1.7</compilerVersion>
+                    <encoding>UTF-8</encoding>
+                    <fork>true</fork>
+                    <debug>false</debug>
+                    <debuglevel>lines,vars,source</debuglevel>
+                    <meminitial>256</meminitial>
+                    <maxmem>512</maxmem>
+                </configuration>
+            </plugin>
+
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-dependency-plugin</artifactId>
+                <version>2.10</version>
+                <executions>
+                    <execution>
+                        <id>copy-all-dependencies</id>
+                        <phase>package</phase>
+                        <goals>
+                            <goal>copy-dependencies</goal>
+                        </goals>
+                        <configuration>
+                            <outputDirectory>${project.build.directory}/tests-package/lib</outputDirectory>
+                            <overWriteReleases>false</overWriteReleases>
+                            <overWriteSnapshots>false</overWriteSnapshots>
+                            <overWriteIfNewer>true</overWriteIfNewer>
+                        </configuration>
+                    </execution>
+<!-- -->
+                    <execution>
+                        <id>copy-main-dependencies</id>
+                        <phase>package</phase>
+                        <goals>
+                            <goal>copy-dependencies</goal>
+                        </goals>
+                        <configuration>
+                            <outputDirectory>${project.build.directory}/libs</outputDirectory>
+                            <overWriteReleases>false</overWriteReleases>
+                            <overWriteSnapshots>false</overWriteSnapshots>
+                            <overWriteIfNewer>true</overWriteIfNewer>
+                            <excludeTransitive>true</excludeTransitive>
+                            <excludeGroupIds>
+                                org.apache.ignite,org.springframework,org.gridgain
+                            </excludeGroupIds>
+                            <excludeArtifactIds>
+                                commons-logging,slf4j-api,cache-api,slf4j-api,aopalliance
+                            </excludeArtifactIds>
+                            <includeScope>runtime</includeScope>
+                        </configuration>
+                    </execution>
+<!-- -->
+                </executions>
+            </plugin>
+
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-antrun-plugin</artifactId>
+                <version>1.8</version>
+                <dependencies>
+                    <dependency>
+                        <groupId>ant-contrib</groupId>
+                        <artifactId>ant-contrib</artifactId>
+                        <version>1.0b3</version>
+                        <exclusions>
+                            <exclusion>
+                                <groupId>ant</groupId>
+                                <artifactId>ant</artifactId>
+                            </exclusion>
+                        </exclusions>
+                    </dependency>
+                </dependencies>
+                <executions>
+                    <execution>
+                        <id>package-tests</id>
+                        <phase>package</phase>
+                        <goals>
+                            <goal>run</goal>
+                        </goals>
+                        <configuration>
+                            <target>
+                                <taskdef resource="net/sf/antcontrib/antlib.xml"/>
+                                <if>
+                                    <available file="${project.build.directory}/test-classes" type="dir"/>
+                                    <then>
+                                        <copy todir="${project.build.directory}/tests-package/lib">
+                                            <fileset dir="${project.build.directory}">
+                                                <include name="*.jar"/>
+                                            </fileset>
+                                        </copy>
+
+                                        <jar destfile="${project.build.directory}/tests-package/lib/${project.artifactId}-${project.version}-tests.jar">
+                                            <fileset dir="${project.build.directory}/test-classes">
+                                                <include name="**/*.class"/>
+                                            </fileset>
+                                        </jar>
+
+                                        <copy todir="${project.build.directory}/tests-package/settings">
+                                            <fileset dir="${project.build.directory}/test-classes">
+                                                <include name="**/*.properties"/>
+                                                <include name="**/*.xml"/>
+                                            </fileset>
+                                        </copy>
+
+                                        <copy todir="${project.build.directory}/tests-package">
+                                            <fileset dir="${project.build.testSourceDirectory}/../scripts">
+                                                <include name="**/*"/>
+                                            </fileset>
+                                        </copy>
+
+                                        <fixcrlf srcdir="${project.build.directory}/tests-package" eol="lf" eof="remove">
+                                            <include name="*.sh"/>
+                                        </fixcrlf>
+
+                                        <copy todir="${project.build.directory}/tests-package" >
+                                            <fileset dir="${project.build.testSourceDirectory}/..">
+                                                <include name="bootstrap/**"/>
+                                            </fileset>
+                                        </copy>
+
+                                        <fixcrlf srcdir="${project.build.directory}/tests-package/bootstrap" eol="lf" eof="remove">
+                                            <include name="**"/>
+                                        </fixcrlf>
+
+                                        <zip destfile="${project.build.directory}/ignite-cassandra-tests-${project.version}.zip"
+                                             compress="true" whenempty="create" level="9" encoding="UTF-8"
+                                             useLanguageEncodingFlag="true" createUnicodeExtraFields="not-encodeable">
+
+                                            <zipfileset dir="${project.build.directory}/tests-package" prefix="ignite-cassandra-tests">
+                                                <exclude name="**/*.sh"/>
+                                            </zipfileset>
+
+                                            <zipfileset dir="${project.build.directory}/tests-package" prefix="ignite-cassandra-tests" filemode="555">
+                                                <include name="**/*.sh"/>
+                                            </zipfileset>
+                                        </zip>
+                                    </then>
+                                </if>
+                            </target>
+                        </configuration>
+                    </execution>
+                </executions>
+            </plugin>
+
+        </plugins>
+    </build>
+</project>
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/ignite/blob/b33eb027/modules/cassandra/src/main/java/org/apache/ignite/cache/store/cassandra/CassandraCacheStore.java
----------------------------------------------------------------------
diff --git a/modules/cassandra/src/main/java/org/apache/ignite/cache/store/cassandra/CassandraCacheStore.java b/modules/cassandra/src/main/java/org/apache/ignite/cache/store/cassandra/CassandraCacheStore.java
new file mode 100644
index 0000000..f7e7917
--- /dev/null
+++ b/modules/cassandra/src/main/java/org/apache/ignite/cache/store/cassandra/CassandraCacheStore.java
@@ -0,0 +1,409 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.ignite.cache.store.cassandra;
+
+import com.datastax.driver.core.BoundStatement;
+import com.datastax.driver.core.PreparedStatement;
+import com.datastax.driver.core.Row;
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.Future;
+import javax.cache.Cache;
+import javax.cache.integration.CacheLoaderException;
+import javax.cache.integration.CacheWriterException;
+import org.apache.ignite.IgniteCheckedException;
+import org.apache.ignite.IgniteLogger;
+import org.apache.ignite.cache.store.CacheStore;
+import org.apache.ignite.cache.store.CacheStoreSession;
+import org.apache.ignite.cache.store.cassandra.datasource.DataSource;
+import org.apache.ignite.cache.store.cassandra.persistence.KeyValuePersistenceSettings;
+import org.apache.ignite.cache.store.cassandra.persistence.PersistenceController;
+import org.apache.ignite.cache.store.cassandra.session.CassandraSession;
+import org.apache.ignite.cache.store.cassandra.session.ExecutionAssistant;
+import org.apache.ignite.cache.store.cassandra.session.GenericBatchExecutionAssistant;
+import org.apache.ignite.cache.store.cassandra.session.LoadCacheCustomQueryWorker;
+import org.apache.ignite.internal.util.typedef.internal.U;
+import org.apache.ignite.lang.IgniteBiInClosure;
+import org.apache.ignite.logger.NullLogger;
+import org.apache.ignite.resources.CacheStoreSessionResource;
+import org.apache.ignite.resources.LoggerResource;
+
+/**
+ * Implementation of {@link CacheStore} backed by Cassandra database.
+ *
+ * @param <K> Ignite cache key type.
+ * @param <V> Ignite cache value type.
+ */
+public class CassandraCacheStore<K, V> implements CacheStore<K, V> {
+    /** Connection attribute property name. */
+    private static final String ATTR_CONN_PROP = "CASSANDRA_STORE_CONNECTION";
+
+    /** Auto-injected store session. */
+    @CacheStoreSessionResource
+    private CacheStoreSession storeSes;
+
+    /** Auto-injected logger instance. */
+    @LoggerResource
+    private IgniteLogger log;
+
+    /** Cassandra data source. */
+    private DataSource dataSrc;
+
+    /** Max workers thread count. These threads are responsible for load cache. */
+    private int maxPoolSize = Runtime.getRuntime().availableProcessors();
+
+    /** Controller component responsible for serialization logic. */
+    private PersistenceController controller;
+
+    /**
+     * Store constructor.
+     *
+     * @param dataSrc Data source.
+     * @param settings Persistence settings for Ignite key and value objects.
+     * @param maxPoolSize Max workers thread count.
+     */
+    public CassandraCacheStore(DataSource dataSrc, KeyValuePersistenceSettings settings, int maxPoolSize) {
+        this.dataSrc = dataSrc;
+        this.controller = new PersistenceController(settings);
+        this.maxPoolSize = maxPoolSize;
+    }
+
+    /** {@inheritDoc} */
+    @Override public void loadCache(IgniteBiInClosure<K, V> clo, Object... args) throws CacheLoaderException {
+        if (clo == null || args == null || args.length == 0)
+            return;
+
+        ExecutorService pool = null;
+
+        Collection<Future<?>> futs = new ArrayList<>(args.length);
+
+        try {
+            pool = Executors.newFixedThreadPool(maxPoolSize);
+
+            CassandraSession ses = getCassandraSession();
+
+            for (Object obj : args) {
+                if (obj == null || !(obj instanceof String) || !((String)obj).trim().toLowerCase().startsWith("select"))
+                    continue;
+
+                futs.add(pool.submit(new LoadCacheCustomQueryWorker<>(ses, (String) obj, controller, log, clo)));
+            }
+
+            for (Future<?> fut : futs)
+                U.get(fut);
+
+            if (log != null && log.isDebugEnabled() && storeSes != null)
+                log.debug("Cache loaded from db: " + storeSes.cacheName());
+        }
+        catch (IgniteCheckedException e) {
+            if (storeSes != null)
+                throw new CacheLoaderException("Failed to load Ignite cache: " + storeSes.cacheName(), e.getCause());
+            else
+                throw new CacheLoaderException("Failed to load cache", e.getCause());
+        }
+        finally {
+            U.shutdownNow(getClass(), pool, log);
+        }
+    }
+
+    /** {@inheritDoc} */
+    @Override public void sessionEnd(boolean commit) throws CacheWriterException {
+        if (storeSes == null || storeSes.transaction() == null)
+            return;
+
+        CassandraSession cassandraSes = (CassandraSession) storeSes.properties().remove(ATTR_CONN_PROP);
+
+        U.closeQuiet(cassandraSes);
+    }
+
+    /** {@inheritDoc} */
+    @SuppressWarnings({"unchecked"})
+    @Override public V load(final K key) throws CacheLoaderException {
+        if (key == null)
+            return null;
+
+        CassandraSession ses = getCassandraSession();
+
+        try {
+            return ses.execute(new ExecutionAssistant<V>() {
+                @Override public boolean tableExistenceRequired() {
+                    return false;
+                }
+
+                @Override public String getStatement() {
+                    return controller.getLoadStatement(false);
+                }
+
+                @Override public BoundStatement bindStatement(PreparedStatement statement) {
+                    return controller.bindKey(statement, key);
+                }
+
+                @Override public KeyValuePersistenceSettings getPersistenceSettings() {
+                    return controller.getPersistenceSettings();
+                }
+
+                @Override public String operationName() {
+                    return "READ";
+                }
+
+                @Override public V process(Row row) {
+                    return row == null ? null : (V)controller.buildValueObject(row);
+                }
+            });
+        }
+        finally {
+            closeCassandraSession(ses);
+        }
+    }
+
+    /** {@inheritDoc} */
+    @SuppressWarnings("unchecked")
+    @Override public Map<K, V> loadAll(Iterable<? extends K> keys) throws CacheLoaderException {
+        if (keys == null || !keys.iterator().hasNext())
+            return new HashMap<>();
+
+        CassandraSession ses = getCassandraSession();
+
+        try {
+            return ses.execute(new GenericBatchExecutionAssistant<Map<K, V>, K>() {
+                private Map<K, V> data = new HashMap<>();
+
+                /** {@inheritDoc} */
+                @Override public String getStatement() {
+                    return controller.getLoadStatement(true);
+                }
+
+                /** {@inheritDoc} */
+                @Override  public BoundStatement bindStatement(PreparedStatement statement, K key) {
+                    return controller.bindKey(statement, key);
+                }
+
+                /** {@inheritDoc} */
+                @Override public KeyValuePersistenceSettings getPersistenceSettings() {
+                    return controller.getPersistenceSettings();
+                }
+
+                /** {@inheritDoc} */
+                @Override public String operationName() {
+                    return "BULK_READ";
+                }
+
+                /** {@inheritDoc} */
+                @Override public Map<K, V> processedData() {
+                    return data;
+                }
+
+                /** {@inheritDoc} */
+                @Override protected void process(Row row) {
+                    data.put((K)controller.buildKeyObject(row), (V)controller.buildValueObject(row));
+                }
+            }, keys);
+        }
+        finally {
+            closeCassandraSession(ses);
+        }
+    }
+
+    /** {@inheritDoc} */
+    @Override public void write(final Cache.Entry<? extends K, ? extends V> entry) throws CacheWriterException {
+        if (entry == null || entry.getKey() == null)
+            return;
+
+        CassandraSession ses = getCassandraSession();
+
+        try {
+            ses.execute(new ExecutionAssistant<Void>() {
+                @Override public boolean tableExistenceRequired() {
+                    return true;
+                }
+
+                @Override public String getStatement() {
+                    return controller.getWriteStatement();
+                }
+
+                @Override public BoundStatement bindStatement(PreparedStatement statement) {
+                    return controller.bindKeyValue(statement, entry.getKey(), entry.getValue());
+                }
+
+                @Override public KeyValuePersistenceSettings getPersistenceSettings() {
+                    return controller.getPersistenceSettings();
+                }
+
+                @Override public String operationName() {
+                    return "WRITE";
+                }
+
+                @Override public Void process(Row row) {
+                    return null;
+                }
+            });
+        }
+        finally {
+            closeCassandraSession(ses);
+        }
+    }
+
+    /** {@inheritDoc} */
+    @Override public void writeAll(Collection<Cache.Entry<? extends K, ? extends V>> entries) throws CacheWriterException {
+        if (entries == null || entries.isEmpty())
+            return;
+
+        CassandraSession ses = getCassandraSession();
+
+        try {
+            ses.execute(new GenericBatchExecutionAssistant<Void, Cache.Entry<? extends K, ? extends V>>() {
+                /** {@inheritDoc} */
+                @Override public String getStatement() {
+                    return controller.getWriteStatement();
+                }
+
+                /** {@inheritDoc} */
+                @Override public BoundStatement bindStatement(PreparedStatement statement,
+                    Cache.Entry<? extends K, ? extends V> entry) {
+                    return controller.bindKeyValue(statement, entry.getKey(), entry.getValue());
+                }
+
+                /** {@inheritDoc} */
+                @Override public KeyValuePersistenceSettings getPersistenceSettings() {
+                    return controller.getPersistenceSettings();
+                }
+
+                /** {@inheritDoc} */
+                @Override public String operationName() {
+                    return "BULK_WRITE";
+                }
+
+                /** {@inheritDoc} */
+                @Override public boolean tableExistenceRequired() {
+                    return true;
+                }
+            }, entries);
+        }
+        finally {
+            closeCassandraSession(ses);
+        }
+    }
+
+    /** {@inheritDoc} */
+    @Override public void delete(final Object key) throws CacheWriterException {
+        if (key == null)
+            return;
+
+        CassandraSession ses = getCassandraSession();
+
+        try {
+            ses.execute(new ExecutionAssistant<Void>() {
+                @Override public boolean tableExistenceRequired() {
+                    return false;
+                }
+
+                @Override public String getStatement() {
+                    return controller.getDeleteStatement();
+                }
+
+                @Override public BoundStatement bindStatement(PreparedStatement statement) {
+                    return controller.bindKey(statement, key);
+                }
+
+
+                @Override public KeyValuePersistenceSettings getPersistenceSettings() {
+                    return controller.getPersistenceSettings();
+                }
+
+                @Override public String operationName() {
+                    return "DELETE";
+                }
+
+                @Override public Void process(Row row) {
+                    return null;
+                }
+            });
+        }
+        finally {
+            closeCassandraSession(ses);
+        }
+    }
+
+    /** {@inheritDoc} */
+    @Override public void deleteAll(Collection<?> keys) throws CacheWriterException {
+        if (keys == null || keys.isEmpty())
+            return;
+
+        CassandraSession ses = getCassandraSession();
+
+        try {
+            ses.execute(new GenericBatchExecutionAssistant<Void, Object>() {
+                /** {@inheritDoc} */
+                @Override public String getStatement() {
+                    return controller.getDeleteStatement();
+                }
+
+                /** {@inheritDoc} */
+                @Override public BoundStatement bindStatement(PreparedStatement statement, Object key) {
+                    return controller.bindKey(statement, key);
+                }
+
+                /** {@inheritDoc} */
+                @Override public KeyValuePersistenceSettings getPersistenceSettings() {
+                    return controller.getPersistenceSettings();
+                }
+
+                @Override public String operationName() {
+                    return "BULK_DELETE";
+                }
+            }, keys);
+        }
+        finally {
+            closeCassandraSession(ses);
+        }
+    }
+
+    /**
+     * Gets Cassandra session wrapper or creates new if it doesn't exist.
+     * This wrapper hides all the low-level Cassandra interaction details by providing only high-level methods.
+     *
+     * @return Cassandra session wrapper.
+     */
+    private CassandraSession getCassandraSession() {
+        if (storeSes == null || storeSes.transaction() == null)
+            return dataSrc.session(log != null ? log : new NullLogger());
+
+        CassandraSession ses = (CassandraSession) storeSes.properties().get(ATTR_CONN_PROP);
+
+        if (ses == null) {
+            ses = dataSrc.session(log != null ? log : new NullLogger());
+            storeSes.properties().put(ATTR_CONN_PROP, ses);
+        }
+
+        return ses;
+    }
+
+    /**
+     * Releases Cassandra related resources.
+     *
+     * @param ses Cassandra session wrapper.
+     */
+    private void closeCassandraSession(CassandraSession ses) {
+        if (ses != null && (storeSes == null || storeSes.transaction() == null))
+            U.closeQuiet(ses);
+    }
+}

http://git-wip-us.apache.org/repos/asf/ignite/blob/b33eb027/modules/cassandra/src/main/java/org/apache/ignite/cache/store/cassandra/CassandraCacheStoreFactory.java
----------------------------------------------------------------------
diff --git a/modules/cassandra/src/main/java/org/apache/ignite/cache/store/cassandra/CassandraCacheStoreFactory.java b/modules/cassandra/src/main/java/org/apache/ignite/cache/store/cassandra/CassandraCacheStoreFactory.java
new file mode 100644
index 0000000..7584dfb
--- /dev/null
+++ b/modules/cassandra/src/main/java/org/apache/ignite/cache/store/cassandra/CassandraCacheStoreFactory.java
@@ -0,0 +1,200 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.ignite.cache.store.cassandra;
+
+import javax.cache.configuration.Factory;
+import org.apache.ignite.IgniteException;
+import org.apache.ignite.cache.store.cassandra.datasource.DataSource;
+import org.apache.ignite.cache.store.cassandra.persistence.KeyValuePersistenceSettings;
+import org.apache.ignite.internal.IgniteComponentType;
+import org.apache.ignite.internal.util.spring.IgniteSpringHelper;
+import org.apache.ignite.resources.SpringApplicationContextResource;
+
+/**
+ * Factory class to instantiate {@link CassandraCacheStore}.
+ *
+ * @param <K> Ignite cache key type
+ * @param <V> Ignite cache value type
+ */
+public class CassandraCacheStoreFactory<K, V> implements Factory<CassandraCacheStore<K, V>> {
+    /** */
+    private static final long serialVersionUID = 0L;
+
+    /** Auto-injected Spring ApplicationContext resource. */
+    @SpringApplicationContextResource
+    private Object appCtx;
+
+    /** Name of data source bean. */
+    private String dataSrcBean;
+
+    /** Name of persistence settings bean. */
+    private String persistenceSettingsBean;
+
+    /** Data source. */
+    private transient DataSource dataSrc;
+
+    /** Persistence settings. */
+    private KeyValuePersistenceSettings persistenceSettings;
+
+    /** Max workers thread count. These threads are responsible for load cache. */
+    private int maxPoolSize = Runtime.getRuntime().availableProcessors();
+
+    /** {@inheritDoc} */
+    @Override public CassandraCacheStore<K, V> create() {
+        return new CassandraCacheStore<>(getDataSource(), getPersistenceSettings(), getMaxPoolSize());
+    }
+
+    /**
+     * Sets data source.
+     *
+     * @param dataSrc Data source.
+     *
+     * @return {@code This} for chaining.
+     */
+    @SuppressWarnings("UnusedDeclaration")
+    public CassandraCacheStoreFactory<K, V> setDataSource(DataSource dataSrc) {
+        this.dataSrc = dataSrc;
+
+        return this;
+    }
+
+    /**
+     * Sets data source bean name.
+     *
+     * @param beanName Data source bean name.
+     * @return {@code This} for chaining.
+     */
+    public CassandraCacheStoreFactory<K, V> setDataSourceBean(String beanName) {
+        this.dataSrcBean = beanName;
+
+        return this;
+    }
+
+    /**
+     * Sets persistence settings.
+     *
+     * @param settings Persistence settings.
+     * @return {@code This} for chaining.
+     */
+    @SuppressWarnings("UnusedDeclaration")
+    public CassandraCacheStoreFactory<K, V> setPersistenceSettings(KeyValuePersistenceSettings settings) {
+        this.persistenceSettings = settings;
+
+        return this;
+    }
+
+    /**
+     * Sets persistence settings bean name.
+     *
+     * @param beanName Persistence settings bean name.
+     * @return {@code This} for chaining.
+     */
+    public CassandraCacheStoreFactory<K, V> setPersistenceSettingsBean(String beanName) {
+        this.persistenceSettingsBean = beanName;
+
+        return this;
+    }
+
+    /**
+     * @return Data source.
+     */
+    private DataSource getDataSource() {
+        if (dataSrc != null)
+            return dataSrc;
+
+        if (dataSrcBean == null)
+            throw new IllegalStateException("Either DataSource bean or DataSource itself should be specified");
+
+        if (appCtx == null) {
+            throw new IllegalStateException("Failed to get Cassandra DataSource cause Spring application " +
+                "context wasn't injected into CassandraCacheStoreFactory");
+        }
+
+        Object obj = loadSpringContextBean(appCtx, dataSrcBean);
+
+        if (!(obj instanceof DataSource))
+            throw new IllegalStateException("Incorrect connection bean '" + dataSrcBean + "' specified");
+
+        return dataSrc = (DataSource)obj;
+    }
+
+    /**
+     * @return Persistence settings.
+     */
+    private KeyValuePersistenceSettings getPersistenceSettings() {
+        if (persistenceSettings != null)
+            return persistenceSettings;
+
+        if (persistenceSettingsBean == null) {
+            throw new IllegalStateException("Either persistence settings bean or persistence settings itself " +
+                "should be specified");
+        }
+
+        if (appCtx == null) {
+            throw new IllegalStateException("Failed to get Cassandra persistence settings cause Spring application " +
+                "context wasn't injected into CassandraCacheStoreFactory");
+        }
+
+        Object obj = loadSpringContextBean(appCtx, persistenceSettingsBean);
+
+        if (!(obj instanceof KeyValuePersistenceSettings)) {
+            throw new IllegalStateException("Incorrect persistence settings bean '" +
+                persistenceSettingsBean + "' specified");
+        }
+
+        return persistenceSettings = (KeyValuePersistenceSettings)obj;
+    }
+
+    /**
+     * Get maximum workers thread count. These threads are responsible for queries execution.
+     *
+     * @return Maximum workers thread count.
+     */
+    public int getMaxPoolSize() {
+        return maxPoolSize;
+    }
+
+    /**
+     * Set Maximum workers thread count. These threads are responsible for queries execution.
+     *
+     * @param maxPoolSize Max workers thread count.
+     * @return {@code This} for chaining.
+     */
+    public CassandraCacheStoreFactory<K, V> setMaxPoolSize(int maxPoolSize) {
+        this.maxPoolSize = maxPoolSize;
+
+        return this;
+    }
+
+    /**
+     * Loads bean from Spring ApplicationContext.
+     *
+     * @param appCtx Application context.
+     * @param beanName Bean name to load.
+     * @return Loaded bean.
+     */
+    private Object loadSpringContextBean(Object appCtx, String beanName) {
+        try {
+            IgniteSpringHelper spring = IgniteComponentType.SPRING.create(false);
+            return spring.loadBeanFromAppContext(appCtx, beanName);
+        }
+        catch (Exception e) {
+            throw new IgniteException("Failed to load bean in application context [beanName=" + beanName + ", igniteConfig=" + appCtx + ']', e);
+        }
+    }
+}

http://git-wip-us.apache.org/repos/asf/ignite/blob/b33eb027/modules/cassandra/src/main/java/org/apache/ignite/cache/store/cassandra/bean/CassandraLifeCycleBean.java
----------------------------------------------------------------------
diff --git a/modules/cassandra/src/main/java/org/apache/ignite/cache/store/cassandra/bean/CassandraLifeCycleBean.java b/modules/cassandra/src/main/java/org/apache/ignite/cache/store/cassandra/bean/CassandraLifeCycleBean.java
new file mode 100644
index 0000000..11f8145
--- /dev/null
+++ b/modules/cassandra/src/main/java/org/apache/ignite/cache/store/cassandra/bean/CassandraLifeCycleBean.java
@@ -0,0 +1,149 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.ignite.cache.store.cassandra.bean;
+
+import org.apache.cassandra.service.CassandraDaemon;
+import org.apache.ignite.IgniteLogger;
+import org.apache.ignite.lifecycle.LifecycleBean;
+import org.apache.ignite.lifecycle.LifecycleEventType;
+import org.apache.ignite.resources.LoggerResource;
+
+/**
+ * Implementation of {@link LifecycleBean} to start embedded Cassandra instance on Ignite cluster startup
+ */
+public class CassandraLifeCycleBean implements LifecycleBean {
+    /** System property specifying Cassandra jmx port */
+    private static final String CASSANDRA_JMX_PORT_PROP = "cassandra.jmx.local.port";
+
+    /** System property specifying Cassandra YAML config file */
+    private static final String CASSANDRA_CONFIG_PROP = "cassandra.config";
+
+    /** Prefix for file path syntax */
+    private static final String FILE_PREFIX = "file:///";
+
+    /** Auto-injected logger instance. */
+    @LoggerResource
+    private IgniteLogger log;
+
+    /** Instance of embedded Cassandra database */
+    private CassandraDaemon embeddedCassandraDaemon;
+
+    /** JMX port for embedded Cassandra instance */
+    private String jmxPort;
+
+    /** YAML config file for embedded Cassandra */
+    private String cassandraCfgFile;
+
+    /**
+     * Returns JMX port for embedded Cassandra
+     * @return JMX port
+     */
+    public String getJmxPort() {
+        return jmxPort;
+    }
+
+    /**
+     * Setter for embedded Cassandra JMX port
+     * @param jmxPort embedded Cassandra JMX port
+     */
+    public void setJmxPort(String jmxPort) {
+        this.jmxPort = jmxPort;
+    }
+
+    /**
+     * Returns embedded Cassandra YAML config file
+     * @return YAML config file
+     */
+    public String getCassandraConfigFile() {
+        return cassandraCfgFile;
+    }
+
+    /**
+     * Setter for embedded Cassandra YAML config file
+     * @param cassandraCfgFile YAML config file
+     */
+    public void setCassandraConfigFile(String cassandraCfgFile) {
+        this.cassandraCfgFile = cassandraCfgFile;
+    }
+
+    /** {@inheritDoc} */
+    @Override public void onLifecycleEvent(LifecycleEventType evt) {
+        if (evt == LifecycleEventType.BEFORE_NODE_START)
+            startEmbeddedCassandra();
+        else if (evt == LifecycleEventType.BEFORE_NODE_STOP)
+            stopEmbeddedCassandra();
+    }
+
+    /**
+     * Starts embedded Cassandra instance
+     */
+    private void startEmbeddedCassandra() {
+        if (log != null) {
+            log.info("-------------------------------");
+            log.info("| Starting embedded Cassandra |");
+            log.info("-------------------------------");
+        }
+
+        try {
+            if (jmxPort != null)
+                System.setProperty(CASSANDRA_JMX_PORT_PROP, jmxPort);
+
+            if (cassandraCfgFile != null)
+                System.setProperty(CASSANDRA_CONFIG_PROP, FILE_PREFIX + cassandraCfgFile);
+
+            embeddedCassandraDaemon = new CassandraDaemon(true);
+            embeddedCassandraDaemon.init(null);
+            embeddedCassandraDaemon.start();
+        }
+        catch (Exception e) {
+            throw new RuntimeException("Failed to start embedded Cassandra", e);
+        }
+
+        if (log != null) {
+            log.info("------------------------------");
+            log.info("| Embedded Cassandra started |");
+            log.info("------------------------------");
+        }
+    }
+
+    /**
+     * Stops embedded Cassandra instance
+     */
+    private void stopEmbeddedCassandra() {
+        if (log != null) {
+            log.info("-------------------------------");
+            log.info("| Stopping embedded Cassandra |");
+            log.info("-------------------------------");
+        }
+
+        if (embeddedCassandraDaemon != null) {
+            try {
+                embeddedCassandraDaemon.deactivate();
+            }
+            catch (Throwable e) {
+                throw new RuntimeException("Failed to stop embedded Cassandra", e);
+            }
+        }
+
+        if (log != null) {
+            log.info("------------------------------");
+            log.info("| Embedded Cassandra stopped |");
+            log.info("------------------------------");
+        }
+    }
+}

http://git-wip-us.apache.org/repos/asf/ignite/blob/b33eb027/modules/cassandra/src/main/java/org/apache/ignite/cache/store/cassandra/common/CassandraHelper.java
----------------------------------------------------------------------
diff --git a/modules/cassandra/src/main/java/org/apache/ignite/cache/store/cassandra/common/CassandraHelper.java b/modules/cassandra/src/main/java/org/apache/ignite/cache/store/cassandra/common/CassandraHelper.java
new file mode 100644
index 0000000..d3bff7f
--- /dev/null
+++ b/modules/cassandra/src/main/java/org/apache/ignite/cache/store/cassandra/common/CassandraHelper.java
@@ -0,0 +1,133 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.ignite.cache.store.cassandra.common;
+
+import com.datastax.driver.core.Cluster;
+import com.datastax.driver.core.Session;
+import com.datastax.driver.core.exceptions.InvalidQueryException;
+import com.datastax.driver.core.exceptions.NoHostAvailableException;
+import com.datastax.driver.core.exceptions.ReadTimeoutException;
+import java.util.regex.Pattern;
+import org.apache.ignite.internal.util.typedef.internal.U;
+
+/**
+ * Helper class providing methods to work with Cassandra session and exceptions
+ */
+public class CassandraHelper {
+    /** Cassandra error message if specified keyspace doesn't exist. */
+    private static final Pattern KEYSPACE_EXIST_ERROR1 = Pattern.compile("Keyspace [0-9a-zA-Z_]+ does not exist");
+
+    /** Cassandra error message if trying to create table inside nonexistent keyspace. */
+    private static final Pattern KEYSPACE_EXIST_ERROR2 = Pattern.compile("Cannot add table '[0-9a-zA-Z_]+' to non existing keyspace.*");
+
+    /** Cassandra error message if specified table doesn't exist. */
+    private static final Pattern TABLE_EXIST_ERROR = Pattern.compile("unconfigured table [0-9a-zA-Z_]+");
+
+    /** Cassandra error message if trying to use prepared statement created from another session. */
+    private static final String PREP_STATEMENT_CLUSTER_INSTANCE_ERROR = "You may have used a PreparedStatement that " +
+        "was created with another Cluster instance";
+
+    /** Closes Cassandra driver session. */
+    public static void closeSession(Session driverSes) {
+        if (driverSes == null)
+            return;
+
+        Cluster cluster = driverSes.getCluster();
+
+        if (!driverSes.isClosed())
+            U.closeQuiet(driverSes);
+
+        if (!cluster.isClosed())
+            U.closeQuiet(cluster);
+    }
+
+    /**
+     * Checks if Cassandra keyspace absence error occur.
+     *
+     * @param e Exception to check.
+     * @return {@code true} in case of keyspace absence error.
+     */
+    public static boolean isKeyspaceAbsenceError(Throwable e) {
+        while (e != null) {
+            if (e instanceof InvalidQueryException &&
+                (KEYSPACE_EXIST_ERROR1.matcher(e.getMessage()).matches() ||
+                    KEYSPACE_EXIST_ERROR2.matcher(e.getMessage()).matches()))
+                return true;
+
+            e = e.getCause();
+        }
+
+        return false;
+    }
+
+    /**
+     * Checks if Cassandra table absence error occur.
+     *
+     * @param e Exception to check.
+     * @return {@code true} in case of table absence error.
+     */
+    public static boolean isTableAbsenceError(Throwable e) {
+        while (e != null) {
+            if (e instanceof InvalidQueryException &&
+                (TABLE_EXIST_ERROR.matcher(e.getMessage()).matches() ||
+                    KEYSPACE_EXIST_ERROR1.matcher(e.getMessage()).matches() ||
+                    KEYSPACE_EXIST_ERROR2.matcher(e.getMessage()).matches()))
+                return true;
+
+            e = e.getCause();
+        }
+
+        return false;
+    }
+
+    /**
+     * Checks if Cassandra host availability error occur, thus host became unavailable.
+     *
+     * @param e Exception to check.
+     * @return {@code true} in case of host not available error.
+     */
+    public static boolean isHostsAvailabilityError(Throwable e) {
+        while (e != null) {
+            if (e instanceof NoHostAvailableException ||
+                e instanceof ReadTimeoutException)
+                return true;
+
+            e = e.getCause();
+        }
+
+        return false;
+    }
+
+    /**
+     * Checks if Cassandra error occur because of prepared statement created in one session was used in another session.
+     *
+     * @param e Exception to check.
+     * @return {@code true} in case of invalid usage of prepared statement.
+     */
+    public static boolean isPreparedStatementClusterError(Throwable e) {
+        while (e != null) {
+            if (e instanceof InvalidQueryException && e.getMessage().contains(PREP_STATEMENT_CLUSTER_INSTANCE_ERROR))
+                return true;
+
+            e = e.getCause();
+        }
+
+        return false;
+    }
+}
+

http://git-wip-us.apache.org/repos/asf/ignite/blob/b33eb027/modules/cassandra/src/main/java/org/apache/ignite/cache/store/cassandra/common/PropertyMappingHelper.java
----------------------------------------------------------------------
diff --git a/modules/cassandra/src/main/java/org/apache/ignite/cache/store/cassandra/common/PropertyMappingHelper.java b/modules/cassandra/src/main/java/org/apache/ignite/cache/store/cassandra/common/PropertyMappingHelper.java
new file mode 100644
index 0000000..9053a93
--- /dev/null
+++ b/modules/cassandra/src/main/java/org/apache/ignite/cache/store/cassandra/common/PropertyMappingHelper.java
@@ -0,0 +1,220 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.ignite.cache.store.cassandra.common;
+
+import com.datastax.driver.core.DataType;
+import com.datastax.driver.core.Row;
+import java.beans.PropertyDescriptor;
+import java.lang.annotation.Annotation;
+import java.math.BigDecimal;
+import java.math.BigInteger;
+import java.net.InetAddress;
+import java.nio.ByteBuffer;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.UUID;
+import org.apache.commons.beanutils.PropertyUtils;
+import org.apache.ignite.cache.store.cassandra.serializer.Serializer;
+
+/**
+ * Helper class providing bunch of methods to discover fields of POJO objects and
+ * map builtin Java types to appropriate Cassandra types.
+ */
+public class PropertyMappingHelper {
+    /** Bytes array Class type. */
+    private static final Class BYTES_ARRAY_CLASS = (new byte[] {}).getClass();
+
+    /** Mapping from Java to Cassandra types. */
+    private static final Map<Class, DataType.Name> JAVA_TO_CASSANDRA_MAPPING = new HashMap<Class, DataType.Name>() {{
+        put(String.class, DataType.Name.TEXT);
+        put(Integer.class, DataType.Name.INT);
+        put(int.class, DataType.Name.INT);
+        put(Short.class, DataType.Name.INT);
+        put(short.class, DataType.Name.INT);
+        put(Long.class, DataType.Name.BIGINT);
+        put(long.class, DataType.Name.BIGINT);
+        put(Double.class, DataType.Name.DOUBLE);
+        put(double.class, DataType.Name.DOUBLE);
+        put(Boolean.class, DataType.Name.BOOLEAN);
+        put(boolean.class, DataType.Name.BOOLEAN);
+        put(Float.class, DataType.Name.FLOAT);
+        put(float.class, DataType.Name.FLOAT);
+        put(ByteBuffer.class, DataType.Name.BLOB);
+        put(BYTES_ARRAY_CLASS, DataType.Name.BLOB);
+        put(BigDecimal.class, DataType.Name.DECIMAL);
+        put(InetAddress.class, DataType.Name.INET);
+        put(Date.class, DataType.Name.TIMESTAMP);
+        put(UUID.class, DataType.Name.UUID);
+        put(BigInteger.class, DataType.Name.VARINT);
+    }};
+
+    /**
+     * Maps Cassandra type to specified Java type.
+     *
+     * @param clazz java class.
+     *
+     * @return Cassandra type.
+     */
+    public static DataType.Name getCassandraType(Class clazz) {
+        return JAVA_TO_CASSANDRA_MAPPING.get(clazz);
+    }
+
+    /**
+     * Returns property descriptor by class property name.
+     *
+     * @param clazz class from which to get property descriptor.
+     * @param prop name of the property.
+     *
+     * @return property descriptor.
+     */
+    public static PropertyDescriptor getPojoPropertyDescriptor(Class clazz, String prop) {
+        List<PropertyDescriptor> descriptors = getPojoPropertyDescriptors(clazz, false);
+
+        if (descriptors == null || descriptors.isEmpty())
+            throw new IllegalArgumentException("POJO class " + clazz.getName() + " doesn't have '" + prop + "' property");
+
+        for (PropertyDescriptor descriptor : descriptors) {
+            if (descriptor.getName().equals(prop))
+                return descriptor;
+        }
+
+        throw new IllegalArgumentException("POJO class " + clazz.getName() + " doesn't have '" + prop + "' property");
+    }
+
+    /**
+     * Extracts all property descriptors from a class.
+     *
+     * @param clazz class which property descriptors should be extracted.
+     * @param primitive boolean flag indicating that only property descriptors for primitive properties should be extracted.
+     *
+     * @return list of class property descriptors
+     */
+    public static List<PropertyDescriptor> getPojoPropertyDescriptors(Class clazz, boolean primitive) {
+        return getPojoPropertyDescriptors(clazz, null, primitive);
+    }
+
+    /**
+     * Extracts all property descriptors having specific annotation from a class.
+     *
+     * @param clazz class which property descriptors should be extracted.
+     * @param annotation annotation to look for.
+     * @param primitive boolean flag indicating that only property descriptors for primitive properties should be extracted.
+     *
+     * @return list of class property descriptors
+     */
+    public static <T extends Annotation> List<PropertyDescriptor> getPojoPropertyDescriptors(Class clazz,
+        Class<T> annotation, boolean primitive) {
+        PropertyDescriptor[] descriptors = PropertyUtils.getPropertyDescriptors(clazz);
+
+        List<PropertyDescriptor> list = new ArrayList<>(descriptors == null ? 1 : descriptors.length);
+
+        if (descriptors == null || descriptors.length == 0)
+            return list;
+
+        for (PropertyDescriptor descriptor : descriptors) {
+            if (descriptor.getReadMethod() == null || descriptor.getWriteMethod() == null ||
+                (primitive && !isPrimitivePropertyDescriptor(descriptor)))
+                continue;
+
+            if (annotation == null || descriptor.getReadMethod().getAnnotation(annotation) != null)
+                list.add(descriptor);
+        }
+
+        return list;
+    }
+
+    /**
+     * Checks if property descriptor describes primitive property (int, boolean, long and etc.)
+     *
+     * @param desc property descriptor.
+     *
+     * @return {@code true} property is primitive
+     */
+    public static boolean isPrimitivePropertyDescriptor(PropertyDescriptor desc) {
+        return PropertyMappingHelper.JAVA_TO_CASSANDRA_MAPPING.containsKey(desc.getPropertyType());
+    }
+
+    /**
+     * Returns value of specific column in the row returned by CQL statement.
+     *
+     * @param row row returned by CQL statement.
+     * @param col column name.
+     * @param clazz java class to which column value should be casted.
+     * @param serializer serializer to use if column stores BLOB otherwise could be null.
+     *
+     * @return row column value.
+     */
+    public static Object getCassandraColumnValue(Row row, String col, Class clazz, Serializer serializer) {
+        if (String.class.equals(clazz))
+            return row.getString(col);
+
+        if (Integer.class.equals(clazz) || int.class.equals(clazz))
+            return row.getInt(col);
+
+        if (Short.class.equals(clazz) || short.class.equals(clazz))
+            return (short)row.getInt(col);
+
+        if (Long.class.equals(clazz) || long.class.equals(clazz))
+            return row.getLong(col);
+
+        if (Double.class.equals(clazz) || double.class.equals(clazz))
+            return row.getDouble(col);
+
+        if (Boolean.class.equals(clazz) || boolean.class.equals(clazz))
+            return row.getBool(col);
+
+        if (Float.class.equals(clazz) || float.class.equals(clazz))
+            return row.getFloat(col);
+
+        if (ByteBuffer.class.equals(clazz))
+            return row.getBytes(col);
+
+        if (PropertyMappingHelper.BYTES_ARRAY_CLASS.equals(clazz)) {
+            ByteBuffer buf = row.getBytes(col);
+
+            return buf == null ? null : buf.array();
+        }
+
+        if (BigDecimal.class.equals(clazz))
+            return row.getDecimal(col);
+
+        if (InetAddress.class.equals(clazz))
+            return row.getInet(col);
+
+        if (Date.class.equals(clazz))
+            return row.getTimestamp(col);
+
+        if (UUID.class.equals(clazz))
+            return row.getUUID(col);
+
+        if (BigInteger.class.equals(clazz))
+            return row.getVarint(col);
+
+        if (serializer == null) {
+            throw new IllegalStateException("Can't deserialize value from '" + col + "' Cassandra column, " +
+                "cause there is no BLOB serializer specified");
+        }
+
+        ByteBuffer buf = row.getBytes(col);
+
+        return buf == null ? null : serializer.deserialize(buf);
+    }
+}

http://git-wip-us.apache.org/repos/asf/ignite/blob/b33eb027/modules/cassandra/src/main/java/org/apache/ignite/cache/store/cassandra/common/RandomSleeper.java
----------------------------------------------------------------------
diff --git a/modules/cassandra/src/main/java/org/apache/ignite/cache/store/cassandra/common/RandomSleeper.java b/modules/cassandra/src/main/java/org/apache/ignite/cache/store/cassandra/common/RandomSleeper.java
new file mode 100644
index 0000000..6745a16
--- /dev/null
+++ b/modules/cassandra/src/main/java/org/apache/ignite/cache/store/cassandra/common/RandomSleeper.java
@@ -0,0 +1,104 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.ignite.cache.store.cassandra.common;
+
+import java.util.Random;
+import org.apache.ignite.IgniteException;
+import org.apache.ignite.IgniteLogger;
+
+/**
+ * Provides sleep method with randomly selected sleep time from specified range and
+ * incrementally shifts sleep time range for each next sleep attempt
+ *
+ */
+public class RandomSleeper {
+    /** */
+    private int min;
+
+    /** */
+    private int max;
+
+    /** */
+    private int incr;
+
+    /** */
+    private IgniteLogger log;
+
+    /** */
+    private Random random = new Random(System.currentTimeMillis());
+
+    /** */
+    private int summary = 0;
+
+    /**
+     * Creates sleeper instance.
+     *
+     * @param min minimum sleep time (in milliseconds)
+     * @param max maximum sleep time (in milliseconds)
+     * @param incr time range shift increment (in milliseconds)
+     */
+    public RandomSleeper(int min, int max, int incr, IgniteLogger log) {
+        if (min <= 0)
+            throw new IllegalArgumentException("Incorrect min time specified: " + min);
+
+        if (max <= min)
+            throw new IllegalArgumentException("Incorrect max time specified: " + max);
+
+        if (incr < 10)
+            throw new IllegalArgumentException("Incorrect increment specified: " + incr);
+
+        this.min = min;
+        this.max = max;
+        this.incr = incr;
+        this.log = log;
+    }
+
+    /**
+     * Sleeps
+     */
+    public void sleep() {
+        try {
+            int timeout = random.nextInt(max - min + 1) + min;
+
+            if (log != null)
+                log.info("Sleeping for " + timeout + "ms");
+
+            Thread.sleep(timeout);
+
+            summary += timeout;
+
+            if (log != null)
+                log.info("Sleep completed");
+        }
+        catch (InterruptedException e) {
+            throw new IgniteException("Random sleep interrupted", e);
+        }
+
+        min += incr;
+        max += incr;
+    }
+
+    /**
+     * Returns summary sleep time.
+     *
+     * @return Summary sleep time in milliseconds.
+     */
+    public int getSleepSummary() {
+        return summary;
+    }
+}

http://git-wip-us.apache.org/repos/asf/ignite/blob/b33eb027/modules/cassandra/src/main/java/org/apache/ignite/cache/store/cassandra/common/SystemHelper.java
----------------------------------------------------------------------
diff --git a/modules/cassandra/src/main/java/org/apache/ignite/cache/store/cassandra/common/SystemHelper.java b/modules/cassandra/src/main/java/org/apache/ignite/cache/store/cassandra/common/SystemHelper.java
new file mode 100644
index 0000000..5d51488
--- /dev/null
+++ b/modules/cassandra/src/main/java/org/apache/ignite/cache/store/cassandra/common/SystemHelper.java
@@ -0,0 +1,46 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.ignite.cache.store.cassandra.common;
+
+import java.net.InetAddress;
+import java.net.UnknownHostException;
+
+/**
+ * Helper class providing system information about the host (ip, hostname, os and etc.)
+ */
+public class SystemHelper {
+    /** System line separator. */
+    public static final String LINE_SEPARATOR = System.getProperty("line.separator");
+
+    /** Host name. */
+    public static final String HOST_NAME;
+
+    /** Host IP address */
+    public static final String HOST_IP;
+
+    static {
+        try {
+            InetAddress addr = InetAddress.getLocalHost();
+            HOST_NAME = addr.getHostName();
+            HOST_IP = addr.getHostAddress();
+        }
+        catch (UnknownHostException e) {
+            throw new IllegalStateException("Failed to get host/ip of current computer", e);
+        }
+    }
+}

http://git-wip-us.apache.org/repos/asf/ignite/blob/b33eb027/modules/cassandra/src/main/java/org/apache/ignite/cache/store/cassandra/datasource/Credentials.java
----------------------------------------------------------------------
diff --git a/modules/cassandra/src/main/java/org/apache/ignite/cache/store/cassandra/datasource/Credentials.java b/modules/cassandra/src/main/java/org/apache/ignite/cache/store/cassandra/datasource/Credentials.java
new file mode 100644
index 0000000..e1fd60c
--- /dev/null
+++ b/modules/cassandra/src/main/java/org/apache/ignite/cache/store/cassandra/datasource/Credentials.java
@@ -0,0 +1,37 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.ignite.cache.store.cassandra.datasource;
+
+/**
+ * Provides credentials for Cassandra (instead of specifying user/password directly in Spring context XML).
+ */
+public interface Credentials {
+    /**
+     * Returns user name
+     *
+     * @return user name
+     */
+    public String getUser();
+
+    /**
+     * Returns password
+     *
+     * @return password
+     */
+    public String getPassword();
+}


Mime
View raw message