public class DataFileAvroResult<K,T extends PersistentBase> extends ResultBase<K,T>
DataFileReader
backed Result.dataStore, key, limit, offset, persistent, query
Constructor and Description |
---|
DataFileAvroResult(DataStore<K,T> dataStore,
Query<K,T> query,
org.apache.avro.file.DataFileReader<T> reader) |
DataFileAvroResult(DataStore<K,T> dataStore,
Query<K,T> query,
org.apache.avro.file.DataFileReader<T> reader,
org.apache.avro.file.SeekableInput in,
long start,
long length) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
float |
getProgress()
Returns how far along the result has iterated, a value between 0 and 1.
|
boolean |
nextInner()
ResultBase.next() calls this function to read the
actual results. |
clear, filter, get, getDataStore, getKey, getKeyClass, getOffset, getOrCreatePersistent, getPersistentClass, getQuery, isLimitReached, next
public DataFileAvroResult(DataStore<K,T> dataStore, Query<K,T> query, org.apache.avro.file.DataFileReader<T> reader) throws IOException
IOException
public DataFileAvroResult(DataStore<K,T> dataStore, Query<K,T> query, org.apache.avro.file.DataFileReader<T> reader, org.apache.avro.file.SeekableInput in, long start, long length) throws IOException
IOException
public void close() throws IOException
close
in interface Result<K,T extends PersistentBase>
close
in class ResultBase<K,T extends PersistentBase>
IOException
public float getProgress() throws IOException
Result
IOException
public boolean nextInner() throws IOException
ResultBase
ResultBase.next()
calls this function to read the
actual results.nextInner
in class ResultBase<K,T extends PersistentBase>
IOException
Copyright © 2010-2014 The Apache Software Foundation. All Rights Reserved.