me.prettyprint.cassandra.service.spring
Class HectorTemplateImpl

java.lang.Object
  me.prettyprint.cassandra.service.spring.HectorTemplateImpl

All Implemented Interfaces:

HectorTemplate

public class HectorTemplateImpl
extends Object
implements HectorTemplate

Implementation of the HectorTemplate

Author:

Bozhidar Bozhanov

Constructor Summary

HectorTemplateImpl()

HectorTemplateImpl(Cluster cluster, String keyspace, int replicationFactor, String replicationStrategyClass, ConfigurableConsistencyLevel configurableConsistencyLevelPolicy)

Method Summary

long	createClock() Creates a clock of now with the default clock resolution (micorosec) as defined in CassandraHost
<N,V> HColumn<N,V>	createColumn(N name, V value) Creates a column with the clock of now.
<N,V> HColumn<N,V>	createColumn(N name, V value, long clock) Creates a column with the specified name/value and clock.
<N,V> HColumn<N,V>	createColumn(N name, V value, long clock, Serializer<N> nameSerializer, Serializer<V> valueSerializer)
<K,N,V> ColumnQuery<K,N,V>	createColumnQuery()
<K,N,V> ColumnQuery<K,N,V>	createColumnQuery(Serializer<V> valueSerializer)
<K,N> CountQuery<K,N>	createCountQuery(Serializer<K> keySerializer, Serializer<N> nameSerializer)
<K,N,V> IndexedSlicesQuery<K,N,V>	createIndexSlicesQuery(Serializer<K> keySerializer, Serializer<N> nameSerializer, Serializer<V> valueSerializer)
<K,N,V> MultigetSliceQuery<K,N,V>	createMultigetSliceQuery(Serializer<K> keySerializer, Serializer<N> nameSerializer, Serializer<V> valueSerializer)
<K,SN,N,V> MultigetSubSliceQuery<K,SN,N,V>	createMultigetSubSliceQuery(Serializer<K> keySerializer, Serializer<SN> sNameSerializer, Serializer<N> nameSerializer, Serializer<V> valueSerializer)
<K,SN,N,V> MultigetSuperSliceQuery<K,SN,N,V>	createMultigetSuperSliceQuery(Serializer<K> keySerializer, Serializer<SN> sNameSerializer, Serializer<N> nameSerializer, Serializer<V> valueSerializer)
<K,N,V> Mutator<K>	createMutator()
<K,N,V> Mutator<K>	createMutator(Serializer<K> keySerializer)
<K,N,V> RangeSlicesQuery<K,N,V>	createRangeSlicesQuery(Serializer<K> keySerializer, Serializer<N> nameSerializer, Serializer<V> valueSerializer)
<K,SN,N,V> RangeSubSlicesQuery<K,SN,N,V>	createRangeSubSlicesQuery(Serializer<K> keySerializer, Serializer<SN> sNameSerializer, Serializer<N> nameSerializer, Serializer<V> valueSerializer)
<K,SN,N,V> RangeSuperSlicesQuery<K,SN,N,V>	createRangeSuperSlicesQuery(Serializer<K> keySerializer, Serializer<SN> sNameSerializer, Serializer<N> nameSerializer, Serializer<V> valueSerializer)
<K> SliceQuery<K,ByteBuffer,ByteBuffer>	createSliceQuery()
<K,N,V> SliceQuery<K,N,V>	createSliceQuery(Serializer<K> keySerializer, Serializer<N> nameSerializer, Serializer<V> valueSerializer)
<K,SN,N> SubCountQuery<K,SN,N>	createSubCountQuery(Serializer<K> keySerializer, Serializer<SN> superNameSerializer, Serializer<N> nameSerializer)
<K,SN,N,V> SubSliceQuery<K,SN,N,V>	createSubSliceQuery(Serializer<K> keySerializer, Serializer<SN> sNameSerializer, Serializer<N> nameSerializer, Serializer<V> valueSerializer)
<SN,N,V> HSuperColumn<SN,N,V>	createSuperColumn(SN name, List<HColumn<N,V>> columns)
<SN,N,V> HSuperColumn<SN,N,V>	createSuperColumn(SN name, List<HColumn<N,V>> columns, long clock, Serializer<SN> superNameSerializer, Serializer<N> nameSerializer, Serializer<V> valueSerializer)
<SN,N,V> HSuperColumn<SN,N,V>	createSuperColumn(SN name, List<HColumn<N,V>> columns, Serializer<SN> superNameSerializer, Serializer<N> nameSerializer, Serializer<V> valueSerializer) createSuperColumn accepts a variable number of column arguments
<K,SN,N,V> SuperColumnQuery<K,SN,N,V>	createSuperColumnQuery(Serializer<K> keySerializer, Serializer<SN> sNameSerializer, Serializer<N> nameSerializer, Serializer<V> valueSerializer)
<K,SN> SuperCountQuery<K,SN>	createSuperCountQuery(Serializer<K> keySerializer, Serializer<SN> superNameSerializer)
<K> SuperSliceQuery<K,ByteBuffer,ByteBuffer,ByteBuffer>	createSuperSliceQuery()
<K,SN,N,V> SuperSliceQuery<K,SN,N,V>	createSuperSliceQuery(Serializer<K> keySerializer, Serializer<SN> sNameSerializer, Serializer<N> nameSerializer, Serializer<V> valueSerializer)
Cluster	getCluster()
ConfigurableConsistencyLevel	getConfigurableConsistencyLevelPolicy()
Keyspace	getKeyspace()
String	getKeyspaceName()
int	getReplicationFactor()
String	getReplicationStrategyClass()
void	init()
void	setCluster(Cluster cluster)
void	setConfigurableConsistencyLevelPolicy(ConfigurableConsistencyLevel configurableConsistencyLevelPolicy)
void	setKeyspace(Keyspace keyspace)
void	setKeyspaceName(String keyspace)
void	setReplicationFactor(int replicationFactor)
void	setReplicationStrategyClass(String replicationStrategyClass)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HectorTemplateImpl

public HectorTemplateImpl()

HectorTemplateImpl

public HectorTemplateImpl(Cluster cluster,
                          String keyspace,
                          int replicationFactor,
                          String replicationStrategyClass,
                          ConfigurableConsistencyLevel configurableConsistencyLevelPolicy)

Method Detail

init

public void init()

createMutator

public <K,N,V> Mutator<K> createMutator(Serializer<K> keySerializer)

Specified by:

createMutator in interface HectorTemplate

createColumnQuery

public <K,N,V> ColumnQuery<K,N,V> createColumnQuery()

Specified by:

createColumnQuery in interface HectorTemplate

createColumnQuery

public <K,N,V> ColumnQuery<K,N,V> createColumnQuery(Serializer<V> valueSerializer)

Specified by:

createColumnQuery in interface HectorTemplate

createCountQuery

public <K,N> CountQuery<K,N> createCountQuery(Serializer<K> keySerializer,
                                              Serializer<N> nameSerializer)

Specified by:

createCountQuery in interface HectorTemplate

createSuperCountQuery

public <K,SN> SuperCountQuery<K,SN> createSuperCountQuery(Serializer<K> keySerializer,
                                                          Serializer<SN> superNameSerializer)

Specified by:

createSuperCountQuery in interface HectorTemplate

createSubCountQuery

public <K,SN,N> SubCountQuery<K,SN,N> createSubCountQuery(Serializer<K> keySerializer,
                                                          Serializer<SN> superNameSerializer,
                                                          Serializer<N> nameSerializer)

Specified by:

createSubCountQuery in interface HectorTemplate

createSuperColumnQuery

public <K,SN,N,V> SuperColumnQuery<K,SN,N,V> createSuperColumnQuery(Serializer<K> keySerializer,
                                                                    Serializer<SN> sNameSerializer,
                                                                    Serializer<N> nameSerializer,
                                                                    Serializer<V> valueSerializer)

Specified by:

createSuperColumnQuery in interface HectorTemplate

createMultigetSliceQuery

public <K,N,V> MultigetSliceQuery<K,N,V> createMultigetSliceQuery(Serializer<K> keySerializer,
                                                                  Serializer<N> nameSerializer,
                                                                  Serializer<V> valueSerializer)

Specified by:

createMultigetSliceQuery in interface HectorTemplate

createMultigetSuperSliceQuery

public <K,SN,N,V> MultigetSuperSliceQuery<K,SN,N,V> createMultigetSuperSliceQuery(Serializer<K> keySerializer,
                                                                                  Serializer<SN> sNameSerializer,
                                                                                  Serializer<N> nameSerializer,
                                                                                  Serializer<V> valueSerializer)

Specified by:

createMultigetSuperSliceQuery in interface HectorTemplate

createMultigetSubSliceQuery

public <K,SN,N,V> MultigetSubSliceQuery<K,SN,N,V> createMultigetSubSliceQuery(Serializer<K> keySerializer,
                                                                              Serializer<SN> sNameSerializer,
                                                                              Serializer<N> nameSerializer,
                                                                              Serializer<V> valueSerializer)

Specified by:

createMultigetSubSliceQuery in interface HectorTemplate

createRangeSlicesQuery

public <K,N,V> RangeSlicesQuery<K,N,V> createRangeSlicesQuery(Serializer<K> keySerializer,
                                                              Serializer<N> nameSerializer,
                                                              Serializer<V> valueSerializer)

Specified by:

createRangeSlicesQuery in interface HectorTemplate

createRangeSuperSlicesQuery

public <K,SN,N,V> RangeSuperSlicesQuery<K,SN,N,V> createRangeSuperSlicesQuery(Serializer<K> keySerializer,
                                                                              Serializer<SN> sNameSerializer,
                                                                              Serializer<N> nameSerializer,
                                                                              Serializer<V> valueSerializer)

Specified by:

createRangeSuperSlicesQuery in interface HectorTemplate

createRangeSubSlicesQuery

public <K,SN,N,V> RangeSubSlicesQuery<K,SN,N,V> createRangeSubSlicesQuery(Serializer<K> keySerializer,
                                                                          Serializer<SN> sNameSerializer,
                                                                          Serializer<N> nameSerializer,
                                                                          Serializer<V> valueSerializer)

Specified by:

createRangeSubSlicesQuery in interface HectorTemplate

createSliceQuery

public <K,N,V> SliceQuery<K,N,V> createSliceQuery(Serializer<K> keySerializer,
                                                  Serializer<N> nameSerializer,
                                                  Serializer<V> valueSerializer)

Specified by:

createSliceQuery in interface HectorTemplate

createSubSliceQuery

public <K,SN,N,V> SubSliceQuery<K,SN,N,V> createSubSliceQuery(Serializer<K> keySerializer,
                                                              Serializer<SN> sNameSerializer,
                                                              Serializer<N> nameSerializer,
                                                              Serializer<V> valueSerializer)

Specified by:

createSubSliceQuery in interface HectorTemplate

createSuperSliceQuery

public <K,SN,N,V> SuperSliceQuery<K,SN,N,V> createSuperSliceQuery(Serializer<K> keySerializer,
                                                                  Serializer<SN> sNameSerializer,
                                                                  Serializer<N> nameSerializer,
                                                                  Serializer<V> valueSerializer)

Specified by:

createSuperSliceQuery in interface HectorTemplate

createSuperColumn

public <SN,N,V> HSuperColumn<SN,N,V> createSuperColumn(SN name,
                                                       List<HColumn<N,V>> columns,
                                                       Serializer<SN> superNameSerializer,
                                                       Serializer<N> nameSerializer,
                                                       Serializer<V> valueSerializer)

Description copied from interface: HectorTemplate

createSuperColumn accepts a variable number of column arguments

Specified by:

createSuperColumn in interface HectorTemplate

Parameters:

name - supercolumn name

createSuperColumn

public <SN,N,V> HSuperColumn<SN,N,V> createSuperColumn(SN name,
                                                       List<HColumn<N,V>> columns,
                                                       long clock,
                                                       Serializer<SN> superNameSerializer,
                                                       Serializer<N> nameSerializer,
                                                       Serializer<V> valueSerializer)

Specified by:

createSuperColumn in interface HectorTemplate

createColumn

public <N,V> HColumn<N,V> createColumn(N name,
                                       V value,
                                       long clock,
                                       Serializer<N> nameSerializer,
                                       Serializer<V> valueSerializer)

Specified by:

createColumn in interface HectorTemplate

createColumn

public <N,V> HColumn<N,V> createColumn(N name,
                                       V value)

Description copied from interface: HectorTemplate

Creates a column with the clock of now.

Specified by:

createColumn in interface HectorTemplate

createColumn

public <N,V> HColumn<N,V> createColumn(N name,
                                       V value,
                                       long clock)

Description copied from interface: HectorTemplate

Creates a column with the specified name/value and clock.

Specified by:

createColumn in interface HectorTemplate

createClock

public long createClock()

Description copied from interface: HectorTemplate

Creates a clock of now with the default clock resolution (micorosec) as defined in CassandraHost

Specified by:

createClock in interface HectorTemplate

createMutator

public <K,N,V> Mutator<K> createMutator()

Specified by:

createMutator in interface HectorTemplate

createIndexSlicesQuery

public <K,N,V> IndexedSlicesQuery<K,N,V> createIndexSlicesQuery(Serializer<K> keySerializer,
                                                                Serializer<N> nameSerializer,
                                                                Serializer<V> valueSerializer)

Specified by:

createIndexSlicesQuery in interface HectorTemplate

createSuperColumn

public <SN,N,V> HSuperColumn<SN,N,V> createSuperColumn(SN name,
                                                       List<HColumn<N,V>> columns)

Specified by:

createSuperColumn in interface HectorTemplate

createSliceQuery

public <K> SliceQuery<K,ByteBuffer,ByteBuffer> createSliceQuery()

Specified by:

createSliceQuery in interface HectorTemplate

createSuperSliceQuery

public <K> SuperSliceQuery<K,ByteBuffer,ByteBuffer,ByteBuffer> createSuperSliceQuery()

Specified by:

createSuperSliceQuery in interface HectorTemplate

getKeyspaceName

public String getKeyspaceName()

Specified by:

getKeyspaceName in interface HectorTemplate

setKeyspaceName

public void setKeyspaceName(String keyspace)

getKeyspace

public Keyspace getKeyspace()

setKeyspace

public void setKeyspace(Keyspace keyspace)

getConfigurableConsistencyLevelPolicy

public ConfigurableConsistencyLevel getConfigurableConsistencyLevelPolicy()

setConfigurableConsistencyLevelPolicy

public void setConfigurableConsistencyLevelPolicy(ConfigurableConsistencyLevel configurableConsistencyLevelPolicy)

getReplicationStrategyClass

public String getReplicationStrategyClass()

Specified by:

getReplicationStrategyClass in interface HectorTemplate

setReplicationStrategyClass

public void setReplicationStrategyClass(String replicationStrategyClass)

getReplicationFactor

public int getReplicationFactor()

Specified by:

getReplicationFactor in interface HectorTemplate

setReplicationFactor

public void setReplicationFactor(int replicationFactor)

getCluster

public Cluster getCluster()

Specified by:

getCluster in interface HectorTemplate

setCluster

public void setCluster(Cluster cluster)