@InterfaceAudience.Private public abstract class WriterBase extends Object implements DefaultWALProvider.Writer
| Modifier and Type | Field and Description |
|---|---|
protected CompressionContext |
compressionContext |
protected Configuration |
conf |
| Constructor and Description |
|---|
WriterBase() |
| Modifier and Type | Method and Description |
|---|---|
void |
init(FileSystem fs,
Path path,
Configuration conf,
boolean overwritable) |
boolean |
initializeCompressionContext(Configuration conf,
Path path) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitappend, getLength, syncprotected CompressionContext compressionContext
protected Configuration conf
public void init(FileSystem fs,
Path path,
Configuration conf,
boolean overwritable)
throws IOException
init in interface DefaultWALProvider.WriterIOExceptionpublic boolean initializeCompressionContext(Configuration conf,
Path path)
throws IOException
IOException