Fabian Hueske created FLINK-4088: ------------------------------------ Summary: Add interface to save and load TableSources Key: FLINK-4088 URL: https://issues.apache.org/jira/browse/FLINK-4088 Project: Flink Issue Type: Improvement Components: Table API & SQL Affects Versions: 1.1.0 Reporter: Fabian Hueske
Add an interface to save and load table sources similar to Java's {{Serializable}} interface. TableSources should implement the interface to become saveable and loadable. This could be used as follows: {code} val cts = new CsvTableSource( "/path/to/csvfile", Array("name", "age", "address"), Array(BasicTypeInfo.STRING_TYPEINFO, ...), ... ) cts.saveToFile("/path/to/tablesource/file") // ----- val tEnv: TableEnvironment = ??? tEnv.loadTableSource("persons", "/path/to/tablesource/file") {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)