Package org.apache.beam.runners.spark.translation.streaming

Class CreateStreamingSparkView.Factory<ElemT,ViewT>

java.lang.Object

org.apache.beam.runners.spark.translation.streaming.CreateStreamingSparkView.Factory<ElemT,ViewT>

All Implemented Interfaces:

org.apache.beam.sdk.runners.PTransformOverrideFactory<PCollection<ElemT>,PCollection<ElemT>,PTransform<PCollection<ElemT>,PCollection<ElemT>>>

Enclosing class:

CreateStreamingSparkView<ElemT,ViewT>

public static class CreateStreamingSparkView.Factory<ElemT,ViewT>
extends Object
implements org.apache.beam.sdk.runners.PTransformOverrideFactory<PCollection<ElemT>,PCollection<ElemT>,PTransform<PCollection<ElemT>,PCollection<ElemT>>>

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.beam.sdk.runners.PTransformOverrideFactory

org.apache.beam.sdk.runners.PTransformOverrideFactory.PTransformReplacement<InputT extends PInput,OutputT extends POutput>, org.apache.beam.sdk.runners.PTransformOverrideFactory.ReplacementOutput

Field Summary

Fields

Modifier and Type	Field	Description
static final CreateStreamingSparkView.Factory	INSTANCE

Method Summary

Modifier and Type	Method	Description
org.apache.beam.sdk.runners.PTransformOverrideFactory.PTransformReplacement<PCollection<ElemT>,PCollection<ElemT>>	getReplacementTransform(org.apache.beam.sdk.runners.AppliedPTransform<PCollection<ElemT>,PCollection<ElemT>,PTransform<PCollection<ElemT>,PCollection<ElemT>>> transform)
Map<PCollection<?>,org.apache.beam.sdk.runners.PTransformOverrideFactory.ReplacementOutput>	mapOutputs(Map<TupleTag<?>,PCollection<?>> outputs, PCollection<ElemT> newOutput)

Methods inherited from class java.lang.Object

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

Field Details

INSTANCE

public static final CreateStreamingSparkView.Factory INSTANCE

Method Details

getReplacementTransform

public org.apache.beam.sdk.runners.PTransformOverrideFactory.PTransformReplacement<PCollection<ElemT>,PCollection<ElemT>> getReplacementTransform(org.apache.beam.sdk.runners.AppliedPTransform<PCollection<ElemT>,PCollection<ElemT>,PTransform<PCollection<ElemT>,PCollection<ElemT>>> transform)

Specified by:

getReplacementTransform in interface org.apache.beam.sdk.runners.PTransformOverrideFactory<PCollection<ElemT>,PCollection<ElemT>,PTransform<PCollection<ElemT>,PCollection<ElemT>>>

mapOutputs

public Map<PCollection<?>,org.apache.beam.sdk.runners.PTransformOverrideFactory.ReplacementOutput> mapOutputs(Map<TupleTag<?>,PCollection<?>> outputs,
 PCollection<ElemT> newOutput)

Specified by:

mapOutputs in interface org.apache.beam.sdk.runners.PTransformOverrideFactory<PCollection<ElemT>,PCollection<ElemT>,PTransform<PCollection<ElemT>,PCollection<ElemT>>>