org.apache.spark.examples

streaming

package streaming

Visibility
  1. Public
  2. All

Type Members

  1. final class JavaKinesisWordCountASL extends AnyRef

Value Members

  1. object KinesisWordCountASL extends Logging

    Consumes messages from a Amazon Kinesis streams and does wordcount.

  2. object KinesisWordProducerASL

    Usage: KinesisWordProducerASL <stream-name> <endpoint-url> \ <records-per-sec> <words-per-record>

Ungrouped