Я хочу сделать поток небольших данных, вызывая его снова и снова

Question

У меня вопрос, у меня есть небольшие данные CSV, которые я могу запустить на лету с помощью kafka. У меня вопрос: могу ли я вызывать одни и те же данные снова и снова, используя окно и триггер, или он будет вызывать мои данные только один раз?

1,35
2,45
3,55
4,65
5,555 

Это те данные, которые я хочу вызывать снова и снова,Хотя я и сам так не думаю, поэтому лучше принять второе мнение, потому что я новичок. Спасибо за помощь

Answer 1

Не уверен, что вы подразумеваете под данными о вызовах снова и снова. Но вы можете создать поток этих данных в Flink, используя SourceFunction. Например, следующий источник создает поток этого CSV-файла и генерирует его каждую секунду.

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

DataStream<String> csvStream = env.addSource(new SourceFunction<String>() {
    @Override
    public void run(SourceContext<String> sourceContext) throws Exception {
        String data = "1,35\n" +
                "2,45\n" +
                "3,55\n" +
                "4,65\n" +
                "5,555";

        while(true) {
            sourceContext.collect(data);
            TimeUnit.SECONDS.sleep(1);
        }
    }

    @Override
    public void cancel() {

    }
});