@Override
  protected FileBasedReader<KV<K, V>> createSingleFileReader(PipelineOptions options) {
    Set<String> serializationNames = Sets.newHashSet(
        keySerializationClass.getName(),
        valueSerializationClass.getName()
    );
    return new SeqFileReader<>(this, keyClass, valueClass,
        serializationNames.toArray(new String[serializationNames.size()]));
  }
@ Override protected FileBasedReader < KV < K , V > > createSingleFileReader ( PipelineOptions options ) { Set < String > serializationNames = Sets . newHashSet ( keySerializationClass . getName ( ) , valueSerializationClass . getName ( ) ) ; return new SeqFileReader < > ( this , keyClass , valueClass , serializationNames . toArray ( new String [ serializationNames . size ( ) ] ) ) ; }
{@inheritDoc}