com.baidu.hugegraph.backend.store.cassandra

Class CassandraEntryIterator

java.lang.Object

com.baidu.hugegraph.backend.store.BackendEntryIterator

com.baidu.hugegraph.backend.store.cassandra.CassandraEntryIterator

All Implemented Interfaces:

com.baidu.hugegraph.iterator.Metadatable, AutoCloseable, Iterator<BackendEntry>

public class CassandraEntryIterator
extends BackendEntryIterator

Nested Class Summary

Nested classes/interfaces inherited from class com.baidu.hugegraph.backend.store.BackendEntryIterator

BackendEntryIterator.EmptyIterator

Field Summary

Fields inherited from class com.baidu.hugegraph.backend.store.BackendEntryIterator

current, query

Constructor Summary

Constructors

Constructor and Description
CassandraEntryIterator(com.datastax.driver.core.ResultSet results, Query query, java.util.function.BiFunction<BackendEntry,com.datastax.driver.core.Row,BackendEntry> merger)

Method Summary

Modifier and Type	Method and Description
void	close()
protected boolean	fetch()
protected String	pageState()
protected long	sizeOf(BackendEntry entry)
protected long	skip(BackendEntry entry, long skip)

Methods inherited from class com.baidu.hugegraph.backend.store.BackendEntryIterator

checkCapacity, count, exceedLimit, fetched, hasNext, metadata, next, offset, skipOffset

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, remove

Constructor Detail

CassandraEntryIterator

public CassandraEntryIterator(com.datastax.driver.core.ResultSet results,
                              Query query,
                              java.util.function.BiFunction<BackendEntry,com.datastax.driver.core.Row,BackendEntry> merger)

Method Detail

close

public void close()
           throws Exception

Throws:

Exception

fetch

protected final boolean fetch()

Specified by:

fetch in class BackendEntryIterator

sizeOf

protected final long sizeOf(BackendEntry entry)

Overrides:

sizeOf in class BackendEntryIterator

skip

protected final long skip(BackendEntry entry,
                          long skip)

Overrides:

skip in class BackendEntryIterator

pageState

protected String pageState()

Specified by:

pageState in class BackendEntryIterator