Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[SPARK-7799][SPARK-12786][Streaming]Add "streaming-akka" project #10744

Closed
wants to merge 14 commits into from
Closed

[SPARK-7799][SPARK-12786][Streaming]Add "streaming-akka" project #10744

wants to merge 14 commits into from

Commits on Jan 13, 2016

  1. Add "streaming-akka" project 

    Include the following changes:

1. Add "streaming-akka" project and org.apache.spark.streaming.akka.AkkaUtils for creating an actorStream
2. Remove "StreamingContext.actorStream" and "JavaStreamingContext.actorStream"
3. Update the ActorWordCount example and add the JavaActorWordCount example
4. Make "streaming-zeromq" depend on "streaming-akka" and update the codes accordingly
    @zsxwing
    zsxwing committed Jan 13, 2016
    Configuration menu
    Copy the full SHA
    a5ec644 View commit details
    Browse the repository at this point in the history

  2. Fix Mima tests

    @zsxwing
    zsxwing committed Jan 13, 2016
    Configuration menu
    Copy the full SHA
    c20b51a View commit details
    Browse the repository at this point in the history

Commits on Jan 18, 2016

  1. actorStream -> createStream

    @zsxwing
    zsxwing committed Jan 18, 2016
    Configuration menu
    Copy the full SHA
    f267157 View commit details
    Browse the repository at this point in the history

  2. Use standard Akka confs

    @zsxwing
    zsxwing committed Jan 18, 2016
    Configuration menu
    Copy the full SHA
    f650ff5 View commit details
    Browse the repository at this point in the history

  3. Use Function0 rather than ActorSystemFactory and update a lot of docs

    @zsxwing
    zsxwing committed Jan 18, 2016
    Configuration menu
    Copy the full SHA
    f2a07d4 View commit details
    Browse the repository at this point in the history

  4. Update zeromq

    @zsxwing
    zsxwing committed Jan 18, 2016
    Configuration menu
    Copy the full SHA
    463569c View commit details
    Browse the repository at this point in the history

  5. Minor doc fix

    @zsxwing
    zsxwing committed Jan 18, 2016
    Configuration menu
    Copy the full SHA
    4e25229 View commit details
    Browse the repository at this point in the history

Commits on Jan 19, 2016

  1. doc for Python API not supported

    @zsxwing
    zsxwing committed Jan 19, 2016
    Configuration menu
    Copy the full SHA
    9a1b275 View commit details
    Browse the repository at this point in the history

  2. Fix docs

    @zsxwing
    zsxwing committed Jan 19, 2016
    Configuration menu
    Copy the full SHA
    d495ecc View commit details
    Browse the repository at this point in the history

  3. Add a default ActorSystem

    @zsxwing
    zsxwing committed Jan 19, 2016
    Configuration menu
    Copy the full SHA
    0c8bd04 View commit details
    Browse the repository at this point in the history

  4. Remove some Java overloads

    @zsxwing
    zsxwing committed Jan 19, 2016
    Configuration menu
    Copy the full SHA
    5ac46f9 View commit details
    Browse the repository at this point in the history

Commits on Jan 20, 2016

  1. Add unit tests

    @zsxwing
    zsxwing committed Jan 20, 2016
    Configuration menu
    Copy the full SHA
    9e36df1 View commit details
    Browse the repository at this point in the history

  2. Fix the compiler error

    @zsxwing
    zsxwing committed Jan 20, 2016
    Configuration menu
    Copy the full SHA
    5e2ac50 View commit details
    Browse the repository at this point in the history

  3. Merge branch 'master' into streaming-akka-2

    @zsxwing
    zsxwing committed Jan 20, 2016
    Configuration menu
    Copy the full SHA
    c31be35 View commit details
    Browse the repository at this point in the history