Package cz.o2.proxima.direct.io.pubsub

Class PubSubStorage

java.lang.Object

cz.o2.proxima.direct.io.pubsub.PubSubStorage

All Implemented Interfaces:

AbstractDataAccessorFactory<DirectDataOperator,DataAccessor>, DataAccessorFactory, java.io.Serializable

@Stable
@AutoService(DataAccessorFactory.class)
public class PubSubStorage
extends java.lang.Object
implements DataAccessorFactory

A DataAccessorFactory for PubSub.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface cz.o2.proxima.core.storage.internal.AbstractDataAccessorFactory

AbstractDataAccessorFactory.Accept

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	CFG_DEFAULT_ALLOWED_TIMESTAMP_SKEW
static java.lang.String	CFG_DEFAULT_MAX_ACK_DEADLINE
static java.lang.String	CFG_DEFAULT_SUBSCRIPTION_ACK_DEADLINE
static java.lang.String	CFG_DEFAULT_SUBSCRIPTION_AUTO_CREATE
static java.lang.String	CFG_DEFAULT_WATERMARK_ESTIMATE_DURATION

Constructor Summary

Constructors

Constructor	Description
PubSubStorage()

Method Summary

Modifier and Type	Method	Description
AbstractDataAccessorFactory.Accept	accepts(java.net.URI uri)	Check if this factory can create accessors for given URI.
DataAccessor	createAccessor(DirectDataOperator operator, AttributeFamilyDescriptor family)	Create the accessor for give AttributeFamilyDescriptor.
void	setup(Repository repo)	Setup the factory for using given Repository.

Methods inherited from class java.lang.Object

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

Field Detail

CFG_DEFAULT_MAX_ACK_DEADLINE

public static final java.lang.String CFG_DEFAULT_MAX_ACK_DEADLINE

See Also:

Constant Field Values

CFG_DEFAULT_SUBSCRIPTION_AUTO_CREATE

public static final java.lang.String CFG_DEFAULT_SUBSCRIPTION_AUTO_CREATE

See Also:

Constant Field Values

CFG_DEFAULT_SUBSCRIPTION_ACK_DEADLINE

public static final java.lang.String CFG_DEFAULT_SUBSCRIPTION_ACK_DEADLINE

See Also:

Constant Field Values

CFG_DEFAULT_WATERMARK_ESTIMATE_DURATION

public static final java.lang.String CFG_DEFAULT_WATERMARK_ESTIMATE_DURATION

See Also:

Constant Field Values

CFG_DEFAULT_ALLOWED_TIMESTAMP_SKEW

public static final java.lang.String CFG_DEFAULT_ALLOWED_TIMESTAMP_SKEW

See Also:

Constant Field Values

Constructor Detail

PubSubStorage

public PubSubStorage()

Method Detail

setup

public void setup(Repository repo)

Description copied from interface: AbstractDataAccessorFactory

Setup the factory for using given Repository.

Specified by:

setup in interface AbstractDataAccessorFactory<DirectDataOperator,DataAccessor>

Parameters:

repo - the repository that will be used with the factory

createAccessor

public DataAccessor createAccessor(DirectDataOperator operator,
                                   AttributeFamilyDescriptor family)

Description copied from interface: AbstractDataAccessorFactory

Create the accessor for give AttributeFamilyDescriptor.

Specified by:

createAccessor in interface AbstractDataAccessorFactory<DirectDataOperator,DataAccessor>

Parameters:

operator - operator to create the accessor for

family - attribute family descriptor

Returns:

AbstractDataAccessor for given operator and family

accepts

public AbstractDataAccessorFactory.Accept accepts(java.net.URI uri)

Description copied from interface: AbstractDataAccessorFactory

Check if this factory can create accessors for given URI.

Specified by:

accepts in interface AbstractDataAccessorFactory<DirectDataOperator,DataAccessor>

Parameters:

uri - the URI to create accessor for

Returns:

acception mark