[ https://issues.apache.org/jira/browse/FLINK-4088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jark Wu closed FLINK-4088. -------------------------- Resolution: Won't Fix This can be achieved by FLIP-129. > 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 SQL / API > Affects Versions: 1.1.0 > Reporter: Fabian Hueske > Priority: Minor > Labels: auto-deprioritized-major, auto-unassigned > > 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 (v8.3.4#803005)