Re: Handling Schema Variability and Applying Regex Patterns in Flink Job Configuration

2023-11-07 Thread arjun s
> file path. If this option is set, > > -- the connector will recursive > all files under the directory > > -- of `path` option > > > > Best, > > Yu Chen > > > > > >

Re: Handling Schema Variability and Applying Regex Patterns in Flink Job Configuration

2023-11-07 Thread Yu Chen
-- matched with the absolute file > path. If this option is set, > -- the connector will recursive all > files under the directory > -- of `path` option > > Best, > Yu Chen > >

Re: Handling Schema Variability and Applying Regex Patterns in Flink Job Configuration

2023-11-07 Thread arjun s
ill recursive all files > under the directory-- of `path` option > > > Best, > Yu Chen > > > [1] > https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/connectors/table/filesystem/ > > --

Re: Handling Schema Variability and Applying Regex Patterns in Flink Job Configuration

2023-11-06 Thread Andrew Otto
iles >> under the directory-- of `path` >> option >> >> >> Best, >> Yu Chen >> >> >> [1] >> https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/connectors/table/filesystem/ >&

Re: Handling Schema Variability and Applying Regex Patterns in Flink Job Configuration

2023-11-06 Thread arjun s
-- of `path` option > > > Best, > Yu Chen > > > [1] > https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/connectors/table/filesystem/ > > -- > *发件人:* arjun s > *发送时间:* 2023年11月6日 20:50 > *收件人:* user@flin

回复: Handling Schema Variability and Applying Regex Patterns in Flink Job Configuration

2023-11-06 Thread Chen Yu
-- of `path` option Best, Yu Chen [1] https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/connectors/table/filesystem/ 发件人: arjun s 发送时间: 2023年11月6日 20:50 收件人: user@flink.apache.org 主题: Handling Schema Variability and Applying Regex P

Handling Schema Variability and Applying Regex Patterns in Flink Job Configuration

2023-11-06 Thread arjun s
Hi team, I'm currently utilizing the Table API function within my Flink job, with the objective of reading records from CSV files located in a source directory. To obtain the file names, I'm creating a table and specifying the schema using the Table API in Flink. Consequently, when the schema match