Class RecordReaderGenericRdfBase<U,​G,​A,​T>

    • Field Detail

      • baseIriKey

        protected final String baseIriKey
      • headerBytesKey

        protected final String headerBytesKey
      • prefixesMaxLengthKey

        protected String prefixesMaxLengthKey
      • baseIri

        protected String baseIri
      • lang

        protected org.apache.jena.riot.Lang lang
    • Constructor Detail

      • RecordReaderGenericRdfBase

        public RecordReaderGenericRdfBase​(String minRecordLengthKey,
                                          String maxRecordLengthKey,
                                          String probeRecordCountKey,
                                          String prefixesMaxLengthKey,
                                          Pattern recordSearchPattern,
                                          org.apache.jena.riot.Lang lang,
                                          Accumulating<U,​G,​A,​T> accumulating)
    • Method Detail

      • initialize

        public void initialize​(org.apache.hadoop.mapreduce.InputSplit inputSplit,
                               org.apache.hadoop.mapreduce.TaskAttemptContext context)
                        throws IOException
        Description copied from class: RecordReaderGenericBase
        Read out config paramaters (prefixes, length thresholds, ...) and examine the codec in order to set an internal flag whether the stream will be encoded or not.
        Overrides:
        initialize in class RecordReaderGenericBase<U,​G,​A,​T>
        Throws:
        IOException