forked from https://github.com/GoogleCloudPlatform/DataflowTemplates/tree/7af50b7dc86b80285bb706549a3d5d6b7b2f03ff