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

Class ScalaInterop

java.lang.Object

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

public class ScalaInterop
extends Object

Utilities for easier interoperability with the Spark Scala API.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	ScalaInterop.Fun1<T,V>
static interface	ScalaInterop.Fun2<T1,T2,V>

Method Summary

Modifier and Type	Method	Description
static <T> scala.collection.immutable.List<T>	concat(scala.collection.immutable.List<T> a, scala.collection.immutable.List<T> b)
static <T> scala.collection.immutable.List<T>	emptyList()
static <T, V> ScalaInterop.Fun1<T,V>	fun1(ScalaInterop.Fun1<T,V> fun)
static <T1, T2, V> ScalaInterop.Fun2<T1,T2,V>	fun2(ScalaInterop.Fun2<T1,T2,V> fun)
static <T extends @NonNull Object> Iterator<T>	javaIterator(scala.collection.Iterator<T> it)	Java Iterator of Scala Iterator.
static <T> scala.collection.Seq<T>	listOf(T t)
static <T extends @NonNull Object, V> scala.PartialFunction<T,V>	match(Class<V> clazz)
static <T extends @NonNull Object, V> scala.PartialFunction<T,T>	replace(Class<V> clazz, T replace)
static <T extends @NonNull Object> scala.collection.Iterator<T>	scalaIterator(Iterable<T> iterable)	Scala Iterator of Java Iterable.
static <T extends @NonNull Object> scala.collection.Iterator<T>	scalaIterator(Iterator<T> it)	Scala Iterator of Java Iterator.
static <T> scala.collection.Seq<T>	seqOf(T... t)
static <T1, T2> scala.Tuple2<T1,T2>	tuple(T1 t1, T2 t2)

Methods inherited from class java.lang.Object

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

Method Details

seqOf

public static <T> scala.collection.Seq<T> seqOf(T... t)

concat

public static <T>
scala.collection.immutable.List<T> concat(scala.collection.immutable.List<T> a,
 scala.collection.immutable.List<T> b)

listOf

public static <T> scala.collection.Seq<T> listOf(T t)

emptyList

public static <T>
scala.collection.immutable.List<T> emptyList()

scalaIterator

public static <T extends @NonNull Object>
scala.collection.Iterator<T> scalaIterator(Iterable<T> iterable)

Scala Iterator of Java Iterable.

scalaIterator

public static <T extends @NonNull Object>
scala.collection.Iterator<T> scalaIterator(Iterator<T> it)

Scala Iterator of Java Iterator.

javaIterator

public static <T extends @NonNull Object>
Iterator<T> javaIterator(scala.collection.Iterator<T> it)

Java Iterator of Scala Iterator.

tuple

public static <T1,
T2> scala.Tuple2<T1,T2> tuple(T1 t1,
 T2 t2)

replace

public static <T extends @NonNull Object,
V>
scala.PartialFunction<T,T> replace(Class<V> clazz,
 T replace)

match

public static <T extends @NonNull Object,
V>
scala.PartialFunction<T,V> match(Class<V> clazz)

fun1

public static <T,
V> ScalaInterop.Fun1<T,V> fun1(ScalaInterop.Fun1<T,V> fun)

fun2

public static <T1,
T2,
V>
ScalaInterop.Fun2<T1,T2,V> fun2(ScalaInterop.Fun2<T1,T2,V> fun)