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

Class PubSubAccessor

java.lang.Object

cz.o2.proxima.core.storage.AbstractStorage

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

cz.o2.proxima.direct.io.pubsub.PubSubAccessor

All Implemented Interfaces:

AbstractDataAccessor, DataAccessor, java.io.Serializable

public class PubSubAccessor
extends AbstractStorage.SerializableAbstractStorage
implements DataAccessor

A DataAccessor for Google PubSub.

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	CFG_MAX_ACK_DEADLINE
static java.lang.String	CFG_SUBSCRIPTION_ACK_DEADLINE
static java.lang.String	CFG_SUBSCRIPTION_AUTOCREATE

Method Summary

Modifier and Type	Method	Description
cz.o2.proxima.direct.io.pubsub.PubSubAccessor.BulkConfig	getBulk()
java.util.Map<java.lang.String,java.lang.Object>	getCfg()
java.util.Optional<CommitLogReader>	getCommitLogReader(Context context)	Retrieve commit log reader (if applicable).
int	getMaxAckDeadline()
java.lang.String	getProject()
int	getSubscriptionAckDeadline()
java.lang.String	getTopic()
PubSubWatermarkConfiguration	getWatermarkConfiguration()
java.util.Optional<AttributeWriterBase>	getWriter(Context context)	Retrieve writer (if applicable).
boolean	isBulk()
boolean	isSubscriptionAutoCreate()
java.lang.String	toString()

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

equals, getEntityDescriptor, getUri, hashCode

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, 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, getRandomAccessReader, isAcceptable

Field Detail

CFG_MAX_ACK_DEADLINE

public static final java.lang.String CFG_MAX_ACK_DEADLINE

See Also:

Constant Field Values

CFG_SUBSCRIPTION_AUTOCREATE

public static final java.lang.String CFG_SUBSCRIPTION_AUTOCREATE

See Also:

Constant Field Values

CFG_SUBSCRIPTION_ACK_DEADLINE

public static final java.lang.String CFG_SUBSCRIPTION_ACK_DEADLINE

See Also:

Constant Field Values

Method Detail

isBulk

public boolean isBulk()

getCommitLogReader

public java.util.Optional<CommitLogReader> getCommitLogReader(Context context)

Description copied from interface: DataAccessor

Retrieve commit log reader (if applicable).

Specified by:

getCommitLogReader in interface DataAccessor

Parameters:

context - serializable context provided by repository

Returns:

optional @{link CommitLogReader} of this accessor

getWriter

public java.util.Optional<AttributeWriterBase> getWriter(Context context)

Description copied from interface: DataAccessor

Retrieve writer (if applicable).

Specified by:

getWriter in interface DataAccessor

Parameters:

context - the serializable context provided by repository

Returns:

optional AttributeWriterBase of this accessor

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getCfg

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

getProject

public java.lang.String getProject()

getTopic

public java.lang.String getTopic()

getMaxAckDeadline

public int getMaxAckDeadline()

getSubscriptionAckDeadline

public int getSubscriptionAckDeadline()

isSubscriptionAutoCreate

public boolean isSubscriptionAutoCreate()

getWatermarkConfiguration

public PubSubWatermarkConfiguration getWatermarkConfiguration()

getBulk

@Nullable
public cz.o2.proxima.direct.io.pubsub.PubSubAccessor.BulkConfig getBulk()