Package org.aksw.jena_sparql_api.rx.io.resultset

Class SPARQLResultExProcessorBuilder

java.lang.Object

org.aksw.jena_sparql_api.rx.io.resultset.SPARQLResultExProcessorBuilder

public class SPARQLResultExProcessorBuilder
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected Closeable	closeAction
protected long	deferCount
protected Supplier<? extends OutputStream>	err
protected int	jqDepth
protected boolean	jqFlatMode
protected boolean	jqMode
protected Supplier<? extends OutputStream>	out
protected String	outFormat
protected OutputMode	outputMode
protected org.apache.jena.shared.PrefixMapping	prefixMapping
protected org.apache.jena.riot.RDFFormat	quadFormat
protected Collection<? extends org.aksw.jenax.stmt.core.SparqlStmt>	stmts
protected org.apache.jena.riot.RDFFormat	tripleFormat

Constructor Summary

Constructors

Constructor	Description
SPARQLResultExProcessorBuilder()

Method Summary

Modifier and Type	Method	Description
SPARQLResultExProcessor	build()
static SPARQLResultExProcessorImpl	configureForOutputMode(OutputMode outputMode, OutputStream out, OutputStream err, org.apache.jena.shared.PrefixMapping pm, org.apache.jena.riot.RDFFormat outRdfFormat, long deferCount, org.apache.jena.riot.Lang outLang, List<org.apache.jena.sparql.core.Var> resultSetVars, Closeable closeAction)	Configure a SPARQLResultExProcessor to delegate JSON, triples/quads and bindings to the appropriate target.
static SPARQLResultExProcessor	configureProcessor(OutputStream out, OutputStream err, String outFormat, Collection<? extends org.aksw.jenax.stmt.core.SparqlStmt> stmts, org.apache.jena.shared.PrefixMapping prefixMapping, org.apache.jena.riot.RDFFormat tripleFormat, org.apache.jena.riot.RDFFormat quadFormat, long deferCount, boolean jqMode, int jqDepth, boolean jqFlatMode, Closeable closeAction)
static SPARQLResultExProcessorBuilder	create()
static SPARQLResultExProcessorBuilder	createForQuadOutput()
Closeable	getCloseAction()
long	getDeferCount()
Supplier<? extends OutputStream>	getErr()
int	getJqDepth()
Supplier<? extends OutputStream>	getOut()
String	getOutFormat()
OutputMode	getOutputMode()
org.apache.jena.shared.PrefixMapping	getPrefixMapping()
org.apache.jena.riot.RDFFormat	getQuadFormat()
Collection<? extends org.aksw.jenax.stmt.core.SparqlStmt>	getStmts()
org.apache.jena.riot.RDFFormat	getTripleFormat()
boolean	isJqFlatMode()
boolean	isJqMode()
SPARQLResultExProcessorBuilder	setCloseAction(Closeable closeAction)
SPARQLResultExProcessorBuilder	setDeferCount(long deferCount)
SPARQLResultExProcessorBuilder	setErr(Supplier<? extends OutputStream> err)
SPARQLResultExProcessorBuilder	setJqDepth(int jqDepth)
SPARQLResultExProcessorBuilder	setJqFlatMode(boolean jqFlatMode)
SPARQLResultExProcessorBuilder	setJqMode(boolean jqMode)
SPARQLResultExProcessorBuilder	setOut(Supplier<? extends OutputStream> out)
SPARQLResultExProcessorBuilder	setOutFormat(String outFormat)
SPARQLResultExProcessorBuilder	setOutputMode(OutputMode outputMode)
SPARQLResultExProcessorBuilder	setPrefixMapping(org.apache.jena.shared.PrefixMapping prefixMapping)
SPARQLResultExProcessorBuilder	setQuadFormat(org.apache.jena.riot.RDFFormat quadFormat)
SPARQLResultExProcessorBuilder	setStmts(Collection<? extends org.aksw.jenax.stmt.core.SparqlStmt> stmts)
SPARQLResultExProcessorBuilder	setTripleFormat(org.apache.jena.riot.RDFFormat tripleFormat)

Methods inherited from class java.lang.Object

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

Field Details

outputMode

protected OutputMode outputMode

out

protected Supplier<? extends OutputStream> out

err

protected Supplier<? extends OutputStream> err

outFormat

protected String outFormat

prefixMapping

protected org.apache.jena.shared.PrefixMapping prefixMapping

tripleFormat

protected org.apache.jena.riot.RDFFormat tripleFormat

quadFormat

protected org.apache.jena.riot.RDFFormat quadFormat

deferCount

protected long deferCount

jqMode

protected boolean jqMode

jqDepth

protected int jqDepth

jqFlatMode

protected boolean jqFlatMode

closeAction

protected Closeable closeAction

stmts

protected Collection<? extends org.aksw.jenax.stmt.core.SparqlStmt> stmts

Constructor Details

SPARQLResultExProcessorBuilder

public SPARQLResultExProcessorBuilder()

Method Details

getOut

public Supplier<? extends OutputStream> getOut()

getOutputMode

public OutputMode getOutputMode()

setOutputMode

public SPARQLResultExProcessorBuilder setOutputMode(OutputMode outputMode)

setOut

public SPARQLResultExProcessorBuilder setOut(Supplier<? extends OutputStream> out)

getErr

public Supplier<? extends OutputStream> getErr()

setErr

public SPARQLResultExProcessorBuilder setErr(Supplier<? extends OutputStream> err)

getOutFormat

public String getOutFormat()

setOutFormat

public SPARQLResultExProcessorBuilder setOutFormat(String outFormat)

getPrefixMapping

public org.apache.jena.shared.PrefixMapping getPrefixMapping()

setPrefixMapping

public SPARQLResultExProcessorBuilder setPrefixMapping(org.apache.jena.shared.PrefixMapping prefixMapping)

getTripleFormat

public org.apache.jena.riot.RDFFormat getTripleFormat()

setTripleFormat

public SPARQLResultExProcessorBuilder setTripleFormat(org.apache.jena.riot.RDFFormat tripleFormat)

getQuadFormat

public org.apache.jena.riot.RDFFormat getQuadFormat()

setQuadFormat

public SPARQLResultExProcessorBuilder setQuadFormat(org.apache.jena.riot.RDFFormat quadFormat)

getDeferCount

public long getDeferCount()

setDeferCount

public SPARQLResultExProcessorBuilder setDeferCount(long deferCount)

isJqMode

public boolean isJqMode()

setJqMode

public SPARQLResultExProcessorBuilder setJqMode(boolean jqMode)

getJqDepth

public int getJqDepth()

setJqDepth

public SPARQLResultExProcessorBuilder setJqDepth(int jqDepth)

isJqFlatMode

public boolean isJqFlatMode()

setJqFlatMode

public SPARQLResultExProcessorBuilder setJqFlatMode(boolean jqFlatMode)

getCloseAction

public Closeable getCloseAction()

setCloseAction

public SPARQLResultExProcessorBuilder setCloseAction(Closeable closeAction)

getStmts

public Collection<? extends org.aksw.jenax.stmt.core.SparqlStmt> getStmts()

setStmts

public SPARQLResultExProcessorBuilder setStmts(Collection<? extends org.aksw.jenax.stmt.core.SparqlStmt> stmts)

build

public SPARQLResultExProcessor build()

create

public static SPARQLResultExProcessorBuilder create()

createForQuadOutput

public static SPARQLResultExProcessorBuilder createForQuadOutput()

configureProcessor

public static SPARQLResultExProcessor configureProcessor(OutputStream out,
 OutputStream err,
 String outFormat,
 Collection<? extends org.aksw.jenax.stmt.core.SparqlStmt> stmts,
 org.apache.jena.shared.PrefixMapping prefixMapping,
 org.apache.jena.riot.RDFFormat tripleFormat,
 org.apache.jena.riot.RDFFormat quadFormat,
 long deferCount,
 boolean jqMode,
 int jqDepth,
 boolean jqFlatMode,
 Closeable closeAction)

Parameters:

outFormat -

stmts -

prefixMapping -

quadFormat - Allows to preset a streaming format in case quads were requested

deferCount -

jqMode -

jqDepth -

jqFlatMode -

Returns:

configureForOutputMode

public static SPARQLResultExProcessorImpl configureForOutputMode(OutputMode outputMode,
 OutputStream out,
 OutputStream err,
 org.apache.jena.shared.PrefixMapping pm,
 org.apache.jena.riot.RDFFormat outRdfFormat,
 long deferCount,
 org.apache.jena.riot.Lang outLang,
 List<org.apache.jena.sparql.core.Var> resultSetVars,
 Closeable closeAction)

Configure a SPARQLResultExProcessor to delegate JSON, triples/quads and bindings to the appropriate target. TODO Wrap as a builder

Parameters:

outputMode -

out -

err -

pm -

outRdfFormat -

deferCount - Number of items to analyze for used prefixes before writing them out

outLang -

resultSetVars -

closeAction -

Returns: