Package org.apache.beam.runners.spark.structuredstreaming.translation.utils

Internal utils to translate Beam pipelines to Spark streaming.

See: Description

Interface Summary

Interface	Description
ScalaInterop.Fun1<T,V>
ScalaInterop.Fun2<T1,T2,V>

Class Summary

Class	Description
CachedSideInputReader	SideInputReader that caches materialized views.
ScalaInterop	Utilities for easier interoperability with the Spark Scala API.

Package org.apache.beam.runners.spark.structuredstreaming.translation.utils Description

Internal utils to translate Beam pipelines to Spark streaming.