C D E G H I L M N O P R S T

C

CassandraAnalyticsFileSystem - Class in org.wso2.carbon.analytics.datasource.cassandra

This class represents the Cassandra implementation of AnalyticsFileSystem.

CassandraAnalyticsFileSystem() - Constructor for class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsFileSystem

CassandraAnalyticsRecordStore - Class in org.wso2.carbon.analytics.datasource.cassandra

This class represents the Cassandra implementation of AnalyticsRecordStore.

CassandraAnalyticsRecordStore() - Constructor for class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore

CassandraAnalyticsRecordStore.CassandraDirectDataIterator - Class in org.wso2.carbon.analytics.datasource.cassandra

Cassandra data AnalyticsIterator implementation for streaming, which reads data directly from the data table.

CassandraAnalyticsRecordStore.CassandraDirectDataIterator(int, String, Iterator<Row>, List<String>) - Constructor for class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore.CassandraDirectDataIterator

CassandraAnalyticsRecordStore.CassandraRecordIDDataIterator - Class in org.wso2.carbon.analytics.datasource.cassandra

Cassandra data AnalyticsIterator implementation for streaming, which reads data using the record id based lookups.

CassandraAnalyticsRecordStore.CassandraRecordIDDataIterator(int, String, Iterator<Row>, List<String>) - Constructor for class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore.CassandraRecordIDDataIterator

CassandraAnalyticsRecordStore.CassandraTokenRangeDataIterator - Class in org.wso2.carbon.analytics.datasource.cassandra

Cassandra data AnalyticsIterator implementation for streaming, which reads data using the given token ranges.

CassandraAnalyticsRecordStore.CassandraTokenRangeDataIterator(int, String, List<String>, List<CassandraTokenRange>, int) - Constructor for class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore.CassandraTokenRangeDataIterator

CassandraAnalyticsRecordStore.GlobalCassandraRecordGroup - Class in org.wso2.carbon.analytics.datasource.cassandra

Cassandra RecordGroup implementation to be used without partitioning.

CassandraAnalyticsRecordStore.GlobalCassandraRecordGroup(int, String, List<String>, long, long, int) - Constructor for class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore.GlobalCassandraRecordGroup

CassandraAnalyticsRecordStore.GlobalCassandraRecordGroup(int, String, List<String>, List<String>) - Constructor for class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore.GlobalCassandraRecordGroup

CassandraTokenRange - Class in org.wso2.carbon.analytics.datasource.cassandra

A Serializable token range class to be used in record groups.

CassandraTokenRange(Object, Object) - Constructor for class org.wso2.carbon.analytics.datasource.cassandra.CassandraTokenRange

CassandraUtils - Class in org.wso2.carbon.analytics.datasource.cassandra

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

CassandraUtils() - Constructor for class org.wso2.carbon.analytics.datasource.cassandra.CassandraUtils

close() - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore.CassandraDirectDataIterator

close() - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore.CassandraRecordIDDataIterator

close() - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore.CassandraTokenRangeDataIterator

createInput(String) - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsFileSystem

createOutput(String) - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsFileSystem

createTable(int, String) - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore

D

DATASOURCE_NAME - Static variable in class org.wso2.carbon.analytics.datasource.cassandra.CassandraUtils

delete(String) - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsFileSystem

delete(int, String, long, long) - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore

delete(int, String, List<String>) - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore

deleteTable(int, String) - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore

destroy() - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsFileSystem

destroy() - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore

E

exists(String) - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsFileSystem

G

get(int, String, int, List<String>, long, long, int, int) - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore

get(int, String, int, List<String>, List<String>) - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore

getColumns() - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore.GlobalCassandraRecordGroup

getColumns() - Method in class org.wso2.carbon.analytics.datasource.cassandra.TokenRangeRecordGroup

getCount() - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore.GlobalCassandraRecordGroup

getCount() - Method in class org.wso2.carbon.analytics.datasource.cassandra.TokenRangeRecordGroup

getEnd() - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraTokenRange

getIds() - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore.GlobalCassandraRecordGroup

getLocations() - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore.GlobalCassandraRecordGroup

getLocations() - Method in class org.wso2.carbon.analytics.datasource.cassandra.TokenRangeRecordGroup

getRecordCount(int, String, long, long) - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore

getStart() - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraTokenRange

getTableName() - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore.GlobalCassandraRecordGroup

getTableName() - Method in class org.wso2.carbon.analytics.datasource.cassandra.TokenRangeRecordGroup

getTenantId() - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore.GlobalCassandraRecordGroup

getTenantId() - Method in class org.wso2.carbon.analytics.datasource.cassandra.TokenRangeRecordGroup

getTimeFrom() - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore.GlobalCassandraRecordGroup

getTimeTo() - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore.GlobalCassandraRecordGroup

getTokenRanges() - Method in class org.wso2.carbon.analytics.datasource.cassandra.TokenRangeRecordGroup

H

hasNext() - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore.CassandraDirectDataIterator

hasNext() - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore.CassandraRecordIDDataIterator

hasNext() - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore.CassandraTokenRangeDataIterator

I

init(Map<String, String>) - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsFileSystem

init(Map<String, String>) - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore

isByIds() - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore.GlobalCassandraRecordGroup

isPaginationSupported() - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore

isRecordCountSupported() - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore

L

length(String) - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsFileSystem

list(String) - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsFileSystem

M

main(String[]) - Static method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraUtils

mkdir(String) - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsFileSystem

N

next() - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore.CassandraDirectDataIterator

next() - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore.CassandraRecordIDDataIterator

next() - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore.CassandraTokenRangeDataIterator

O

org.wso2.carbon.analytics.datasource.cassandra - package org.wso2.carbon.analytics.datasource.cassandra

P

put(List<Record>) - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore

R

readRecords(RecordGroup) - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore

remove() - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore.CassandraDirectDataIterator

remove() - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore.CassandraRecordIDDataIterator

remove() - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore.CassandraTokenRangeDataIterator

renameFileInDirectory(String, String, String) - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsFileSystem

S

setLength(String, long) - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsFileSystem

splitParentChild(String) - Static method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraUtils

sync(String) - Method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsFileSystem

T

TokenRangeRecordGroup - Class in org.wso2.carbon.analytics.datasource.cassandra

Cassandra RecordGroup implementation, which is token range aware, used for partition based record groups.

TokenRangeRecordGroup(int, String, List<String>, List<CassandraTokenRange>, String, int) - Constructor for class org.wso2.carbon.analytics.datasource.cassandra.TokenRangeRecordGroup

C D E G H I L M N O P R S T