Hi Frank ,
I think we have a similar case in my case I should be able to set the pojo
from the outside to analyze API-REST.
my strategy in my case and define my schema by using a JSON to convert JSON
data formats to Flink Row
so for example imagine your date is something like this : public stati
a custom TableSource that queries the data from
> the rest API and converts the JSON directly into a Row data type.
> This would also avoid going through the DataStream API just for ingesting
> the data.
>
> Best, Fabian
>
> Am Mi., 4. Sept. 2019 um 15:57 Uhr schrieb Ste
Hi guys ,
It's been a while since I'm studying TABLE APIs for integration into my
system.
when i take a look on this documentation
:
https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/table/connect.html#connectors
I understand that it is possible to apply a JSON FORMAT on the connec
ction
> for signalling that there was no result.
>
> Best,
> Aljoscha
>
> On 8. May 2017, at 21:47, Steve Robert wrote:
>
> Hi guys,
>
> AsyncCollector.collect(Throwable) method seem to not release the
> Thread.
> This scenario may be problematic when calling an
possible to create an empty Collection and collect this empty
collection to force the Thread to be released but this workflow seems
strange to me.
thank for your help
--
Steve Robert <https://www.linkedin.com/company/qualys>
Software Engineer
srob...@qualys.com
T
Qualys, Inc. – Contin
