我已经使用管道生成器实现了流管道，一切正常。 它每 5 秒更新一次。现在我必须使用代码存储库实现相同的逻辑。想检查是否有人已经尝试过实施相同的方法以及它是如何工作的？ 是否有任何特定的装饰器或应该使用@increment？
Pipeline Builder 是构建流式管道的主要方式。
据我所知，您不能像使用 Pipeline Builder 那样使用代码存储库来定义流管道。
但是，您可以使用代码存储库来定义流 UDF，然后可以像任何其他转换一样从管道构建器中调用它。您基本上可以构建自己的函数“库”（可以输出 1 或 N 行，有键或无键等）并在 Pipeline Builder 中使用这些块。 https://www.palantir.com/docs/foundry/transforms-java/user-definition-functions#publish-to-a-deployment-repository