public class

CassandraDBUtils

extends Object
java.lang.Object
   ↳ com.mulesoft.mule.cassandradb.CassandraDBUtils

Class Overview

Utility class to make the transformations from String and collections to the types that the API handles

Summary

Fields
private static TypeInferringSerializer typeInferringSerializer
Public Constructors
CassandraDBUtils()
Public Methods
static JsonNode columnOrSuperColumnToJSONNode(ColumnOrSuperColumn columnOrSuperColumn)
static Map columnOrSuperColumnToMap(ColumnOrSuperColumn columnOrSuperColumn, List<ColumnSerializer> columnSerializers)
static JsonNode columnToJSONNode(Column column)
static ColumnParent generateColumnParent(String columnParent)
static SliceRange generateSliceRange(String start, String finish, boolean reversed, int count)
static String jsonNodeToString(JsonNode node)
static JsonNode listOfColumnsToJSONNode(List<ColumnOrSuperColumn> listOfColumns)
static List listOfColumnsToMap(List<ColumnOrSuperColumn> listOfColumns, List<ColumnSerializer> columnSerializers)
static ColumnPath parseColumnPath(String columnPath)
static void populateMap(Map columnMap, Column column, Map<String, Serializer> serializerMap)
static ByteBuffer toByteBuffer(Object value)
static List<ByteBuffer> toByteBufferList(List<String> rowKeys)
static List<ColumnDef> toColumnDefinition(Map<String, String> columnMetadata)
static List<CfDef> toColumnDefinition(List<String> list, String keyspace)
static List<IndexExpression> toIndexExpression(List<IndexExpresion> list)
[Expand]
Inherited Methods
From class java.lang.Object

Fields

private static TypeInferringSerializer typeInferringSerializer

Public Constructors

public CassandraDBUtils ()

Public Methods

public static JsonNode columnOrSuperColumnToJSONNode (ColumnOrSuperColumn columnOrSuperColumn)

Parameters
columnOrSuperColumn
Throws
Exception

public static Map columnOrSuperColumnToMap (ColumnOrSuperColumn columnOrSuperColumn, List<ColumnSerializer> columnSerializers)

Parameters
columnOrSuperColumn
columnSerializers

public static JsonNode columnToJSONNode (Column column)

Parameters
column
Throws
Exception

public static ColumnParent generateColumnParent (String columnParent)

Parameters
columnParent
Throws
UnsupportedEncodingException

public static SliceRange generateSliceRange (String start, String finish, boolean reversed, int count)

Parameters
start
finish
reversed
count
Throws
UnsupportedEncodingException

public static String jsonNodeToString (JsonNode node)

Parameters
node
Throws
Exception

public static JsonNode listOfColumnsToJSONNode (List<ColumnOrSuperColumn> listOfColumns)

Parameters
listOfColumns
Throws
Exception

public static List listOfColumnsToMap (List<ColumnOrSuperColumn> listOfColumns, List<ColumnSerializer> columnSerializers)

Parameters
listOfColumns
columnSerializers

public static ColumnPath parseColumnPath (String columnPath)

Parameters
columnPath
Throws
UnsupportedEncodingException

public static void populateMap (Map columnMap, Column column, Map<String, Serializer> serializerMap)

Parameters
columnMap
column
serializerMap

public static ByteBuffer toByteBuffer (Object value)

Parameters
value
Throws
UnsupportedEncodingException

public static List<ByteBuffer> toByteBufferList (List<String> rowKeys)

Parameters
rowKeys
Throws
UnsupportedEncodingException

public static List<ColumnDef> toColumnDefinition (Map<String, String> columnMetadata)

Parameters
columnMetadata

public static List<CfDef> toColumnDefinition (List<String> list, String keyspace)

Parameters
list
keyspace

public static List<IndexExpression> toIndexExpression (List<IndexExpresion> list)

Parameters
list