google-cloud-dataflow

1зной

2ответ

Как сообщить о недопустимых данных при обработке данных с помощью потока данных Google?

Я смотрю documentation и provided examples, чтобы узнать, как я могу сообщить о недопустимых данных при обработке данных с помощью dataflow service. Pipeline p = Pipeline.create(options); p.apply(Tex

0зной

1ответ

разные кодеры для того же класса в работе потока данных

Я пытаюсь использовать разные кодеры для того же класса для двух различных сценариев: Чтение из входных файлов в формате JSON - с помощью data = TextIO.Read.from(options.getInput()).withCoder(new Code

0зной

1ответ

Тема безопасна для SerializableFunction в потоке облачных данных

Я реализую интерфейс SerializableFunction, и я хотел бы повторно использовать некоторые дорогие вспомогательные объекты, которые я создаю в конструкторе. Когда этот класс используется в задаче потока

2зной

1ответ

Тип машины для заданий потока данных Google Cloud

Я заметил, что есть опция, которая позволяет указать тип машины. Каковы критерии, которые я должен использовать, чтобы решить, следует ли переопределять тип машины по умолчанию? В некоторых эксперимен

0зной

1ответ

Сколько экземпляров JVM создается в каждом экземпляре GCE в Google Cloud Dataflow?

У меня всегда есть ровно 1 рабочий JVM рабочего потока данных для экземпляра GCE, или я могу когда-либо оказаться в ситуации, когда планировщик вращает несколько JVM на одном экземпляре GCE - например