阅读时感到困惑https://github.com/datastax/spark-cassandra-connector/blob/master/doc/reference.md#read-调谐参数
concurrent.reads:为joinwithcassandra表设置读取并行性。
input.reads\ per\ u sec:设置joinwithcassandratable每秒每个核心的最大请求数
从datastax中的sde读取concurrent.reads的说明:https://groups.google.com/a/lists.datastax.com/d/msg/spark-connector-user/paqm1lt7qlk/h41wlnhfbaaj
Concurrent reads set to 4 means in a 4 core spark executor means, 16 requests will run MAX at the same time.
看起来concurrent.reads与input.reads每秒执行的操作相同。
他们之间真正的区别是什么?
1条答案
按热度按时间qxsslcnc1#
他们不一样,但可以被视为相关的。。。
concurrent.reads
定义每个核心可以同时发送多少个请求(所谓的飞行中请求)。在某些情况下,您可以将其从默认值降低,以避免cassandra节点因并行处理过多请求而过载;input.reads_per_sec
定义每秒每个核心可以执行的请求数。