kellen
kellen
Estimate the size of input collections and allow users to configure (rough) numBytes rather than numShards. I propose dropping `numShards` completely. Also propose dropping special handling of "unsharded" sparkey and...
Annotated BQ classes are transformed into case classes but the plugin lacks the `copy` method so IntelliJ reports an error
``` import com.google.protobuf.Any // if imported, will throw a coder error below case class A(userId: Int) object Job { def main(cmdlineArgs: Array[String]): Unit = { implicitly[com.spotify.scio.coders.Coder[A]] } } ``` Throws:...
Internal spotify discussions suggest that the default `maxPendingRequests=1` may no longer be a good default and a higher value (e.g. `6`) may make more sense for batch. We should write...
Adds support for Beam's managed transforms and for Iceberg, which is implemented as a managed transform. Note this is on a snapshot of magnolify, will need a release before merge.
Releases are currently manual
I looked into whether importing some subset of chill was reasonable but most of the various chill deps are kryo serializers or registrars, so appear to be required for our...
non-draft status for CI