Skip to content
#

beam

Here are 195 public repositories matching this topic...

kellen
kellen commented Aug 26, 2020

When using e.g. AvroSortedBucketIO, if a file pattern is passed as part of the input path, scio should output a helpful error message. Current behavior in 0.9.3 leads to a NullPointerException.

val myEntityPaths: List[String] = List(
  "gs://bucket/dir1/*.avro",
  "gs://bucket/dir2/*.avro",
)
sc.sortMergeCoGroup(
  classOf[String],
  AvroSortedBucketIO
    .read(new TupleTag[MyE

Improve this page

Add a description, image, and links to the beam topic page so that developers can more easily learn about it.

Curate this topic

Add this topic to your repo

To associate your repository with the beam topic, visit your repo's landing page and select "manage topics."

Learn more

You can’t perform that action at this time.