Package com.datastax.driver.core

Class TabletMap

java.lang.Object

com.datastax.driver.core.TabletMap

@Beta
public class TabletMap
extends Object

Holds currently known tablet mappings. Updated lazily through received custom payloads described in Scylla's CQL protocol extensions (tablets-routing-v1).

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TabletMap.HostShardPair	Simple class to hold UUID of a host and a shard number.
static class	TabletMap.KeyspaceTableNamePair	Simple keyspace name and table name pair.
static class	TabletMap.Tablet	Represents a single tablet created from tablets-routing-v1 custom payload.
static class	TabletMap.TabletSet	Set of tablets bundled with ReadWriteLock to allow concurrent modification for different sets.

Constructor Summary

Constructors

Constructor	Description
TabletMap(com.datastax.driver.core.Cluster.Manager cluster, ConcurrentMap<TabletMap.KeyspaceTableNamePair,TabletMap.TabletSet> mapping)

Method Summary

Modifier and Type	Method	Description
static TabletMap	emptyMap(com.datastax.driver.core.Cluster.Manager cluster)
Map<TabletMap.KeyspaceTableNamePair,TabletMap.TabletSet>	getMapping()	Returns the mapping of tables to their tablets.
TupleType	getPayloadInnerTuple()
TupleType	getPayloadOuterTuple()
List<Host>	getReplicas(String keyspace, String table, long token)	Finds hosts that have replicas for a given table and token combination.
TypeCodec<TupleValue>	getTabletPayloadCodec()
void	removeTableMappings(TabletMap.KeyspaceTableNamePair key)
void	removeTableMappings(String keyspace)
void	removeTableMappings(String keyspace, String table)

Methods inherited from class java.lang.Object

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

Constructor Detail

TabletMap

public TabletMap(com.datastax.driver.core.Cluster.Manager cluster,
                 ConcurrentMap<TabletMap.KeyspaceTableNamePair,TabletMap.TabletSet> mapping)

Method Detail

emptyMap

public static TabletMap emptyMap(com.datastax.driver.core.Cluster.Manager cluster)

getMapping

public Map<TabletMap.KeyspaceTableNamePair,TabletMap.TabletSet> getMapping()

Returns the mapping of tables to their tablets.

Returns:

the Map keyed by (keyspace,table) pairs with TabletMap.TabletSet as value type.

getReplicas

public List<Host> getReplicas(String keyspace,
                              String table,
                              long token)

Finds hosts that have replicas for a given table and token combination. Meant for use in query planning. Can return empty collection if internal replica list information is determined not up to date.

Parameters:

keyspace - the keyspace that table is in

table - the table name

token - the token to look for

Returns:

List(immutable) of Host instances that do have a tablet for the given token and table combination.

getPayloadOuterTuple

public TupleType getPayloadOuterTuple()

getPayloadInnerTuple

public TupleType getPayloadInnerTuple()

getTabletPayloadCodec

public TypeCodec<TupleValue> getTabletPayloadCodec()

removeTableMappings

public void removeTableMappings(TabletMap.KeyspaceTableNamePair key)

removeTableMappings

public void removeTableMappings(String keyspace,
                                String table)

removeTableMappings

public void removeTableMappings(String keyspace)