apache-flink

1зной

1ответ

Обновление Dgraph в реальном времени с помощью Flink

Я ищу низкоуровневый граф DB, который позволяет выполнять глубинные запросы при обновлении в реальном времени. Возможно ли обновление Dgraph в реальном времени с помощью процессов Flink? Я хотел бы по

0зной

1ответ

Масштабирование потока Apache Flink

Я новичок в Apache Flink и стараюсь понять некоторые рекомендации по масштабированию работ Flink Streaming вместе с Kafka. Некоторые вопросы, на которые я не могу найти ответы, включают: Сколько поток

1зной

1ответ

Пытается расширить Gelly Graph

Я пытаюсь расширить Gelly Graph на график с краями с Tuple5 вместо Tuple 3. Это невозможно, расширив гелевый график, поскольку конструктор является закрытым. Я пошел вперед и создал свой собственный к

1зной

1ответ

Flink Gelly расширения края класс и использовать его в DataSet

В Gelly я пытаюсь сделать специальную Грань называется височного края, чтобы сделать это проще я сделал класс под названием Temporaledgev3: public class TemporalEdgev3<K, V> extends Edge<K, Tuple3<V,I

0зной

1ответ

Flink Кафка Connector ошибка во время выполнения

Я использую: Flink 1.1.2 Кафка 2.10-0.10.0.1 Flink разъем-Кафка-0.9.2.10-1.0.0 Я использую следующий очень простой/базовое приложение Properties properties = new Properties(); properties.setPr

1зной

1ответ

Share state среди операторов в Flink

Интересно, возможно ли во Flink делиться состоянием между операторами. Скажите, например, что у меня есть разделение по ключу на операторе, и мне нужно часть состояния раздела A внутри раздела C (по к