Class CombinedWriter
java.lang.Object
org.apache.hadoop.hbase.regionserver.wal.CombinedWriterBase<WALProvider.Writer>
org.apache.hadoop.hbase.regionserver.wal.CombinedWriter
- All Implemented Interfaces:
Closeable
,AutoCloseable
,WALProvider.Writer
,WALProvider.WriterBase
@Private
public final class CombinedWriter
extends CombinedWriterBase<WALProvider.Writer>
implements WALProvider.Writer
-
Nested Class Summary
-
Field Summary
Modifier and TypeFieldDescriptionprivate final org.apache.hbase.thirdparty.com.google.common.collect.ImmutableList<ExecutorService>
Fields inherited from class org.apache.hadoop.hbase.regionserver.wal.CombinedWriterBase
writers
-
Constructor Summary
ModifierConstructorDescriptionprivate
CombinedWriter
(org.apache.hbase.thirdparty.com.google.common.collect.ImmutableList<WALProvider.Writer> writers) -
Method Summary
Modifier and TypeMethodDescriptionvoid
private void
apply
(CombinedWriter.Action action) void
close()
static CombinedWriter
create
(WALProvider.Writer writer, WALProvider.Writer... writers) void
sync
(boolean forceSync) Methods inherited from class org.apache.hadoop.hbase.regionserver.wal.CombinedWriterBase
getLength, getSyncedLength
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.apache.hadoop.hbase.wal.WALProvider.WriterBase
getLength, getSyncedLength
-
Field Details
-
executors
private final org.apache.hbase.thirdparty.com.google.common.collect.ImmutableList<ExecutorService> executors
-
-
Constructor Details
-
CombinedWriter
private CombinedWriter(org.apache.hbase.thirdparty.com.google.common.collect.ImmutableList<WALProvider.Writer> writers)
-
-
Method Details
-
apply
- Throws:
IOException
-
sync
- Specified by:
sync
in interfaceWALProvider.Writer
- Throws:
IOException
-
append
- Specified by:
append
in interfaceWALProvider.Writer
- Throws:
IOException
-
close
- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Overrides:
close
in classCombinedWriterBase<WALProvider.Writer>
- Throws:
IOException
-
create
-