Prashant Sharma
|
8f3ac240cb
|
Fixed Warning: ClassManifest -> ClassTag
|
2013-04-29 16:39:13 +05:30 |
|
Prashant Sharma
|
4b4a36ea7d
|
Fixed pom.xml with updated dependencies.
|
2013-04-29 12:55:43 +05:30 |
|
Andrew Ash
|
f1d8871ca1
|
Uniform whitespace across scala examples
|
2013-04-09 23:35:13 -04:00 |
|
Matei Zaharia
|
65caa8f711
|
Merge remote-tracking branch 'jey/bump-development-version-to-0.8.0'
Conflicts:
docs/_config.yml
project/SparkBuild.scala
|
2013-04-08 12:43:17 -04:00 |
|
Matei Zaharia
|
b362df39ea
|
Merge pull request #552 from MLnick/master
Bumping version for Twitter Algebird to latest
|
2013-04-07 17:17:52 -07:00 |
|
Nick Pentreath
|
0f54344fd8
|
Bumping Algebird version in examples now that it supports JDK 1.6
|
2013-04-03 13:15:34 +02:00 |
|
Erik van oosten
|
b5e60c3253
|
Corrected order of CountMinSketchMonoid arguments
|
2013-04-02 15:25:22 +03:00 |
|
Jey Kottalam
|
bc8ba222ff
|
Bump development version to 0.8.0
|
2013-03-28 15:42:01 -07:00 |
|
Matei Zaharia
|
ca4d083ec8
|
Merge pull request #528 from MLnick/java-examples
[SPARK-707] Adding Java versions of Pi, LogQuery and K-Means examples
|
2013-03-20 11:22:36 -07:00 |
|
Nick Pentreath
|
52398cc1a3
|
Java indentation 4 --> 2 spaces
|
2013-03-20 09:55:42 +02:00 |
|
Nick Pentreath
|
9fa47a2039
|
A few cosmetic changes for JavaKMeans
|
2013-03-19 15:31:03 +02:00 |
|
Nick Pentreath
|
568ddf7330
|
Adding Java K-Means example
|
2013-03-19 15:29:22 +02:00 |
|
Nick Pentreath
|
b990caeb80
|
Changes to more closely match line length limit style
|
2013-03-17 20:03:27 +02:00 |
|
Mikhail Bautin
|
7fd2708eda
|
Add a log4j compile dependency to fix build in IntelliJ
Also rename parent project to spark-parent (otherwise it shows up as
"parent" in IntelliJ, which is very confusing).
|
2013-03-15 11:41:51 -07:00 |
|
Nick Pentreath
|
13757b1198
|
Adding Java versions of Pi and LogQuery
|
2013-03-15 10:52:01 +02:00 |
|
Mark Hamstra
|
8b06b359da
|
bump version to 0.7.1-SNAPSHOT in the subproject poms to keep the maven build building.
|
2013-02-28 23:34:34 -08:00 |
|
Matei Zaharia
|
5d7b591cfe
|
Pass a code JAR to SparkContext in our examples. Fixes SPARK-594.
|
2013-02-25 19:34:32 -08:00 |
|
Matei Zaharia
|
6b87ef7c86
|
Fix compile error
|
2013-02-25 14:01:16 -08:00 |
|
Matei Zaharia
|
01bd136ba5
|
Use public method sparkContext instead of protected sc in streaming examples
|
2013-02-25 13:27:11 -08:00 |
|
Tathagata Das
|
f282bc4960
|
Changed Algebird from 0.1.9 to 0.1.8
|
2013-02-24 12:44:12 -08:00 |
|
Tathagata Das
|
c1a040db3a
|
Fixed bugs in examples.
|
2013-02-24 11:00:30 -08:00 |
|
Tathagata Das
|
41285eaae3
|
Fixed differences in APIs of StreamingContext and JavaStreamingContext. Change rawNetworkStream to rawSocketStream, and added twitter, actor, zeroMQ streams to JavaStreamingContext. Also added them to JavaAPISuite.
|
2013-02-23 16:25:07 -08:00 |
|
Tathagata Das
|
cfa65ebff1
|
Merge pull request #480 from MLnick/streaming-eg-algebird
[Streaming] Examples using Twitter's Algebird library
|
2013-02-22 12:29:04 -08:00 |
|
Tathagata Das
|
688e62718f
|
Merge pull request #479 from ScrapCodes/zeromq-streaming
Zeromq streaming
|
2013-02-22 12:17:17 -08:00 |
|
Nick Pentreath
|
d9bdae8cc2
|
Adding documentation for HLL and CMS examples. More efficient and clear use of the monoids.
|
2013-02-21 12:31:31 +02:00 |
|
Nick Pentreath
|
718474b9c6
|
Bumping Algebird to 0.1.9
|
2013-02-21 12:11:31 +02:00 |
|
Nick Pentreath
|
16d456742e
|
Merge remote-tracking branch 'upstream/streaming' into streaming-eg-algebird
|
2013-02-21 09:33:08 +02:00 |
|
Tathagata Das
|
972fe7714f
|
Merge branch 'mesos-streaming' into streaming
Conflicts:
streaming/src/test/java/spark/streaming/JavaAPISuite.java
|
2013-02-20 11:06:01 -08:00 |
|
Tathagata Das
|
fb9956256d
|
Merge branch 'mesos-master' into streaming
Conflicts:
core/src/main/scala/spark/rdd/CheckpointRDD.scala
streaming/src/main/scala/spark/streaming/dstream/ReducedWindowedDStream.scala
|
2013-02-20 09:01:29 -08:00 |
|
Prashant Sharma
|
4e5b09664c
|
fixes corresponding to review feedback at pull request #479
|
2013-02-20 19:14:52 +05:30 |
|
Prashant Sharma
|
05dc385649
|
A bug fix post merge, following changes to AkkaUtils
|
2013-02-20 15:28:12 +05:30 |
|
Nick Pentreath
|
8a281399f9
|
Streaming example using Twitter Algebird's Count Min Sketch monoid
|
2013-02-19 17:56:02 +02:00 |
|
Nick Pentreath
|
d8ee184d95
|
Dependencies and refactoring for streaming HLL example, and using context.twitterStream method
|
2013-02-19 17:42:57 +02:00 |
|
Prashant Sharma
|
8d44480d84
|
example for demonstrating ZeroMQ stream
|
2013-02-19 19:42:14 +05:30 |
|
Nick Pentreath
|
315ea069e8
|
Merge remote-tracking branch 'upstream/streaming' into streaming-eg-algebird
Conflicts:
project/SparkBuild.scala
|
2013-02-19 13:58:05 +02:00 |
|
Nick Pentreath
|
015893f0e8
|
Adding streaming HyperLogLog example using Algebird
|
2013-02-19 13:21:33 +02:00 |
|
Tathagata Das
|
7e30c46aaf
|
Added comment to the KafkaWordCount, given by Sean McNamara.
|
2013-02-19 03:05:44 -08:00 |
|
Tathagata Das
|
9e82be1503
|
Merge branch 'streaming' into ScrapCodes-streaming-actor
Conflicts:
docs/plugin-custom-receiver.md
streaming/src/main/scala/spark/streaming/StreamingContext.scala
streaming/src/main/scala/spark/streaming/dstream/KafkaInputDStream.scala
streaming/src/main/scala/spark/streaming/dstream/PluggableInputDStream.scala
streaming/src/main/scala/spark/streaming/receivers/ActorReceiver.scala
streaming/src/test/scala/spark/streaming/InputStreamsSuite.scala
|
2013-02-19 02:48:50 -08:00 |
|
Tathagata Das
|
12ea14c211
|
Changed networkStream to socketStream and pluggableNetworkStream to become networkStream as a way to create streams from arbitrary network receiver.
|
2013-02-18 15:18:34 -08:00 |
|
Tathagata Das
|
6a6e6bda57
|
Merge branch 'streaming' into ScrapCode-streaming
Conflicts:
streaming/src/main/scala/spark/streaming/dstream/KafkaInputDStream.scala
streaming/src/main/scala/spark/streaming/dstream/NetworkInputDStream.scala
|
2013-02-18 13:26:12 -08:00 |
|
Tathagata Das
|
4b8402e900
|
Moved Java streaming examples to examples/src/main/java/spark/streaming/... and fixed logging in NetworkInputTracker to highlight errors when receiver deregisters/shuts down.
|
2013-02-14 18:10:37 -08:00 |
|
Tathagata Das
|
def8126d77
|
Added TwitterInputDStream from example to StreamingContext. Renamed example TwitterBasic to TwitterPopularTags.
|
2013-02-14 17:49:43 -08:00 |
|
Tathagata Das
|
2eacf22401
|
Removed countByKeyAndWindow on paired DStreams, and added countByValueAndWindow for all DStreams. Updated both scala and java API and testsuites.
|
2013-02-14 12:21:47 -08:00 |
|
Prashant Sharma
|
291dd47c7f
|
Taking FeederActor out as seperate program
|
2013-02-08 14:34:07 +05:30 |
|
Tathagata Das
|
4cc223b478
|
Merge branch 'mesos-master' into streaming
|
2013-02-07 13:59:31 -08:00 |
|
Tathagata Das
|
12300758cc
|
Merge pull request #372 from Reinvigorate/sm-kafka
Removing offset management code that is non-existent in kafka 0.7.0+
|
2013-02-07 12:41:07 -08:00 |
|
Patrick Wendell
|
dab81a8511
|
Fixing to match Spark styleguide
|
2013-02-05 20:57:04 -08:00 |
|
Patrick Wendell
|
cc37601ecb
|
Adding an example with an OLAP roll-up
|
2013-02-04 14:18:11 -08:00 |
|
Mikhail Bautin
|
fe3eceab57
|
Remove activation of profiles by default
See the discussion at https://github.com/mesos/spark/pull/355 for why
default profile activation is a problem.
|
2013-01-31 13:30:41 -08:00 |
|
Prashant Sharma
|
4496bf197b
|
Improved document comment in example
|
2013-01-25 14:34:38 +05:30 |
|