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

2023-11-07 Thread arjun s
ectory > > -- of `path` option > > > > Best, > > Yu Chen > > > > > > [1] > https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/connectors/table/filesystem/ > > > > 发件人: arjun s > > 发送时间

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

2023-11-07 Thread Yu Chen
ecursive 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/ > > 发件人: arjun s > 发送时间: 2023年

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

2023-11-07 Thread arjun s
en > > > [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 Applyi

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

2023-11-06 Thread Andrew Otto
-- 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
ath` 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 Patterns in Flink Job Configuration

2023-11-06 Thread Chen Yu
` 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 Patterns in Flink Job

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