com.baidu.hugegraph.backend.store.cassandra

Class CassandraTable

java.lang.Object

com.baidu.hugegraph.backend.store.BackendTable<CassandraSessionPool.Session,TableBackendEntry.Row>

com.baidu.hugegraph.backend.store.cassandra.CassandraTable

Direct Known Subclasses:

CassandraTables.Counters, CassandraTables.Edge, CassandraTables.EdgeLabel, CassandraTables.IndexLabel, CassandraTables.PropertyKey, CassandraTables.RangeIndex, CassandraTables.SecondaryIndex, CassandraTables.Vertex, CassandraTables.VertexLabel

public abstract class CassandraTable
extends BackendTable<CassandraSessionPool.Session,TableBackendEntry.Row>

Nested Class Summary

Nested classes/interfaces inherited from class com.baidu.hugegraph.backend.store.BackendTable

BackendTable.ShardSpliter<Session extends BackendSession>

Constructor Summary

Constructors

Constructor and Description
CassandraTable(String table)

Method Summary

Modifier and Type	Method and Description
void	append(CassandraSessionPool.Session session, TableBackendEntry.Row entry) Append several elements to the collection column of a row
void	clear(CassandraSessionPool.Session session)
protected static com.datastax.driver.core.querybuilder.Select	cloneSelect(com.datastax.driver.core.querybuilder.Select select, String table)
protected com.datastax.driver.core.querybuilder.Clause	condition2Cql(Condition condition)
protected void	createIndex(CassandraSessionPool.Session session, String indexLabel, HugeKeys column)
protected void	createTable(CassandraSessionPool.Session session, com.google.common.collect.ImmutableMap<HugeKeys,com.datastax.driver.core.DataType> partitionKeys, com.google.common.collect.ImmutableMap<HugeKeys,com.datastax.driver.core.DataType> clusteringKeys, com.google.common.collect.ImmutableMap<HugeKeys,com.datastax.driver.core.DataType> columns)
void	delete(CassandraSessionPool.Session session, TableBackendEntry.Row entry) Delete an entire row
protected void	dropTable(CassandraSessionPool.Session session)
void	eliminate(CassandraSessionPool.Session session, TableBackendEntry.Row entry) Eliminate several elements from the collection column of a row
static com.datastax.driver.core.querybuilder.Clause	formatEQ(HugeKeys key, Object value)
static String	formatKey(HugeKeys key)
protected List<HugeKeys>	idColumnName()
protected List<Object>	idColumnValue(Id id)
protected List<Long>	idColumnValue(TableBackendEntry.Row entry)
void	insert(CassandraSessionPool.Session session, TableBackendEntry.Row entry) Insert an entire row
protected BackendEntry	mergeEntries(BackendEntry e1, BackendEntry e2)
protected List<HugeKeys>	modifiableColumnName()
static HugeKeys	parseKey(String name)
protected List<HugeKeys>	pkColumnName()
Iterator<BackendEntry>	query(CassandraSessionPool.Session session, Query query)
protected List<com.datastax.driver.core.querybuilder.Select>	query2Select(String table, Query query)
protected Collection<com.datastax.driver.core.querybuilder.Select>	queryCondition2Select(Query query, com.datastax.driver.core.querybuilder.Select select)
protected List<com.datastax.driver.core.querybuilder.Select>	queryId2Select(Query query, com.datastax.driver.core.querybuilder.Select select)
protected void	registerMetaHandlers()
protected com.datastax.driver.core.querybuilder.Clause	relation2Cql(Condition.Relation relation)
protected Iterator<BackendEntry>	results2Entries(Query q, com.datastax.driver.core.ResultSet r)
protected static Object	serializeValue(Object value)
protected void	setPageState(Query query, List<com.datastax.driver.core.querybuilder.Select> selects)
void	truncate(CassandraSessionPool.Session session)
protected void	truncateTable(CassandraSessionPool.Session session)

Methods inherited from class com.baidu.hugegraph.backend.store.BackendTable

init, joinTableName, metaDispatcher, registerMetaHandler, table, tableType

Methods inherited from class java.lang.Object

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

Constructor Detail

CassandraTable

public CassandraTable(String table)

Method Detail

registerMetaHandlers

protected void registerMetaHandlers()

Overrides:

registerMetaHandlers in class BackendTable<CassandraSessionPool.Session,TableBackendEntry.Row>

query

public Iterator<BackendEntry> query(CassandraSessionPool.Session session,
                                    Query query)

Specified by:

query in class BackendTable<CassandraSessionPool.Session,TableBackendEntry.Row>

query2Select

protected List<com.datastax.driver.core.querybuilder.Select> query2Select(String table,
                                                                          Query query)

setPageState

protected void setPageState(Query query,
                            List<com.datastax.driver.core.querybuilder.Select> selects)

queryId2Select

protected List<com.datastax.driver.core.querybuilder.Select> queryId2Select(Query query,
                                                                            com.datastax.driver.core.querybuilder.Select select)

queryCondition2Select

protected Collection<com.datastax.driver.core.querybuilder.Select> queryCondition2Select(Query query,
                                                                                         com.datastax.driver.core.querybuilder.Select select)

condition2Cql

protected com.datastax.driver.core.querybuilder.Clause condition2Cql(Condition condition)

relation2Cql

protected com.datastax.driver.core.querybuilder.Clause relation2Cql(Condition.Relation relation)

cloneSelect

protected static com.datastax.driver.core.querybuilder.Select cloneSelect(com.datastax.driver.core.querybuilder.Select select,
                                                                          String table)

serializeValue

protected static Object serializeValue(Object value)

results2Entries

protected Iterator<BackendEntry> results2Entries(Query q,
                                                 com.datastax.driver.core.ResultSet r)

pkColumnName

protected List<HugeKeys> pkColumnName()

idColumnName

protected List<HugeKeys> idColumnName()

idColumnValue

protected List<Object> idColumnValue(Id id)

idColumnValue

protected List<Long> idColumnValue(TableBackendEntry.Row entry)

modifiableColumnName

protected List<HugeKeys> modifiableColumnName()

mergeEntries

protected BackendEntry mergeEntries(BackendEntry e1,
                                    BackendEntry e2)

formatKey

public static final String formatKey(HugeKeys key)

parseKey

public static final HugeKeys parseKey(String name)

formatEQ

public static final com.datastax.driver.core.querybuilder.Clause formatEQ(HugeKeys key,
                                                                          Object value)

insert

public void insert(CassandraSessionPool.Session session,
                   TableBackendEntry.Row entry)

Insert an entire row

Specified by:

insert in class BackendTable<CassandraSessionPool.Session,TableBackendEntry.Row>

append

public void append(CassandraSessionPool.Session session,
                   TableBackendEntry.Row entry)

Append several elements to the collection column of a row

Specified by:

append in class BackendTable<CassandraSessionPool.Session,TableBackendEntry.Row>

eliminate

public void eliminate(CassandraSessionPool.Session session,
                      TableBackendEntry.Row entry)

Eliminate several elements from the collection column of a row

Specified by:

eliminate in class BackendTable<CassandraSessionPool.Session,TableBackendEntry.Row>

delete

public void delete(CassandraSessionPool.Session session,
                   TableBackendEntry.Row entry)

Delete an entire row

Specified by:

delete in class BackendTable<CassandraSessionPool.Session,TableBackendEntry.Row>

createTable

protected void createTable(CassandraSessionPool.Session session,
                           com.google.common.collect.ImmutableMap<HugeKeys,com.datastax.driver.core.DataType> partitionKeys,
                           com.google.common.collect.ImmutableMap<HugeKeys,com.datastax.driver.core.DataType> clusteringKeys,
                           com.google.common.collect.ImmutableMap<HugeKeys,com.datastax.driver.core.DataType> columns)

dropTable

protected void dropTable(CassandraSessionPool.Session session)

truncateTable

protected void truncateTable(CassandraSessionPool.Session session)

createIndex

protected void createIndex(CassandraSessionPool.Session session,
                           String indexLabel,
                           HugeKeys column)

clear

public void clear(CassandraSessionPool.Session session)

Specified by:

clear in class BackendTable<CassandraSessionPool.Session,TableBackendEntry.Row>

truncate

public void truncate(CassandraSessionPool.Session session)