Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Read ¶
func Read( scope beam.Scope, cfg ReadConfig, elemType reflect.Type, ) beam.PCollection
func Write ¶
func Write( scope beam.Scope, cfg WriteConfig, col beam.PCollection, )
Types ¶
type ReadConfig ¶
type WriteConfig ¶
Click to show internal directories.
Click to hide internal directories.