SequenceFileWriter extends StreamWriterBase<Tuple2<K, V>> implements InputTypeConfigurable { @Override public Writer<Tuple2<K, V>> duplicate() { return new SequenceFileWriter<>(this); } SequenceFileWriter();  SequenceFileWriter(String compressionCodecName,
			SequenceFile.CompressionType compressionType); protected  SequenceFileWriter(SequenceFileWriter<K, V> other); @Override void open(FileSystem fs, Path path); @Override void close(); @Override void write(Tuple2<K, V> element); @Override void setInputType(TypeInformation<?> type, ExecutionConfig executionConfig); @Override Writer<Tuple2<K, V>> duplicate(); @Override int hashCode(); @Override boolean equals(Object other);  }
@Test public void testDuplicate() { SequenceFileWriter<Text, Text> writer = new SequenceFileWriter("BZ", SequenceFile.CompressionType.BLOCK); writer.setSyncOnFlush(true); Writer<Tuple2<Text, Text>> other = writer.duplicate(); assertTrue(writer.equals(other)); writer.setSyncOnFlush(false); assertFalse(writer.equals(other)); }