Neville Li
Neville Li
That test you linked doesn't cover `Arbitrary[List[T]]` though, which summons `CanBuildFrom` transitively. So it was probably an unused import. Forking for 2.13 might be a different issue since `CanBuildFrom` was...
Some builds failed because of sbt classloading: ``` [error] Test suite com.twitter.chill.java.PriorityQueueSpec failed with java.lang.ClassNotFoundException: com.twitter.chill.java.TestPriorityQueue$$Lambda$6275/1415420090. [error] This may be due to the ClassLoaderLayeringStrategy (ScalaLibrary) used by your task. [error]...
:+1: on the mutable backed BF & immutable `present` idea. But of course I'm biased since we use BF a lot internally. @johnynek any thoughts?
https://github.com/trinodb/trino/actions/runs/3333395748/jobs/5516194415 from #14734
@lukasz-walkiewicz yeah I left those alone for this exact reason. Can save them for later.
This is more of an internal use case i.e. granting limited views to sensitive data sets without full access. Most of the work will probably be done in our internal...
@francescoperera Also curious if your company has similar problem with ACL management and if something like authorized views can help.
Since we don't know the level of parallelism due to machine type, autoscaling, etc., the easiest would be sample `n` in memory for each `DoFn` thread and do a random...
It might be possible of the `k` items in each stream are weighted, i.e. with a random number. Similar to how Beam's transform work?
@pabloem sounds good! Can you link the JIRA ticket here once filed?