Я пытаюсь написать функцию, которая читает данные из bigtable и конвертировать ByteString в Genric record - PullRequest
Новая
       5

Я пытаюсь написать функцию, которая читает данные из bigtable и конвертировать ByteString в Genric record

0 голосов
/ 08 января 2019

Я пытаюсь написать функцию BigTableAvroFn, которая читает строку больших таблиц и с помощью луча apache преобразует ее в общую запись Avro. Как преобразовать данные строки в общую запись? 

pipeline.apply("Read from Bigtable", read)
    .apply("Transform to Avro", ParDo(new BigtableToAvroFn()));

    return pipeline.run();
}

статический класс BigtableToAvroFn расширяется DoFn {

@ProcessElement
public void processElement(ProcessContext c) {
    Row row = c.element();
}

Поскольку я начинающий в Apache Beam, любая помощь будет принята с благодарностью.

...