com.baidu.hugegraph.backend.store.cassandra

类 CassandraShard

java.lang.Object

com.baidu.hugegraph.backend.store.cassandra.CassandraShard

public class CassandraShard
extends Object

CassandraShard is used for cassandra scanning operations. Each shard represents a range of tokens for a node. Reading data from a given shard does not cross multiple nodes. Refer to AbstractColumnFamilyInputFormat from https://github.com/2013Commons/hive-cassandra/

构造器概要

构造器

构造器和说明
CassandraShard(CassandraSessionPool.Session session, String keyspace, String table)

方法概要

限定符和类型	方法和说明
List<Shard>	getSplits(long splitPartitions, long splitSize) Get splits of a table
List<Shard>	getSplits(String start, String end, int splitPartitions, int splitSize) Get splits of a table in specified range NOTE: maybe we don't need this method

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

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

构造器详细资料

CassandraShard

public CassandraShard(CassandraSessionPool.Session session,
                      String keyspace,
                      String table)

方法详细资料

getSplits

public List<Shard> getSplits(long splitPartitions,
                             long splitSize)

Get splits of a table

参数:

splitPartitions: - expected partitions count per split

splitSize: - expected size(bytes) per split, splitPartitions will be ignored if splitSize is passed

返回:

a list of Shard

getSplits

public List<Shard> getSplits(String start,
                             String end,
                             int splitPartitions,
                             int splitSize)

Get splits of a table in specified range NOTE: maybe we don't need this method

参数:

start: - the start of range

end: - the end of range

splitPartitions: - expected partitions count per split

splitSize: - expected size(bytes) per split, splitPartitions will be ignored if splitSize is passed

返回:

a list of Shard