Hi François,
you should read the documentation from top to bottom. The overview part
[1] explains how everything plays together with examples.
Regards,
Timo
[1]
https://ci.apache.org/projects/flink/flink-docs-master/dev/table/connect.html#overview
Am 30.08.18 um 10:41 schrieb Till Rohrmann:
Hi François,
as Vino said, the BatchTableEnvironment does not provide a
`withFormat` method. Admittedly, the documentation does not state it
too explicitly but you can only call the `withFormat` method on a
table connector as indicated here [1]. If you think that you need to
get the data from somewhere first before defining a format, then it
becomes clear that you first need to define a connector.
[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/table/connect.html#table-formats
Cheers,
Till
On Thu, Aug 30, 2018 at 4:46 AM vino yang <yanghua1...@gmail.com
<mailto:yanghua1...@gmail.com>> wrote:
Hi francois,
Maybe you can refer to the comments of this source code?[1]
https://github.com/apache/flink/blob/master/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/BatchTableEnvironment.scala#L143
Thanks, vino.
françois lacombe <francois.laco...@dcbrain.com
<mailto:francois.laco...@dcbrain.com>> 于2018年8月29日周三
下午10:54写道:
Hi Vino,
Thanks for this answer.
I can't find in the docs where it's about BatchTableDescriptor
https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/table/connect.html#csv-format
It sounds like the withFormat method is applied on
TableEnvironment object on this page.
All the best
François
2018-08-28 4:37 GMT+02:00 vino yang <yanghua1...@gmail.com
<mailto:yanghua1...@gmail.com>>:
Hi Francois,
Yes, the withFormat API comes from an instance of
BatchTableDescriptor, and the BatchTableDescriptor
instance is returned by the connect API, so you should
call BatchTableEnvironment#connect first.
Thanks, vino.
françois lacombe <francois.laco...@dcbrain.com
<mailto:francois.laco...@dcbrain.com>> 于2018年8月27日周一
下午10:26写道:
Hi all,
I'm currently trying to load a CSV file content with
Flink 1.6.0 table API.
This error is raised as a try to execute the code
written in docs
https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/table/connect.html#csv-format
ExecutionEnvironment env =
ExecutionEnvironment.getExecutionEnvironment();
BatchTableEnvironment tEnv =
TableEnvironment.getTableEnvironment(env);
tEnv.withFormat(new Csv(...));
> Exception in thread "main" java.lang.Error:
Unresolved compilation problem:
The method withFormat(Csv) is undefined for the
type BatchTableEnvironment
Am I wrong?
Thanks in advance for any hint
François