com.baidu.hugegraph.backend.store.cassandra

类 CassandraTable

java.lang.Object

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

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

直接已知子类:

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>

嵌套类概要

从类继承的嵌套类/接口 com.baidu.hugegraph.backend.store.BackendTable

BackendTable.ShardSpliter<Session extends BackendSession>

构造器概要

构造器

构造器和说明
CassandraTable(String table)

方法概要

限定符和类型	方法和说明
void	append(CassandraSessionPool.Session session, TableBackendEntry.Row entry) Append several elements to the collection column of a row
protected com.datastax.driver.core.querybuilder.Update	buildAppend(TableBackendEntry.Row entry)
protected com.datastax.driver.core.querybuilder.Delete	buildDelete(TableBackendEntry.Row entry)
protected com.datastax.driver.core.querybuilder.Update	buildEliminate(TableBackendEntry.Row entry)
protected com.datastax.driver.core.querybuilder.Insert	buildInsert(TableBackendEntry.Row entry)
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 <R> Iterator<R>	query(Query query, java.util.function.Function<com.datastax.driver.core.Statement,com.datastax.driver.core.ResultSet> fetcher, java.util.function.BiFunction<Query,com.datastax.driver.core.ResultSet,Iterator<R>> parser)
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)
Number	queryNumber(CassandraSessionPool.Session session, Query query)
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 void	setPageState(Query query, List<com.datastax.driver.core.querybuilder.Select> selects)
void	truncate(CassandraSessionPool.Session session)
protected void	truncateTable(CassandraSessionPool.Session session)

从类继承的方法 com.baidu.hugegraph.backend.store.BackendTable

init, joinTableName, metaDispatcher, registerMetaHandler, table, tableType

从类继承的方法 java.lang.Object

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

构造器详细资料

CassandraTable

public CassandraTable(String table)

方法详细资料

registerMetaHandlers

protected void registerMetaHandlers()

覆盖:

registerMetaHandlers 在类中 BackendTable<CassandraSessionPool.Session,TableBackendEntry.Row>

queryNumber

public Number queryNumber(CassandraSessionPool.Session session,
                          Query query)

指定者:

queryNumber 在类中 BackendTable<CassandraSessionPool.Session,TableBackendEntry.Row>

query

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

指定者:

query 在类中 BackendTable<CassandraSessionPool.Session,TableBackendEntry.Row>

query

protected <R> Iterator<R> query(Query query,
                                java.util.function.Function<com.datastax.driver.core.Statement,com.datastax.driver.core.ResultSet> fetcher,
                                java.util.function.BiFunction<Query,com.datastax.driver.core.ResultSet,Iterator<R>> parser)

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)

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

指定者:

insert 在类中 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

指定者:

append 在类中 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

指定者:

eliminate 在类中 BackendTable<CassandraSessionPool.Session,TableBackendEntry.Row>

delete

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

Delete an entire row

指定者:

delete 在类中 BackendTable<CassandraSessionPool.Session,TableBackendEntry.Row>

buildInsert

protected com.datastax.driver.core.querybuilder.Insert buildInsert(TableBackendEntry.Row entry)

buildAppend

protected com.datastax.driver.core.querybuilder.Update buildAppend(TableBackendEntry.Row entry)

buildEliminate

protected com.datastax.driver.core.querybuilder.Update buildEliminate(TableBackendEntry.Row entry)

buildDelete

protected com.datastax.driver.core.querybuilder.Delete buildDelete(TableBackendEntry.Row entry)

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)

指定者:

clear 在类中 BackendTable<CassandraSessionPool.Session,TableBackendEntry.Row>

truncate

public void truncate(CassandraSessionPool.Session session)