apache-flink

0зной

1ответ

Apache Flink Википедию редактировать аналитик с Scala

Я пытаюсь переписать википедия редактировать поток аналитик в Apache FLiNK учебников в Scala от https://ci.apache.org/projects/flink/flink-docs-release-1.2/quickstart/run_example_quickstart.html Код и

2зной

1ответ

Требует ли Apache Flink AWS S3 Sink Hadoop для локального тестирования?

Я относительно новичок в Apache Flink, и я пытаюсь создать простой проект, который создает файл в ведро AWS S3. Основываясь на документации, похоже, что для этого требуется, чтобы Hadoop был установле

3зной

1ответ

Есть примеры использования аккумулятора гистограммы в Flink

Я наткнулся на класс гистограммы в иерархии Flink, но там нет «вот как вы можете использовать эту» документацию вокруг него. Я хотел сделать что-то вроде: dataStream .countWindowAll(100) .fo

0зной

1ответ

категоризировать или GroupBy данных Datastream и процесс с КЭП отдельно

Предположим, у меня есть поток данных x:1, y:2 , z:3 , x:7 , y:-1, z:0, z:3 , z:2, y:3 ,x: 2 ,y:6 Как я положил x,y,z в их собственном ведре и применить мое правило КЭП на нем. x:1, x:7,x: 2 y:2, y

0зной

1ответ

SplitStream для динамического выходного ключа (Выбрать)

Это мой код. SplitStream<MonitoringEvent> splitStream = inputStream.split(new OutputSelector<MonitoringEvent>() { @Override public Iterable<String> select(MonitoringEvent me) { List<

1зной

3ответ

Невозможно записать на S3 с помощью S3-приемника с использованием StreamExecutionEnvironment - Apache Flink 1.1.4

Я создал простой проект Apache Flink, который будет считывать данные из темы Kafka и записывать эти данные в ведро S3. Я не получаю никаких ошибок при запуске проекта, и он успешно читает каждое сообщ

0зной

1ответ

Flink: Trigger.onElement работает

Я делаю функции на потоке данных, DataStream<Tuple4<String,String,Double,Double>> price_warning=datastream_in .flatMap(new Splitter())// transformation flatmap .keyBy(2) .window(SlidingProcessingTimeW

0зной

1ответ

СЕР - шаблон не выполняется после добавления окна

// Создание окна из десяти пунктов WindowedStream<ObservationEvent,Tuple,GlobalWindow> windowStream = inputStream.keyBy("rackId").countWindow(10); // Применение функционального окна, добавляя некото