我有一个数据流,它具有用于Sink活动的参数化数据集。在dataset中,它有一个我已配置为用作文件名的参数。
在Dataflow接收器活动“设置”中,应该使用什么“文件名”选项来调用我在这里的数据流设置中指定的文件名:
如果我将"Filename选项“设置为"Output to single file”,然后将"Output to single file“保留为空,则会失败。
如果我将"Filename选项“设置为"Default”,它将无法工作。
如果我将其设置为“输出单个文件”并指定"@dataset().Fi
我有一个关于Ignite的流媒体部分的问题。
我所理解的是,这是一种将数据导入缓存的方法,但我也看到,我们可以配置流接收器来应用一些其他自定义逻辑。
因此,我尝试创建一个带有接收器的类和一个将数据注入到流中的类(服务器模式下有2个main和2个Ignite实例),但我“只是”将数据放到了streamer的缓存中(没有任何自定义逻辑处理到接收器中)。所以,我问我是不是遗漏了什么,或者我没有很好地理解Ignite中的流是什么。
如果我把发送者的部分放入接收者,我就有了指纹。
有人知道我做错了什么(或理解错了什么)吗?
Receiver类:
public class Receiver {
p