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
CassandraAnalyticsRecordStore.CassandraRecordTSBasedIDDataIterator(int tenantId, String tableName, Iterator<com.datastax.driver.core.Row> resultSetItr, List<String> columns)

Method Summary

Methods

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

Constructor Detail

CassandraAnalyticsRecordStore.CassandraRecordTSBasedIDDataIterator

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