ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

[HOTFIX] Fixing style failures in Kinesis source

Browse source
This commit is contained in:
Patrick Wendell 2015-05-19 00:02:06 -07:00
parent 9ebb44f8ab
commit 23cf897112
2 changed files with 6 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
extras/kinesis-asl/src/main/scala/org/apache/spark/examples/streaming/KinesisWordCountASL.scala
View file

@ -119,7 +119,8 @@ object KinesisWordCountASL extends Logging {
val batchInterval = Milliseconds(2000) val batchInterval = Milliseconds(2000)
// Kinesis checkpoint interval is the interval at which the DynamoDB is updated with information // Kinesis checkpoint interval is the interval at which the DynamoDB is updated with information
//on sequence number of records that have been received. Same as batchInterval for this example. // on sequence number of records that have been received. Same as batchInterval for this
// example.
val kinesisCheckpointInterval = batchInterval val kinesisCheckpointInterval = batchInterval
// Get the region name from the endpoint URL to save Kinesis Client Library metadata in // Get the region name from the endpoint URL to save Kinesis Client Library metadata in
@ -173,7 +174,8 @@ object KinesisWordProducerASL {
if (args.length != 4) { if (args.length != 4) {
System.err.println( System.err.println(
""" """
|Usage: KinesisWordProducerASL <stream-name> <endpoint-url> <records-per-sec> <words-per-record> |Usage: KinesisWordProducerASL <stream-name> <endpoint-url> <records-per-sec>
<words-per-record>
| |
| <stream-name> is the name of the Kinesis stream | <stream-name> is the name of the Kinesis stream
| <endpoint-url> is the endpoint of the Kinesis service | <endpoint-url> is the endpoint of the Kinesis service

4
extras/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisReceiver.scala
View file

@ -82,8 +82,8 @@ private[kinesis] class KinesisReceiver(
*/ */
/** /**
* workerId is used by the KCL should be based on the ip address of the actual Spark Worker where this code runs * workerId is used by the KCL should be based on the ip address of the actual Spark Worker
* (not the driver's IP address.) * where this code runs (not the driver's IP address.)
*/ */
private var workerId: String = null private var workerId: String = null