Как использовать System.console в качестве источника Apache Flink

Question

Как использовать System.console в качестве источника Apache Flink

C # 3.0:

string html = new Func<string>(() =>
{
    string webpage;

    try
    {
        using(WebClient downloader = new WebClient())
        {
            webpage = downloader.DownloadString(url);
        }
    }
    catch(WebException)
    {
        Console.WriteLine("Download failed.");  
    }

    return webpage;
})();

0

java apache-flink flink-streaming

задан AsadSMalik 18 January 2019 в 17:41

1 ответ

Другие вопросы по тегам:

java apache-flink flink-streaming

Похожие вопросы:

score 0 · Answer 1

Использование консоли в качестве источника данных, безусловно, выполнимо, но есть проблема, заключающаяся в том, что ваше приложение не будет отказоустойчивым, поскольку Flink не сможет перематывать и воспроизводить входной поток в случае сбоя. [114 ]

Но это часто делается для прототипов и экспериментов, обычно с SocketTextStreamFunction, как в

env.addSource(new SocketTextStreamFunction("localhost", 9999, "\n", -1))

. Затем вы можете использовать netcat для подключения консоли к порту 9999

nc -lk 9999

[117 ] или, как требуют некоторые версии netcat,

nc -l -p 9000