implicit final class SparkeySCollection extends AnyVal
- Alphabetic
- By Inheritance
- SparkeySCollection
- AnyVal
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new SparkeySCollection(self: SCollection[SparkeyUri])
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- Any
- final def ##: Int
- Definition Classes
- Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- Any
- def asCachedStringSparkeySideInput(cache: Cache[String, String]): SideInput[CachedStringSparkeyReader]
Convert this SCollection to a SideInput of
CachedStringSparkeyReader
, to be used with SCollection.withSideInputs.Convert this SCollection to a SideInput of
CachedStringSparkeyReader
, to be used with SCollection.withSideInputs.- Annotations
- @experimental()
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def asSparkeySideInput: SideInput[SparkeyReader]
Convert this SCollection to a SideInput of
SparkeyReader
, to be used with SCollection.withSideInputs.Convert this SCollection to a SideInput of
SparkeyReader
, to be used with SCollection.withSideInputs.- Annotations
- @experimental()
- def asTypedSparkeySideInput[T](decoder: (Array[Byte]) => T): SideInput[TypedSparkeyReader[T]]
Convert this SCollection to a SideInput of
SparkeyReader
, to be used with SCollection.withSideInputs.Convert this SCollection to a SideInput of
SparkeyReader
, to be used with SCollection.withSideInputs. The provided decoder function will map from the underlying byte array to a JVM type, and the optional Cache object can be used to cache reads in memory after decoding.- Annotations
- @experimental()
- def asTypedSparkeySideInput[T](cache: Cache[String, T])(decoder: (Array[Byte]) => T): SideInput[TypedSparkeyReader[T]]
Convert this SCollection to a SideInput of
SparkeyReader
, to be used with SCollection.withSideInputs.Convert this SCollection to a SideInput of
SparkeyReader
, to be used with SCollection.withSideInputs. The provided decoder function will map from the underlying byte array to a JVM type, and the optional Cache object can be used to cache reads in memory after decoding.- Annotations
- @experimental()
- def getClass(): Class[_ <: AnyVal]
- Definition Classes
- AnyVal → Any
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def toString(): String
- Definition Classes
- Any