在Dataflow管道中解析Stackdriver LogEntry JSON

I'm building a Dataflow pipeline to process Stackdriver logs, the data are read from Pub/Sub and results written into BigQuery. When I read from Pub/Sub I get JSON strings of I'm building a Dataflow pipeline to process Sta