Class RecordReaderGenericRdfAccumulatingBase<U,G,A,T>
- java.lang.Object
-
- org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.LongWritable,T>
-
- net.sansa_stack.hadoop.core.RecordReaderGenericBase<U,G,A,T>
-
- net.sansa_stack.hadoop.format.jena.base.RecordReaderGenericRdfBase<U,G,A,T>
-
- net.sansa_stack.hadoop.format.jena.base.RecordReaderGenericRdfAccumulatingBase<U,G,A,T>
-
- All Implemented Interfaces:
Closeable
,AutoCloseable
- Direct Known Subclasses:
RecordReaderRdfTrigDataset
public abstract class RecordReaderGenericRdfAccumulatingBase<U,G,A,T> extends RecordReaderGenericRdfBase<U,G,A,T>
-
-
Field Summary
-
Fields inherited from class net.sansa_stack.hadoop.format.jena.base.RecordReaderGenericRdfBase
baseIri, baseIriKey, headerBytesKey, lang, prefixesMaxLengthKey
-
Fields inherited from class net.sansa_stack.hadoop.core.RecordReaderGenericBase
accumulating, codec, currentKey, currentValue, datasetFlow, decompressor, EMPTY_BYTE_ARRAY, isEncoded, isFirstSplit, maxRecordLength, maxRecordLengthKey, minRecordLength, minRecordLengthKey, postambleBytes, preambleBytes, probeRecordCount, probeRecordCountKey, raisedThrowable, rawStream, recordStartPattern, split, splitEnd, splitLength, splitStart, stream
-
-
Constructor Summary
Constructors Constructor Description RecordReaderGenericRdfAccumulatingBase(String minRecordLengthKey, String maxRecordLengthKey, String probeRecordCountKey, String prefixesMaxLengthKey, Pattern recordSearchPattern, org.apache.jena.riot.Lang lang, Accumulating<U,G,A,T> accumulating)
-
Method Summary
-
Methods inherited from class net.sansa_stack.hadoop.format.jena.base.RecordReaderGenericRdfBase
initialize
-
Methods inherited from class net.sansa_stack.hadoop.core.RecordReaderGenericBase
aggregate, close, createRecordFlow, didHitSplitBound, effectiveInputStream, effectiveInputStreamSupp, findFirstPositionWithProbeSuccess, findNextRecord, getCurrentKey, getCurrentValue, getPos, getProgress, initRecordFlow, lines, logClose, logUnexpectedClose, nextKeyValue, parse, parseFromSeekable, prober, setStreamToInterval
-
-