Skip to content
New issue

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

#

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

Already on GitHub? # to your account

Jump to bottom

Streamline - Flink Runner - Rules processor support #541

Open
arunmahadevan opened this issue Apr 11, 2017 · 1 comment
Open

Streamline - Flink Runner - Rules processor support #541

arunmahadevan opened this issue Apr 11, 2017 · 1 comment
Labels
enhancement

Comments

@arunmahadevan
Copy link
Contributor

This is a subtask of #535

Streamline has support for rules executed via RuleProcessorRuntime. The design time (layout) representation of this is RulesProcessor.

This task is to translate and execute rule in flink by reusing the RuleProcessorRuntime.

Refer:
RuleProcessorRuntime
RulesProcessor
RulesBolt
@arunmahadevan
Copy link
Contributor Author

Thinking about it further, it maybe possible to directly express the rule filter conditions in the flink table apis (if using the flink table APIs for the runner).

# for free to join this conversation on GitHub. Already have an account? # to comment
Assignees
No one assigned
Labels
enhancement
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
2 participants
@harshach @arunmahadevan