Удалить дубликаты через триггеры / срабатывания окон

Допустим, у меня есть неограниченный набор предложений, введенных с помощью идентификатора пользователя, и я хочу, чтобы постоянно обновлялось значение того,...

Обнаружение изменений состояния ключа

Как решить «Ни Jetty ALPN, ни OpenSSL через netty-tcnative не были правильно настроены»?

Как использовать memcache в потоке данных?

Как загрузить данные в Google Cloud Bigtable из Google BigQuery

Чтение нескольких файлов .gz и определение, какая строка принадлежит какому файлу

Я читаю несколько файлов .gz для обработки с использованием потока данных Google. Конечный пункт назначения данных - BigQuery. Таблица BigQuery имеет выделен...

Как получить максимальную метку времени текущего скользящего окна

Сбой потока данных с java.lang.NoSuchMethodError: io.grpc.protobuf.ProtoUtils.marshaller (Lcom / google / protobuf / Message;)

Я пытаюсь запустить задание Dataflow в Google Cloud. Это всегда терпит неудачу с:java.lang.NoSuchMethodError: io.grpc.protobuf.ProtoUtils.marshaller (Lcom / ...

Чтение CSV-заголовка с помощью Dataflow

У меня есть файл CSV, и я не знаю названия столбцов заранее. Мне нужно вывести данные в JSON после некоторых преобразований в Google Dataflow.Каков наилучший...

Использование неограниченных данных в окнах с триггером по умолчанию

у меня естьPub / Sub тема + подписка и хотите использовать и объединять неограниченные данные из подписки вПоток данных, Я использую фиксированное окно и зап...