Serialized Form

Package org.apache.beam.runners.jet.metrics

Class org.apache.beam.runners.jet.metrics.BoundedTrieImpl extends org.apache.beam.runners.jet.metrics.AbstractMetric<org.apache.beam.runners.core.metrics.BoundedTrieData> implements Serializable

Serialized Fields

boundedTrieDataData

org.apache.beam.runners.core.metrics.BoundedTrieData boundedTrieDataData

Class org.apache.beam.runners.jet.metrics.CounterImpl extends org.apache.beam.runners.jet.metrics.AbstractMetric<java.lang.Long> implements Serializable

Serialized Fields

count

long count

Class org.apache.beam.runners.jet.metrics.DistributionImpl extends org.apache.beam.runners.jet.metrics.AbstractMetric<org.apache.beam.runners.core.metrics.DistributionData> implements Serializable

Serialized Fields

distributionData

org.apache.beam.runners.core.metrics.DistributionData distributionData

Class org.apache.beam.runners.jet.metrics.GaugeImpl extends org.apache.beam.runners.jet.metrics.AbstractMetric<org.apache.beam.runners.core.metrics.GaugeData> implements Serializable

Serialized Fields

gaugeData

org.apache.beam.runners.core.metrics.GaugeData gaugeData

Class org.apache.beam.runners.jet.metrics.JetMetricsContainer extends java.lang.Object implements Serializable

Serialized Fields

accumulator

com.hazelcast.map.IMap<java.lang.String,org.apache.beam.runners.core.metrics.MetricUpdates> accumulator

boundedTries

java.util.Map<org.apache.beam.sdk.metrics.MetricName,BoundedTrieImpl> boundedTries

counters

java.util.Map<org.apache.beam.sdk.metrics.MetricName,CounterImpl> counters

distributions

java.util.Map<org.apache.beam.sdk.metrics.MetricName,DistributionImpl> distributions

gauges

java.util.Map<org.apache.beam.sdk.metrics.MetricName,GaugeImpl> gauges

metricsKey

java.lang.String metricsKey

stepName

java.lang.String stepName

stringSets

java.util.Map<org.apache.beam.sdk.metrics.MetricName,StringSetImpl> stringSets

Class org.apache.beam.runners.jet.metrics.StringSetImpl extends org.apache.beam.runners.jet.metrics.AbstractMetric<org.apache.beam.runners.core.metrics.StringSetData> implements Serializable

Serialized Fields

stringSetData

org.apache.beam.runners.core.metrics.StringSetData stringSetData

Package org.apache.beam.runners.jet.processors

Class org.apache.beam.runners.jet.processors.FlattenP.Supplier extends java.lang.Object implements Serializable

Serialized Fields

inputCollectionCoders

java.util.Map<java.lang.String,org.apache.beam.sdk.coders.Coder> inputCollectionCoders

inputOrdinalCoders

java.util.Map<java.lang.Integer,org.apache.beam.sdk.coders.Coder> inputOrdinalCoders

outputCoder

org.apache.beam.sdk.coders.Coder outputCoder

ownerId

java.lang.String ownerId

Class org.apache.beam.runners.jet.processors.ParDoP.Supplier extends org.apache.beam.runners.jet.processors.AbstractParDoP.AbstractSupplier<InputT,OutputT> implements Serializable

Class org.apache.beam.runners.jet.processors.StatefulParDoP.Supplier extends org.apache.beam.runners.jet.processors.AbstractParDoP.AbstractSupplier<org.apache.beam.sdk.values.KV<?,?>,OutputT> implements Serializable