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

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

Internal utils to translate Beam pipelines to Spark streaming.

Related Packages

Package	Description
org.apache.beam.runners.spark.structuredstreaming.translation	Internal translators for running Beam pipelines on Spark.
org.apache.beam.runners.spark.structuredstreaming.translation.batch	Internal utilities to translate Beam pipelines to Spark batching.
org.apache.beam.runners.spark.structuredstreaming.translation.helpers	Internal helpers to translate Beam pipelines to Spark streaming.

Class	Description
ScalaInterop	Utilities for easier interoperability with the Spark Scala API.
ScalaInterop.Fun1<T,V>
ScalaInterop.Fun2<T1,T2,V>