Skip to content
This repository has been archived by the owner on May 12, 2021. It is now read-only.

[IMPROVEMENT] Application base on Apache Beam #876

Closed
wants to merge 82 commits into from

Conversation

r7raul1984
Copy link

  • Use beam pipeline powered by spark to run log parse application.

Just for reviewing , don't merge.

r7raul1984 added 30 commits February 22, 2017 08:00
- EAGLE-424
 - Support kafka add/remove topic without requiring restart of the alert engine
 - Read spec metadata by restful web app
 - Create UnitSparkTopologyRunner to demo spark streaming usage
- EAGLE-425
 - Use Spark Accumulator to save and recover state
 - Use Spark Accumulator to support Hybird Time Window

https://issues.apache.org/jira/browse/EAGLE-348
…est/metadata/policies/validate" by jackson-module-afterburner to 2.6.0 .
…function.

- Write a checkpoint JavaStreamingContext code.
@jhsenjaliya
Copy link
Contributor

Hi @r7raul1984 , do you have any update for this PR ?

@r7raul1984
Copy link
Author

@jhsenjaliya no update for this PR

@jhsenjaliya
Copy link
Contributor

jhsenjaliya commented Sep 5, 2017

@r7raul1984 can you provide more info or status on this PR? is there a plan to get this platform update into Apache Eagle ? it would be awesome btw.
also does this only need rebase ? is this PR working and tested ? please let us know.

@r7raul1984 r7raul1984 closed this Sep 6, 2017
@r7raul1984
Copy link
Author

@jhsenjaliya I will do more work on it, so i closed the pr.

Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
None yet
Projects
None yet
4 participants