Package cz.o2.proxima.beam.core.direct.io

Class CommitLogRead

java.lang.Object

org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PBegin,org.apache.beam.sdk.values.PCollection<StreamElement>>

cz.o2.proxima.beam.core.direct.io.CommitLogRead

All Implemented Interfaces:

java.io.Serializable, org.apache.beam.sdk.transforms.display.HasDisplayData

public class CommitLogRead
extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PBegin,org.apache.beam.sdk.values.PCollection<StreamElement>>

A PTransform that reads from a CommitLogReader using splittable DoFn.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.beam.sdk.transforms.PTransform

annotations, displayData, name, resourceHints

Method Summary

Modifier and Type	Method	Description
org.apache.beam.sdk.values.PCollection<StreamElement>	expand(org.apache.beam.sdk.values.PBegin input)
static CommitLogRead	of(java.lang.String observeName, Position position, long limit, RepositoryFactory repositoryFactory, CommitLogReader reader)	Create the CommitLogRead transform.
static CommitLogRead	of(java.lang.String observeName, Position position, long limit, Repository repo, CommitLogReader reader)	Create the CommitLogRead transform.
static CommitLogRead	ofBounded(java.lang.String observeName, long limit, RepositoryFactory repositoryFactory, CommitLogReader reader)	Create the CommitLogRead transform.

Methods inherited from class org.apache.beam.sdk.transforms.PTransform

addAnnotation, compose, compose, getAdditionalInputs, getAnnotations, getDefaultOutputCoder, getDefaultOutputCoder, getDefaultOutputCoder, getKindString, getName, getResourceHints, populateDisplayData, setDisplayData, setResourceHints, toString, validate, validate

Methods inherited from class java.lang.Object

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

Method Detail

of

public static CommitLogRead of(java.lang.String observeName,
                               Position position,
                               long limit,
                               Repository repo,
                               CommitLogReader reader)

Create the CommitLogRead transform.

Parameters:

observeName - name of the observer

position - Position to read from

limit - limit (use Long.MAX_VALUE for unbounded

repo - repository

reader - the reader

Returns:

CommitLogRead transform for the commit log

of

public static CommitLogRead of(java.lang.String observeName,
                               Position position,
                               long limit,
                               RepositoryFactory repositoryFactory,
                               CommitLogReader reader)

Create the CommitLogRead transform.

Parameters:

observeName - name of the observer

position - Position to read from

limit - limit (use Long.MAX_VALUE for unbounded

repositoryFactory - repository factory

reader - the reader

Returns:

CommitLogRead transform for the commit log

ofBounded

public static CommitLogRead ofBounded(java.lang.String observeName,
                                      long limit,
                                      RepositoryFactory repositoryFactory,
                                      CommitLogReader reader)

Create the CommitLogRead transform.

Parameters:

observeName - name of the observer

limit - limit (use Long.MAX_VALUE for unbounded

repositoryFactory - repository factory

reader - the reader

Returns:

CommitLogRead transform for the commit log

expand

public org.apache.beam.sdk.values.PCollection<StreamElement> expand(org.apache.beam.sdk.values.PBegin input)

Specified by:

expand in class org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PBegin,org.apache.beam.sdk.values.PCollection<StreamElement>>