public final class NoEOFWALStreamReader extends Object implements org.apache.hadoop.hbase.wal.WALStreamReader
Modifier and Type | Field and Description |
---|---|
private static org.slf4j.Logger |
LOG |
private org.apache.hadoop.hbase.wal.WALStreamReader |
reader |
Modifier | Constructor and Description |
---|---|
private |
NoEOFWALStreamReader(org.apache.hadoop.hbase.wal.WALStreamReader reader) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
private int |
count() |
static int |
count(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path path,
org.apache.hadoop.conf.Configuration conf) |
static int |
count(org.apache.hadoop.hbase.wal.WALFactory walFactory,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path path) |
static NoEOFWALStreamReader |
create(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path path,
org.apache.hadoop.conf.Configuration conf) |
static NoEOFWALStreamReader |
create(org.apache.hadoop.hbase.wal.WALFactory walFactory,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path path) |
long |
getPosition() |
org.apache.hadoop.hbase.wal.WAL.Entry |
next(org.apache.hadoop.hbase.wal.WAL.Entry reuse) |
private static final org.slf4j.Logger LOG
private org.apache.hadoop.hbase.wal.WALStreamReader reader
private NoEOFWALStreamReader(org.apache.hadoop.hbase.wal.WALStreamReader reader)
public org.apache.hadoop.hbase.wal.WAL.Entry next(org.apache.hadoop.hbase.wal.WAL.Entry reuse) throws IOException
next
in interface org.apache.hadoop.hbase.wal.WALStreamReader
IOException
public long getPosition() throws IOException
getPosition
in interface org.apache.hadoop.hbase.wal.WALStreamReader
IOException
public void close()
close
in interface Closeable
close
in interface AutoCloseable
close
in interface org.apache.hadoop.hbase.wal.WALStreamReader
private int count() throws IOException
IOException
public static NoEOFWALStreamReader create(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, org.apache.hadoop.conf.Configuration conf) throws IOException
IOException
public static NoEOFWALStreamReader create(org.apache.hadoop.hbase.wal.WALFactory walFactory, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path) throws IOException
IOException
public static int count(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, org.apache.hadoop.conf.Configuration conf) throws IOException
IOException
public static int count(org.apache.hadoop.hbase.wal.WALFactory walFactory, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path) throws IOException
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.