Commit message (Collapse) | Author | Age | Files | Lines | ||
---|---|---|---|---|---|---|
... | ||||||
| * | | | Fix review comments, add a new api to SparkHadoopUtil to create appropriate ↵ | Mridul Muralidharan | 2013-04-22 | 1 | -4/+6 | |
| | | | | | | | | | | | | | | | | Configuration. Modify an example to show how to use SplitInfo | |||||
| * | | | Move back to 2.0.2-alpha, since 2.0.3-alpha is not available in cloudera ↵ | Mridul Muralidharan | 2013-04-17 | 1 | -3/+7 | |
| | | | | | | | | | | | | | | | | yet. Also, add netty dependency explicitly to prevent resolving to older 2.3x version. Additionally, comment out retrievePattern to ensure correct netty is picked up | |||||
| * | | | Add support for building against hadoop2-yarn : adding new maven profile for it | Mridul Muralidharan | 2013-04-07 | 1 | -5/+29 | |
| |/ / | ||||||
| * | | Re-enable deprecation warnings since there are only two | Holden Karau | 2013-03-24 | 1 | -1/+1 | |
| | | | ||||||
| * | | Makes the syntax highlighting on the build file not broken in emacs. | Holden Karau | 2013-03-24 | 1 | -1/+1 | |
| |/ | ||||||
| * | Fix reference bug in Kryo serializer, add test, update version | Hiral Patel | 2013-03-07 | 1 | -1/+1 | |
| | | ||||||
| * | Change version to 0.7.1-SNAPSHOT for development branch | Matei Zaharia | 2013-02-27 | 1 | -1/+1 | |
| | | ||||||
| * | Change version number to 0.7.0 | Matei Zaharia | 2013-02-25 | 1 | -1/+1 | |
| | | ||||||
| * | Update Hadoop dependency to 1.0.4 | Matei Zaharia | 2013-02-25 | 1 | -2/+2 | |
| | | ||||||
| * | Moving akka dependency resolver to shared. | Prashant Sharma | 2013-02-25 | 1 | -1/+3 | |
| | | ||||||
* | | changing streaming resolver for akka | seanm | 2013-03-13 | 1 | -1/+1 | |
| | | ||||||
* | | adding typesafe repo to streaming resolvers so that akka-zeromq is found | seanm | 2013-03-11 | 1 | -0/+3 | |
|/ | ||||||
* | Fixed class paths and dependencies based on Matei's comments. | Tathagata Das | 2013-02-24 | 1 | -4/+1 | |
| | ||||||
* | Changed Algebird from 0.1.9 to 0.1.8 | Tathagata Das | 2013-02-24 | 1 | -1/+1 | |
| | ||||||
* | Fixed resolver for akka-zeromq | Tathagata Das | 2013-02-22 | 1 | -0/+3 | |
| | ||||||
* | Merge pull request #480 from MLnick/streaming-eg-algebird | Tathagata Das | 2013-02-22 | 1 | -1/+2 | |
|\ | | | | | [Streaming] Examples using Twitter's Algebird library | |||||
| * | Bumping Algebird to 0.1.9 | Nick Pentreath | 2013-02-21 | 1 | -1/+1 | |
| | | ||||||
| * | Merge remote-tracking branch 'upstream/streaming' into streaming-eg-algebird | Nick Pentreath | 2013-02-19 | 1 | -5/+3 | |
| |\ | | | | | | | | | | | | | Conflicts: project/SparkBuild.scala | |||||
| * | | Adding streaming HyperLogLog example using Algebird | Nick Pentreath | 2013-02-19 | 1 | -1/+2 | |
| | | | ||||||
* | | | fixes corresponding to review feedback at pull request #479 | Prashant Sharma | 2013-02-20 | 1 | -2/+2 | |
| | | | ||||||
* | | | ZeroMQ stream as receiver | Prashant Sharma | 2013-02-19 | 1 | -0/+1 | |
| |/ |/| | ||||||
* | | Added TwitterInputDStream from example to StreamingContext. Renamed example ↵ | Tathagata Das | 2013-02-14 | 1 | -5/+3 | |
|/ | | | | TwitterBasic to TwitterPopularTags. | |||||
* | Add easymock to SBT configuration. | Charles Reiss | 2013-01-29 | 1 | -1/+2 | |
| | ||||||
* | Add Maven build file for streaming, and fix some issues in SBT file | Matei Zaharia | 2013-01-20 | 1 | -7/+9 | |
| | | | | | | As part of this, changed our Scala 2.9.2 Kafka library to be available as a local Maven repository, following the example in (http://blog.dub.podval.org/2010/01/maven-in-project-repository.html) | |||||
* | Merge branch 'master' into streaming | Tathagata Das | 2013-01-15 | 1 | -1/+3 | |
|\ | | | | | | | | | | | | | | | | | Conflicts: core/src/main/scala/spark/rdd/CoGroupedRDD.scala core/src/main/scala/spark/rdd/FilteredRDD.scala docs/_layouts/global.html docs/index.md run | |||||
| * | Merge pull request #357 from tysonjh/master | Matei Zaharia | 2013-01-10 | 1 | -0/+1 | |
| |\ | | | | | | | JSON support added to WebUI | |||||
| | * | Removed io.spray spray-json dependency as it is not needed. | Tyson | 2013-01-09 | 1 | -1/+0 | |
| | | | ||||||
| | * | Added the spray implicit marshaller library | Tyson | 2013-01-09 | 1 | -0/+2 | |
| | | | | | | | | | | | | Added the io.spray JSON library | |||||
| * | | Retrieve jars to a flat directory so * can be used for the classpath. | Stephen Haberman | 2013-01-08 | 1 | -0/+1 | |
| | | | ||||||
| * | | Update Hadoop dependency to 1.0.3 as 0.20 has Sun specific dependencies. Also | Shivaram Venkataraman | 2013-01-07 | 1 | -1/+1 | |
| | | | | | | | | | | | | | | | fix SequenceFileRDDFunctions to pick the right type conversion across Hadoop versions | |||||
* | | | Merge branch 'streaming-merge' into dev-merge | Tathagata Das | 2013-01-07 | 1 | -1/+4 | |
|\ \ \ | ||||||
| * \ \ | Merge pull request #8 from radlab/twitter-example | Patrick Wendell | 2012-12-29 | 1 | -1/+4 | |
| |\ \ \ | | | | | | | | | | | Adding a Twitter InputDStream with an example | |||||
| | * | | | Adding a Twitter InputDStream with an example | Patrick Wendell | 2012-12-21 | 1 | -1/+4 | |
| | | | | | ||||||
* | | | | | Moved Spark Streaming examples to examples sub-project. | Tathagata Das | 2013-01-06 | 1 | -1/+1 | |
| | | | | | ||||||
* | | | | | Merge branch 'mesos' into dev-merge | Tathagata Das | 2012-12-26 | 1 | -1/+1 | |
|\ \ \ \ \ | |/ / / / |/| | / / | | |/ / | |/| | | ||||||
| * | | | Merge pull request #341 from rxin/4a3fb06ac2d11125feb08acbbd4df76d1e91b677 | Matei Zaharia | 2012-12-21 | 1 | -1/+1 | |
| |\ \ \ | | | | | | | | | | | Kryo2 update against Spark master | |||||
| | * | | | Updated Kryo to 2.20. | Reynold Xin | 2012-10-16 | 1 | -1/+1 | |
| | | | | | ||||||
* | | | | | Merge branch 'master' of github.com:mesos/spark into dev | Reynold Xin | 2012-12-20 | 1 | -1/+1 | |
|\| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Conflicts: core/src/main/scala/spark/MapOutputTracker.scala core/src/main/scala/spark/PairRDDFunctions.scala core/src/main/scala/spark/ParallelCollection.scala core/src/main/scala/spark/RDD.scala core/src/main/scala/spark/rdd/BlockRDD.scala core/src/main/scala/spark/rdd/CartesianRDD.scala core/src/main/scala/spark/rdd/CoGroupedRDD.scala core/src/main/scala/spark/rdd/CoalescedRDD.scala core/src/main/scala/spark/rdd/FilteredRDD.scala core/src/main/scala/spark/rdd/FlatMappedRDD.scala core/src/main/scala/spark/rdd/GlommedRDD.scala core/src/main/scala/spark/rdd/HadoopRDD.scala core/src/main/scala/spark/rdd/MapPartitionsRDD.scala core/src/main/scala/spark/rdd/MapPartitionsWithSplitRDD.scala core/src/main/scala/spark/rdd/MappedRDD.scala core/src/main/scala/spark/rdd/PipedRDD.scala core/src/main/scala/spark/rdd/SampledRDD.scala core/src/main/scala/spark/rdd/ShuffledRDD.scala core/src/main/scala/spark/rdd/UnionRDD.scala core/src/main/scala/spark/storage/BlockManager.scala core/src/main/scala/spark/storage/BlockManagerId.scala core/src/main/scala/spark/storage/BlockManagerMaster.scala core/src/main/scala/spark/storage/StorageLevel.scala core/src/main/scala/spark/util/MetadataCleaner.scala core/src/main/scala/spark/util/TimeStampedHashMap.scala core/src/test/scala/spark/storage/BlockManagerSuite.scala run | |||||
| * | | | | Let the slave notify the master block removal. | Reynold Xin | 2012-12-20 | 1 | -1/+1 | |
| | |_|/ | |/| | | ||||||
* | | | | Adding Flume InputDStream | Patrick Wendell | 2012-12-07 | 1 | -1/+2 | |
| |_|/ |/| | | ||||||
* | | | Added kafka JAR | Denny | 2012-12-05 | 1 | -1/+1 | |
| | | | ||||||
* | | | Working on kafka. | Denny | 2012-11-06 | 1 | -1/+3 | |
| | | | ||||||
* | | | Merge remote-tracking branch 'public/master' into dev | Matei Zaharia | 2012-10-24 | 2 | -18/+93 | |
|\| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Conflicts: core/src/main/scala/spark/BlockStoreShuffleFetcher.scala core/src/main/scala/spark/KryoSerializer.scala core/src/main/scala/spark/MapOutputTracker.scala core/src/main/scala/spark/RDD.scala core/src/main/scala/spark/SparkContext.scala core/src/main/scala/spark/executor/Executor.scala core/src/main/scala/spark/network/Connection.scala core/src/main/scala/spark/network/ConnectionManagerTest.scala core/src/main/scala/spark/rdd/BlockRDD.scala core/src/main/scala/spark/rdd/NewHadoopRDD.scala core/src/main/scala/spark/scheduler/ShuffleMapTask.scala core/src/main/scala/spark/scheduler/cluster/StandaloneSchedulerBackend.scala core/src/main/scala/spark/storage/BlockManager.scala core/src/main/scala/spark/storage/BlockMessage.scala core/src/main/scala/spark/storage/BlockStore.scala core/src/main/scala/spark/storage/StorageLevel.scala core/src/main/scala/spark/util/AkkaUtils.scala project/SparkBuild.scala run | |||||
| * | | Bump up version to 0.7.0-SNAPSHOT for master branch | Matei Zaharia | 2012-10-22 | 1 | -1/+1 | |
| | | | ||||||
| * | | Update version to 0.6.1-SNAPSHOT to show this is in development | Matei Zaharia | 2012-10-22 | 1 | -1/+1 | |
| | | | ||||||
| * | | Support for Hadoop 2 distributions such as cdh4 | Thomas Dudziak | 2012-10-18 | 1 | -2/+8 | |
| |/ | ||||||
| * | Removing credentials line in build. | Patrick Wendell | 2012-10-14 | 1 | -1/+0 | |
| | | ||||||
| * | Comment out PGP stuff for publish-local to work | Matei Zaharia | 2012-10-14 | 2 | -4/+6 | |
| | | ||||||
| * | Changed default Hadoop version back to 0.20.205 | Matei Zaharia | 2012-10-14 | 1 | -1/+1 | |
| | | ||||||
| * | Uncomment Maven publishing stuff and set version to 0.6.0 | Matei Zaharia | 2012-10-13 | 2 | -12/+12 | |
| | |