Apache flink中数据流/运算符与线程的相关性
问题：
- 在运行时，引擎会为每个数据流创建一个线程吗？还是每个操作员一个线程？
- 是否可以在作业启动时在运行时动态创建数据流？（即，如果作业启动时从文件中读取N，并且需要创建相应的N个流）
- 当创建大量流(N~10000个）时，与在单个流中创建N个分区相比，是否有任何特定的性能影响？
共有1个答案
问题#1:在运行时，引擎会为每个数据流创建一个线程吗？还是每个操作员一个线程？
在我看来，流和运营商没有直接的关系。您需要查看执行计划，以便了解流是如何连接到操作符的。同时也依赖于并行性，在flink中也有各种类型的并行性
问题#2:是否可以在作业启动时在运行时动态创建数据流？
是的，有可能。简单的方法是创建一个流生成器，它实现RichParallelSourceFunction函数并以一定的速率发送流。
问题#3:当创建大量流(N~10000个）时，相对于单个流中的N个分区，是否有任何特定的性能影响？
是的，我认为会有一些性能影响，您可以通过生成多个流，然后比较处理延迟来证实这一点
-
左值1，是指位于表达式左边的变量，可以是与操作符直接结合的形成的，如自增，自减；也可以是赋值，位运算。 可以支持操作符有：-=,+=,*=,%=,|=,&=,^=,++,--。 特殊的运算符delete delete运算符，用于将某个变量重置为初始值。对于整数，运算符的效果等同于a = 0。而对于定长数组，则是把数组中的每个元素置为初始值，变长数组则是将长度置为0。对于结构体，也是类似，是将所有的
-
本节介绍简单的 C++ if 结构，使程序根据某些条件的真假做出判断。如果条件符合，即为真(true)，则执行if结构体的语句；如果不符合，即条件为假(false)，则不执行语句，稍后将举例说明。 if结构中的条件可以用相等运算符(equality operator)和关系运算符(relational operator)表示，如图1.13关系运算符具有相同的优先级，结合律为从左向右。相等运算符
-
赋值运算符 变量赋值，初始化或改变一个变量的值。 = 等号=赋值运算符，既可用于算术赋值，也可用于字符串赋值。 var=27 category=minerals # "="左右不允许有空格 注意，不要混淆=赋值运算符与=测试操作符。 # = 作为测试操作符 if [ "$string1" = "$string2" ] then command fi # [ "X$string1"
-
运算符相关的魔术方法实在太多了,j就大概列举下面两类： 1、比较运算符 魔术方法 说明 __cmp__(self, other) 如果该方法返回负数，说明 self < other; 返回正数，说明 self > other; 返回 0 说明 self == other。强烈不推荐来定义 __cmp__ , 取而代之, 最好分别定义 __lt__, __eq__ 等方法从而实现比较功能。 __cm
-
在脚本中，运算执行的顺序被称为优先级: 高优先级的操作会比低优先级的操作先执行。^1 表 8-1. 运算符优先级(从高到低) 运算符 含义 注解 var++ var— 后缀自增/自减 C风格运算符 ++var —var 前缀自增/自减 ! ~ 按位取反/逻辑取反 对每一比特位取反/对逻辑判断的结果取反 ** 幂运算 算数运算符 * / % 乘, 除, 取余 算数运算符 + - 加, 减 算数运算符
-
在学习基本的线程管理时，我发现很难理解书中的这些行（粗体）。 一旦您启动了线程，您需要明确地决定是等待它完成（通过与它连接--参见第2.1.2)还是让它自己运行（通过分离它--参见第2.1.3)。如果在std：：Thread对象被销毁之前没有做出决定，那么程序将被终止（std：：Thread析构函数调用std：：Terminate（））。因此，即使存在异常，也必须确保线程正确连接或分离。有关处理此