diff --git a/cassandra/cqlengine/__init__.py b/cassandra/cqlengine/__init__.py new file mode 100644 index 00000000..1c61c4ee --- /dev/null +++ b/cassandra/cqlengine/__init__.py @@ -0,0 +1,9 @@ +# compaction +SizeTieredCompactionStrategy = "SizeTieredCompactionStrategy" +LeveledCompactionStrategy = "LeveledCompactionStrategy" + +# Caching constants. +CACHING_ALL = "ALL" +CACHING_KEYS_ONLY = "KEYS_ONLY" +CACHING_ROWS_ONLY = "ROWS_ONLY" +CACHING_NONE = "NONE" diff --git a/cqlengine/columns.py b/cassandra/cqlengine/columns.py similarity index 99% rename from cqlengine/columns.py rename to cassandra/cqlengine/columns.py index bb2d77bb..cc43a117 100644 --- a/cqlengine/columns.py +++ b/cassandra/cqlengine/columns.py @@ -3,14 +3,14 @@ from copy import deepcopy, copy from datetime import datetime from datetime import date import re -from cassandra.cqltypes import DateType - -from cqlengine.exceptions import ValidationError -from cassandra.encoder import cql_quote import six - import sys +from cassandra.cqltypes import DateType +from cassandra.encoder import cql_quote +from cassandra.cqlengine.exceptions import ValidationError + + # move to central spot class UnicodeMixin(object): if sys.version_info > (3, 0): diff --git a/cqlengine/connection.py b/cassandra/cqlengine/connection.py similarity index 90% rename from cqlengine/connection.py rename to cassandra/cqlengine/connection.py index 34f8da3a..d2af8cae 100644 --- a/cqlengine/connection.py +++ b/cassandra/cqlengine/connection.py @@ -1,17 +1,13 @@ -#http://pypi.python.org/pypi/cql/1.0.4 -#http://code.google.com/a/apache-extras.org/p/cassandra-dbapi2 / -#http://cassandra.apache.org/doc/cql/CQL.html -from __future__ import absolute_import from collections import namedtuple -from cassandra.cluster import Cluster, _NOT_SET, NoHostAvailable -from cassandra.query import SimpleStatement, Statement, dict_factory -from cqlengine.statements import BaseCQLStatement -from cqlengine.exceptions import CQLEngineException, UndefinedKeyspaceException -from cassandra import ConsistencyLevel - import six import logging +from cassandra import ConsistencyLevel +from cassandra.cluster import Cluster, _NOT_SET, NoHostAvailable +from cassandra.query import SimpleStatement, Statement, dict_factory +from cassandra.cqlengine.exceptions import CQLEngineException, UndefinedKeyspaceException +from cassandra.cqlengine.statements import BaseCQLStatement + LOG = logging.getLogger('cqlengine.cql') NOT_SET = _NOT_SET # required for passing timeout to Session.execute @@ -55,7 +51,7 @@ def setup( if not default_keyspace: raise UndefinedKeyspaceException() - from cqlengine import models + from cassandra.cqlengine import models models.DEFAULT_KEYSPACE = default_keyspace default_consistency_level = consistency diff --git a/cqlengine/exceptions.py b/cassandra/cqlengine/exceptions.py similarity index 100% rename from cqlengine/exceptions.py rename to cassandra/cqlengine/exceptions.py diff --git a/cqlengine/functions.py b/cassandra/cqlengine/functions.py similarity index 98% rename from cqlengine/functions.py rename to cassandra/cqlengine/functions.py index d1462907..78d42479 100644 --- a/cqlengine/functions.py +++ b/cassandra/cqlengine/functions.py @@ -1,8 +1,8 @@ from datetime import datetime -from uuid import uuid1 -import sys import six -from cqlengine.exceptions import ValidationError +import sys + +from cassandra.cqlengine.exceptions import ValidationError # move to central spot class UnicodeMixin(object): diff --git a/cqlengine/management.py b/cassandra/cqlengine/management.py similarity index 97% rename from cqlengine/management.py rename to cassandra/cqlengine/management.py index 388efbcd..58f4a871 100644 --- a/cqlengine/management.py +++ b/cassandra/cqlengine/management.py @@ -1,19 +1,18 @@ -import json -import warnings -import six -from cqlengine import SizeTieredCompactionStrategy, LeveledCompactionStrategy -from cqlengine import ONE -from cqlengine.named import NamedTable - -from cqlengine.connection import execute, get_cluster -from cqlengine.exceptions import CQLEngineException - -import logging from collections import namedtuple +import json +import logging +import six + +from cassandra.cqlengine import SizeTieredCompactionStrategy, LeveledCompactionStrategy +from cassandra.cqlengine.connection import execute, get_cluster +from cassandra.cqlengine.exceptions import CQLEngineException +from cassandra.cqlengine.models import Model +from cassandra.cqlengine.named import NamedTable + + Field = namedtuple('Field', ['name', 'type']) logger = logging.getLogger(__name__) -from cqlengine.models import Model # system keyspaces schema_columnfamilies = NamedTable('system', 'schema_columnfamilies') diff --git a/cqlengine/models.py b/cassandra/cqlengine/models.py similarity index 98% rename from cqlengine/models.py rename to cassandra/cqlengine/models.py index d541f1a9..019d6beb 100644 --- a/cqlengine/models.py +++ b/cassandra/cqlengine/models.py @@ -1,12 +1,11 @@ -from collections import OrderedDict import re -import warnings -from cqlengine import columns -from cqlengine.exceptions import ModelException, CQLEngineException, ValidationError -from cqlengine.query import ModelQuerySet, DMLQuery, AbstractQueryableColumn, NOT_SET -from cqlengine.query import DoesNotExist as _DoesNotExist -from cqlengine.query import MultipleObjectsReturned as _MultipleObjectsReturned +from cassandra.cqlengine import columns +from cassandra.cqlengine.exceptions import ModelException, CQLEngineException, ValidationError +from cassandra.cqlengine.query import ModelQuerySet, DMLQuery, AbstractQueryableColumn, NOT_SET +from cassandra.cqlengine.query import DoesNotExist as _DoesNotExist +from cassandra.cqlengine.query import MultipleObjectsReturned as _MultipleObjectsReturned +from cassandra.util import OrderedDict class ModelDefinitionException(ModelException): pass diff --git a/cqlengine/named.py b/cassandra/cqlengine/named.py similarity index 89% rename from cqlengine/named.py rename to cassandra/cqlengine/named.py index c6ba3ac9..0f0b86b2 100644 --- a/cqlengine/named.py +++ b/cassandra/cqlengine/named.py @@ -1,8 +1,7 @@ -from cqlengine.exceptions import CQLEngineException -from cqlengine.query import AbstractQueryableColumn, SimpleQuerySet - -from cqlengine.query import DoesNotExist as _DoesNotExist -from cqlengine.query import MultipleObjectsReturned as _MultipleObjectsReturned +from cassandra.cqlengine.exceptions import CQLEngineException +from cassandra.cqlengine.query import AbstractQueryableColumn, SimpleQuerySet +from cassandra.cqlengine.query import DoesNotExist as _DoesNotExist +from cassandra.cqlengine.query import MultipleObjectsReturned as _MultipleObjectsReturned class QuerySetDescriptor(object): """ diff --git a/cqlengine/operators.py b/cassandra/cqlengine/operators.py similarity index 99% rename from cqlengine/operators.py rename to cassandra/cqlengine/operators.py index 47763566..e609531f 100644 --- a/cqlengine/operators.py +++ b/cassandra/cqlengine/operators.py @@ -1,10 +1,9 @@ import six +import sys class QueryOperatorException(Exception): pass -import sys - # move to central spot class UnicodeMixin(object): if sys.version_info > (3, 0): diff --git a/cqlengine/query.py b/cassandra/cqlengine/query.py similarity index 97% rename from cqlengine/query.py rename to cassandra/cqlengine/query.py index adb559ea..ca647f01 100644 --- a/cqlengine/query.py +++ b/cassandra/cqlengine/query.py @@ -1,20 +1,20 @@ -from __future__ import absolute_import import copy -import time from datetime import datetime, timedelta -from cqlengine import BaseContainerColumn, Map, columns -from cqlengine.columns import Counter, List, Set +import time -from .connection import execute, NOT_SET - -from cqlengine.exceptions import CQLEngineException, ValidationError, LWTException, IfNotExistsWithCounterColumn -from cqlengine.functions import Token, BaseQueryFunction, QueryValue, UnicodeMixin - -#CQL 3 reference: -#http://www.datastax.com/docs/1.1/references/cql/index -from cqlengine.operators import InOperator, EqualsOperator, GreaterThanOperator, GreaterThanOrEqualOperator -from cqlengine.operators import LessThanOperator, LessThanOrEqualOperator, BaseWhereOperator -from cqlengine.statements import WhereClause, SelectStatement, DeleteStatement, UpdateStatement, AssignmentClause, InsertStatement, BaseCQLStatement, MapUpdateClause, MapDeleteClause, ListUpdateClause, SetUpdateClause, CounterUpdateClause, TransactionClause +from cassandra.cqlengine.columns import BaseContainerColumn, Map, Counter, List, Set +from cassandra.cqlengine.connection import execute, NOT_SET +from cassandra.cqlengine.exceptions import CQLEngineException, ValidationError, LWTException, IfNotExistsWithCounterColumn +from cassandra.cqlengine.functions import Token, BaseQueryFunction, QueryValue, UnicodeMixin +from cassandra.cqlengine.operators import (InOperator, EqualsOperator, GreaterThanOperator, + GreaterThanOrEqualOperator, LessThanOperator, + LessThanOrEqualOperator, BaseWhereOperator) +# import * ? +from cassandra.cqlengine.statements import (WhereClause, SelectStatement, DeleteStatement, + UpdateStatement, AssignmentClause, InsertStatement, + BaseCQLStatement, MapUpdateClause, MapDeleteClause, + ListUpdateClause, SetUpdateClause, CounterUpdateClause, + TransactionClause) class QueryException(CQLEngineException): pass diff --git a/cqlengine/statements.py b/cassandra/cqlengine/statements.py similarity index 99% rename from cqlengine/statements.py rename to cassandra/cqlengine/statements.py index b044c86c..917b9862 100644 --- a/cqlengine/statements.py +++ b/cassandra/cqlengine/statements.py @@ -1,16 +1,15 @@ -import time from datetime import datetime, timedelta +import time import six -from cqlengine.functions import QueryValue -from cqlengine.operators import BaseWhereOperator, InOperator +import sys + +from cassandra.cqlengine.functions import QueryValue +from cassandra.cqlengine.operators import BaseWhereOperator, InOperator class StatementException(Exception): pass - -import sys - class UnicodeMixin(object): if sys.version_info > (3, 0): __str__ = lambda x: x.__unicode__() diff --git a/cqlengine/tests/__init__.py b/cassandra/cqlengine/tests/__init__.py similarity index 100% rename from cqlengine/tests/__init__.py rename to cassandra/cqlengine/tests/__init__.py diff --git a/cqlengine/tests/base.py b/cassandra/cqlengine/tests/base.py similarity index 100% rename from cqlengine/tests/base.py rename to cassandra/cqlengine/tests/base.py diff --git a/cqlengine/tests/columns/__init__.py b/cassandra/cqlengine/tests/columns/__init__.py similarity index 100% rename from cqlengine/tests/columns/__init__.py rename to cassandra/cqlengine/tests/columns/__init__.py diff --git a/cqlengine/tests/columns/test_container_columns.py b/cassandra/cqlengine/tests/columns/test_container_columns.py similarity index 100% rename from cqlengine/tests/columns/test_container_columns.py rename to cassandra/cqlengine/tests/columns/test_container_columns.py diff --git a/cqlengine/tests/columns/test_counter_column.py b/cassandra/cqlengine/tests/columns/test_counter_column.py similarity index 100% rename from cqlengine/tests/columns/test_counter_column.py rename to cassandra/cqlengine/tests/columns/test_counter_column.py diff --git a/cqlengine/tests/columns/test_static_column.py b/cassandra/cqlengine/tests/columns/test_static_column.py similarity index 100% rename from cqlengine/tests/columns/test_static_column.py rename to cassandra/cqlengine/tests/columns/test_static_column.py diff --git a/cqlengine/tests/columns/test_validation.py b/cassandra/cqlengine/tests/columns/test_validation.py similarity index 100% rename from cqlengine/tests/columns/test_validation.py rename to cassandra/cqlengine/tests/columns/test_validation.py diff --git a/cqlengine/tests/columns/test_value_io.py b/cassandra/cqlengine/tests/columns/test_value_io.py similarity index 100% rename from cqlengine/tests/columns/test_value_io.py rename to cassandra/cqlengine/tests/columns/test_value_io.py diff --git a/cqlengine/tests/connections/__init__.py b/cassandra/cqlengine/tests/connections/__init__.py similarity index 100% rename from cqlengine/tests/connections/__init__.py rename to cassandra/cqlengine/tests/connections/__init__.py diff --git a/cqlengine/tests/management/__init__.py b/cassandra/cqlengine/tests/management/__init__.py similarity index 100% rename from cqlengine/tests/management/__init__.py rename to cassandra/cqlengine/tests/management/__init__.py diff --git a/cqlengine/tests/management/test_compaction_settings.py b/cassandra/cqlengine/tests/management/test_compaction_settings.py similarity index 100% rename from cqlengine/tests/management/test_compaction_settings.py rename to cassandra/cqlengine/tests/management/test_compaction_settings.py diff --git a/cqlengine/tests/management/test_management.py b/cassandra/cqlengine/tests/management/test_management.py similarity index 100% rename from cqlengine/tests/management/test_management.py rename to cassandra/cqlengine/tests/management/test_management.py diff --git a/cqlengine/tests/model/__init__.py b/cassandra/cqlengine/tests/model/__init__.py similarity index 100% rename from cqlengine/tests/model/__init__.py rename to cassandra/cqlengine/tests/model/__init__.py diff --git a/cqlengine/tests/model/test_class_construction.py b/cassandra/cqlengine/tests/model/test_class_construction.py similarity index 100% rename from cqlengine/tests/model/test_class_construction.py rename to cassandra/cqlengine/tests/model/test_class_construction.py diff --git a/cqlengine/tests/model/test_equality_operations.py b/cassandra/cqlengine/tests/model/test_equality_operations.py similarity index 100% rename from cqlengine/tests/model/test_equality_operations.py rename to cassandra/cqlengine/tests/model/test_equality_operations.py diff --git a/cqlengine/tests/model/test_model.py b/cassandra/cqlengine/tests/model/test_model.py similarity index 100% rename from cqlengine/tests/model/test_model.py rename to cassandra/cqlengine/tests/model/test_model.py diff --git a/cqlengine/tests/model/test_model_io.py b/cassandra/cqlengine/tests/model/test_model_io.py similarity index 100% rename from cqlengine/tests/model/test_model_io.py rename to cassandra/cqlengine/tests/model/test_model_io.py diff --git a/cqlengine/tests/model/test_polymorphism.py b/cassandra/cqlengine/tests/model/test_polymorphism.py similarity index 100% rename from cqlengine/tests/model/test_polymorphism.py rename to cassandra/cqlengine/tests/model/test_polymorphism.py diff --git a/cqlengine/tests/model/test_updates.py b/cassandra/cqlengine/tests/model/test_updates.py similarity index 100% rename from cqlengine/tests/model/test_updates.py rename to cassandra/cqlengine/tests/model/test_updates.py diff --git a/cqlengine/tests/model/test_validation.py b/cassandra/cqlengine/tests/model/test_validation.py similarity index 100% rename from cqlengine/tests/model/test_validation.py rename to cassandra/cqlengine/tests/model/test_validation.py diff --git a/cqlengine/tests/model/test_value_lists.py b/cassandra/cqlengine/tests/model/test_value_lists.py similarity index 100% rename from cqlengine/tests/model/test_value_lists.py rename to cassandra/cqlengine/tests/model/test_value_lists.py diff --git a/cqlengine/tests/operators/__init__.py b/cassandra/cqlengine/tests/operators/__init__.py similarity index 100% rename from cqlengine/tests/operators/__init__.py rename to cassandra/cqlengine/tests/operators/__init__.py diff --git a/cqlengine/tests/operators/test_assignment_operators.py b/cassandra/cqlengine/tests/operators/test_assignment_operators.py similarity index 100% rename from cqlengine/tests/operators/test_assignment_operators.py rename to cassandra/cqlengine/tests/operators/test_assignment_operators.py diff --git a/cqlengine/tests/operators/test_base_operator.py b/cassandra/cqlengine/tests/operators/test_base_operator.py similarity index 100% rename from cqlengine/tests/operators/test_base_operator.py rename to cassandra/cqlengine/tests/operators/test_base_operator.py diff --git a/cqlengine/tests/operators/test_where_operators.py b/cassandra/cqlengine/tests/operators/test_where_operators.py similarity index 100% rename from cqlengine/tests/operators/test_where_operators.py rename to cassandra/cqlengine/tests/operators/test_where_operators.py diff --git a/cqlengine/tests/query/__init__.py b/cassandra/cqlengine/tests/query/__init__.py similarity index 100% rename from cqlengine/tests/query/__init__.py rename to cassandra/cqlengine/tests/query/__init__.py diff --git a/cqlengine/tests/query/test_batch_query.py b/cassandra/cqlengine/tests/query/test_batch_query.py similarity index 100% rename from cqlengine/tests/query/test_batch_query.py rename to cassandra/cqlengine/tests/query/test_batch_query.py diff --git a/cqlengine/tests/query/test_datetime_queries.py b/cassandra/cqlengine/tests/query/test_datetime_queries.py similarity index 100% rename from cqlengine/tests/query/test_datetime_queries.py rename to cassandra/cqlengine/tests/query/test_datetime_queries.py diff --git a/cqlengine/tests/query/test_named.py b/cassandra/cqlengine/tests/query/test_named.py similarity index 100% rename from cqlengine/tests/query/test_named.py rename to cassandra/cqlengine/tests/query/test_named.py diff --git a/cqlengine/tests/query/test_queryoperators.py b/cassandra/cqlengine/tests/query/test_queryoperators.py similarity index 100% rename from cqlengine/tests/query/test_queryoperators.py rename to cassandra/cqlengine/tests/query/test_queryoperators.py diff --git a/cqlengine/tests/query/test_queryset.py b/cassandra/cqlengine/tests/query/test_queryset.py similarity index 100% rename from cqlengine/tests/query/test_queryset.py rename to cassandra/cqlengine/tests/query/test_queryset.py diff --git a/cqlengine/tests/query/test_updates.py b/cassandra/cqlengine/tests/query/test_updates.py similarity index 100% rename from cqlengine/tests/query/test_updates.py rename to cassandra/cqlengine/tests/query/test_updates.py diff --git a/cqlengine/tests/statements/__init__.py b/cassandra/cqlengine/tests/statements/__init__.py similarity index 100% rename from cqlengine/tests/statements/__init__.py rename to cassandra/cqlengine/tests/statements/__init__.py diff --git a/cqlengine/tests/statements/test_assignment_clauses.py b/cassandra/cqlengine/tests/statements/test_assignment_clauses.py similarity index 100% rename from cqlengine/tests/statements/test_assignment_clauses.py rename to cassandra/cqlengine/tests/statements/test_assignment_clauses.py diff --git a/cqlengine/tests/statements/test_assignment_statement.py b/cassandra/cqlengine/tests/statements/test_assignment_statement.py similarity index 100% rename from cqlengine/tests/statements/test_assignment_statement.py rename to cassandra/cqlengine/tests/statements/test_assignment_statement.py diff --git a/cqlengine/tests/statements/test_base_clause.py b/cassandra/cqlengine/tests/statements/test_base_clause.py similarity index 100% rename from cqlengine/tests/statements/test_base_clause.py rename to cassandra/cqlengine/tests/statements/test_base_clause.py diff --git a/cqlengine/tests/statements/test_base_statement.py b/cassandra/cqlengine/tests/statements/test_base_statement.py similarity index 100% rename from cqlengine/tests/statements/test_base_statement.py rename to cassandra/cqlengine/tests/statements/test_base_statement.py diff --git a/cqlengine/tests/statements/test_delete_statement.py b/cassandra/cqlengine/tests/statements/test_delete_statement.py similarity index 100% rename from cqlengine/tests/statements/test_delete_statement.py rename to cassandra/cqlengine/tests/statements/test_delete_statement.py diff --git a/cqlengine/tests/statements/test_insert_statement.py b/cassandra/cqlengine/tests/statements/test_insert_statement.py similarity index 100% rename from cqlengine/tests/statements/test_insert_statement.py rename to cassandra/cqlengine/tests/statements/test_insert_statement.py diff --git a/cqlengine/tests/statements/test_quoter.py b/cassandra/cqlengine/tests/statements/test_quoter.py similarity index 100% rename from cqlengine/tests/statements/test_quoter.py rename to cassandra/cqlengine/tests/statements/test_quoter.py diff --git a/cqlengine/tests/statements/test_select_statement.py b/cassandra/cqlengine/tests/statements/test_select_statement.py similarity index 100% rename from cqlengine/tests/statements/test_select_statement.py rename to cassandra/cqlengine/tests/statements/test_select_statement.py diff --git a/cqlengine/tests/statements/test_update_statement.py b/cassandra/cqlengine/tests/statements/test_update_statement.py similarity index 100% rename from cqlengine/tests/statements/test_update_statement.py rename to cassandra/cqlengine/tests/statements/test_update_statement.py diff --git a/cqlengine/tests/statements/test_where_clause.py b/cassandra/cqlengine/tests/statements/test_where_clause.py similarity index 100% rename from cqlengine/tests/statements/test_where_clause.py rename to cassandra/cqlengine/tests/statements/test_where_clause.py diff --git a/cqlengine/tests/test_batch_query.py b/cassandra/cqlengine/tests/test_batch_query.py similarity index 100% rename from cqlengine/tests/test_batch_query.py rename to cassandra/cqlengine/tests/test_batch_query.py diff --git a/cqlengine/tests/test_consistency.py b/cassandra/cqlengine/tests/test_consistency.py similarity index 100% rename from cqlengine/tests/test_consistency.py rename to cassandra/cqlengine/tests/test_consistency.py diff --git a/cqlengine/tests/test_ifnotexists.py b/cassandra/cqlengine/tests/test_ifnotexists.py similarity index 100% rename from cqlengine/tests/test_ifnotexists.py rename to cassandra/cqlengine/tests/test_ifnotexists.py diff --git a/cqlengine/tests/test_load.py b/cassandra/cqlengine/tests/test_load.py similarity index 100% rename from cqlengine/tests/test_load.py rename to cassandra/cqlengine/tests/test_load.py diff --git a/cqlengine/tests/test_timestamp.py b/cassandra/cqlengine/tests/test_timestamp.py similarity index 100% rename from cqlengine/tests/test_timestamp.py rename to cassandra/cqlengine/tests/test_timestamp.py diff --git a/cqlengine/tests/test_transaction.py b/cassandra/cqlengine/tests/test_transaction.py similarity index 100% rename from cqlengine/tests/test_transaction.py rename to cassandra/cqlengine/tests/test_transaction.py diff --git a/cqlengine/tests/test_ttl.py b/cassandra/cqlengine/tests/test_ttl.py similarity index 100% rename from cqlengine/tests/test_ttl.py rename to cassandra/cqlengine/tests/test_ttl.py diff --git a/cqlengine/VERSION b/cqlengine/VERSION deleted file mode 100644 index 88541566..00000000 --- a/cqlengine/VERSION +++ /dev/null @@ -1 +0,0 @@ -0.21.0 diff --git a/cqlengine/__init__.py b/cqlengine/__init__.py deleted file mode 100644 index 0961afd3..00000000 --- a/cqlengine/__init__.py +++ /dev/null @@ -1,33 +0,0 @@ -import pkg_resources - -from cassandra import ConsistencyLevel - -from cqlengine.columns import * -from cqlengine.functions import * -from cqlengine.models import Model -from cqlengine.query import BatchQuery - - -__cqlengine_version_path__ = pkg_resources.resource_filename('cqlengine', - 'VERSION') -__version__ = open(__cqlengine_version_path__, 'r').readline().strip() - -# compaction -SizeTieredCompactionStrategy = "SizeTieredCompactionStrategy" -LeveledCompactionStrategy = "LeveledCompactionStrategy" - -# Caching constants. -CACHING_ALL = "ALL" -CACHING_KEYS_ONLY = "KEYS_ONLY" -CACHING_ROWS_ONLY = "ROWS_ONLY" -CACHING_NONE = "NONE" - -ANY = ConsistencyLevel.ANY -ONE = ConsistencyLevel.ONE -TWO = ConsistencyLevel.TWO -THREE = ConsistencyLevel.THREE -QUORUM = ConsistencyLevel.QUORUM -LOCAL_ONE = ConsistencyLevel.LOCAL_ONE -LOCAL_QUORUM = ConsistencyLevel.LOCAL_QUORUM -EACH_QUORUM = ConsistencyLevel.EACH_QUORUM -ALL = ConsistencyLevel.ALL