org.apache.spark.streaming.util

Class WriteAheadLogRandomReader

Object

org.apache.spark.streaming.util.WriteAheadLogRandomReader

All Implemented Interfaces:

java.io.Closeable, AutoCloseable

public class WriteAheadLogRandomReader
extends Object
implements java.io.Closeable

A random access reader for reading write ahead log files written using WriteAheadLogWriter. Given the file segment info, this reads the record (bytebuffer) from the log file.

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
java.nio.ByteBuffer	read(WriteAheadLogFileSegment segment)

Methods inherited from class Object

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

Constructor Detail

WriteAheadLogRandomReader

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

Method Detail

read

public java.nio.ByteBuffer read(WriteAheadLogFileSegment segment)

close

public void close()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface AutoCloseable