Dataflow

Você está implementando um pipeline Dataflow para processar dados de sensores em tempo real. O pipeline tem que processar dados com latência mínima e garantir exatamente uma vez na saída. Qual recurso do Dataflow/Apache Beam você deve usar para garantir a consistência dos dados com baixa latência?