object JoinStreaming
- Alphabetic
- By Inheritance
- JoinStreaming
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
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
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
join(ssc: StreamingContext, partialResultsStream: DStream[(String, BulletData)], broadcastedConfig: Broadcast[BulletSparkConfig]): DStream[(String, BulletResult)]
Join and aggregate the partial results stream.
Join and aggregate the partial results stream.
This method takes the com.yahoo.bullet.spark.data.BulletData stream coming from the QueryDataUnioning phase and the FilterStreaming phase and emits the com.yahoo.bullet.spark.data.BulletResult stream to the ResultEmitter phase. It combines all the partial results with the same key and emits the com.yahoo.bullet.spark.data.BulletResult accordingly. It uses mapWithState to remember the intermediate combined results.
- ssc
The Spark streaming context.
- partialResultsStream
The com.yahoo.bullet.spark.data.BulletData partial results stream.
- broadcastedConfig
The broadcasted com.yahoo.bullet.spark.utils.BulletSparkConfig configuration that has been validated.
- returns
A com.yahoo.bullet.spark.data.BulletResult stream which contains results to be emitted.
-
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()
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
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( ... )