ApacheBeamTextIO.read().from()在文件模式中不解释转义的特殊字符。
创始人
2024-09-05 12:01:49
0

在文件模式中使用反斜杠转义特殊字符,或使用正则表达式来匹配文件名。以下是一些示例代码:

方法一:使用反斜杠转义特殊字符

Pipeline p = Pipeline.create();
PCollection lines = p.apply(TextIO.read().from("file:///path/to/file\\[1-3\\].txt"));

此示例中,文件路径中包含转义的方括号,用于匹配文件名中的数字范围。

方法二:使用正则表达式

Pipeline p = Pipeline.create();
PCollection lines = p.apply(TextIO.read().from("/path/to/files/*")
                .withHintMatchesManyFiles()
                .withCompressionType(CompressionType.AUTO)
                .withCoder(StringUtf8Coder.of())
                .withDelimiter("\\n")
                .withFilenamePolicy(
                        DefaultFilenamePolicy.constructUsingStandardParameters(
                                new SerializableFunction() {
                                    @Override
                                    public ResourceId apply(String input) {
                                        return FileBasedSink.convertToFileResourceIfPossible(input);
                                    }
                                },
                                "output",
                                ".txt",
                                false
                        ))
                .withParseFn(new DoFn() {
                    @ProcessElement
                    public void processElement(ProcessContext c) {
                        // process each line
                        String line = c.element();
                        c.output(line);
                    }
                }));

此示例中,文件路径中使用通配符“*”来匹配文件名。但是,使用withHintMatchesManyFiles()方法和withFilenamePolicy()方法来指定文件名的过滤器和解释器,并使用正则表达式来匹配文件名的模式。同时,使用withParseFn()方法来处理每一行的数据。

相关内容

热门资讯

安装了Anaconda之后找不... 在安装Anaconda后,如果找不到Jupyter Notebook,可以尝试以下解决方法:检查环境...
安装安卓应用时出现“Play ... 在安装安卓应用时出现“Play Protect 警告弹窗”的原因是Google Play Prote...
iwatch怎么连接安卓系统,... 你有没有想过,那款时尚又实用的iWatch,竟然只能和iPhone好上好?别急,今天就来给你揭秘,怎...
vivo安卓系统取消更新系统,... 亲爱的vivo手机用户们,你们是不是也遇到了这样的烦恼:手机里突然冒出一个更新提示,点开一看,哇,新...
安卓系统怎么连不上carlif... 安卓系统无法连接CarLife的原因及解决方法随着智能手机的普及,CarLife这一车载互联功能为驾...
避免在粘贴双引号时向VS 20... 在粘贴双引号时向VS 2022添加反斜杠的问题通常是由于编辑器的自动转义功能引起的。为了避免这个问题...
安装apache-beam==... 出现此错误可能是因为用户的Python版本太低,而apache-beam==2.34.0需要更高的P...
iqoo安卓14系统怎么升级系... 亲爱的iQOO手机用户们,是不是觉得你的手机系统有点儿落伍了呢?别急,今天就来手把手教你如何升级到最...
Android Recycle... 要在Android RecyclerView中实现滑动卡片效果,可以按照以下步骤进行操作:首先,在项...
oppo手机安卓系统换成苹果系... OPPO手机安卓系统换成苹果系统:现实吗?如何操作?随着智能手机市场的不断发展,用户对于手机系统的需...