Package org.apache.beam.sdk.io.gcp.bigtable.changestreams.estimator
@Internal
package org.apache.beam.sdk.io.gcp.bigtable.changestreams.estimator
Classes related to estimating the throughput of the change streams SDFs. This is initially copied
from the Spanner change streams implementation. They are currently separate since both features
are under active development and may diverge
-
ClassDescriptionAn estimator to provide an estimate on the byte throughput of the outputted elements.This class is used to estimate the size in bytes of a given element.Represents an error during encoding (serializing) a class.NoOp implementation of a size estimator.