Package cz.o2.proxima.beam.core

Class BeamProxyTransform

java.lang.Object

cz.o2.proxima.beam.core.BeamProxyTransform

All Implemented Interfaces:

ContextualProxyTransform<BeamDataOperator>, DataOperatorAware, ProxyTransform, java.io.Serializable

public abstract class BeamProxyTransform
extends java.lang.Object
implements ContextualProxyTransform<BeamDataOperator>

Transform applicable on proxied attributes in apply section.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
BeamProxyTransform()

Method Summary

Modifier and Type	Method	Description
abstract org.apache.beam.sdk.values.PCollection<StreamElement>	createBatch(org.apache.beam.sdk.Pipeline pipeline, long startStamp, long endStamp)
abstract org.apache.beam.sdk.values.PCollection<StreamElement>	createStream(java.lang.String name, org.apache.beam.sdk.Pipeline pipeline, Position position, boolean stopAtCurrent, boolean eventTime, long limit)
abstract org.apache.beam.sdk.values.PCollection<StreamElement>	createStreamFromUpdates(org.apache.beam.sdk.Pipeline pipeline, long startStamp, long endStamp, long limit)
boolean	isDelegateOf(DataOperatorFactory operatorFactory)	Verify if this Transformation belongs to given DataOperatorFactory

Methods inherited from class java.lang.Object

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

Methods inherited from interface cz.o2.proxima.core.transform.ContextualProxyTransform

setup

Methods inherited from interface cz.o2.proxima.core.transform.DataOperatorAware

as, isContextual

Methods inherited from interface cz.o2.proxima.core.transform.ProxyTransform

asContextual, asElementWise

Constructor Detail

BeamProxyTransform

public BeamProxyTransform()

Method Detail

createStream

public abstract org.apache.beam.sdk.values.PCollection<StreamElement> createStream(java.lang.String name,
                                                                                   org.apache.beam.sdk.Pipeline pipeline,
                                                                                   Position position,
                                                                                   boolean stopAtCurrent,
                                                                                   boolean eventTime,
                                                                                   long limit)

createStreamFromUpdates

public abstract org.apache.beam.sdk.values.PCollection<StreamElement> createStreamFromUpdates(org.apache.beam.sdk.Pipeline pipeline,
                                                                                              long startStamp,
                                                                                              long endStamp,
                                                                                              long limit)

createBatch

public abstract org.apache.beam.sdk.values.PCollection<StreamElement> createBatch(org.apache.beam.sdk.Pipeline pipeline,
                                                                                  long startStamp,
                                                                                  long endStamp)

isDelegateOf

public final boolean isDelegateOf(DataOperatorFactory operatorFactory)

Description copied from interface: DataOperatorAware

Verify if this Transformation belongs to given DataOperatorFactory

Specified by:

isDelegateOf in interface DataOperatorAware

Parameters:

operatorFactory - the DataOperatorFactory

Returns:

boolean