org.apache.beam.runners.spark.structuredstreaming.translation.batch.functions

Class SideInputValues.BaseSideInputValues<BinaryT,ValuesT,T>

java.lang.Object

org.apache.beam.runners.spark.structuredstreaming.translation.batch.functions.SideInputValues.BaseSideInputValues<BinaryT,ValuesT,T>

All Implemented Interfaces:

com.esotericsoftware.kryo.KryoSerializable, java.io.Serializable, SideInputValues<T>

Direct Known Subclasses:

SideInputValues.ByWindow, SideInputValues.Global

Enclosing interface:

SideInputValues<T>

public abstract static class SideInputValues.BaseSideInputValues<BinaryT,ValuesT,T>
extends java.lang.Object
implements SideInputValues<T>

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.beam.runners.spark.structuredstreaming.translation.batch.functions.SideInputValues

SideInputValues.BaseSideInputValues<BinaryT,ValuesT,T>, SideInputValues.ByWindow<T>, SideInputValues.Global<T>, SideInputValues.Loader<T>

Method Summary

Modifier and Type	Method and Description
void	read(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Input input)
void	write(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Output output)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.beam.runners.spark.structuredstreaming.translation.batch.functions.SideInputValues

get, loader

Method Detail

write

public void write(com.esotericsoftware.kryo.Kryo kryo,
                  com.esotericsoftware.kryo.io.Output output)

Specified by:

write in interface com.esotericsoftware.kryo.KryoSerializable

read

public void read(com.esotericsoftware.kryo.Kryo kryo,
                 com.esotericsoftware.kryo.io.Input input)

Specified by:

read in interface com.esotericsoftware.kryo.KryoSerializable