:
Hello Flink community,
I am running into an issue with a custom FileInputFormat class and would
appreciate your help.
My goal is to read all files from a directory as paths:
val env : ExecutionEnvironment = ExecutionEnvironment.getExecut
ionEnvironment
var source : DataSet[String] = env.readFil
lo Flink community,
>
> I am running into an issue with a custom FileInputFormat class and would
> appreciate your help.
>
> My goal is to read all files from a directory as paths:
>
> val env : ExecutionEnvironment = ExecutionEnvironment.getExecut
> ionEnvironment
>
>
Hello Flink community,
I am running into an issue with a custom FileInputFormat class and would
appreciate your help.
My goal is to read all files from a directory as paths:
val env : ExecutionEnvironment =
ExecutionEnvironment.getExecutionEnvironment
var source : DataSet[String
