Package cz.o2.proxima.direct.io.blob

Class BlobStorageAccessor

java.lang.Object

cz.o2.proxima.core.storage.AbstractStorage

cz.o2.proxima.core.storage.AbstractStorage.SerializableAbstractStorage

cz.o2.proxima.direct.io.blob.BlobStorageAccessor

All Implemented Interfaces:

AbstractDataAccessor, DataAccessor, java.io.Serializable

@Internal
public abstract class BlobStorageAccessor
extends AbstractStorage.SerializableAbstractStorage
implements DataAccessor

A DataAccessor for blob storages.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class cz.o2.proxima.core.storage.AbstractStorage

AbstractStorage.SerializableAbstractStorage

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	ALLOWED_LATENESS_MS	Maximal allowed lateness to wait before segment is rolled.
static java.lang.String	LOG_ROLL_INTERVAL	How often to roll the blob in milliseconds.
static java.lang.String	PARTITION_MAX_BLOBS	Maximal number of blobs to be put in single partition.
static java.lang.String	PARTITION_MAX_TIME_SPAN_MS	Maximal amount of time (in milliseconds) a partition containing multiple blobs can span.
static java.lang.String	PARTITION_SIZE	Minimal size of partition in bytes.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	BlobStorageAccessor(AttributeFamilyDescriptor family)

Method Summary

Modifier and Type	Method	Description
long	getAllowedLateness()
java.util.Map<java.lang.String,java.lang.Object>	getCfg()
NamingConvention	getNamingConvention()
int	getPartitionMaxNumBlobs()
long	getPartitionMaxTimeSpanMs()
long	getPartitionMinSize()
long	getRollPeriod()
abstract FileSystem	getTargetFileSystem()
java.io.File	getTmpDir()

Methods inherited from class cz.o2.proxima.core.storage.AbstractStorage

equals, hashCode

Methods inherited from class java.lang.Object

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

Methods inherited from interface cz.o2.proxima.core.storage.internal.AbstractDataAccessor

getUri

Methods inherited from interface cz.o2.proxima.direct.core.DataAccessor

getBatchLogReader, getCachedView, getCommitLogReader, getRandomAccessReader, getWriter, isAcceptable

Field Detail

LOG_ROLL_INTERVAL

public static final java.lang.String LOG_ROLL_INTERVAL

How often to roll the blob in milliseconds.

See Also:

Constant Field Values

ALLOWED_LATENESS_MS

public static final java.lang.String ALLOWED_LATENESS_MS

Maximal allowed lateness to wait before segment is rolled. Late data are put to separate blob and flushed periodically with on time data.

See Also:

Constant Field Values

PARTITION_SIZE

public static final java.lang.String PARTITION_SIZE

Minimal size of partition in bytes.

See Also:

Constant Field Values

PARTITION_MAX_BLOBS

public static final java.lang.String PARTITION_MAX_BLOBS

Maximal number of blobs to be put in single partition.

See Also:

Constant Field Values

PARTITION_MAX_TIME_SPAN_MS

public static final java.lang.String PARTITION_MAX_TIME_SPAN_MS

Maximal amount of time (in milliseconds) a partition containing multiple blobs can span.

See Also:

Constant Field Values

Constructor Detail

BlobStorageAccessor

protected BlobStorageAccessor(AttributeFamilyDescriptor family)

Method Detail

getCfg

public java.util.Map<java.lang.String,java.lang.Object> getCfg()

getTargetFileSystem

public abstract FileSystem getTargetFileSystem()

getNamingConvention

public NamingConvention getNamingConvention()

getTmpDir

public java.io.File getTmpDir()

getRollPeriod

public long getRollPeriod()

getAllowedLateness

public long getAllowedLateness()

getPartitionMinSize

public long getPartitionMinSize()

getPartitionMaxNumBlobs

public int getPartitionMaxNumBlobs()

getPartitionMaxTimeSpanMs

public long getPartitionMaxTimeSpanMs()