org.apache.beam.runners.spark.structuredstreaming.translation.helpers

Class SideInputBroadcast

java.lang.Object

org.apache.beam.runners.spark.structuredstreaming.translation.helpers.SideInputBroadcast

All Implemented Interfaces:

java.io.Serializable

public class SideInputBroadcast
extends java.lang.Object
implements java.io.Serializable

Broadcast helper for side inputs.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SideInputBroadcast()

Method Summary

Modifier and Type	Method and Description
void	add(java.lang.String key, org.apache.spark.broadcast.Broadcast<?> bcast, Coder<?> coder)
org.apache.spark.broadcast.Broadcast<?>	getBroadcastValue(java.lang.String key)
Coder<?>	getCoder(java.lang.String key)

Methods inherited from class java.lang.Object

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

Constructor Detail

SideInputBroadcast

public SideInputBroadcast()

Method Detail

add

public void add(java.lang.String key,
                org.apache.spark.broadcast.Broadcast<?> bcast,
                Coder<?> coder)

getBroadcastValue

public org.apache.spark.broadcast.Broadcast<?> getBroadcastValue(java.lang.String key)

getCoder

public Coder<?> getCoder(java.lang.String key)