Package org.apache.beam.sdk.io.gcp.spanner.changestreams.estimator
package org.apache.beam.sdk.io.gcp.spanner.changestreams.estimator
Classes related to estimating the throughput of the change streams SDFs.
-
ClassDescriptionAn estimator to provide an estimate on the throughput of the outputted elements.Represents an error during encoding (serializing) a class.NoOp implementation of a throughput estimator.This class is used to estimate the size in bytes of a given element.An estimator to calculate the throughput of the outputted elements from a DoFn.