org.wso2.carbon.analytics.datasource.cassandra

Class CassandraUtils

java.lang.Object

org.wso2.carbon.analytics.datasource.cassandra.CassandraUtils

public class CassandraUtils
extends Object

This class contains utility methods related to the Cassandra data connector.

Constructor Summary

Constructors

Constructor and Description
CassandraUtils()

Method Summary

Modifier and Type	Method and Description
static String	extractAFSKSName(Map<String,String> properties)
static String	extractARSKSName(Map<String,String> properties)
static String	extractClass(Map<String,String> properties)
static String	extractDataSourceName(Map<String,String> properties)
static int	extractReplicationFactor(Map<String,String> properties)
static String	generateCreateKeyspaceQuery(String ks, Map<String,String> properties)
static String[]	splitParentChild(String path)

Methods inherited from class java.lang.Object

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

Constructor Detail

CassandraUtils

public CassandraUtils()

Method Detail

splitParentChild

public static String[] splitParentChild(String path)

generateCreateKeyspaceQuery

public static String generateCreateKeyspaceQuery(String ks,
                                                 Map<String,String> properties)
                                          throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Throws:

org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

extractDataSourceName

public static String extractDataSourceName(Map<String,String> properties)
                                    throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Throws:

org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

extractAFSKSName

public static String extractAFSKSName(Map<String,String> properties)

extractARSKSName

public static String extractARSKSName(Map<String,String> properties)

extractClass

public static String extractClass(Map<String,String> properties)

extractReplicationFactor

public static int extractReplicationFactor(Map<String,String> properties)
                                    throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Throws:

org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException