org.apache.spark.streaming.util

Class WriteAheadLogWriter

Object

org.apache.spark.streaming.util.WriteAheadLogWriter

All Implemented Interfaces:

java.io.Closeable, AutoCloseable

public class WriteAheadLogWriter
extends Object
implements java.io.Closeable

A writer for writing byte-buffers to a write ahead log file.

Constructor Summary

Constructors

Constructor and Description
WriteAheadLogWriter(String path, org.apache.hadoop.conf.Configuration hadoopConf)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
WriteAheadLogFileSegment	write(java.nio.ByteBuffer data) Write the bytebuffer to the log file

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WriteAheadLogWriter

public WriteAheadLogWriter(String path,
                   org.apache.hadoop.conf.Configuration hadoopConf)

Method Detail

write

public WriteAheadLogFileSegment write(java.nio.ByteBuffer data)

Write the bytebuffer to the log file

close

public void close()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface AutoCloseable