GitHub user r7raul1984 opened a pull request:
https://github.com/apache/eagle/pull/876
[IMPROVEMENT] Application base on Apache Beam
- Use beam pipeline powered by spark to run log parse application.
Just for reviewing , don't merge.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/r7raul1984/eagle beam
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/eagle/pull/876.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #876
----
commit f31b671e88232d517ba99d802023799a7e43f1f6
Author: r7raul1984 <[email protected]>
Date: 2017-02-22T08:00:54Z
Add beam application and enviroment .
commit f6908d4f8cd591f8bb34f60813f9d7577881c599
Author: r7raul1984 <[email protected]>
Date: 2017-02-22T08:41:12Z
Merge remote-tracking branch 'origin/master' into master-beam
commit 9e31f5c8e946651035893e12bc62e931ccee69bf
Author: r7raul1984 <[email protected]>
Date: 2017-02-23T02:59:12Z
Beam app draft.
commit d8f023daaa002268b0e30de263f2515000deda7e
Author: r7raul1984 <[email protected]>
Date: 2017-02-23T05:03:39Z
Merge remote-tracking branch 'origin/master' into master-beam
commit 9529d3a8390d9563d8beb7f285e686b7c1e555d0
Author: r7raul1984 <[email protected]>
Date: 2017-02-23T08:22:56Z
Add beam application module.
commit 984eac4f94d6168e36d5e9da681368fc7840d334
Author: r7raul1984 <[email protected]>
Date: 2017-02-27T08:45:55Z
Add beam application with kafka support .
commit eb0995982e3c02cbcb411f7d1308266ff639562c
Author: r7raul1984 <[email protected]>
Date: 2017-02-28T02:51:49Z
Use sparkpipeline result to track app status.
commit accc2b8a55a8596ad24e2bea6470d9031f2e00ed
Author: r7raul1984 <[email protected]>
Date: 2017-02-28T03:05:47Z
Modify metric system test to support kafka 0.9 api.
commit bdec4a7c01684725b7f76e1580504ab80275b9ac
Author: r7raul1984 <[email protected]>
Date: 2017-02-28T04:45:40Z
Modify some code.
commit 8c5e45c4b7fdb9f9ad12aac09025cd08147ada35
Author: r7raul1984 <[email protected]>
Date: 2017-03-10T05:51:11Z
Add kafka8IO dependency.
commit 3bf3c6bd3e74380ac60534c765f704ce040af245
Author: r7raul1984 <[email protected]>
Date: 2017-03-10T05:55:58Z
Add beam application and enviroment .
commit d4215a1dcca91ddf868e3759bea3fd143627d78a
Author: r7raul1984 <[email protected]>
Date: 2017-03-10T06:35:06Z
Fix some config
commit 9c178a2994ce18da453d79c854f06aef1892c72f
Author: r7raul1984 <[email protected]>
Date: 2017-03-10T09:09:20Z
Fix some dependency and modify app code.
commit 45a48292cee59bf4944c575ed93652165df018d2
Author: r7raul1984 <[email protected]>
Date: 2017-03-13T05:22:18Z
Fix kafka serializationexception by cast timestamp to string type.
commit 3d5c608e56efee795c83aed81930b995a7d186c4
Author: r7raul1984 <[email protected]>
Date: 2017-03-13T07:20:36Z
Modify dependency version.
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
