Я выполняю запрос: "SELECT e.name,d.name FROM emp as e, department as d WHERE e.dept = d

Я реализовал пакетирование по N элементам, как описано в этом ответе: Может ли вход хранилища...

Я пытаюсь разделить мой конвейер на множество меньших конвейеров, чтобы они выполнялись быстрее.Я...

Я читал, что Combine более эффективно группирует PCollection по ключам, поскольку он может...

Можно ли получить доступ к номерам строк со строками, считанными в PCollection из TextIO.Read?Для...

Конвейер Пример использования: Этот конвейер читает файлы json из 30 каталогов GCS, каждый день...

У меня есть следующая структура BigTable для примера: Table1 : column_family_1 : column_1 : value...

После использования TextIO.read для получения PCollection<String> отдельных строк, возможно...

Вопрос связан с this . Я пытаюсь получить образец элементов в PCollection с использованием Python...

У меня есть PCollection, и я хотел бы использовать ParDo для фильтрации некоторых элементов из него

Autoscaling: Unable to reach resize target in zone us-central1-b. QUOTA_EXCEEDED: Quota...

Мы вытащили код BeamSql из главной ветви на GitHub, так как он, кажется, поддерживает поля типа...

У нас есть конвейер Apache Beam 2.4.0, который выполняет запросы BeamSql.В BeamSql оператор SQL...

Каковы лучшие практики, когда http вызывает из DoFn в конвейере, который будет работать в облачном...

У нас есть конвейер Apache Beam, и нам нужно выполнить несколько запросов BeamSql. Запросы не...

Я пытаюсь сгруппировать большое количество ключей, используя Apache Beam.Я не могу использовать...

Мы выполняем рабочий процесс Dataflow, который использует Kafka и записывает мгновенные файлы avro...

Извинения , пытаясь быть кратким и ясным, мое предыдущее описание моего вопроса превратилось в...

Мы используем Beam 2.2 java sdk с Google Dataflow Runner. Мы получаем пакеты данных за 4 часа в...