我已经看到了这两个流。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年,除了<代码>之外,它们基本上是相同的。名称(“打印到标准输出”)零件,对吗?
是的,这是相同的流。print()只是流的快捷方式。addSink(新的PrintSinkFunction
java prettyprint-override">@PublicEvolving
public DataStreamSink<T> print() {
PrintSinkFunction<T> printFunction = new PrintSinkFunction<>();
return addSink(printFunction).name("Print to Std. Out");
}
当我去Apache Spark流媒体网站时,我看到了一句话:
我使用包。当我编写''函数时,例如、等,会出现此错误消息。 错误:IllegalArgumentException(Java):您的InputStream既不是OLE2流,也不是OOXML流 在使用这个函数之前,我按照http://www.r-bloggers.com/get-r-and-java-1-8-to-work-cogether-on-osx/link的方式对R和Mac OS X之间的崩
我想读取Excel文件,这些文件以的形式通过REST传递。为此,我有类: 如果我用这个来运行这个: 很好用。但是,如果我将这个类与一起使用,来自over REST的 我包装流是因为如果我不这样做,我会得到这个异常:。我从这里得到的。 难道不能使用Apache POI和REST中的流来读取Excel文件吗?还是我做错了什么?
如果我想在Flink中分裂一个流,那么最好的方法是什么?
null 其中lambda1、2等是条件检查函数,例如 但不知什么原因对我不起作用,也许还有其他方法?正如我从文档(https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/side_output.html)中了解到的,OutputTag用于创建标记为tag的附加消息。还是我错了?