什么是TopicTopic翻译过来是主题的意思，一个Topic就像数据库中的一张表。Producer发布的消息可以带有主题，主题相同的消息记录放在一个集合里。什么是PartitionPartition是最小的存储单元，每个Partition都是一个单独的log文件，每条记录都以追加的形式写入。Topic在Partition里如何体现如下图，一份topic的数据有三部分组成，下图设置的分片数是2。在下图中一份topic的数据=replica0_1+replica1_1+replica2_1,但是为了保证容错率每一部分的数据需要在另外一台机器（broker）进行备份，比如在Borker1这台机器上

ExtractingvalueusingWindowandPartition我在pyspark中有一个数据框12345678910id|value1  01  11  02  12  03  03  03  1我想提取同一id组中value列中第一次出现1之后的所有行。我创建了带有Id分区的窗口，但不知道如何获取值1之后存在的行。我期待结果是1234567 id|value  1  1  1  0  2  1  2  0  3  1你有定义窗口内排序的东西吗？否则我认为结果将是不确定的我只能按id列订购。底层数据模型是一个集合，而不是一个列表，例如对于id=1，值0、1和0可以按任何顺序处理。

ExtractingvalueusingWindowandPartition我在pyspark中有一个数据框12345678910id|value1  01  11  02  12  03  03  03  1我想提取同一id组中value列中第一次出现1之后的所有行。我创建了带有Id分区的窗口，但不知道如何获取值1之后存在的行。我期待结果是1234567 id|value  1  1  1  0  2  1  2  0  3  1你有定义窗口内排序的东西吗？否则我认为结果将是不确定的我只能按id列订购。底层数据模型是一个集合，而不是一个列表，例如对于id=1，值0、1和0可以按任何顺序处理。