You don't have to wrap the existing socket source. You will have to
create your own source function which directly reads from the web
socket and forwards the results to the next Flink operator. Then you
will call env.addSource(new YourWebSocketSource());
To get started, you might want to read the
Like Fabian said, there is no built-in solution. If you want to use
encryption over a socket, you will have to implement your own socket
source using an encryption library.
On Wed, Oct 5, 2016 at 10:03 AM, Fabian Hueske wrote:
> Hi,
>
> the TextSocketSink is rather meant for demo purposes than to
Hi,
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 A
