判断文件名中是否包含子串，一直进不去

人家用的是shell，结果一楼给个java代码，问答区真的演。

判断文件名中是否包含子串，其实很简单，就是长字符串是否包含短字符串，我这边给个例子：

1、使用[[ ... ]]

str="我是长字符串" 
subStr="我是短字符串" 

if [[ ${str} == *${subStr}* ]] ;then
    echo -e "字符串 '${str}' 包含: '${subStr}'."
else
    echo -e "字符串 '${str}' 不包含: '${subStr}'."
fi                       

2、使用grep

str="我是长字符串" 
subStr="我是短字符串"
 
if echo ${str} | grep ${subStr} ;then
    echo -e "字符串 '${str}' 包含: '${subStr}'."
else
    echo -e "字符串 '${str}' 不包含: '${subStr}'."
fi                       

3、使用=~

str="我是长字符串" 
subStr="我是短字符串"
 
if [[ ${str} =~ ${subStr} ]] ;then
    echo -e "字符串 '${str}' 包含: '${subStr}'."
else
    echo -e "字符串 '${str}' 不包含: '${subStr}'."
fi                       

用=～试试，*就不用写了。

此答案来自钉钉群“【2】Apache Flink China 社区”

可以使用Java语言中的String类的contains方法。我写个代码给你

public static void main(String[] args) throws Exception {
  StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
  DataStream<String> text = env.readTextFile("file:///path/to/file");
  text.filter(new FilterFunction<String>() {
    @Override
    public boolean filter(String value) throws Exception {
      return value.contains("substring");
    }
  }).print();
  env.execute("Flink Streaming Java API Skeleton");
}

但是得确保文件的路径是正确的，如果仍然进不去，请检查控制台输出的日志信息，以确定问题的根本原因。