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
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
you can collect an empty Collection
> for signalling that there was no result.
>
> Best,
> Aljoscha
>
> On 8. May 2017, at 21:47, Steve Robert <srob...@qualys.com> wrote:
>
> Hi guys,
>
> AsyncCollector.collect(Throwable) method seem to not release the
> Thread
return null;
});
}
it is 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
