Package cz.o2.proxima.beam.storage

Class TestStreamStorage

java.lang.Object

cz.o2.proxima.beam.storage.TestStreamStorage

All Implemented Interfaces:

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

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

Storage with URI scheme test-stream://. This storage is backed by TestStream and enables fine-tuning with regard to watermark and other stream aspects.

See Also:

Serialized Form

Nested Class Summary

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

AbstractDataAccessorFactory.Accept

Constructor Summary

Constructors

Constructor	Description
TestStreamStorage()

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(BeamDataOperator operator, AttributeFamilyDescriptor familyDescriptor)	Create the accessor for give AttributeFamilyDescriptor.
static void	putStream(Repository repo, AttributeFamilyDescriptor family, org.apache.beam.sdk.testing.TestStream<StreamElement> stream)	Put given TestStream for given AttributeFamilyDescriptor.
static cz.o2.proxima.typesafe.config.Config	replaceStorages(cz.o2.proxima.typesafe.config.Config config)	Replace all storages in all attribute families in given config with test-stream.
static cz.o2.proxima.typesafe.config.Config	replaceStorages(cz.o2.proxima.typesafe.config.Config config, UnaryPredicate<java.lang.String> familyFilter)	Replace all storages in all attribute families in given config with test-stream.
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

Constructor Detail

TestStreamStorage

public TestStreamStorage()

Method Detail

replaceStorages

public static cz.o2.proxima.typesafe.config.Config replaceStorages(cz.o2.proxima.typesafe.config.Config config)

Replace all storages in all attribute families in given config with test-stream.

Parameters:

config - the configuration to replace

Returns:

replaced config

replaceStorages

public static cz.o2.proxima.typesafe.config.Config replaceStorages(cz.o2.proxima.typesafe.config.Config config,
                                                                   UnaryPredicate<java.lang.String> familyFilter)

Replace all storages in all attribute families in given config with test-stream.

Parameters:

config - the configuration to replace

familyFilter - filter for families to replace storage in

Returns:

replaced config

putStream

public static void putStream(Repository repo,
                             AttributeFamilyDescriptor family,
                             org.apache.beam.sdk.testing.TestStream<StreamElement> stream)

Put given TestStream for given AttributeFamilyDescriptor.

Parameters:

repo - repository

family - attribute family descriptor

stream - the stream to use as data source

setup

public void setup(Repository repo)

Description copied from interface: AbstractDataAccessorFactory

Setup the factory for using given Repository.

Specified by:

setup in interface AbstractDataAccessorFactory<BeamDataOperator,DataAccessor>

Parameters:

repo - the repository that will be used with the factory

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<BeamDataOperator,DataAccessor>

Parameters:

uri - the URI to create accessor for

Returns:

acception mark

createAccessor

public DataAccessor createAccessor(BeamDataOperator operator,
                                   AttributeFamilyDescriptor familyDescriptor)

Description copied from interface: AbstractDataAccessorFactory

Create the accessor for give AttributeFamilyDescriptor.

Specified by:

createAccessor in interface AbstractDataAccessorFactory<BeamDataOperator,DataAccessor>

Parameters:

operator - operator to create the accessor for

familyDescriptor - attribute family descriptor

Returns:

AbstractDataAccessor for given operator and family