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 and 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 and Description
TabletMap(com.datastax.driver.core.Cluster.Manager cluster, ConcurrentMap<TabletMap.KeyspaceTableNamePair,TabletMap.TabletSet> mapping)

Method Summary

Modifier and Type	Method and 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(String keyspace)
void	removeTableMappings(String keyspace, String table)
void	removeTableMappings(TabletMap.KeyspaceTableNamePair key)

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)