如何为Apache Flink DataStream提供数据
我对阿帕奇Flink是新手。我想创建一个DataStream，并向它提供来自另一个系统的值。
我找到了如何添加“SourceFunctions”的示例，在该函数中，我必须等待来自源代码的值，并通过调用CTX.Collect将这些值发布到Flink，然后再次等待，这就是轮询。
这能做到吗？否则，我必须在SourceFunction中执行连接和回调，然后用sleep做一个循环，但我不想这样做...
我已经在Flink中看到了“用于外部数据访问的异步I/O”，但为此我仍然需要一个源流，它是用SourceFunctions（poll/loop）提要的。
共有1个答案
如果不想在流作业中添加sourcefunction，我建议使用Kafka或其他消息队列，您可以将数据从异步源发送到这些队列，并将Flink流作业连接到消息队列。
-
问题内容： 我正在使用JDK 1.6.0_26中的VisualVM来分析在Tomcat下运行的Java Webapp，但是VisualVM经常告诉我它没有足够的内存来拍摄快照，并使用-Xmx开关为Netbeans提供更多的内存。 。问题是，我在Netbeans之外运行VisualVM，那么如何为jvisualvm.exe提供JVM参数？ 问题答案： 应该能够修改内存中的设置 并且在排队。
-
我需要为Spring Security的< code>UserDetailsService实现提供一个可选的附加参数。 举个简单的例子，假设我需要为属于用户的宠物传递一个宠物ID。 并非所有用户都有宠物，但如果它们有宠物，则实现 类有一个需要在登录时检索的宠物。 以下是我迄今为止所尝试的： 如何通过Spring安全登录页面传递附加参数 公认答案的问题是，实现在意识到和 我研究过的其他方法包括定制和
-
我正在使用和来记录WebApi2项目。我有一个使用XML正文并返回文本响应的操作。我希望留档包含XML输入的示例-例如
-
JAX-RS 具有 HTTP 谓词的注释（）和 （），但没有注释。如何为 HTTP 动词添加注释？ 如下所示：
-
我必须在我的项目中使用设计支持库的。我想在中的和之间留出空格。我在中设置了边距和填充，甚至在中也设置了边距和填充，但这两个都不起作用。这里我附上屏幕截图和我的编码。
-
问题内容： 如何将sql_variant参数添加到SQL CLR存储过程？使用System.Object不起作用，并且我看不到任何可以使用的属性。 问题答案： 在“从SQL Books Online映射CLR参数数据”中，列出了“对象”作为用于映射sql_variant的正确类型。 我创建了一个简单的SQL Server项目，并向其中添加了以下类： 然后，我修改了test.sql文件以执行此存储的