org.wso2.carbon.analytics.datasource.cassandra

Class CassandraAnalyticsRecordStore.CassandraRecordIDDataIterator

java.lang.Object

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

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>

Direct Known Subclasses:

CassandraAnalyticsRecordStore.CassandraRecordTSBasedIDDataIterator

Enclosing class:

CassandraAnalyticsRecordStore

public class CassandraAnalyticsRecordStore.CassandraRecordIDDataIterator
extends Object
implements org.wso2.carbon.analytics.datasource.commons.AnalyticsIterator<org.wso2.carbon.analytics.datasource.commons.Record>

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

Field Summary

Fields

Modifier and Type	Field and Description
protected List<String>	columns
protected org.wso2.carbon.analytics.datasource.commons.AnalyticsIterator<org.wso2.carbon.analytics.datasource.commons.Record>	dataItr
protected Iterator<com.datastax.driver.core.Row>	resultSetItr
protected String	tableName
protected int	tenantId

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
boolean	hasNext()
org.wso2.carbon.analytics.datasource.commons.Record	next()
protected void	populateBatch()
void	remove()

Methods inherited from class java.lang.Object

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

Field Detail

tenantId

protected int tenantId

tableName

protected String tableName

columns

protected List<String> columns

resultSetItr

protected Iterator<com.datastax.driver.core.Row> resultSetItr

dataItr

protected org.wso2.carbon.analytics.datasource.commons.AnalyticsIterator<org.wso2.carbon.analytics.datasource.commons.Record> dataItr

Constructor Detail

CassandraAnalyticsRecordStore.CassandraRecordIDDataIterator

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

Method Detail

populateBatch

protected void populateBatch()

hasNext

public boolean hasNext()

Specified by:

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

next

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

Specified by:

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

remove

public void remove()

Specified by:

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

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException