diff options
| author | Kousuke Saruta <sarutak@oss.nttdata.co.jp> | 2014-08-25 19:40:08 -0700 |
|---|---|---|
| committer | Matei Zaharia <matei@databricks.com> | 2014-08-25 19:40:23 -0700 |
| commit | 62f5009f6795b17638d2a1e8e51db0890030d8d6 (patch) | |
| tree | d6f4941eef3d09d132c891af12bcac2266b62205 /extras | |
| parent | 9f04db17e50568d5580091add9100693177d7c4f (diff) | |
| download | spark-62f5009f6795b17638d2a1e8e51db0890030d8d6.tar.gz spark-62f5009f6795b17638d2a1e8e51db0890030d8d6.tar.bz2 spark-62f5009f6795b17638d2a1e8e51db0890030d8d6.zip | |
[SPARK-2976] Replace tabs with spaces
Author: Kousuke Saruta <sarutak@oss.nttdata.co.jp>
Closes #1895 from sarutak/SPARK-2976 and squashes the following commits:
1cf7e69 [Kousuke Saruta] Merge branch 'master' of git://git.apache.org/spark into SPARK-2976
d1e0666 [Kousuke Saruta] Modified styles
c5e80a4 [Kousuke Saruta] Remove tab from JavaPageRank.java and JavaKinesisWordCountASL.java
c003b36 [Kousuke Saruta] Removed tab from sorttable.js
Diffstat (limited to 'extras')
| -rw-r--r-- | extras/kinesis-asl/src/main/java/org/apache/spark/examples/streaming/JavaKinesisWordCountASL.java | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/extras/kinesis-asl/src/main/java/org/apache/spark/examples/streaming/JavaKinesisWordCountASL.java b/extras/kinesis-asl/src/main/java/org/apache/spark/examples/streaming/JavaKinesisWordCountASL.java index a8b907b241..1a710d7b18 100644 --- a/extras/kinesis-asl/src/main/java/org/apache/spark/examples/streaming/JavaKinesisWordCountASL.java +++ b/extras/kinesis-asl/src/main/java/org/apache/spark/examples/streaming/JavaKinesisWordCountASL.java @@ -130,10 +130,10 @@ public final class JavaKinesisWordCountASL { /* Create the same number of Kinesis DStreams/Receivers as Kinesis stream's shards */ List<JavaDStream<byte[]>> streamsList = new ArrayList<JavaDStream<byte[]>>(numStreams); for (int i = 0; i < numStreams; i++) { - streamsList.add( - KinesisUtils.createStream(jssc, streamName, endpointUrl, checkpointInterval, - InitialPositionInStream.LATEST, StorageLevel.MEMORY_AND_DISK_2()) - ); + streamsList.add( + KinesisUtils.createStream(jssc, streamName, endpointUrl, checkpointInterval, + InitialPositionInStream.LATEST, StorageLevel.MEMORY_AND_DISK_2()) + ); } /* Union all the streams if there is more than 1 stream */ |