@InterfaceAudience.Private public abstract class WriterBase extends Object implements DefaultWALProvider.Writer
Modifier and Type | Field and Description |
---|---|
protected CompressionContext |
compressionContext |
protected org.apache.hadoop.conf.Configuration |
conf |
Constructor and Description |
---|
WriterBase() |
Modifier and Type | Method and Description |
---|---|
void |
init(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path path,
org.apache.hadoop.conf.Configuration conf,
boolean overwritable) |
boolean |
initializeCompressionContext(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.Path path) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
append, getLength, sync
protected CompressionContext compressionContext
protected org.apache.hadoop.conf.Configuration conf
public void init(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, org.apache.hadoop.conf.Configuration conf, boolean overwritable) throws IOException
init
in interface DefaultWALProvider.Writer
IOException
public boolean initializeCompressionContext(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.Path path) throws IOException
IOException
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.