Documentation ¶ Index ¶ func DataframeTransform(expansionAddr string) *beam.Pipeline type TestRow Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ func DataframeTransform ¶ func DataframeTransform(expansionAddr string) *beam.Pipeline Types ¶ type TestRow ¶ type TestRow struct { A int64 `beam:"a"` B int32 `beam:"b"` } Source Files ¶ View all Source files dataframe.go Click to show internal directories. Click to hide internal directories.