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
Date: 2017-02-22T08:00:54Z
Add beam application and enviroment .
commit f6908d4f8cd591f8bb34f60813f9d7577881c599
Author: r7raul1984
Date: 2017-02-22T08:41:12Z
Merge remote-tracking branch 'origin/master' into master-beam
commit 9e31f5c8e946651035893e12bc62e931ccee69bf
Author: r7raul1984
Date: 2017-02-23T02:59:12Z
Beam app draft.
commit d8f023daaa002268b0e30de263f2515000deda7e
Author: r7raul1984
Date: 2017-02-23T05:03:39Z
Merge remote-tracking branch 'origin/master' into master-beam
commit 9529d3a8390d9563d8beb7f285e686b7c1e555d0
Author: r7raul1984
Date: 2017-02-23T08:22:56Z
Add beam application module.
commit 984eac4f94d6168e36d5e9da681368fc7840d334
Author: r7raul1984
Date: 2017-02-27T08:45:55Z
Add beam application with kafka support .
commit eb0995982e3c02cbcb411f7d1308266ff639562c
Author: r7raul1984
Date: 2017-02-28T02:51:49Z
Use sparkpipeline result to track app status.
commit accc2b8a55a8596ad24e2bea6470d9031f2e00ed
Author: r7raul1984
Date: 2017-02-28T03:05:47Z
Modify metric system test to support kafka 0.9 api.
commit bdec4a7c01684725b7f76e1580504ab80275b9ac
Author: r7raul1984
Date: 2017-02-28T04:45:40Z
Modify some code.
commit 8c5e45c4b7fdb9f9ad12aac09025cd08147ada35
Author: r7raul1984
Date: 2017-03-10T05:51:11Z
Add kafka8IO dependency.
commit 3bf3c6bd3e74380ac60534c765f704ce040af245
Author: r7raul1984
Date: 2017-03-10T05:55:58Z
Add beam application and enviroment .
commit d4215a1dcca91ddf868e3759bea3fd143627d78a
Author: r7raul1984
Date: 2017-03-10T06:35:06Z
Fix some config
commit 9c178a2994ce18da453d79c854f06aef1892c72f
Author: r7raul1984
Date: 2017-03-10T09:09:20Z
Fix some dependency and modify app code.
commit 45a48292cee59bf4944c575ed93652165df018d2
Author: r7raul1984
Date: 2017-03-13T05:22:18Z
Fix kafka serializationexception by cast timestamp to string type.
commit 3d5c608e56efee795c83aed81930b995a7d186c4
Author: r7raul1984
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 infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
