This project is to transform for reading and writing gzip files in apache beam.
And it is using to official Go SDK on apache beam.
import (
gzipio "github.com/gjbae1212/go-apachebeam-gzipio"
)
p, s := beam.NewPipelineWithRoot()
// Read files
gzipio.Read(s, "read-path")
// Write file
gzipio.Write(s, "write-path", pcollection)
This project is licensed under the MIT License