com.indeed.mph

Class SharedTableReader<K,V>

java.lang.Object

com.indeed.mph.SharedTableReader<K,V>

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class SharedTableReader<K,V>
extends java.lang.Object
implements java.io.Closeable

Thread-safe reference counting version of TableReader.

Author:

alexs

Constructor Summary

Constructors

Constructor and Description
SharedTableReader(TableReader<K,V> reader)

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	containsKey(K key)
V	get(K key)
TableConfig<K,V>	getConfig()
com.indeed.util.core.reference.SharedReference<TableReader<K,V>>	getCopy()
long	getSizeInBytes()
TableReader.TableStats	getStats()
long	getTimestamp()
static <K,V> SharedTableReader<K,V>	open(java.io.File metaPath)
static <K,V> SharedTableReader<K,V>	open(java.io.File metaPath, java.io.File offsetsPath, java.io.File dataPath)
static <K,V> SharedTableReader<K,V>	open(java.lang.String metaPath)
long	size()

Methods inherited from class java.lang.Object

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

Constructor Detail

SharedTableReader

public SharedTableReader(@Nonnull
                         TableReader<K,V> reader)

Method Detail

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException

open

public static <K,V> SharedTableReader<K,V> open(@Nonnull
                                                java.io.File metaPath,
                                                @Nullable
                                                java.io.File offsetsPath,
                                                @Nullable
                                                java.io.File dataPath)
                                         throws java.io.IOException

Throws:

java.io.IOException

open

public static <K,V> SharedTableReader<K,V> open(@Nonnull
                                                java.io.File metaPath)
                                         throws java.io.IOException

Throws:

java.io.IOException

open

public static <K,V> SharedTableReader<K,V> open(@Nonnull
                                                java.lang.String metaPath)
                                         throws java.io.IOException

Throws:

java.io.IOException

getCopy

public com.indeed.util.core.reference.SharedReference<TableReader<K,V>> getCopy()

getConfig

public TableConfig<K,V> getConfig()
                           throws java.io.IOException

Throws:

java.io.IOException

getStats

public TableReader.TableStats getStats()
                                throws java.io.IOException

Throws:

java.io.IOException

containsKey

public boolean containsKey(@Nonnull
                           K key)

get

public V get(@Nonnull
             K key)
      throws java.io.IOException

Throws:

java.io.IOException

size

public long size()

getSizeInBytes

public long getSizeInBytes()

getTimestamp

public long getTimestamp()