当前位置: 首页 > 知识库问答 >
问题:

运动学碎片迭代器解释

柏麒
2023-03-14

我正试着从动觉碎片中获取记录。我循环获取碎片迭代器,然后获取迭代器中的记录。我似乎得到了无数个迭代器,其中没有一个包含任何记录。

我的问题涉及迭代器的寿命。考虑到Kinesis只能保存24小时的数据,迭代器的寿命应该是5分钟,我不应该在任何时间点看到最多288个迭代器吗?

共有1个答案

苏高远
2023-03-14

没有固定数量的分片迭代器,因为分片迭代器只是给定分片中给定记录的唯一位置。

碎片迭代器只是碎片中某个点上给定记录的序列号。

根据这里的留档:

序列号是与流中摄取的每条记录相关联的标识符,并在将记录放入流时分配。每个流都有一个或多个分片

碎片迭代器指定开始顺序读取数据记录的碎片位置。

所以从上面来看,我相信分片迭代器实际上是一个基于时间戳的任意ID。

位置是使用碎片中数据记录的序列号指定的。

因此迭代器的数量实际上与给定碎片中记录的数量关系更密切。

 类似资料:
  • 好的,我将从一个详细的用例开始,并解释我的问题: 我使用第三方web分析平台,该平台利用AWS Kinesis流将数据从客户端传递到最终目的地--Kinesis流; web分析平台使用2个流: 数据收集器流(单个碎片流); 第二流,用于充实来自收集器流(单个碎片流)的原始数据;最重要的是,该流使用迭代器类型使用来自第一个流的原始数据; 我的问题是,我检索的数据不一致,没有时间逻辑在其中。 > 当我

  • 我可以使用一个片段作为一个活动吗?我已经创建了一个片段,但我希望它有像活动一样的功能,所以我使用片段扩展碎片活动。然而,我有一个带有碎片的导航抽屉。当我更改为“扩展碎片活动”时,我的代码有问题?请给我指路。

  • 如果在创建Kinesis数据流时,我指定了碎片的数量,比如说10个,并且每次我放入记录时,我都会给它分配一个随机分区键,如下所示: kinesis将如何决定将记录放入某个碎片中,如果唯一分区键的数量大于碎片的数量,会发生什么情况?

  • 问题 你想得到一个由迭代器生成的切片对象,但是标准切片操作并不能做到。 解决方案 函数 itertools.islice() 正好适用于在迭代器和生成器上做切片操作。比如: >>> def count(n): ... while True: ... yield n ... n += 1 ... >>> c = count(0) >>> c[10:20] Tr

  • 由于不推荐使用TabActivity,我需要找到一种方法来使用片段。在我知道它如何工作之前,我已经使用了碎片,但我需要一个指南来创建我的标签主机与碎片活动。我在互联网上找到了几个例子,它们都是关于将片段放入标签的容器中的。

  • 这似乎是一个具有挑战性的动画,但我有一种感觉,这可以很容易地完成。我正在尝试实现如下所示的片段之间的动画(请参阅第二和第三象限) 进入和退出并不难,但是预显示下一张和上一张卡片的屏幕以及无缝切换到下一张卡片超出了我的知识范围。如果有人制作过类似的动画,请给我一些指点。 编辑 Android的官方文档在点击时过渡,即当用户点击页面缩小以显示最后一页和上一页时,滑动将其移动到下一页。我的要求是将页面保