我正在尝试写一个BigTableAvroFn函数,它读取bigtable行,并使用apache光束将其转换为Avro通用记录.How我是否可以将行数据转换为一般记录?
pipeline.apply("Read from Bigtable", read)
.apply("Transform to Avro", ParDo(new BigtableToAvroFn()));
return pipeline.run();
}
静态类BigtableToAvroFn扩展了DoFn {
@ProcessElement
public void proces
我在从本地机器向我们的云平台提交Apache光束示例时遇到了问题。
但是当我尝试运行python wordcount示例时,我得到了以下错误:
IOError: Could not upload to GCS path gs://my_bucket/tmp: access denied.
Please verify that credentials are valid and that you have write access
to the specified path.