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

是“流”。addSink(新的PrintSinkFunction())`和`流。print()`在Flink中也是一样

危飞跃
2023-03-14

我已经看到了这两个流。addSink(新的PrintSinkFunction

基于https://github.com/apache/flink/blob/b2a342c6a6ef154ed3c1a44826ce2be14e538386/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java#L972-1973年,除了<代码>之外,它们基本上是相同的。名称(“打印到标准输出”)零件,对吗?

共有1个答案

郎慎之
2023-03-14

是的,这是相同的流。print()只是流的快捷方式。addSink(新的PrintSinkFunction

java prettyprint-override">@PublicEvolving
public DataStreamSink<T> print() {
    PrintSinkFunction<T> printFunction = new PrintSinkFunction<>();
    return addSink(printFunction).name("Print to Std. Out");
}
 类似资料: