Serialized Form

Package org.apache.beam.sdk.io.components.deadletterqueue

Class org.apache.beam.sdk.io.components.deadletterqueue.DLQRouter extends org.apache.beam.sdk.transforms.PTransform<@NonNull org.apache.beam.sdk.values.PCollectionTuple,@NonNull org.apache.beam.sdk.values.PCollection<T>> implements Serializable

Serialized Fields

badMessages

org.apache.beam.sdk.values.TupleTag<K> badMessages

errorSink

org.apache.beam.sdk.transforms.PTransform<@NonNull org.apache.beam.sdk.values.PCollection<K>,?> errorSink

goodMessages

org.apache.beam.sdk.values.TupleTag<T> goodMessages

Package org.apache.beam.sdk.io.components.deadletterqueue.sinks

Class org.apache.beam.sdk.io.components.deadletterqueue.sinks.ThrowingSink extends org.apache.beam.sdk.transforms.PTransform<@NonNull org.apache.beam.sdk.values.PCollection<T>,@NonNull org.apache.beam.sdk.values.PDone> implements Serializable

Class org.apache.beam.sdk.io.components.deadletterqueue.sinks.ThrowingSink.ThrowingDoFn extends org.apache.beam.sdk.transforms.DoFn<T,org.apache.beam.repackaged.core.org.apache.commons.lang3.ObjectUtils.Null> implements Serializable

Package org.apache.beam.sdk.io.components.ratelimiter

Class org.apache.beam.sdk.io.components.ratelimiter.EnvoyRateLimiter extends java.lang.Object implements Serializable

Serialized Fields

context

EnvoyRateLimiterContext context

factory

EnvoyRateLimiterFactory factory

Class org.apache.beam.sdk.io.components.ratelimiter.EnvoyRateLimiterContext extends java.lang.Object implements Serializable

Class org.apache.beam.sdk.io.components.ratelimiter.EnvoyRateLimiterFactory extends java.lang.Object implements Serializable

Serialized Fields

options

RateLimiterOptions options

requestsAllowed

org.apache.beam.sdk.metrics.Counter requestsAllowed

requestsThrottled

org.apache.beam.sdk.metrics.Counter requestsThrottled

requestsTotal

org.apache.beam.sdk.metrics.Counter requestsTotal

rpcErrors

org.apache.beam.sdk.metrics.Counter rpcErrors

rpcLatency

org.apache.beam.sdk.metrics.Distribution rpcLatency

rpcRetries

org.apache.beam.sdk.metrics.Counter rpcRetries

sleeper

org.apache.beam.sdk.util.Sleeper sleeper

throttlingSignaler

ThrottlingSignaler throttlingSignaler

Class org.apache.beam.sdk.io.components.ratelimiter.RateLimiterOptions extends java.lang.Object implements Serializable