package util
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- util
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Type Members
-
class
GroupConsecutiveIterator[T, R] extends Iterator[(R, Iterator[T])]
Groups consecutive records that share a projection from an iterator to form an iterator of iterators.
Groups consecutive records that share a projection from an iterator to form an iterator of iterators.
You can think of this as Iterator equivalent of.groupBy that only works on consecutive records.
- class KryoClosure1[T1, R] extends KryoWrapper[(T1) ⇒ R] with (T1) ⇒ R
- class KryoClosure2[T1, T2, R] extends KryoWrapper[(T1, T2) ⇒ R] with (T1, T2) ⇒ R
-
class
KryoWrapper[T] extends Serializable
A wrapper around some unserializable objects that make them both Java serializable.
A wrapper around some unserializable objects that make them both Java serializable. Internally, Kryo is used for serialization.
Use KryoWrapper(value) to create a wrapper.
- implicit class TryOption[T] extends AnyRef
- implicit class withLayerIdUtilMethods extends MethodExtensions[LayerId]
Value Members
- object GroupConsecutiveIterator
- object KryoClosure
-
object
KryoSerializer
Java object serialization using Kryo.
Java object serialization using Kryo. This is much more efficient, but Kryo sometimes is buggy to use. We use this mainly to serialize the object inspectors.
- object KryoWrapper extends Serializable
- object SparkUtils