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 java.lang.Object

Utilities for easier interoperability with the Spark Scala API.

Nested Class Summary

Nested Classes

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

Method Summary

Modifier and Type	Method and 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> java.util.Iterator<T>	javaIterator(scala.collection.Iterator<T> it) Java Iterator of Scala Iterator.
static <T> scala.collection.Seq<T>	listOf(T t)
static <T,V> scala.PartialFunction<T,V>	match(java.lang.Class<V> clazz)
static <T,V> scala.PartialFunction<T,T>	replace(java.lang.Class<V> clazz, T replace)
static <T> scala.collection.Iterator<T>	scalaIterator(java.lang.Iterable<T> iterable) Scala Iterator of Java Iterable.
static <T> scala.collection.Iterator<T>	scalaIterator(java.util.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 Detail

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> scala.collection.Iterator<T> scalaIterator(java.lang.Iterable<T> iterable)

Scala Iterator of Java Iterable.

scalaIterator

public static <T> scala.collection.Iterator<T> scalaIterator(java.util.Iterator<T> it)

Scala Iterator of Java Iterator.

javaIterator

public static <T> java.util.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,V> scala.PartialFunction<T,T> replace(java.lang.Class<V> clazz,
                                                       T replace)

match

public static <T,V> scala.PartialFunction<T,V> match(java.lang.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)