org.deri.tarql

Class CSVTable

java.lang.Object

com.hp.hpl.jena.sparql.algebra.table.TableBase

org.deri.tarql.CSVTable

All Implemented Interfaces:

com.hp.hpl.jena.sparql.algebra.Table

public class CSVTable
extends com.hp.hpl.jena.sparql.algebra.table.TableBase
implements com.hp.hpl.jena.sparql.algebra.Table

Implementation of ARQ's Table interface over a CSV file. Supports opening multiple iterators over the input, which will lead to multiple passes over the input CSV file. Connects to the input as lazily as possible, while still supporting the entire Table interface including size().

Field Summary

Fields

Modifier and Type	Field and Description
private java.lang.Boolean	isEmptyCache
private com.hp.hpl.jena.util.iterator.ClosableIterator<com.hp.hpl.jena.sparql.engine.binding.Binding>	nextParser
private java.util.List<com.hp.hpl.jena.util.iterator.ClosableIterator<com.hp.hpl.jena.sparql.engine.binding.Binding>>	openIterators
private CSVOptions	options
private java.lang.Integer	sizeCache
private InputStreamSource	source
private java.util.List<com.hp.hpl.jena.sparql.core.Var>	varsCache

Constructor Summary

Constructors

Constructor and Description
CSVTable(InputStreamSource source)
CSVTable(InputStreamSource source, CSVOptions options)

Method Summary

Methods

Modifier and Type	Method and Description
void	closeTable() Closes any open iterators over the table.
private CSVParser	createParser()
private void	ensureHasParser()
java.util.List<java.lang.String>	getVarNames()
java.util.List<com.hp.hpl.jena.sparql.core.Var>	getVars()
boolean	isEmpty() Returns true if the table has zero rows.
com.hp.hpl.jena.sparql.engine.QueryIterator	iterator(com.hp.hpl.jena.sparql.engine.ExecutionContext ctxt)
com.hp.hpl.jena.util.iterator.ClosableIterator<com.hp.hpl.jena.sparql.engine.binding.Binding>	rows()
int	size() Returns the number of rows in the table.

Methods inherited from class com.hp.hpl.jena.sparql.algebra.table.TableBase

addBinding, close, contains, equals, eval, hashCode, toResultSet, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.hp.hpl.jena.sparql.algebra.Table

addBinding, close, contains, toResultSet

Field Detail

source

private final InputStreamSource source

options

private final CSVOptions options

openIterators

private final java.util.List<com.hp.hpl.jena.util.iterator.ClosableIterator<com.hp.hpl.jena.sparql.engine.binding.Binding>> openIterators

nextParser

private com.hp.hpl.jena.util.iterator.ClosableIterator<com.hp.hpl.jena.sparql.engine.binding.Binding> nextParser

varsCache

private java.util.List<com.hp.hpl.jena.sparql.core.Var> varsCache

isEmptyCache

private java.lang.Boolean isEmptyCache

sizeCache

private java.lang.Integer sizeCache

Constructor Detail

CSVTable

public CSVTable(InputStreamSource source)

CSVTable

public CSVTable(InputStreamSource source,
        CSVOptions options)

Method Detail

iterator

public com.hp.hpl.jena.sparql.engine.QueryIterator iterator(com.hp.hpl.jena.sparql.engine.ExecutionContext ctxt)

Specified by:

iterator in interface com.hp.hpl.jena.sparql.algebra.Table

rows

public com.hp.hpl.jena.util.iterator.ClosableIterator<com.hp.hpl.jena.sparql.engine.binding.Binding> rows()

Specified by:

rows in interface com.hp.hpl.jena.sparql.algebra.Table

getVars

public java.util.List<com.hp.hpl.jena.sparql.core.Var> getVars()

Specified by:

getVars in interface com.hp.hpl.jena.sparql.algebra.Table

getVarNames

public java.util.List<java.lang.String> getVarNames()

Specified by:

getVarNames in interface com.hp.hpl.jena.sparql.algebra.Table

isEmpty

public boolean isEmpty()

Returns true if the table has zero rows. Is fast.

Specified by:

isEmpty in interface com.hp.hpl.jena.sparql.algebra.Table

Specified by:

isEmpty in class com.hp.hpl.jena.sparql.algebra.table.TableBase

size

public int size()

Returns the number of rows in the table. Is fast if an iterator over the table has already been exhausted. Otherwise, it will make a complete parsing pass over the input.

Specified by:

size in interface com.hp.hpl.jena.sparql.algebra.Table

Specified by:

size in class com.hp.hpl.jena.sparql.algebra.table.TableBase

closeTable

public void closeTable()

Closes any open iterators over the table.

Specified by:

closeTable in class com.hp.hpl.jena.sparql.algebra.table.TableBase

ensureHasParser

private void ensureHasParser()

createParser

private CSVParser createParser()