A C D E G H I K N O P R S T

A

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

C

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.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.CassandraRecordTSBasedIDDataIterator - Class in org.wso2.carbon.analytics.datasource.cassandra

CassandraAnalyticsRecordStore.CassandraRecordIDDataIterator based variant for considering indexed timestamp values also for doing read-repair for duplicated timestamps in the index.

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.CassandraTSValidatingDirectDataIterator - Class in org.wso2.carbon.analytics.datasource.cassandra

CassandraAnalyticsRecordStore.CassandraDirectDataIterator based iterator which does timestamp based read-repair operations for data records lookups.

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

Cassandra RecordGroup implementation to be used without partitioning.

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

Constants related to Cassandra DAS data connector.

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

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

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

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

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

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

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

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

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

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

CLASS - Static variable in class org.wso2.carbon.analytics.datasource.cassandra.CassandraConstants

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

columns - Variable in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore.CassandraRecordIDDataIterator

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

D

dataItr - Variable in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore.CassandraRecordIDDataIterator

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

DEFAULT_AFS_KS_NAME - Static variable in class org.wso2.carbon.analytics.datasource.cassandra.CassandraConstants

DEFAULT_ARS_KS_NAME - Static variable in class org.wso2.carbon.analytics.datasource.cassandra.CassandraConstants

DEFAULT_CLASS - Static variable in class org.wso2.carbon.analytics.datasource.cassandra.CassandraConstants

DEFAULT_REPLICATION_FACTOR - Static variable in class org.wso2.carbon.analytics.datasource.cassandra.CassandraConstants

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.CassandraAnalyticsRecordStore

E

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

extractAFSKSName(Map<String, String>) - Static method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraUtils

extractARSKSName(Map<String, String>) - Static method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraUtils

extractClass(Map<String, String>) - Static method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraUtils

extractDataSourceName(Map<String, String>) - Static method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraUtils

extractReplicationFactor(Map<String, String>) - Static method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraUtils

G

generateCreateKeyspaceQuery(String, Map<String, String>) - Static method in class org.wso2.carbon.analytics.datasource.cassandra.CassandraUtils

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

getHosts() - 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

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

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

H

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

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

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

I

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

K

KEYSPACE - Static variable in class org.wso2.carbon.analytics.datasource.cassandra.CassandraConstants

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

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

O

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

P

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

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

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

RECORD_INSERT_STATEMENTS_CACHE_SIZE - Static variable in class org.wso2.carbon.analytics.datasource.cassandra.CassandraConstants

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

REPLICATION_FACTOR - Static variable in class org.wso2.carbon.analytics.datasource.cassandra.CassandraConstants

resultSetItr - Variable in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore.CassandraRecordIDDataIterator

S

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

STREAMING_BATCH_SIZE - Static variable in class org.wso2.carbon.analytics.datasource.cassandra.CassandraConstants

T

tableName - Variable in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore.CassandraDirectDataIterator

tableName - Variable in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore.CassandraRecordIDDataIterator

tenantId - Variable in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore.CassandraDirectDataIterator

tenantId - Variable in class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore.CassandraRecordIDDataIterator

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

TS_MULTIPLIER - Static variable in class org.wso2.carbon.analytics.datasource.cassandra.CassandraConstants

A C D E G H I K N O P R S T