[
https://issues.apache.org/jira/browse/IGNITE-3303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15423029#comment-15423029
]
Saikat Maitra commented on IGNITE-3303:
---------------------------------------
[~avinogradov]
Hi Anton,
Thank you for your feedback. I will review and update the changes. The
LinkedBlockingQueue is static as we would like to have single queue for the
source. The IgnitePredicate filter can be static as it does not have a state
associated with it and it just filter on CacheEvents.
{code} synchronized (ctx.getCheckpointLock()) {code} is necessary as mentioned
in the flink docs for SourceFunction.
https://ci.apache.org/projects/flink/flink-docs-release-0.9/api/java/org/apache/flink/streaming/api/functions/source/SourceFunction.html#run-org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext-
Regards
Saikat
> Apache Flink Integration - Flink source to run a continuous query against one
> or multiple caches
> ------------------------------------------------------------------------------------------------
>
> Key: IGNITE-3303
> URL: https://issues.apache.org/jira/browse/IGNITE-3303
> Project: Ignite
> Issue Type: New Feature
> Components: streaming
> Reporter: Saikat Maitra
> Assignee: Anton Vinogradov
>
> Apache Flink integration
> +++ *Ignite as a bidirectional Connector* +++
> As a Flink source => run a continuous query against one or multiple
> caches [4].
> Related discussion :
> http://apache-ignite-developers.2346864.n4.nabble.com/Apache-Flink-lt-gt-Apache-Ignite-integration-td8163.html
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
