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

Class SideInputValues.BaseSideInputValues<BinaryT,ValuesT extends @NonNull Object,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, Serializable, SideInputValues<T>

Direct Known Subclasses:

SideInputValues.ByWindow, SideInputValues.Global

Enclosing interface:

SideInputValues<T>

public abstract static class SideInputValues.BaseSideInputValues<BinaryT,ValuesT extends @NonNull Object,T>
extends 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 extends @NonNull Object,T>, SideInputValues.ByWindow<T>, SideInputValues.Global<T>, SideInputValues.Loader<T>

Method Summary

Modifier and Type	Method	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

Method Details

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