org.wso2.carbon.analytics.datasource.cassandra

Class CassandraAnalyticsRecordStore.CassandraRecordTSBasedIDDataIterator

java.lang.Object

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

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

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.CassandraRecordTSBasedIDDataIterator
extends CassandraAnalyticsRecordStore.CassandraRecordIDDataIterator

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

Field Summary

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

columns, dataItr, resultSetItr, tableName, tenantId

Constructor Summary

Constructors

Constructor and Description
CassandraRecordTSBasedIDDataIterator(int tenantId, String tableName, Iterator<com.datastax.driver.core.Row> resultSetItr, List<String> columns)

Method Summary

Modifier and Type	Method and Description
protected void	populateBatch()

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

close, hasNext, next, 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

CassandraRecordTSBasedIDDataIterator

public CassandraRecordTSBasedIDDataIterator(int tenantId,
                                            String tableName,
                                            Iterator<com.datastax.driver.core.Row> resultSetItr,
                                            List<String> columns)

Method Detail

populateBatch

protected void populateBatch()

Overrides:

populateBatch in class CassandraAnalyticsRecordStore.CassandraRecordIDDataIterator