org.wso2.carbon.analytics.datasource.cassandra

Class CassandraAnalyticsRecordStore.CassandraTSValidatingDirectDataIterator

java.lang.Object

org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore.CassandraDirectDataIterator

org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore.CassandraTSValidatingDirectDataIterator

All Implemented Interfaces:

Closeable, AutoCloseable, Iterator<org.wso2.carbon.analytics.datasource.commons.Record>, org.wso2.carbon.analytics.datasource.commons.AnalyticsIterator<org.wso2.carbon.analytics.datasource.commons.Record>

Enclosing class:

CassandraAnalyticsRecordStore

public class CassandraAnalyticsRecordStore.CassandraTSValidatingDirectDataIterator
extends CassandraAnalyticsRecordStore.CassandraDirectDataIterator

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

Field Summary

Fields inherited from class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore.CassandraDirectDataIterator

tableName, tenantId

Constructor Summary

Constructors

Constructor and Description
CassandraTSValidatingDirectDataIterator(int tenantId, String tableName, Iterator<com.datastax.driver.core.Row> resultSetItr, List<String> columns, org.apache.commons.collections.MultiMap tsIds)

Method Summary

Modifier and Type	Method and Description
boolean	hasNext()
org.wso2.carbon.analytics.datasource.commons.Record	next()

Methods inherited from class org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsRecordStore.CassandraDirectDataIterator

close, remove

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining

Constructor Detail

CassandraTSValidatingDirectDataIterator

public CassandraTSValidatingDirectDataIterator(int tenantId,
                                               String tableName,
                                               Iterator<com.datastax.driver.core.Row> resultSetItr,
                                               List<String> columns,
                                               org.apache.commons.collections.MultiMap tsIds)

Method Detail

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<org.wso2.carbon.analytics.datasource.commons.Record>

Overrides:

hasNext in class CassandraAnalyticsRecordStore.CassandraDirectDataIterator

next

public org.wso2.carbon.analytics.datasource.commons.Record next()

Specified by:

next in interface Iterator<org.wso2.carbon.analytics.datasource.commons.Record>

Overrides:

next in class CassandraAnalyticsRecordStore.CassandraDirectDataIterator