Class

com.twitter.scalding.serialization

KryoHadoop

Related Doc: package serialization

Permalink

class KryoHadoop extends KryoInstantiator

Source
KryoHadoop.scala
Linear Supertypes
KryoInstantiator, Serializable, AnyRef, Any
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. KryoHadoop
  2. KryoInstantiator
  3. Serializable
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new KryoHadoop(config: chill.config.Config)

    Permalink

Value Members

  1. final def !=(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any

  2. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any

  3. final def ==(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any

  4. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any

  5. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  6. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef

  7. def equals(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any

  8. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )

  9. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any

  10. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any

  11. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any

  12. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef

  13. def newKryo(): Kryo

    Permalink

    TODO!!! Deal with this issue.

    TODO!!! Deal with this issue. The problem is grouping by Kryo serialized objects silently breaks the results. If Kryo gets in front of TupleSerialization (and possibly Writable, unclear at this time), grouping is broken. There are two issues here: 1) Kryo objects not being compared properly. 2) Kryo being used instead of cascading.

    We must identify each and fix these bugs.

    Definition Classes
    KryoHadoop → KryoInstantiator

  14. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef

  15. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef

  16. def setClassLoader(arg0: ClassLoader): KryoInstantiator

    Permalink
    Definition Classes
    KryoInstantiator

  17. def setInstantiatorStrategy(arg0: InstantiatorStrategy): KryoInstantiator

    Permalink
    Definition Classes
    KryoInstantiator

  18. def setReferences(arg0: Boolean): KryoInstantiator

    Permalink
    Definition Classes
    KryoInstantiator

  19. def setRegistrationRequired(arg0: Boolean): KryoInstantiator

    Permalink
    Definition Classes
    KryoInstantiator

  20. def setThreadContextClassLoader(): KryoInstantiator

    Permalink
    Definition Classes
    KryoInstantiator

  21. final def synchronized[T0](arg0: ⇒ T0): T0

    Permalink
    Definition Classes
    AnyRef

  22. def toString(): String

    Permalink
    Definition Classes
    AnyRef → Any

  23. val useRefs: Boolean

    Permalink

  24. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  25. final def wait(arg0: Long, arg1: Int): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  26. final def wait(arg0: Long): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  27. def withRegistrar(arg0: IKryoRegistrar): KryoInstantiator

    Permalink
    Definition Classes
    KryoInstantiator

Inherited from KryoInstantiator

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped