public class RecordReaderTrigDataset extends RecordReaderGenericRdfBase<org.apache.jena.sparql.core.Quad,org.apache.jena.graph.Node,org.apache.jena.query.Dataset,org.apache.jena.query.Dataset>
Modifier and Type | Class and Description |
---|---|
static class |
RecordReaderTrigDataset.AccumulatingDataset |
Modifier and Type | Field and Description |
---|---|
static String |
PREFIXES_MAXLENGTH_KEY |
static String |
RECORD_MAXLENGTH_KEY |
static String |
RECORD_MINLENGTH_KEY |
static String |
RECORD_PROBECOUNT_KEY |
protected static Pattern |
trigFwdPattern |
lang, prefixesMaxLengthKey
accumulating, baseIri, baseIriKey, codec, currentKey, currentValue, datasetFlow, decompressor, headerBytesKey, isEncoded, maxRecordLength, maxRecordLengthKey, minRecordLength, minRecordLengthKey, prefixBytes, probeRecordCount, probeRecordCountKey, rawStream, recordStartPattern, split, splitEnd, splitLength, splitStart, stream
Constructor and Description |
---|
RecordReaderTrigDataset() |
Modifier and Type | Method and Description |
---|---|
protected io.reactivex.rxjava3.core.Flowable<org.apache.jena.sparql.core.Quad> |
parse(Callable<InputStream> inputStreamSupplier)
Create a flowable from the input stream.
|
aggregate, close, createRecordFlow, findFirstPositionWithProbeSuccess, findNextRecord, getCurrentKey, getCurrentValue, getProgress, initialize, initRecordFlow, logClose, logUnexpectedClose, nextKeyValue, setStreamToInterval
public static final String RECORD_MINLENGTH_KEY
public static final String RECORD_MAXLENGTH_KEY
public static final String RECORD_PROBECOUNT_KEY
public static final String PREFIXES_MAXLENGTH_KEY
protected static final Pattern trigFwdPattern
protected io.reactivex.rxjava3.core.Flowable<org.apache.jena.sparql.core.Quad> parse(Callable<InputStream> inputStreamSupplier)
RecordReaderGenericBase
parse
in class RecordReaderGenericBase<org.apache.jena.sparql.core.Quad,org.apache.jena.graph.Node,org.apache.jena.query.Dataset,org.apache.jena.query.Dataset>
inputStreamSupplier
- A supplier of input streams. May supply the same underlying stream
on each call hence only at most a single stream should be taken from the supplier.
Supplied streams are safe to use in try-with-resources blocks (possibly using CloseShieldInputStream).
Taken streams should be closed by the client code.Copyright © 2016–2021 Smart Data Analytics (SDA) Research Group. All rights reserved.