Beam / Dataflow PubsubIO: Когда назначается временная метка по умолчанию?

Question

Если атрибут отметки времени не назначен во время публикации или чтения, какая отметка времени используется для создания окон? Документация гласит, что система впервые видит каждую запись. Это топология потока данных системы или Pub / Sub?

Если атрибут timestampAttribute не указан, система сгенерирует запись временные метки в первый раз, когда он видит каждую запись. Все окна будут сделано относительно этих временных меток.

Answer 1

Отметка времени, назначаемая сообщениям, если вы не указали атрибут отметки времени, представляет собой «publishTime», установленный в сообщении pubsub.

См .: https://github.com/apache/beam/blob/50d0760faf01bdcdea988157a6b732bb448ba4b8/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubJsonClient.java#L178