如何在Apache Flink Streaming 0.10.0中指定覆盖到WriteEastText？
我在scala中有一个方法
计数。WritesText（指向文件的路径）
当文件已经存在时，它会引发异常，并建议指定文件或目录已经存在。在NO_OVERWRITE模式下不会覆盖现有文件和目录。使用OVERWRITE模式覆盖现有的文件和目录。但是我没有在DataStream类中找到一个接受org.apache.flink.core.fs.FileSystem的方法。WriteMode.只有一个签名接受Long为毫秒。
共有2个答案
请注意：这个问题现在已经解决了。您可以调用。WriteEasText（文件路径，org.apache.flink.core.fs.FileSystem.WriteMode.OVERWRITE）
Scala API当前缺少相应WriteMode参数的重载。这是一个错误，将被修复。
同时，您始终可以通过fs.overwrite-file配置参数控制Flink的默认覆盖行为。如果在flink-conf.yaml中将此参数设置为fs.overwrite-file： true，则写入文件将始终覆盖。
相应JIRA问题的状态可在此处找到。
-
问题内容： 我想覆盖指令ng-click：在每次执行ng-click之前进行一些$ rootscope更改。怎么做？ 问题答案： 您不能覆盖AngularJS内置指令。但是，您可以定义多个具有相同名称的指令，并使它们针对同一元素执行。通过为指令分配适当的值，您可以控制指令在内置指令之前还是之后运行。 该插件显示了如何构建在内置指令执行之前执行的指令。该代码也显示在下面。单击链接时，自定义将首先运行
-
问题内容： 例如，在Java中，注释不仅提供覆盖的编译时检查，而且还提供了出色的自记录代码。 我只是在寻找文档（尽管如果它是指示诸如pylint之类的检查器的指标，那是一个额外的好处）。我可以在某处添加注释或文档字符串，但是在Python中指示替代的惯用方式是什么？ 问题答案： 基于此和fwc：s的答案，我创建了一个pip可安装软件包 https://github.com/mkorpela/ove
-
问题内容： 我目前在glassfish v2.1中使用基于身份的身份验证来登录用户，并且工作正常。我想切换到该网站，并希望能够获得最初请求的URL（即在重定向到登录页面之前），并在我的程序化登录代码中使用它，以便在身份验证后将用户重定向回请求的页面。 我已经看过源代码-在我的情况下，它是（catalina代码库），它将初始请求保存在会话中的对象中，但是该会话不是，因此没有直接方法可以访问它。 还是
-
问题内容： 未正确探讨此问题。真正的问题在于。 原始问题中的第一个代码粘贴将产生预期的结果。但是，仍然需要注意。请参阅以下示例： 是 不 一样的 也就是说，不会自动调用与User对象关联的方法。 实际上 ，如果在模型上被覆盖，将生成以下描述。 摘要 这一切对我来说似乎很愚蠢。这似乎是在告诉我在指定类型时实际上并没有在调用。有人可以解释这里的实际情况吗？ 任何可以帮助我解决这个问题的精灵都可以回答我
-
问题内容： 我想创建一个具有任意大小的div，然后在该div上显示一些内容。完全按照CSS中下面的div定位和调整叠加层大小的最佳方法是什么？ 问题答案： 您可以使用将叠加层放置在div内部，然后在各个方向上将其拉伸，如下所示： CSS 已更新* 您只需要确保您的父div为其添加了属性，并为其设置了更低的属性。 为下面的评论者制作了一个可以在所有浏览器（包括IE7 +）上运行的演示。 从CSS中移
-
我想重写java中的getProperty（）方法。util。物业类别，请告知。 1.Spring上下文文件 2.Java类 3.配置文件 仅供参考：我正在从配置文件中提取批次值，并希望在从中获取值后调用trim（）。属性，以避免代码冗余，尝试重写getProperty（）方法。 使用：Spring 4.0