Package org.apache.iotdb.tsfile.read.query.dataset

Class QueryDataSet

java.lang.Object

org.apache.iotdb.tsfile.read.query.dataset.QueryDataSet

Direct Known Subclasses:

DataSetWithoutTimeGenerator, DataSetWithTimeGenerator

public abstract class QueryDataSet
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	QueryDataSet.EndPoint	For redirect query.

Field Summary

Fields

Modifier and Type	Field	Description
protected int	alreadyReturnedRowNum
protected boolean	ascending
protected int	columnNum
protected List<TSDataType>	dataTypes
protected QueryDataSet.EndPoint	endPoint
protected int	fetchSize
protected List<Path>	paths
protected int	rowLimit
protected int	rowOffset
protected boolean	withoutAllNull	Only if all columns are null, we don't need that row
protected boolean	withoutAnyNull	if any column is null, we don't need that row
protected Set<Integer>	withoutNullColumnsIndex	index set that withoutNullColumns for output data columns

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	QueryDataSet()
protected	QueryDataSet(List<Path> paths, List<TSDataType> dataTypes)
protected	QueryDataSet(List<Path> paths, List<TSDataType> dataTypes, boolean ascending)

Method Summary

Modifier and Type	Method	Description
void	decreaseAlreadyReturnedRowNum()
int	getColumnNum()
List<TSDataType>	getDataTypes()
QueryDataSet.EndPoint	getEndPoint()
List<Path>	getPaths()
int	getRowLimit()
int	getRowOffset()
Set<Integer>	getWithoutNullColumnsIndex()
boolean	hasLimit()
boolean	hasNext()
abstract boolean	hasNextWithoutConstraint()
protected void	initQueryDataSetFields(List<Path> paths, List<TSDataType> dataTypes, boolean ascending)
boolean	isWithoutAllNull()
boolean	isWithoutAnyNull()
RowRecord	next()	This method is used for batch query, return RowRecord.
abstract RowRecord	nextWithoutConstraint()
void	setColumnNum(int columnNum)
void	setDataTypes(List<TSDataType> dataTypes)
void	setEndPoint(QueryDataSet.EndPoint endPoint)
void	setFetchSize(int fetchSize)
void	setRowLimit(int rowLimit)
void	setRowOffset(int rowOffset)
void	setWithoutAllNull(boolean withoutAllNull)
void	setWithoutAnyNull(boolean withoutAnyNull)
void	setWithoutNullColumnsIndex(Set<Integer> withoutNullColumnsIndex)
boolean	withoutNullFilter(RowRecord rowRecord)	check rowRecord whether satisfy without null condition

Methods inherited from class java.lang.Object

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

Field Detail

paths

protected List<Path> paths

dataTypes

protected List<TSDataType> dataTypes

rowLimit

protected int rowLimit

rowOffset

protected int rowOffset

alreadyReturnedRowNum

protected int alreadyReturnedRowNum

fetchSize

protected int fetchSize

ascending

protected boolean ascending

endPoint

protected QueryDataSet.EndPoint endPoint

withoutAnyNull

protected boolean withoutAnyNull

if any column is null, we don't need that row

withoutAllNull

protected boolean withoutAllNull

Only if all columns are null, we don't need that row

withoutNullColumnsIndex

protected Set<Integer> withoutNullColumnsIndex

index set that withoutNullColumns for output data columns

columnNum

protected int columnNum

Constructor Detail

QueryDataSet

protected QueryDataSet()

QueryDataSet

protected QueryDataSet(List<Path> paths,
                       List<TSDataType> dataTypes)

QueryDataSet

protected QueryDataSet(List<Path> paths,
                       List<TSDataType> dataTypes,
                       boolean ascending)

Method Detail

initQueryDataSetFields

protected void initQueryDataSetFields(List<Path> paths,
                                      List<TSDataType> dataTypes,
                                      boolean ascending)

getWithoutNullColumnsIndex

public Set<Integer> getWithoutNullColumnsIndex()

setWithoutNullColumnsIndex

public void setWithoutNullColumnsIndex(Set<Integer> withoutNullColumnsIndex)

hasNext

public boolean hasNext()
                throws IOException

Throws:

IOException

withoutNullFilter

public boolean withoutNullFilter(RowRecord rowRecord)

check rowRecord whether satisfy without null condition

Parameters:

rowRecord - rowRecord

Returns:

true satisfy false don't satisfy

hasNextWithoutConstraint

public abstract boolean hasNextWithoutConstraint()
                                          throws IOException

Throws:

IOException

next

public RowRecord next()
               throws IOException

This method is used for batch query, return RowRecord.

Throws:

IOException

setFetchSize

public void setFetchSize(int fetchSize)

nextWithoutConstraint

public abstract RowRecord nextWithoutConstraint()
                                         throws IOException

Throws:

IOException

getPaths

public List<Path> getPaths()

getDataTypes

public List<TSDataType> getDataTypes()

setDataTypes

public void setDataTypes(List<TSDataType> dataTypes)

getRowLimit

public int getRowLimit()

setRowLimit

public void setRowLimit(int rowLimit)

getRowOffset

public int getRowOffset()

setRowOffset

public void setRowOffset(int rowOffset)

hasLimit

public boolean hasLimit()

getEndPoint

public QueryDataSet.EndPoint getEndPoint()

setEndPoint

public void setEndPoint(QueryDataSet.EndPoint endPoint)

isWithoutAnyNull

public boolean isWithoutAnyNull()

setWithoutAnyNull

public void setWithoutAnyNull(boolean withoutAnyNull)

isWithoutAllNull

public boolean isWithoutAllNull()

setWithoutAllNull

public void setWithoutAllNull(boolean withoutAllNull)

decreaseAlreadyReturnedRowNum

public void decreaseAlreadyReturnedRowNum()

getColumnNum

public int getColumnNum()

setColumnNum

public void setColumnNum(int columnNum)