com.baidu.hugegraph.backend.store.cassandra

Class 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/

Constructor Summary

Constructors

Constructor and Description
CassandraShard(CassandraSessionPool.Session session, String keyspace, String table)

Method Summary

Modifier and Type	Method and Description
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

Methods inherited from class java.lang.Object

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

Constructor Detail

CassandraShard

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

Method Detail

getSplits

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

Get splits of a table

Parameters:

splitPartitions: - expected partitions count per split

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

Returns:

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

Parameters:

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

Returns:

a list of Shard