serialization

Type Members

class ArgsSerializer extends Serializer[Args]
class BinaryDeserializer[T] extends Deserializer[T]
class BinarySerializer[T] extends Serializer[T]
class CascadingBinaryComparator[T] extends Comparator[T] with StreamComparator[InputStream] with cascading.tuple.Hasher[T] with Serializable

This is the type that should be fed to cascading to enable binary comparators
class DateRangeSerializer extends Serializer[DateRange]
class Externalizer[T] extends chill.Externalizer[T]

Annotations
@DefaultSerializer()
class IntFieldSerializer extends Serializer[IntField[_]]
class KryoHadoop extends KryoInstantiator
trait RequiredBinaryComparators extends Job with RequiredBinaryComparatorsConfig

RequiredBinaryComparators provide comparators (or Ordering in Scala) that are capable of comparing keys in their serialized form reducing the amount of time spent in serialization/deserialization.
RequiredBinaryComparators provide comparators (or Ordering in Scala) that are capable of comparing keys in their serialized form reducing the amount of time spent in serialization/deserialization. These comparators are implemented using Scala macros, and currently provide binary comparators for primitives, strings, Options, tuples, collections, case classes and Scrooge objects.
trait RequiredBinaryComparatorsConfig extends Job
trait RequiredBinaryComparatorsExecutionApp extends ExecutionApp

Use this for an ExecutionApp.
class RichDateSerializer extends Serializer[RichDate]

* Below are some serializers for objects in the scalding project.
class StringFieldSerializer extends Serializer[StringField[_]]
class ThrowingSerializer[T] extends Serializer[T]

This is a runtime check for types we should never be serializing
class WrappedSerialization[T] extends org.apache.hadoop.io.serializer.Serialization[T] with Configurable

WrappedSerialization wraps a value in a wrapper class that has an associated Binary that is used to deserialize items wrapped in the wrapper

Value Members

object CascadingBinaryComparator extends Serializable
object Externalizer extends Serializable

We need to control the Kryo created
object RequiredBinaryComparators extends Serializable
object WrappedSerialization

package serialization

Type Members

class ArgsSerializer extends Serializer[Args]

class BinaryDeserializer[T] extends Deserializer[T]

class BinarySerializer[T] extends Serializer[T]

class CascadingBinaryComparator[T] extends Comparator[T] with StreamComparator[InputStream] with cascading.tuple.Hasher[T] with Serializable

class DateRangeSerializer extends Serializer[DateRange]

class Externalizer[T] extends chill.Externalizer[T]

class IntFieldSerializer extends Serializer[IntField[_]]

class KryoHadoop extends KryoInstantiator

trait RequiredBinaryComparators extends Job with RequiredBinaryComparatorsConfig

trait RequiredBinaryComparatorsConfig extends Job

trait RequiredBinaryComparatorsExecutionApp extends ExecutionApp

class RichDateSerializer extends Serializer[RichDate]

class StringFieldSerializer extends Serializer[StringField[_]]

class ThrowingSerializer[T] extends Serializer[T]

class WrappedSerialization[T] extends org.apache.hadoop.io.serializer.Serialization[T] with Configurable

Value Members

object CascadingBinaryComparator extends Serializable

object Externalizer extends Serializable

object RequiredBinaryComparators extends Serializable

object WrappedSerialization

Ungrouped