pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/seq/HdfsAbstractSequenceFileSink.java [87:95]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    protected List<Option> getOptions() throws IllegalArgumentException, IOException {
        List<Option> list = new ArrayList<Option>();
        list.add(Writer.stream(getHdfsStream()));

        if (getCompressionCodec() != null) {
            list.add(Writer.compression(SequenceFile.CompressionType.RECORD, getCompressionCodec()));
        }
        return list;
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink/seq/HdfsAbstractSequenceFileSink.java [87:95]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    protected List<Option> getOptions() throws IllegalArgumentException, IOException {
        List<Option> list = new ArrayList<Option>();
        list.add(Writer.stream(getHdfsStream()));

        if (getCompressionCodec() != null) {
            list.add(Writer.compression(SequenceFile.CompressionType.RECORD, getCompressionCodec()));
        }
        return list;
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -