DObject

abstract def addSink(sink: Sink): T

abstract def compressWith(codec: CompressionCodec, compressionType: CompressionType = CompressionType.BLOCK): T

abstract def join[B](list: DList[B])(implicit arg0: WireFormat[B]): DList[(A, B)]

Create a new distributed list by replicating the value of this distributed object to every element within the provided distributed list

abstract def map[B](f: (A) ⇒ B)(implicit arg0: WireFormat[B]): DObject[B]

Create a new distributed object by apply a function to this distributed object

abstract def toSingleElementDList: DList[A]

abstract def updateSinks(f: (Seq[Sink]) ⇒ Seq[Sink]): T

abstract def zip[B](o: DObject[B])(implicit arg0: WireFormat[B]): DObject[(A, B)]

final def !=(arg0: AnyRef): Boolean

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: AnyRef): Boolean

final def ==(arg0: Any): Boolean

final def asInstanceOf[T0]: T0

def clone(): AnyRef

def compress: T

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def finalize(): Unit

final def getClass(): Class[_]

def hashCode(): Int

final def isInstanceOf[T0]: Boolean

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

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

def toDList[B](implicit ev: <:<[A, Iterable[B]], wfb: WireFormat[B]): DList[B]

def toString(): String

final def wait(): Unit

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

final def wait(arg0: Long): Unit

implicit def wf: WireFormat[A]