mozilla-services / foxsec-pipeline

Log analysis pipeline utilizing Apache Beam
Mozilla Public License 2.0
25 stars 9 forks source link

Replace filter step w/ output tuple #475

Closed kkleemola closed 4 years ago

kkleemola commented 4 years ago

Replaces filtering the entire input for each resource with a single filter step with a pcollection tuple where each resource has a tag with id=resource indicator.