flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fabian Hueske <fhue...@gmail.com>
Subject Re: Processing events through web socket
Date Wed, 05 Oct 2016 08:03:30 GMT

the TextSocketSink is rather meant for demo purposes than to be used in an
actual applications.
I am not aware of any other built-in source that would provide what you are
looking for.
You can implement a custom SourceFunction that does what you need.

Best, Fabian

2016-10-05 9:48 GMT+02:00 Abdul Salam Shaikh <abd.salam.shaikh@gmail.com>:

> I am trying to read data over a websocket from a source(For example wss://
> brisbane.unipulse.com.au:443/OutboundInterfaces/outbound/statements). But
> at the moment the implementation of env.socketTextStream only supports
> plain TCP and has no support for TLS or higher level protocols​. Is there
> any other wrapper/third party API implementation which I can use on top of
> flink to act as a streaming service before transmitting it to flink ?
> --
> Thank
> ​s.​

View raw message