我是Common的新手,我正在尝试从Clojure实现一个repeatedly。例如这将收集5 (rand-int 11)调用,并返回一个列表:(10 1 3 0 2)。目前,我正在做的事情是: (loop for x from 1 to n这看起来不太好,我不得不这样称呼它:(repeatedly 5 #'random
我们有一个从pub/sub读取并写入bigquery的流管道。在不添加窗口函数的情况下,它无法工作,因为默认的全局窗口只触发一次,并且不知道何时重新触发。没有GroupBy或组合。我们真正想要的是一条从pub/sub读取的管道,不管它能得到多少,它都会得到一批,写到bigquery,一旦写好了所有的东西,并且确认了pubsub消息,就会重新触发read- from -pubsub。这个是可能的吗