spark
.
streaming
input
package
input
Visibility
Public
All
Type Members
class
KafkaFunctions
extends AnyRef
A wrapper around StreamingContext for exposing Kafka functions.