org.apache.gora.cassandra.store

Class CassandraMapping

java.lang.Object

org.apache.gora.cassandra.store.CassandraMapping

public class CassandraMapping
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_COLUMNS_TTL
static String	DEFAULT_GCGRACE_SECONDS
static String	DEFAULT_REPLICATION_FACTOR
static String	DEFAULT_REPLICATION_STRATEGY
static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
CassandraMapping(org.jdom.Element keyspace, org.jdom.Element mapping) Primary class for loading Cassandra configuration from the 'MAPPING_FILE'.

Method Summary

Methods

Modifier and Type	Method and Description
void	addColumn(String pFamilyName, String pFieldName, String pColumnName) Add new column to the CassandraMapping using the the below parameters
String	getClusterName() Simply gets the Cassandra cluster (the machines (nodes) in a logical Cassandra instance) name.
String	getColumn(String name)
List<me.prettyprint.hector.api.ddl.ColumnFamilyDefinition>	getColumnFamilyDefinitions()
Map<String,String>	getColumnsAttribs()
String	getFamily(String name)
Map<String,String>	getFamilyMap()
String	getHostName() Simply gets the Cassandra host name.
String	getKeyspaceName() Simply gets the Cassandra namespace for ColumnFamilies, typically one per application
int	getKeyspaceReplicationFactor() gets the replication factor
String	getKeyspaceReplicationStrategy() gets the replication strategy
boolean	isSuper(String family) Read family super attribute.

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final org.slf4j.Logger LOG

DEFAULT_REPLICATION_FACTOR

public static final String DEFAULT_REPLICATION_FACTOR

See Also:

Constant Field Values

DEFAULT_REPLICATION_STRATEGY

public static final String DEFAULT_REPLICATION_STRATEGY

See Also:

Constant Field Values

DEFAULT_COLUMNS_TTL

public static final String DEFAULT_COLUMNS_TTL

See Also:

Constant Field Values

DEFAULT_GCGRACE_SECONDS

public static final String DEFAULT_GCGRACE_SECONDS

See Also:

Constant Field Values

Constructor Detail

CassandraMapping

public CassandraMapping(org.jdom.Element keyspace,
                org.jdom.Element mapping)

Primary class for loading Cassandra configuration from the 'MAPPING_FILE'. It should be noted that should the "qualifier" attribute and its associated value be absent from class field definition, it will automatically be set to the field name value.

Method Detail

getHostName

public String getHostName()

Simply gets the Cassandra host name.

Returns:

hostName

getClusterName

public String getClusterName()

Simply gets the Cassandra cluster (the machines (nodes) in a logical Cassandra instance) name. Clusters can contain multiple keyspaces.

Returns:

clusterName

getKeyspaceName

public String getKeyspaceName()

Simply gets the Cassandra namespace for ColumnFamilies, typically one per application

Returns:

getKeyspaceReplicationStrategy

public String getKeyspaceReplicationStrategy()

gets the replication strategy

Returns:

string class name to be used for strategy

getKeyspaceReplicationFactor

public int getKeyspaceReplicationFactor()

gets the replication factor

Returns:

int replication factor

addColumn

public void addColumn(String pFamilyName,
             String pFieldName,
             String pColumnName)

Add new column to the CassandraMapping using the the below parameters

Parameters:

pFamilyName - the column family name

pFieldName - the Avro field from the Schema

pColumnName - the column name within the column family.

getFamily

public String getFamily(String name)

getColumn

public String getColumn(String name)

getFamilyMap

public Map<String,String> getFamilyMap()

getColumnsAttribs

public Map<String,String> getColumnsAttribs()

isSuper

public boolean isSuper(String family)

Read family super attribute.

Parameters:

family - the family name

Returns:

true is the family is a super column family

getColumnFamilyDefinitions

public List<me.prettyprint.hector.api.ddl.ColumnFamilyDefinition> getColumnFamilyDefinitions()