HI all beam noob. i have written a beam app where i am processing content of a file for dbeugging purposes, i wanted to get a samle of the lines in the file..using the Sample combiner, but i cannot find any examples in python Here's my rough code
... | 'Filter only row longer than 100 chars' >> beam.Filter(lambda row: len(row) > 100) | 'sampling lines' >> beam.transforms.combiners.Sample() but the code above gives me TypeError: unsupported operand type(s) for >>: 'str' and 'Sample' Could anyone help? kind regards Marco
