Type Members
-
class
Abstract10WireFormat[TT, A <: TT, B <: TT, C <: TT, D <: TT, E <: TT, F <: TT, G <: TT, H <: TT, I <: TT, J <: TT] extends WireFormat[TT]
-
class
Abstract11WireFormat[TT, A <: TT, B <: TT, C <: TT, D <: TT, E <: TT, F <: TT, G <: TT, H <: TT, I <: TT, J <: TT, K <: TT] extends WireFormat[TT]
-
class
Abstract12WireFormat[TT, A <: TT, B <: TT, C <: TT, D <: TT, E <: TT, F <: TT, G <: TT, H <: TT, I <: TT, J <: TT, K <: TT, L <: TT] extends WireFormat[TT]
-
class
Abstract13WireFormat[TT, A <: TT, B <: TT, C <: TT, D <: TT, E <: TT, F <: TT, G <: TT, H <: TT, I <: TT, J <: TT, K <: TT, L <: TT, M <: TT] extends WireFormat[TT]
-
class
Abstract14WireFormat[TT, A <: TT, B <: TT, C <: TT, D <: TT, E <: TT, F <: TT, G <: TT, H <: TT, I <: TT, J <: TT, K <: TT, L <: TT, M <: TT, N <: TT] extends WireFormat[TT]
-
class
Abstract15WireFormat[TT, A <: TT, B <: TT, C <: TT, D <: TT, E <: TT, F <: TT, G <: TT, H <: TT, I <: TT, J <: TT, K <: TT, L <: TT, M <: TT, N <: TT, O <: TT] extends WireFormat[TT]
-
class
Abstract16WireFormat[TT, A <: TT, B <: TT, C <: TT, D <: TT, E <: TT, F <: TT, G <: TT, H <: TT, I <: TT, J <: TT, K <: TT, L <: TT, M <: TT, N <: TT, O <: TT, P <: TT] extends WireFormat[TT]
-
class
Abstract17WireFormat[TT, A <: TT, B <: TT, C <: TT, D <: TT, E <: TT, F <: TT, G <: TT, H <: TT, I <: TT, J <: TT, K <: TT, L <: TT, M <: TT, N <: TT, O <: TT, P <: TT, Q <: TT] extends WireFormat[TT]
-
class
Abstract18WireFormat[TT, A <: TT, B <: TT, C <: TT, D <: TT, E <: TT, F <: TT, G <: TT, H <: TT, I <: TT, J <: TT, K <: TT, L <: TT, M <: TT, N <: TT, O <: TT, P <: TT, Q <: TT, R <: TT] extends WireFormat[TT]
-
class
Abstract19WireFormat[TT, A <: TT, B <: TT, C <: TT, D <: TT, E <: TT, F <: TT, G <: TT, H <: TT, I <: TT, J <: TT, K <: TT, L <: TT, M <: TT, N <: TT, O <: TT, P <: TT, Q <: TT, R <: TT, S <: TT] extends WireFormat[TT]
-
class
Abstract20WireFormat[TT, A <: TT, B <: TT, C <: TT, D <: TT, E <: TT, F <: TT, G <: TT, H <: TT, I <: TT, J <: TT, K <: TT, L <: TT, M <: TT, N <: TT, O <: TT, P <: TT, Q <: TT, R <: TT, S <: TT, T <: TT] extends WireFormat[TT]
-
class
Abstract21WireFormat[TT, A <: TT, B <: TT, C <: TT, D <: TT, E <: TT, F <: TT, G <: TT, H <: TT, I <: TT, J <: TT, K <: TT, L <: TT, M <: TT, N <: TT, O <: TT, P <: TT, Q <: TT, R <: TT, S <: TT, T <: TT, U <: TT] extends WireFormat[TT]
-
class
Abstract22WireFormat[TT, A <: TT, B <: TT, C <: TT, D <: TT, E <: TT, F <: TT, G <: TT, H <: TT, I <: TT, J <: TT, K <: TT, L <: TT, M <: TT, N <: TT, O <: TT, P <: TT, Q <: TT, R <: TT, S <: TT, T <: TT, U <: TT, V <: TT] extends WireFormat[TT]
-
-
-
class
Abstract4WireFormat[TT, A <: TT, B <: TT, C <: TT, D <: TT] extends WireFormat[TT]
-
class
Abstract5WireFormat[TT, A <: TT, B <: TT, C <: TT, D <: TT, E <: TT] extends WireFormat[TT]
-
class
Abstract6WireFormat[TT, A <: TT, B <: TT, C <: TT, D <: TT, E <: TT, F <: TT] extends WireFormat[TT]
-
class
Abstract7WireFormat[TT, A <: TT, B <: TT, C <: TT, D <: TT, E <: TT, F <: TT, G <: TT] extends WireFormat[TT]
-
class
Abstract8WireFormat[TT, A <: TT, B <: TT, C <: TT, D <: TT, E <: TT, F <: TT, G <: TT, H <: TT] extends WireFormat[TT]
-
class
Abstract9WireFormat[TT, A <: TT, B <: TT, C <: TT, D <: TT, E <: TT, F <: TT, G <: TT, H <: TT, I <: TT] extends WireFormat[TT]
-
-
-
-
-
-
-
-
class
Case10WireFormat[T, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10] extends WireFormat[T]
-
class
Case11WireFormat[T, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11] extends WireFormat[T]
-
class
Case12WireFormat[T, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12] extends WireFormat[T]
-
class
Case13WireFormat[T, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13] extends WireFormat[T]
-
class
Case14WireFormat[T, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14] extends WireFormat[T]
-
class
Case15WireFormat[T, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15] extends WireFormat[T]
-
class
Case16WireFormat[T, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16] extends WireFormat[T]
-
class
Case17WireFormat[T, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17] extends WireFormat[T]
-
class
Case18WireFormat[T, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18] extends WireFormat[T]
-
class
Case19WireFormat[T, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19] extends WireFormat[T]
-
-
class
Case20WireFormat[T, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20] extends WireFormat[T]
-
class
Case21WireFormat[T, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20, A21] extends WireFormat[T]
-
class
Case22WireFormat[T, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20, A21, A22] extends WireFormat[T]
-
-
-
-
-
-
-
class
Case8WireFormat[T, A1, A2, A3, A4, A5, A6, A7, A8] extends WireFormat[T]
-
class
Case9WireFormat[T, A1, A2, A3, A4, A5, A6, A7, A8, A9] extends WireFormat[T]
-
-
-
-
-
-
-
-
-
-
-
-
-
-
type
DoFn[A, B] = core.DoFn[A, B]
-
-
-
-
type
EnvDoFn[A, B, E] = core.EnvDoFn[A, B, E]
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
case class
RunnableDList[T](list: DList[T]) extends Product with Serializable
-
case class
RunnableDObject[T](o: DObject[T]) extends Product with Serializable
-
-
-
-
-
-
-
class
Tuple10WireFormat[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10] extends WireFormat[(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10)]
-
class
Tuple11WireFormat[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11] extends WireFormat[(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11)]
-
class
Tuple12WireFormat[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12] extends WireFormat[(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12)]
-
class
Tuple13WireFormat[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13] extends WireFormat[(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13)]
-
class
Tuple14WireFormat[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14] extends WireFormat[(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14)]
-
class
Tuple15WireFormat[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15] extends WireFormat[(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15)]
-
class
Tuple16WireFormat[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16] extends WireFormat[(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16)]
-
class
Tuple17WireFormat[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17] extends WireFormat[(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17)]
-
class
Tuple18WireFormat[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18] extends WireFormat[(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18)]
-
class
Tuple19WireFormat[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19] extends WireFormat[(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19)]
-
class
Tuple20WireFormat[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20] extends WireFormat[(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20)]
-
class
Tuple21WireFormat[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21] extends WireFormat[(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21)]
-
class
Tuple22WireFormat[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21, T22] extends WireFormat[(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21, T22)]
-
-
-
-
class
Tuple5WireFormat[T1, T2, T3, T4, T5] extends WireFormat[(T1, T2, T3, T4, T5)]
-
class
Tuple6WireFormat[T1, T2, T3, T4, T5, T6] extends WireFormat[(T1, T2, T3, T4, T5, T6)]
-
class
Tuple7WireFormat[T1, T2, T3, T4, T5, T6, T7] extends WireFormat[(T1, T2, T3, T4, T5, T6, T7)]
-
class
Tuple8WireFormat[T1, T2, T3, T4, T5, T6, T7, T8] extends WireFormat[(T1, T2, T3, T4, T5, T6, T7, T8)]
-
class
Tuple9WireFormat[T1, T2, T3, T4, T5, T6, T7, T8, T9] extends WireFormat[(T1, T2, T3, T4, T5, T6, T7, T8, T9)]
-
-
Value Members
-
final
def
!=(arg0: Any): Boolean
-
final
def
##(): Int
-
final
def
==(arg0: Any): Boolean
-
-
-
-
-
def
AnythingFmt[T <: Serializable]: core.WireFormat[T]
-
implicit
def
ArrayFmt[T](implicit m: Manifest[T], wt: core.WireFormat[T]): core.WireFormat[Array[T]]
-
implicit
def
AvroFmt[T <: SpecificRecordBase](implicit arg0: Manifest[T], arg1: io.avro.AvroSchema[T]): AvroWireFormat[T]
-
-
-
-
-
implicit
def
ComparableGrouping[T <: Comparable[T]]: core.Grouping[T]
-
val
DList: DLists.type
-
val
DObject: DObjects.type
-
-
-
-
-
-
implicit
def
GenericAvroFmt[T <: GenericRecord]: GenericAvroWireFormat[T]
-
-
-
-
implicit
def
IntegerFmt: core.WireFormat[Integer]
-
-
implicit
def
MapFmt[CC[X, Y] <: Map[X, Y], K, V](implicit wtK: core.WireFormat[K], wtV: core.WireFormat[V], bf: CanBuildFrom[_, (K, V), CC[K, V]]): core.WireFormat[CC[K, V]]
-
-
implicit
def
OrderGrouping2[T](implicit arg0: Order[T]): core.Grouping[T]
-
implicit
def
OrderingGrouping[T](implicit arg0: Ordering[T]): core.Grouping[T]
-
-
-
-
-
-
implicit
def
SpecificFixedAvroFmt[T <: SpecificFixed](implicit arg0: Manifest[T], arg1: io.avro.AvroSchema[T]): SpecificFixedAvroWireFormat[T]
-
implicit
def
StringFmt: core.WireFormat[String]
-
implicit
def
TraversableFmt[CC[X] <: Traversable[X], T](implicit wt: core.WireFormat[T], bf: CanBuildFrom[_, T, CC[T]]): core.WireFormat[CC[T]]
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
implicit
def
WritableFmt[T <: Writable](implicit arg0: Manifest[T]): core.WireFormat[T]
-
def
anyToString(any: Any, sep: String): String
-
-
-
-
final
def
asInstanceOf[T0]: T0
-
implicit
def
asRunnableDList[T](list: core.DList[T]): RunnableDList[T]
-
-
-
def
checkedSource[K, V](paths: Seq[String], checkKeyValueTypes: Boolean = true)(implicit arg0: Manifest[K], arg1: Manifest[V]): CheckedSeqSource[K, V, (K, V)]
-
def
clone(): AnyRef
-
-
def
defaultSequenceInputFormat[K, V]: Class[SequenceFileInputFormat[K, V]]
-
def
defaultTextConverter: InputConverter[LongWritable, Text, String]
-
def
defaultTextConverterToString: InputConverter[Text, Text, (String, String)]
-
def
defaultTextConverterWithPath: InputConverter[LongWritable, Text, (String, String)]
-
-
implicit
def
dlistToColWiseWithMapReduceJob[Elem, T](m: DMatrix[Elem, T])(implicit arg0: core.WireFormat[Elem], arg1: Ordering[Elem], arg2: core.WireFormat[T]): DColWiseMatrix[Elem, T]
-
implicit
def
dlistToDMatrix[Elem, Value](v: core.DList[((Elem, Elem), Value)])(implicit arg0: core.WireFormat[Elem], arg1: Ordering[Elem], arg2: core.WireFormat[Value]): DMatrix[Elem, Value]
-
-
-
-
-
implicit
def
dmatrixToDlist[Elem, Value](v: DMatrix[Elem, Value])(implicit arg0: core.WireFormat[Elem], arg1: Ordering[Elem], arg2: core.WireFormat[Value]): core.DList[((Elem, Elem), Value)]
-
implicit
def
dvectorToDList[Elem, V](v: DVector[Elem, V]): DList[(Elem, V)]
-
final
def
eq(arg0: AnyRef): Boolean
-
def
equals(arg0: Any): Boolean
-
def
finalize(): Unit
-
-
-
implicit
def
fromConfiguration(c: Configuration): core.ScoobiConfiguration
-
def
fromDelimitedTextFile[A](path: String, sep: String = "\t", check: InputCheck = Source.defaultInputCheck)(extractFn: PartialFunction[Seq[String], A])(implicit arg0: core.WireFormat[A]): core.DList[A]
-
def
fromDelimitedTextFiles[A](paths: Seq[String], sep: String = "\t", check: InputCheck = Source.defaultInputCheck)(extractFn: PartialFunction[Seq[String], A])(implicit arg0: core.WireFormat[A]): core.DList[A]
-
def
fromLazySeq[A](seq: ⇒ Seq[A], seqSize: Int = 1000)(implicit arg0: core.WireFormat[A]): core.DList[A]
-
-
-
-
-
def
fromSequenceSource[K, V, A](source: SeqSource[K, V, A])(implicit arg0: core.WireFormat[A]): DListImpl[A]
-
def
fromSource[A](source: DataSource[_, _, A])(implicit arg0: core.WireFormat[A]): DListImpl[A]
-
def
fromTextFile(paths: String*): core.DList[String]
-
-
-
-
def
fromTextSource[A](source: DataSource[_, _, A])(implicit arg0: core.WireFormat[A]): DListImpl[A]
-
final
def
getClass(): Class[_]
-
def
hashCode(): Int
-
-
implicit
def
hnilHasWireFormat: core.WireFormat[HNil]
-
implicit
lazy val
implicitParameter: ImplicitParameter
-
implicit
lazy val
implicitParameter1: ImplicitParameter1
-
implicit
lazy val
implicitParameter10: ImplicitParameter10
-
implicit
lazy val
implicitParameter2: ImplicitParameter2
-
implicit
lazy val
implicitParameter3: ImplicitParameter3
-
implicit
lazy val
implicitParameter4: ImplicitParameter4
-
implicit
lazy val
implicitParameter5: ImplicitParameter5
-
implicit
lazy val
implicitParameter6: ImplicitParameter6
-
implicit
lazy val
implicitParameter7: ImplicitParameter7
-
implicit
lazy val
implicitParameter8: ImplicitParameter8
-
implicit
lazy val
implicitParameter9: ImplicitParameter9
-
-
implicit
def
inMemVectorToDObject[Elem, T](in: InMemVector[Elem, T]): DObject[Map[Elem, T]]
-
final
def
isInstanceOf[T0]: Boolean
-
-
-
-
-
-
-
-
def
listToDelimitedTextFile[A <: Product](dl: core.DList[A], path: String, sep: String = "\t", overwrite: Boolean = false, check: OutputCheck = Sink.defaultOutputCheck)(implicit arg0: Manifest[A]): core.DList[String]
-
def
mkAbstractWireFormat[TT, A <: TT, B <: TT, C <: TT, D <: TT, E <: TT, F <: TT, G <: TT, H <: TT, I <: TT, J <: TT, K <: TT, L <: TT, M <: TT, N <: TT, O <: TT, P <: TT, Q <: TT, R <: TT, S <: TT, T <: TT, U <: TT, V <: TT]()(implicit arg0: Manifest[A], arg1: core.WireFormat[A], arg2: Manifest[B], arg3: core.WireFormat[B], arg4: Manifest[C], arg5: core.WireFormat[C], arg6: Manifest[D], arg7: core.WireFormat[D], arg8: Manifest[E], arg9: core.WireFormat[E], arg10: Manifest[F], arg11: core.WireFormat[F], arg12: Manifest[G], arg13: core.WireFormat[G], arg14: Manifest[H], arg15: core.WireFormat[H], arg16: Manifest[I], arg17: core.WireFormat[I], arg18: Manifest[J], arg19: core.WireFormat[J], arg20: Manifest[K], arg21: core.WireFormat[K], arg22: Manifest[L], arg23: core.WireFormat[L], arg24: Manifest[M], arg25: core.WireFormat[M], arg26: Manifest[N], arg27: core.WireFormat[N], arg28: Manifest[O], arg29: core.WireFormat[O], arg30: Manifest[P], arg31: core.WireFormat[P], arg32: Manifest[Q], arg33: core.WireFormat[Q], arg34: Manifest[R], arg35: core.WireFormat[R], arg36: Manifest[S], arg37: core.WireFormat[S], arg38: Manifest[T], arg39: core.WireFormat[T], arg40: Manifest[U], arg41: core.WireFormat[U], arg42: Manifest[V], arg43: core.WireFormat[V]): Abstract22WireFormat[TT, A, B, C, D, E, F, G, H, I, J, K, L, M, N, O, P, Q, R, S, T, U, V]
-
def
mkAbstractWireFormat[TT, A <: TT, B <: TT, C <: TT, D <: TT, E <: TT, F <: TT, G <: TT, H <: TT, I <: TT, J <: TT, K <: TT, L <: TT, M <: TT, N <: TT, O <: TT, P <: TT, Q <: TT, R <: TT, S <: TT, T <: TT, U <: TT]()(implicit arg0: Manifest[A], arg1: core.WireFormat[A], arg2: Manifest[B], arg3: core.WireFormat[B], arg4: Manifest[C], arg5: core.WireFormat[C], arg6: Manifest[D], arg7: core.WireFormat[D], arg8: Manifest[E], arg9: core.WireFormat[E], arg10: Manifest[F], arg11: core.WireFormat[F], arg12: Manifest[G], arg13: core.WireFormat[G], arg14: Manifest[H], arg15: core.WireFormat[H], arg16: Manifest[I], arg17: core.WireFormat[I], arg18: Manifest[J], arg19: core.WireFormat[J], arg20: Manifest[K], arg21: core.WireFormat[K], arg22: Manifest[L], arg23: core.WireFormat[L], arg24: Manifest[M], arg25: core.WireFormat[M], arg26: Manifest[N], arg27: core.WireFormat[N], arg28: Manifest[O], arg29: core.WireFormat[O], arg30: Manifest[P], arg31: core.WireFormat[P], arg32: Manifest[Q], arg33: core.WireFormat[Q], arg34: Manifest[R], arg35: core.WireFormat[R], arg36: Manifest[S], arg37: core.WireFormat[S], arg38: Manifest[T], arg39: core.WireFormat[T], arg40: Manifest[U], arg41: core.WireFormat[U]): Abstract21WireFormat[TT, A, B, C, D, E, F, G, H, I, J, K, L, M, N, O, P, Q, R, S, T, U]
-
def
mkAbstractWireFormat[TT, A <: TT, B <: TT, C <: TT, D <: TT, E <: TT, F <: TT, G <: TT, H <: TT, I <: TT, J <: TT, K <: TT, L <: TT, M <: TT, N <: TT, O <: TT, P <: TT, Q <: TT, R <: TT, S <: TT, T <: TT]()(implicit arg0: Manifest[A], arg1: core.WireFormat[A], arg2: Manifest[B], arg3: core.WireFormat[B], arg4: Manifest[C], arg5: core.WireFormat[C], arg6: Manifest[D], arg7: core.WireFormat[D], arg8: Manifest[E], arg9: core.WireFormat[E], arg10: Manifest[F], arg11: core.WireFormat[F], arg12: Manifest[G], arg13: core.WireFormat[G], arg14: Manifest[H], arg15: core.WireFormat[H], arg16: Manifest[I], arg17: core.WireFormat[I], arg18: Manifest[J], arg19: core.WireFormat[J], arg20: Manifest[K], arg21: core.WireFormat[K], arg22: Manifest[L], arg23: core.WireFormat[L], arg24: Manifest[M], arg25: core.WireFormat[M], arg26: Manifest[N], arg27: core.WireFormat[N], arg28: Manifest[O], arg29: core.WireFormat[O], arg30: Manifest[P], arg31: core.WireFormat[P], arg32: Manifest[Q], arg33: core.WireFormat[Q], arg34: Manifest[R], arg35: core.WireFormat[R], arg36: Manifest[S], arg37: core.WireFormat[S], arg38: Manifest[T], arg39: core.WireFormat[T]): Abstract20WireFormat[TT, A, B, C, D, E, F, G, H, I, J, K, L, M, N, O, P, Q, R, S, T]
-
def
mkAbstractWireFormat[TT, A <: TT, B <: TT, C <: TT, D <: TT, E <: TT, F <: TT, G <: TT, H <: TT, I <: TT, J <: TT, K <: TT, L <: TT, M <: TT, N <: TT, O <: TT, P <: TT, Q <: TT, R <: TT, S <: TT]()(implicit arg0: Manifest[A], arg1: core.WireFormat[A], arg2: Manifest[B], arg3: core.WireFormat[B], arg4: Manifest[C], arg5: core.WireFormat[C], arg6: Manifest[D], arg7: core.WireFormat[D], arg8: Manifest[E], arg9: core.WireFormat[E], arg10: Manifest[F], arg11: core.WireFormat[F], arg12: Manifest[G], arg13: core.WireFormat[G], arg14: Manifest[H], arg15: core.WireFormat[H], arg16: Manifest[I], arg17: core.WireFormat[I], arg18: Manifest[J], arg19: core.WireFormat[J], arg20: Manifest[K], arg21: core.WireFormat[K], arg22: Manifest[L], arg23: core.WireFormat[L], arg24: Manifest[M], arg25: core.WireFormat[M], arg26: Manifest[N], arg27: core.WireFormat[N], arg28: Manifest[O], arg29: core.WireFormat[O], arg30: Manifest[P], arg31: core.WireFormat[P], arg32: Manifest[Q], arg33: core.WireFormat[Q], arg34: Manifest[R], arg35: core.WireFormat[R], arg36: Manifest[S], arg37: core.WireFormat[S]): Abstract19WireFormat[TT, A, B, C, D, E, F, G, H, I, J, K, L, M, N, O, P, Q, R, S]
-
def
mkAbstractWireFormat[TT, A <: TT, B <: TT, C <: TT, D <: TT, E <: TT, F <: TT, G <: TT, H <: TT, I <: TT, J <: TT, K <: TT, L <: TT, M <: TT, N <: TT, O <: TT, P <: TT, Q <: TT, R <: TT]()(implicit arg0: Manifest[A], arg1: core.WireFormat[A], arg2: Manifest[B], arg3: core.WireFormat[B], arg4: Manifest[C], arg5: core.WireFormat[C], arg6: Manifest[D], arg7: core.WireFormat[D], arg8: Manifest[E], arg9: core.WireFormat[E], arg10: Manifest[F], arg11: core.WireFormat[F], arg12: Manifest[G], arg13: core.WireFormat[G], arg14: Manifest[H], arg15: core.WireFormat[H], arg16: Manifest[I], arg17: core.WireFormat[I], arg18: Manifest[J], arg19: core.WireFormat[J], arg20: Manifest[K], arg21: core.WireFormat[K], arg22: Manifest[L], arg23: core.WireFormat[L], arg24: Manifest[M], arg25: core.WireFormat[M], arg26: Manifest[N], arg27: core.WireFormat[N], arg28: Manifest[O], arg29: core.WireFormat[O], arg30: Manifest[P], arg31: core.WireFormat[P], arg32: Manifest[Q], arg33: core.WireFormat[Q], arg34: Manifest[R], arg35: core.WireFormat[R]): Abstract18WireFormat[TT, A, B, C, D, E, F, G, H, I, J, K, L, M, N, O, P, Q, R]
-
def
mkAbstractWireFormat[TT, A <: TT, B <: TT, C <: TT, D <: TT, E <: TT, F <: TT, G <: TT, H <: TT, I <: TT, J <: TT, K <: TT, L <: TT, M <: TT, N <: TT, O <: TT, P <: TT, Q <: TT]()(implicit arg0: Manifest[A], arg1: core.WireFormat[A], arg2: Manifest[B], arg3: core.WireFormat[B], arg4: Manifest[C], arg5: core.WireFormat[C], arg6: Manifest[D], arg7: core.WireFormat[D], arg8: Manifest[E], arg9: core.WireFormat[E], arg10: Manifest[F], arg11: core.WireFormat[F], arg12: Manifest[G], arg13: core.WireFormat[G], arg14: Manifest[H], arg15: core.WireFormat[H], arg16: Manifest[I], arg17: core.WireFormat[I], arg18: Manifest[J], arg19: core.WireFormat[J], arg20: Manifest[K], arg21: core.WireFormat[K], arg22: Manifest[L], arg23: core.WireFormat[L], arg24: Manifest[M], arg25: core.WireFormat[M], arg26: Manifest[N], arg27: core.WireFormat[N], arg28: Manifest[O], arg29: core.WireFormat[O], arg30: Manifest[P], arg31: core.WireFormat[P], arg32: Manifest[Q], arg33: core.WireFormat[Q]): Abstract17WireFormat[TT, A, B, C, D, E, F, G, H, I, J, K, L, M, N, O, P, Q]
-
def
mkAbstractWireFormat[TT, A <: TT, B <: TT, C <: TT, D <: TT, E <: TT, F <: TT, G <: TT, H <: TT, I <: TT, J <: TT, K <: TT, L <: TT, M <: TT, N <: TT, O <: TT, P <: TT]()(implicit arg0: Manifest[A], arg1: core.WireFormat[A], arg2: Manifest[B], arg3: core.WireFormat[B], arg4: Manifest[C], arg5: core.WireFormat[C], arg6: Manifest[D], arg7: core.WireFormat[D], arg8: Manifest[E], arg9: core.WireFormat[E], arg10: Manifest[F], arg11: core.WireFormat[F], arg12: Manifest[G], arg13: core.WireFormat[G], arg14: Manifest[H], arg15: core.WireFormat[H], arg16: Manifest[I], arg17: core.WireFormat[I], arg18: Manifest[J], arg19: core.WireFormat[J], arg20: Manifest[K], arg21: core.WireFormat[K], arg22: Manifest[L], arg23: core.WireFormat[L], arg24: Manifest[M], arg25: core.WireFormat[M], arg26: Manifest[N], arg27: core.WireFormat[N], arg28: Manifest[O], arg29: core.WireFormat[O], arg30: Manifest[P], arg31: core.WireFormat[P]): Abstract16WireFormat[TT, A, B, C, D, E, F, G, H, I, J, K, L, M, N, O, P]
-
def
mkAbstractWireFormat[TT, A <: TT, B <: TT, C <: TT, D <: TT, E <: TT, F <: TT, G <: TT, H <: TT, I <: TT, J <: TT, K <: TT, L <: TT, M <: TT, N <: TT, O <: TT]()(implicit arg0: Manifest[A], arg1: core.WireFormat[A], arg2: Manifest[B], arg3: core.WireFormat[B], arg4: Manifest[C], arg5: core.WireFormat[C], arg6: Manifest[D], arg7: core.WireFormat[D], arg8: Manifest[E], arg9: core.WireFormat[E], arg10: Manifest[F], arg11: core.WireFormat[F], arg12: Manifest[G], arg13: core.WireFormat[G], arg14: Manifest[H], arg15: core.WireFormat[H], arg16: Manifest[I], arg17: core.WireFormat[I], arg18: Manifest[J], arg19: core.WireFormat[J], arg20: Manifest[K], arg21: core.WireFormat[K], arg22: Manifest[L], arg23: core.WireFormat[L], arg24: Manifest[M], arg25: core.WireFormat[M], arg26: Manifest[N], arg27: core.WireFormat[N], arg28: Manifest[O], arg29: core.WireFormat[O]): Abstract15WireFormat[TT, A, B, C, D, E, F, G, H, I, J, K, L, M, N, O]
-
def
mkAbstractWireFormat[TT, A <: TT, B <: TT, C <: TT, D <: TT, E <: TT, F <: TT, G <: TT, H <: TT, I <: TT, J <: TT, K <: TT, L <: TT, M <: TT, N <: TT]()(implicit arg0: Manifest[A], arg1: core.WireFormat[A], arg2: Manifest[B], arg3: core.WireFormat[B], arg4: Manifest[C], arg5: core.WireFormat[C], arg6: Manifest[D], arg7: core.WireFormat[D], arg8: Manifest[E], arg9: core.WireFormat[E], arg10: Manifest[F], arg11: core.WireFormat[F], arg12: Manifest[G], arg13: core.WireFormat[G], arg14: Manifest[H], arg15: core.WireFormat[H], arg16: Manifest[I], arg17: core.WireFormat[I], arg18: Manifest[J], arg19: core.WireFormat[J], arg20: Manifest[K], arg21: core.WireFormat[K], arg22: Manifest[L], arg23: core.WireFormat[L], arg24: Manifest[M], arg25: core.WireFormat[M], arg26: Manifest[N], arg27: core.WireFormat[N]): Abstract14WireFormat[TT, A, B, C, D, E, F, G, H, I, J, K, L, M, N]
-
def
mkAbstractWireFormat[TT, A <: TT, B <: TT, C <: TT, D <: TT, E <: TT, F <: TT, G <: TT, H <: TT, I <: TT, J <: TT, K <: TT, L <: TT, M <: TT]()(implicit arg0: Manifest[A], arg1: core.WireFormat[A], arg2: Manifest[B], arg3: core.WireFormat[B], arg4: Manifest[C], arg5: core.WireFormat[C], arg6: Manifest[D], arg7: core.WireFormat[D], arg8: Manifest[E], arg9: core.WireFormat[E], arg10: Manifest[F], arg11: core.WireFormat[F], arg12: Manifest[G], arg13: core.WireFormat[G], arg14: Manifest[H], arg15: core.WireFormat[H], arg16: Manifest[I], arg17: core.WireFormat[I], arg18: Manifest[J], arg19: core.WireFormat[J], arg20: Manifest[K], arg21: core.WireFormat[K], arg22: Manifest[L], arg23: core.WireFormat[L], arg24: Manifest[M], arg25: core.WireFormat[M]): Abstract13WireFormat[TT, A, B, C, D, E, F, G, H, I, J, K, L, M]
-
def
mkAbstractWireFormat[TT, A <: TT, B <: TT, C <: TT, D <: TT, E <: TT, F <: TT, G <: TT, H <: TT, I <: TT, J <: TT, K <: TT, L <: TT]()(implicit arg0: Manifest[A], arg1: core.WireFormat[A], arg2: Manifest[B], arg3: core.WireFormat[B], arg4: Manifest[C], arg5: core.WireFormat[C], arg6: Manifest[D], arg7: core.WireFormat[D], arg8: Manifest[E], arg9: core.WireFormat[E], arg10: Manifest[F], arg11: core.WireFormat[F], arg12: Manifest[G], arg13: core.WireFormat[G], arg14: Manifest[H], arg15: core.WireFormat[H], arg16: Manifest[I], arg17: core.WireFormat[I], arg18: Manifest[J], arg19: core.WireFormat[J], arg20: Manifest[K], arg21: core.WireFormat[K], arg22: Manifest[L], arg23: core.WireFormat[L]): Abstract12WireFormat[TT, A, B, C, D, E, F, G, H, I, J, K, L]
-
def
mkAbstractWireFormat[TT, A <: TT, B <: TT, C <: TT, D <: TT, E <: TT, F <: TT, G <: TT, H <: TT, I <: TT, J <: TT, K <: TT]()(implicit arg0: Manifest[A], arg1: core.WireFormat[A], arg2: Manifest[B], arg3: core.WireFormat[B], arg4: Manifest[C], arg5: core.WireFormat[C], arg6: Manifest[D], arg7: core.WireFormat[D], arg8: Manifest[E], arg9: core.WireFormat[E], arg10: Manifest[F], arg11: core.WireFormat[F], arg12: Manifest[G], arg13: core.WireFormat[G], arg14: Manifest[H], arg15: core.WireFormat[H], arg16: Manifest[I], arg17: core.WireFormat[I], arg18: Manifest[J], arg19: core.WireFormat[J], arg20: Manifest[K], arg21: core.WireFormat[K]): Abstract11WireFormat[TT, A, B, C, D, E, F, G, H, I, J, K]
-
def
mkAbstractWireFormat[TT, A <: TT, B <: TT, C <: TT, D <: TT, E <: TT, F <: TT, G <: TT, H <: TT, I <: TT, J <: TT]()(implicit arg0: Manifest[A], arg1: core.WireFormat[A], arg2: Manifest[B], arg3: core.WireFormat[B], arg4: Manifest[C], arg5: core.WireFormat[C], arg6: Manifest[D], arg7: core.WireFormat[D], arg8: Manifest[E], arg9: core.WireFormat[E], arg10: Manifest[F], arg11: core.WireFormat[F], arg12: Manifest[G], arg13: core.WireFormat[G], arg14: Manifest[H], arg15: core.WireFormat[H], arg16: Manifest[I], arg17: core.WireFormat[I], arg18: Manifest[J], arg19: core.WireFormat[J]): Abstract10WireFormat[TT, A, B, C, D, E, F, G, H, I, J]
-
def
mkAbstractWireFormat[TT, A <: TT, B <: TT, C <: TT, D <: TT, E <: TT, F <: TT, G <: TT, H <: TT, I <: TT]()(implicit arg0: Manifest[A], arg1: core.WireFormat[A], arg2: Manifest[B], arg3: core.WireFormat[B], arg4: Manifest[C], arg5: core.WireFormat[C], arg6: Manifest[D], arg7: core.WireFormat[D], arg8: Manifest[E], arg9: core.WireFormat[E], arg10: Manifest[F], arg11: core.WireFormat[F], arg12: Manifest[G], arg13: core.WireFormat[G], arg14: Manifest[H], arg15: core.WireFormat[H], arg16: Manifest[I], arg17: core.WireFormat[I]): Abstract9WireFormat[TT, A, B, C, D, E, F, G, H, I]
-
def
mkAbstractWireFormat[TT, A <: TT, B <: TT, C <: TT, D <: TT, E <: TT, F <: TT, G <: TT, H <: TT]()(implicit arg0: Manifest[A], arg1: core.WireFormat[A], arg2: Manifest[B], arg3: core.WireFormat[B], arg4: Manifest[C], arg5: core.WireFormat[C], arg6: Manifest[D], arg7: core.WireFormat[D], arg8: Manifest[E], arg9: core.WireFormat[E], arg10: Manifest[F], arg11: core.WireFormat[F], arg12: Manifest[G], arg13: core.WireFormat[G], arg14: Manifest[H], arg15: core.WireFormat[H]): Abstract8WireFormat[TT, A, B, C, D, E, F, G, H]
-
def
mkAbstractWireFormat[TT, A <: TT, B <: TT, C <: TT, D <: TT, E <: TT, F <: TT, G <: TT]()(implicit arg0: Manifest[A], arg1: core.WireFormat[A], arg2: Manifest[B], arg3: core.WireFormat[B], arg4: Manifest[C], arg5: core.WireFormat[C], arg6: Manifest[D], arg7: core.WireFormat[D], arg8: Manifest[E], arg9: core.WireFormat[E], arg10: Manifest[F], arg11: core.WireFormat[F], arg12: Manifest[G], arg13: core.WireFormat[G]): Abstract7WireFormat[TT, A, B, C, D, E, F, G]
-
def
mkAbstractWireFormat[TT, A <: TT, B <: TT, C <: TT, D <: TT, E <: TT, F <: TT]()(implicit arg0: Manifest[A], arg1: core.WireFormat[A], arg2: Manifest[B], arg3: core.WireFormat[B], arg4: Manifest[C], arg5: core.WireFormat[C], arg6: Manifest[D], arg7: core.WireFormat[D], arg8: Manifest[E], arg9: core.WireFormat[E], arg10: Manifest[F], arg11: core.WireFormat[F]): Abstract6WireFormat[TT, A, B, C, D, E, F]
-
def
mkAbstractWireFormat[TT, A <: TT, B <: TT, C <: TT, D <: TT, E <: TT]()(implicit arg0: Manifest[A], arg1: core.WireFormat[A], arg2: Manifest[B], arg3: core.WireFormat[B], arg4: Manifest[C], arg5: core.WireFormat[C], arg6: Manifest[D], arg7: core.WireFormat[D], arg8: Manifest[E], arg9: core.WireFormat[E]): Abstract5WireFormat[TT, A, B, C, D, E]
-
def
mkAbstractWireFormat[TT, A <: TT, B <: TT, C <: TT, D <: TT]()(implicit arg0: Manifest[A], arg1: core.WireFormat[A], arg2: Manifest[B], arg3: core.WireFormat[B], arg4: Manifest[C], arg5: core.WireFormat[C], arg6: Manifest[D], arg7: core.WireFormat[D]): Abstract4WireFormat[TT, A, B, C, D]
-
def
mkAbstractWireFormat[TT, A <: TT, B <: TT, C <: TT]()(implicit arg0: Manifest[A], arg1: core.WireFormat[A], arg2: Manifest[B], arg3: core.WireFormat[B], arg4: Manifest[C], arg5: core.WireFormat[C]): Abstract3WireFormat[TT, A, B, C]
-
def
mkAbstractWireFormat[TT, A <: TT, B <: TT]()(implicit arg0: Manifest[A], arg1: core.WireFormat[A], arg2: Manifest[B], arg3: core.WireFormat[B]): Abstract2WireFormat[TT, A, B]
-
def
mkCaseWireFormat[T, A1](apply: (A1) ⇒ T, unapply: (T) ⇒ Option[A1])(implicit arg0: core.WireFormat[A1]): core.WireFormat[T]
-
def
mkCaseWireFormat[T](apply: () ⇒ T, unapply: (T) ⇒ Boolean)(implicit arg0: Manifest[T]): core.WireFormat[T]
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
def
mkCaseWireFormat[T, A1, A2, A3, A4, A5, A6](apply: (A1, A2, A3, A4, A5, A6) ⇒ T, unapply: (T) ⇒ Option[(A1, A2, A3, A4, A5, A6)])(implicit arg0: core.WireFormat[A1], arg1: core.WireFormat[A2], arg2: core.WireFormat[A3], arg3: core.WireFormat[A4], arg4: core.WireFormat[A5], arg5: core.WireFormat[A6]): core.WireFormat[T]
-
def
mkCaseWireFormat[T, A1, A2, A3, A4, A5](apply: (A1, A2, A3, A4, A5) ⇒ T, unapply: (T) ⇒ Option[(A1, A2, A3, A4, A5)])(implicit arg0: core.WireFormat[A1], arg1: core.WireFormat[A2], arg2: core.WireFormat[A3], arg3: core.WireFormat[A4], arg4: core.WireFormat[A5]): core.WireFormat[T]
-
def
mkCaseWireFormat[T, A1, A2, A3, A4](apply: (A1, A2, A3, A4) ⇒ T, unapply: (T) ⇒ Option[(A1, A2, A3, A4)])(implicit arg0: core.WireFormat[A1], arg1: core.WireFormat[A2], arg2: core.WireFormat[A3], arg3: core.WireFormat[A4]): core.WireFormat[T]
-
def
mkCaseWireFormat[T, A1, A2, A3](apply: (A1, A2, A3) ⇒ T, unapply: (T) ⇒ Option[(A1, A2, A3)])(implicit arg0: core.WireFormat[A1], arg1: core.WireFormat[A2], arg2: core.WireFormat[A3]): core.WireFormat[T]
-
def
mkCaseWireFormat[T, A1, A2](apply: (A1, A2) ⇒ T, unapply: (T) ⇒ Option[(A1, A2)])(implicit arg0: core.WireFormat[A1], arg1: core.WireFormat[A2]): core.WireFormat[T]
-
def
mkObjectWireFormat[T](x: T)(implicit arg0: Manifest[T]): core.WireFormat[T]
-
final
def
ne(arg0: AnyRef): Boolean
-
final
def
notify(): Unit
-
final
def
notifyAll(): Unit
-
def
objectFromAvroFile[A](paths: Seq[String], checkSchemas: Boolean = true)(implicit arg0: core.WireFormat[A], arg1: AvroSchema[A]): core.DObject[A]
-
def
objectFromAvroFile[A](paths: String*)(implicit arg0: core.WireFormat[A], arg1: AvroSchema[A]): core.DObject[A]
-
def
objectFromDelimitedTextFile[A](path: String, sep: String = "\t", check: InputCheck = Source.defaultInputCheck)(extractFn: PartialFunction[Seq[String], A])(implicit arg0: core.WireFormat[A]): core.DObject[A]
-
def
objectFromSequenceFile[K, V](paths: Seq[String], checkKeyValueTypes: Boolean = true)(implicit arg0: core.WireFormat[K], arg1: SeqSchema[K], arg2: core.WireFormat[V], arg3: SeqSchema[V]): core.DObject[(K, V)]
-
-
def
objectFromTextFile(paths: String*): core.DObject[String]
-
def
objectKeyFromSequenceFile[K](paths: Seq[String], checkKeyType: Boolean = true)(implicit arg0: core.WireFormat[K], arg1: SeqSchema[K]): core.DObject[K]
-
def
objectKeyFromSequenceFile[K](paths: String*)(implicit arg0: core.WireFormat[K], arg1: SeqSchema[K]): core.DObject[K]
-
def
objectToDelimitedTextFile[A <: Product](o: core.DObject[A], path: String, sep: String = "\t", overwrite: Boolean = false, check: OutputCheck = Sink.defaultOutputCheck)(implicit arg0: Manifest[A]): core.DObject[String]
-
def
objectValueFromSequenceFile[V](paths: Seq[String], checkValueType: Boolean = true)(implicit arg0: core.WireFormat[V], arg1: SeqSchema[V]): core.DObject[V]
-
def
objectValueFromSequenceFile[V](paths: String*)(implicit arg0: core.WireFormat[V], arg1: SeqSchema[V]): core.DObject[V]
-
def
partitionedSequenceSink[P, K <: Writable, V <: Writable](path: String, partition: (P) ⇒ String, overwrite: Boolean = false, check: OutputCheck = Sink.defaultOutputCheck)(implicit mk: Manifest[K], mv: Manifest[V], sc: core.ScoobiConfiguration): PartitionedSink[P, K, V, (K, V)]
-
-
-
-
-
-
implicit
def
relationalToDList[K, A](r: Relational[K, A]): core.DList[(K, A)]
-
-
-
-
-
-
-
-
-
-
-
-
-
-
def
sequenceSink[K <: Writable, V <: Writable](path: String, overwrite: Boolean = false, check: OutputCheck = Sink.defaultOutputCheck, checkpoint: Boolean = false, expiryPolicy: core.ExpiryPolicy = ExpiryPolicy.default)(implicit mk: Manifest[K], mv: Manifest[V], sc: core.ScoobiConfiguration): SeqSink[K, V, (K, V)]
-
-
-
def
splitpath[K, V](context: MapContext[K, V, _, _]): String
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
-
implicit
def
taggedTypeGrouping[T, U](implicit arg0: core.Grouping[T]): core.Grouping[@@[T, U]]
-
implicit
def
taggedTypeOrdering[T, U](implicit arg0: Ordering[T]): Ordering[@@[T, U]]
-
implicit
def
taggedTypeWireFormat[T, U](implicit arg0: core.WireFormat[T]): core.WireFormat[@@[T, U]]
-
def
textFilePartitionedSink[P, V](path: String, partition: (P) ⇒ String, overwrite: Boolean = false, check: OutputCheck = Sink.defaultOutputCheck)(implicit arg0: Manifest[P], arg1: Manifest[V]): PartitionedSink[P, NullWritable, V, V]
-
def
textFileSink[A](path: String, overwrite: Boolean = false, check: OutputCheck = Sink.defaultOutputCheck)(implicit arg0: Manifest[A]): TextFileSink[A]
-
-
implicit
def
toBooleanWritable(bool: Boolean): BooleanWritable
-
implicit
def
toByteWritable(byte: Byte): ByteWritable
-
implicit
def
toBytesWritable(byteArr: Array[Byte]): BytesWritable
-
implicit
def
toConfiguration(sc: core.ScoobiConfiguration): Configuration
-
implicit
def
toDoubleWritable(double: Double): DoubleWritable
-
implicit
def
toFloatWritable(float: Float): FloatWritable
-
implicit
def
toIntWritable(int: Int): IntWritable
-
implicit
def
toLongWritable(long: Long): LongWritable
-
def
toString(): String
-
implicit
def
toText(str: String): Text
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
def
valueSource[V](paths: Seq[String])(implicit arg0: io.sequence.SeqSchema[V]): SeqSource[Writable, io.sequence.SequenceInput.valueSource.convV.type.SeqType, V] forSome {val convV: io.sequence.SeqSchema[V]}
-
final
def
wait(): Unit
-
final
def
wait(arg0: Long, arg1: Int): Unit
-
final
def
wait(arg0: Long): Unit
-
Global Scoobi functions and values.