class CouchbaseInputDStream extends ReceiverInputDStream[StreamMessage]
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- CouchbaseInputDStream
- ReceiverInputDStream
- InputDStream
- DStream
- Logging
- Serializable
- Serializable
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Instance Constructors
- new CouchbaseInputDStream(_ssc: StreamingContext, storageLevel: StorageLevel, bucket: String = null, from: StreamFrom = FromNow, to: StreamTo = ToInfinity)
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
val
baseScope: Option[String]
- Attributes
- protected[org.apache.spark.streaming]
- Definition Classes
- InputDStream → DStream
-
def
cache(): DStream[StreamMessage]
- Definition Classes
- DStream
-
def
checkpoint(interval: Duration): DStream[StreamMessage]
- Definition Classes
- DStream
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
def
compute(validTime: Time): Option[RDD[StreamMessage]]
- Definition Classes
- ReceiverInputDStream → DStream
-
def
context: StreamingContext
- Definition Classes
- DStream
-
def
count(): DStream[Long]
- Definition Classes
- DStream
-
def
countByValue(numPartitions: Int)(implicit ord: Ordering[StreamMessage]): DStream[(StreamMessage, Long)]
- Definition Classes
- DStream
-
def
countByValueAndWindow(windowDuration: Duration, slideDuration: Duration, numPartitions: Int)(implicit ord: Ordering[StreamMessage]): DStream[(StreamMessage, Long)]
- Definition Classes
- DStream
-
def
countByWindow(windowDuration: Duration, slideDuration: Duration): DStream[Long]
- Definition Classes
- DStream
-
def
createRDDWithLocalProperties[U](time: Time, displayInnerRDDOps: Boolean)(body: ⇒ U): U
- Attributes
- protected[org.apache.spark.streaming]
- Definition Classes
- DStream
-
def
dependencies: List[DStream[_]]
- Definition Classes
- InputDStream → DStream
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
filter(filterFunc: (StreamMessage) ⇒ Boolean): DStream[StreamMessage]
- Definition Classes
- DStream
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
def
flatMap[U](flatMapFunc: (StreamMessage) ⇒ TraversableOnce[U])(implicit arg0: ClassTag[U]): DStream[U]
- Definition Classes
- DStream
-
def
foreachRDD(foreachFunc: (RDD[StreamMessage], Time) ⇒ Unit): Unit
- Definition Classes
- DStream
-
def
foreachRDD(foreachFunc: (RDD[StreamMessage]) ⇒ Unit): Unit
- Definition Classes
- DStream
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
getReceiver(): Receiver[StreamMessage]
- Definition Classes
- CouchbaseInputDStream → ReceiverInputDStream
-
def
glom(): DStream[Array[StreamMessage]]
- Definition Classes
- DStream
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
val
id: Int
- Definition Classes
- InputDStream
-
def
initializeLogIfNecessary(isInterpreter: Boolean, silent: Boolean): Boolean
- Attributes
- protected
- Definition Classes
- Logging
-
def
initializeLogIfNecessary(isInterpreter: Boolean): Unit
- Attributes
- protected
- Definition Classes
- Logging
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
isTraceEnabled(): Boolean
- Attributes
- protected
- Definition Classes
- Logging
-
def
log: Logger
- Attributes
- protected
- Definition Classes
- Logging
-
def
logDebug(msg: ⇒ String, throwable: Throwable): Unit
- Attributes
- protected
- Definition Classes
- Logging
-
def
logDebug(msg: ⇒ String): Unit
- Attributes
- protected
- Definition Classes
- Logging
-
def
logError(msg: ⇒ String, throwable: Throwable): Unit
- Attributes
- protected
- Definition Classes
- Logging
-
def
logError(msg: ⇒ String): Unit
- Attributes
- protected
- Definition Classes
- Logging
-
def
logInfo(msg: ⇒ String, throwable: Throwable): Unit
- Attributes
- protected
- Definition Classes
- Logging
-
def
logInfo(msg: ⇒ String): Unit
- Attributes
- protected
- Definition Classes
- Logging
-
def
logName: String
- Attributes
- protected
- Definition Classes
- Logging
-
def
logTrace(msg: ⇒ String, throwable: Throwable): Unit
- Attributes
- protected
- Definition Classes
- Logging
-
def
logTrace(msg: ⇒ String): Unit
- Attributes
- protected
- Definition Classes
- Logging
-
def
logWarning(msg: ⇒ String, throwable: Throwable): Unit
- Attributes
- protected
- Definition Classes
- Logging
-
def
logWarning(msg: ⇒ String): Unit
- Attributes
- protected
- Definition Classes
- Logging
-
def
map[U](mapFunc: (StreamMessage) ⇒ U)(implicit arg0: ClassTag[U]): DStream[U]
- Definition Classes
- DStream
-
def
mapPartitions[U](mapPartFunc: (Iterator[StreamMessage]) ⇒ Iterator[U], preservePartitioning: Boolean)(implicit arg0: ClassTag[U]): DStream[U]
- Definition Classes
- DStream
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
def
persist(): DStream[StreamMessage]
- Definition Classes
- DStream
-
def
persist(level: StorageLevel): DStream[StreamMessage]
- Definition Classes
- DStream
-
def
print(num: Int): Unit
- Definition Classes
- DStream
-
def
print(): Unit
- Definition Classes
- DStream
-
val
rateController: Option[RateController]
- Attributes
- protected[org.apache.spark.streaming]
- Definition Classes
- ReceiverInputDStream → InputDStream
-
def
reduce(reduceFunc: (StreamMessage, StreamMessage) ⇒ StreamMessage): DStream[StreamMessage]
- Definition Classes
- DStream
-
def
reduceByWindow(reduceFunc: (StreamMessage, StreamMessage) ⇒ StreamMessage, invReduceFunc: (StreamMessage, StreamMessage) ⇒ StreamMessage, windowDuration: Duration, slideDuration: Duration): DStream[StreamMessage]
- Definition Classes
- DStream
-
def
reduceByWindow(reduceFunc: (StreamMessage, StreamMessage) ⇒ StreamMessage, windowDuration: Duration, slideDuration: Duration): DStream[StreamMessage]
- Definition Classes
- DStream
-
def
repartition(numPartitions: Int): DStream[StreamMessage]
- Definition Classes
- DStream
-
def
saveAsObjectFiles(prefix: String, suffix: String): Unit
- Definition Classes
- DStream
-
def
saveAsTextFiles(prefix: String, suffix: String): Unit
- Definition Classes
- DStream
-
def
slice(fromTime: Time, toTime: Time): Seq[RDD[StreamMessage]]
- Definition Classes
- DStream
-
def
slice(interval: Interval): Seq[RDD[StreamMessage]]
- Definition Classes
- DStream
-
def
slideDuration: Duration
- Definition Classes
- InputDStream → DStream
-
def
start(): Unit
- Definition Classes
- ReceiverInputDStream → InputDStream
-
def
stop(): Unit
- Definition Classes
- ReceiverInputDStream → InputDStream
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
def
transform[U](transformFunc: (RDD[StreamMessage], Time) ⇒ RDD[U])(implicit arg0: ClassTag[U]): DStream[U]
- Definition Classes
- DStream
-
def
transform[U](transformFunc: (RDD[StreamMessage]) ⇒ RDD[U])(implicit arg0: ClassTag[U]): DStream[U]
- Definition Classes
- DStream
-
def
transformWith[U, V](other: DStream[U], transformFunc: (RDD[StreamMessage], RDD[U], Time) ⇒ RDD[V])(implicit arg0: ClassTag[U], arg1: ClassTag[V]): DStream[V]
- Definition Classes
- DStream
-
def
transformWith[U, V](other: DStream[U], transformFunc: (RDD[StreamMessage], RDD[U]) ⇒ RDD[V])(implicit arg0: ClassTag[U], arg1: ClassTag[V]): DStream[V]
- Definition Classes
- DStream
-
def
union(that: DStream[StreamMessage]): DStream[StreamMessage]
- Definition Classes
- DStream
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
def
window(windowDuration: Duration, slideDuration: Duration): DStream[StreamMessage]
- Definition Classes
- DStream
-
def
window(windowDuration: Duration): DStream[StreamMessage]
- Definition Classes
- DStream