Class RecordReaderGenericRdfNonAccumulatingBase<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<T,T,T,T>
-
- net.sansa_stack.hadoop.format.jena.base.RecordReaderGenericRdfNonAccumulatingBase<T>
-
- All Implemented Interfaces:
Closeable
,AutoCloseable
- Direct Known Subclasses:
RecordReaderRdfTrigQuad
,RecordReaderRdfTurtleTriple
public abstract class RecordReaderGenericRdfNonAccumulatingBase<T> extends RecordReaderGenericRdfBase<T,T,T,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
-
-
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
-
-