Serialized Form (Apache Beam 2.13.0)

Package org.apache.beam.runners.apex
- Class org.apache.beam.runners.apex.ApexRunner.CreateApexPCollectionView extends PTransform<PCollection<ElemT>,PCollection<ElemT>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - view
```
PCollectionView<T> view
```
- Class org.apache.beam.runners.apex.ApexYarnLauncher.LaunchParams extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - dag
```
com.datatorrent.api.DAG dag
```
    - launchAttributes
```
com.datatorrent.api.Attribute.AttributeMap launchAttributes
```
    - configProperties
```
java.util.Properties configProperties
```
    - env
```
java.util.HashMap<K,V> env
```
    - cmd
```
java.lang.String cmd
```
Package org.apache.beam.runners.dataflow
- Class org.apache.beam.runners.dataflow.BatchStatefulParDoOverrides.BatchStatefulDoFn extends DoFn<KV<K,java.lang.Iterable<KV<Instant,org.apache.beam.sdk.util.WindowedValue<KV<K,V>>>>>,OutputT> implements Serializable
  - Serialized Fields
    - underlyingDoFn
```
DoFn<InputT,OutputT> underlyingDoFn
```
- Class org.apache.beam.runners.dataflow.CreateDataflowView extends PTransform<PCollection<ElemT>,PCollection<ElemT>> implements Serializable
  - Serialized Fields
    - view
```
PCollectionView<T> view
```
    - streaming
```
boolean streaming
```
- Class org.apache.beam.runners.dataflow.DataflowJobAlreadyExistsException extends DataflowJobException implements Serializable
- Class org.apache.beam.runners.dataflow.DataflowJobAlreadyUpdatedException extends DataflowJobException implements Serializable
- Class org.apache.beam.runners.dataflow.DataflowJobException extends java.lang.RuntimeException implements Serializable
  - Serialized Fields
    - job
```
DataflowPipelineJob job
```
- Class org.apache.beam.runners.dataflow.DataflowRunner.StreamingPCollectionViewWriterFn extends DoFn<java.lang.Iterable<T>,T> implements Serializable
  - Serialized Fields
    - view
```
PCollectionView<T> view
```
    - dataCoder
```
Coder<T> dataCoder
```
- Class org.apache.beam.runners.dataflow.DataflowRunnerInfo extends org.apache.beam.sdk.util.ReleaseInfo implements Serializable
  - Serialized Fields
    - properties
```
java.util.Map<K,V> properties
```
- Class org.apache.beam.runners.dataflow.DataflowServiceException extends DataflowJobException implements Serializable
- Class org.apache.beam.runners.dataflow.PrimitiveParDoSingleFactory.ParDoSingle extends org.apache.beam.runners.core.construction.ForwardingPTransform<PCollection<? extends InputT>,PCollection<OutputT>> implements Serializable
  - Serialized Fields
    - original
```
ParDo.SingleOutput<InputT,OutputT> original
```
    - onlyOutputTag
```
TupleTag<V> onlyOutputTag
```
    - outputCoder
```
Coder<T> outputCoder
```
Package org.apache.beam.runners.dataflow.options
- Class org.apache.beam.runners.dataflow.options.DataflowProfilingOptions.DataflowProfilingAgentConfiguration extends java.util.HashMap<java.lang.String,java.lang.Object> implements Serializable
- Class org.apache.beam.runners.dataflow.options.DataflowWorkerLoggingOptions.WorkerLogLevelOverrides extends java.util.HashMap<java.lang.String,DataflowWorkerLoggingOptions.Level> implements Serializable
Package org.apache.beam.runners.dataflow.util
- Class org.apache.beam.runners.dataflow.util.MonitoringUtil.TimeStampComparator extends java.lang.Object implements Serializable
- Class org.apache.beam.runners.dataflow.util.RandomAccessData.RandomAccessDataCoder extends AtomicCoder<RandomAccessData> implements Serializable
- Class org.apache.beam.runners.dataflow.util.RandomAccessData.UnsignedLexicographicalComparator extends java.lang.Object implements Serializable
Package org.apache.beam.runners.flink
- Class org.apache.beam.runners.flink.CreateStreamingFlinkView.CreateFlinkPCollectionView extends PTransform<PCollection<java.util.List<ElemT>>,PCollection<java.util.List<ElemT>>> implements Serializable
  - Serialized Fields
    - view
```
PCollectionView<T> view
```
- Class org.apache.beam.runners.flink.FlinkStreamingTransformTranslators.StripIdsMap extends java.lang.Object implements Serializable
- Class org.apache.beam.runners.flink.FlinkStreamingTransformTranslators.ToRawUnion extends java.lang.Object implements Serializable
  - Serialized Fields
    - intTag
```
int intTag
```
Package org.apache.beam.runners.flink.metrics
- Class org.apache.beam.runners.flink.metrics.MetricsAccumulator extends java.lang.Object implements Serializable
  - Serialized Fields
    - metricsContainers
```
org.apache.beam.runners.core.metrics.MetricsContainerStepMap metricsContainers
```
Package org.apache.beam.runners.fnexecution.provisioning
- Class org.apache.beam.runners.fnexecution.provisioning.JobInfo extends java.lang.Object implements Serializable
Package org.apache.beam.runners.gearpump.translators
- Class org.apache.beam.runners.gearpump.translators.CreateGearpumpPCollectionViewTranslator extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  -3955521308055056034L
- Class org.apache.beam.runners.gearpump.translators.CreateStreamingGearpumpView.CreateGearpumpPCollectionView extends PTransform<PCollection<java.util.List<ElemT>>,PCollection<java.util.List<ElemT>>> implements Serializable
  - Serialized Fields
    - view
```
PCollectionView<T> view
```
- Class org.apache.beam.runners.gearpump.translators.FlattenPCollectionsTranslator extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  -5552148802472944759L
- Class org.apache.beam.runners.gearpump.translators.GroupByKeyTranslator extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  -8742202583992787659L
- Class org.apache.beam.runners.gearpump.translators.GroupByKeyTranslator.GearpumpWindowFn extends java.lang.Object implements Serializable
  - Serialized Fields
    - isNonMerging
```
boolean isNonMerging
```
- Class org.apache.beam.runners.gearpump.translators.GroupByKeyTranslator.GroupByFn extends io.gearpump.streaming.dsl.javaapi.functions.GroupByFunction<org.apache.beam.sdk.util.WindowedValue<KV<K,V>>,java.nio.ByteBuffer> implements Serializable
  
  serialVersionUID:
  
  -807905402490735530L
  - Serialized Fields
    - keyCoder
```
Coder<T> keyCoder
```
- Class org.apache.beam.runners.gearpump.translators.GroupByKeyTranslator.KeyedByTimestamp extends io.gearpump.streaming.dsl.api.functions.MapFunction<org.apache.beam.sdk.util.WindowedValue<KV<K,V>>,KV<Instant,org.apache.beam.sdk.util.WindowedValue<KV<K,V>>>> implements Serializable
  - Serialized Fields
    - windowFn
```
WindowFn<T,W extends BoundedWindow> windowFn
```
    - timestampCombiner
```
TimestampCombiner timestampCombiner
```
- Class org.apache.beam.runners.gearpump.translators.GroupByKeyTranslator.Merge extends io.gearpump.streaming.dsl.api.functions.FoldFunction<KV<Instant,org.apache.beam.sdk.util.WindowedValue<KV<K,V>>>,KV<Instant,org.apache.beam.sdk.util.WindowedValue<KV<K,java.util.List<V>>>>> implements Serializable
  - Serialized Fields
    - windowFn
```
WindowFn<T,W extends BoundedWindow> windowFn
```
    - timestampCombiner
```
TimestampCombiner timestampCombiner
```
- Class org.apache.beam.runners.gearpump.translators.ParDoMultiOutputTranslator extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  -6023461558200028849L
- Class org.apache.beam.runners.gearpump.translators.ReadBoundedTranslator extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  -3899020490896998330L
- Class org.apache.beam.runners.gearpump.translators.ReadUnboundedTranslator extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  3529494817859948619L
- Class org.apache.beam.runners.gearpump.translators.WindowAssignTranslator extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  -964887482120489061L
- Class org.apache.beam.runners.gearpump.translators.WindowAssignTranslator.AssignWindows extends io.gearpump.streaming.dsl.javaapi.functions.FlatMapFunction<org.apache.beam.sdk.util.WindowedValue<T>,org.apache.beam.sdk.util.WindowedValue<T>> implements Serializable
  
  serialVersionUID:
  
  7284565861938681360L
  - Serialized Fields
    - windowFn
```
WindowFn<T,W extends BoundedWindow> windowFn
```
Package org.apache.beam.runners.gearpump.translators.functions
- Class org.apache.beam.runners.gearpump.translators.functions.DoFnFunction extends io.gearpump.streaming.dsl.javaapi.functions.FlatMapFunction<java.util.List<TranslatorUtils.RawUnionValue>,TranslatorUtils.RawUnionValue> implements Serializable
  
  serialVersionUID:
  
  -5701440128544343353L
  - Serialized Fields
    - doFnRunnerFactory
```
DoFnRunnerFactory<InputT,OutputT> doFnRunnerFactory
```
    - doFn
```
DoFn<InputT,OutputT> doFn
```
    - sideInputs
```
java.util.Collection<E> sideInputs
```
    - tagsToSideInputs
```
java.util.Map<K,V> tagsToSideInputs
```
    - mainOutput
```
TupleTag<V> mainOutput
```
    - sideOutputs
```
java.util.List<E> sideOutputs
```
    - outputManager
```
org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.DoFnOutputManager outputManager
```
Package org.apache.beam.runners.gearpump.translators.io
- Class org.apache.beam.runners.gearpump.translators.io.BoundedSourceWrapper extends GearpumpSource<T> implements Serializable
  
  serialVersionUID:
  
  8199570485738786123L
  - Serialized Fields
    - source
```
BoundedSource<T> source
```
- Class org.apache.beam.runners.gearpump.translators.io.GearpumpSource extends java.lang.Object implements Serializable
  - Serialized Fields
    - serializedOptions
```
org.apache.beam.runners.core.construction.SerializablePipelineOptions serializedOptions
```
    - reader
```
Source.Reader<T> reader
```
    - available
```
boolean available
```
- Class org.apache.beam.runners.gearpump.translators.io.UnboundedSourceWrapper extends GearpumpSource<OutputT> implements Serializable
  
  serialVersionUID:
  
  -2453956849834747150L
  - Serialized Fields
    - source
```
UnboundedSource<OutputT,CheckpointMarkT extends UnboundedSource.CheckpointMark> source
```
- Class org.apache.beam.runners.gearpump.translators.io.ValuesSource extends UnboundedSource<T,UnboundedSource.CheckpointMark> implements Serializable
  
  serialVersionUID:
  
  9113026175795235710L
  - Serialized Fields
    - values
```
byte[] values
```
    - iterableCoder
```
IterableCoder<T> iterableCoder
```
Package org.apache.beam.runners.gearpump.translators.utils
- Class org.apache.beam.runners.gearpump.translators.utils.DoFnRunnerFactory extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  -4109539010014189725L
  - Serialized Fields
    - fn
```
DoFn<InputT,OutputT> fn
```
    - serializedOptions
```
org.apache.beam.runners.core.construction.SerializablePipelineOptions serializedOptions
```
    - sideInputs
```
java.util.Collection<E> sideInputs
```
    - outputManager
```
org.apache.beam.runners.core.DoFnRunners.OutputManager outputManager
```
    - mainOutputTag
```
TupleTag<V> mainOutputTag
```
    - sideOutputTags
```
java.util.List<E> sideOutputTags
```
    - stepContext
```
org.apache.beam.runners.core.StepContext stepContext
```
    - doFnSchemaInformation
```
DoFnSchemaInformation doFnSchemaInformation
```
    - outputCoders
```
java.util.Map<K,V> outputCoders
```
    - windowingStrategy
```
WindowingStrategy<T,W extends BoundedWindow> windowingStrategy
```
- Class org.apache.beam.runners.gearpump.translators.utils.NoOpStepContext extends java.lang.Object implements Serializable
- Class org.apache.beam.runners.gearpump.translators.utils.TranslatorUtils.FromRawUnionValue extends io.gearpump.streaming.dsl.api.functions.MapFunction<TranslatorUtils.RawUnionValue,org.apache.beam.sdk.util.WindowedValue<OutputT>> implements Serializable
  
  serialVersionUID:
  
  -4764968219713478955L
Package org.apache.beam.runners.reference
- Class org.apache.beam.runners.reference.CloseableResource.CloseException extends java.lang.Exception implements Serializable
Package org.apache.beam.runners.spark.aggregators
- Class org.apache.beam.runners.spark.aggregators.NamedAggregators extends java.lang.Object implements Serializable
  - Serialized Fields
    - mNamedAggregators
```
java.util.Map<K,V> mNamedAggregators
```
      Map from aggregator name to current state.
- Class org.apache.beam.runners.spark.aggregators.NamedAggregatorsAccumulator extends org.apache.spark.util.AccumulatorV2<NamedAggregators,NamedAggregators> implements Serializable
  - Serialized Fields
    - value
```
NamedAggregators value
```
Package org.apache.beam.runners.spark.io
- Class org.apache.beam.runners.spark.io.ConsoleIO.Write.Unbound extends PTransform<PCollection<T>,PDone> implements Serializable
  - Serialized Fields
    - num
```
int num
```
- Class org.apache.beam.runners.spark.io.CreateStream extends PTransform<PBegin,PCollection<T>> implements Serializable
  - Serialized Fields
    - batchDuration
```
Duration batchDuration
```
    - batches
```
java.util.Queue<E> batches
```
    - times
```
java.util.Deque<E> times
```
    - coder
```
Coder<T> coder
```
    - initialSystemTime
```
Instant initialSystemTime
```
    - forceWatermarkSync
```
boolean forceWatermarkSync
```
    - lowWatermark
```
Instant lowWatermark
```
- Class org.apache.beam.runners.spark.io.EmptyCheckpointMark extends java.lang.Object implements Serializable
- Class org.apache.beam.runners.spark.io.MicrobatchSource extends Source<T> implements Serializable
  - Serialized Fields
    - source
```
UnboundedSource<OutputT,CheckpointMarkT extends UnboundedSource.CheckpointMark> source
```
    - maxReadTime
```
Duration maxReadTime
```
    - numInitialSplits
```
int numInitialSplits
```
    - maxNumRecords
```
long maxNumRecords
```
    - sourceId
```
int sourceId
```
    - readerCacheInterval
```
double readerCacheInterval
```
    - splitId
```
int splitId
```
- Class org.apache.beam.runners.spark.io.SourceRDD.Bounded extends org.apache.spark.rdd.RDD<org.apache.beam.sdk.util.WindowedValue<T>> implements Serializable
  - Serialized Fields
    - source
```
BoundedSource<T> source
```
    - options
```
org.apache.beam.runners.core.construction.SerializablePipelineOptions options
```
    - numPartitions
```
int numPartitions
```
    - bundleSize
```
long bundleSize
```
    - stepName
```
java.lang.String stepName
```
    - metricsAccum
```
MetricsContainerStepMapAccumulator metricsAccum
```
- Class org.apache.beam.runners.spark.io.SourceRDD.Unbounded extends org.apache.spark.rdd.RDD<scala.Tuple2<Source<T>,CheckpointMarkT extends UnboundedSource.CheckpointMark>> implements Serializable
  - Serialized Fields
    - microbatchSource
```
MicrobatchSource<T,CheckpointMarkT extends UnboundedSource.CheckpointMark> microbatchSource
```
    - options
```
org.apache.beam.runners.core.construction.SerializablePipelineOptions options
```
    - partitioner
```
org.apache.spark.Partitioner partitioner
```
- Class org.apache.beam.runners.spark.io.SparkUnboundedSource.Metadata extends java.lang.Object implements Serializable
  - Serialized Fields
    - numRecords
```
long numRecords
```
    - lowWatermark
```
Instant lowWatermark
```
    - highWatermark
```
Instant highWatermark
```
    - readDurationMillis
```
long readDurationMillis
```
    - metricsContainers
```
org.apache.beam.runners.core.metrics.MetricsContainerStepMap metricsContainers
```
Package org.apache.beam.runners.spark.metrics
- Class org.apache.beam.runners.spark.metrics.MetricsContainerStepMapAccumulator extends org.apache.spark.util.AccumulatorV2<org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap> implements Serializable
  - Serialized Fields
    - value
```
org.apache.beam.runners.core.metrics.MetricsContainerStepMap value
```
Package org.apache.beam.runners.spark.stateful
- Class org.apache.beam.runners.spark.stateful.SparkGroupAlsoByWindowViaWindowSet extends java.lang.Object implements Serializable
- Class org.apache.beam.runners.spark.stateful.SparkGroupAlsoByWindowViaWindowSet.StateAndTimers extends java.lang.Object implements Serializable
  - Serialized Fields
    - state
```
org.apache.beam.vendor.guava.v20_0.com.google.common.collect.Table<R,C,V> state
```
    - serTimers
```
java.util.Collection<E> serTimers
```
Package org.apache.beam.runners.spark.util
- Class org.apache.beam.runners.spark.util.ByteArray extends java.lang.Object implements Serializable
  - Serialized Fields
    - value
```
byte[] value
```
- Class org.apache.beam.runners.spark.util.GlobalWatermarkHolder.SparkWatermarks extends java.lang.Object implements Serializable
  - Serialized Fields
    - lowWatermark
```
Instant lowWatermark
```
    - highWatermark
```
Instant highWatermark
```
    - synchronizedProcessingTime
```
Instant synchronizedProcessingTime
```
- Class org.apache.beam.runners.spark.util.SideInputBroadcast extends java.lang.Object implements Serializable
  - Serialized Fields
    - bcast
```
org.apache.spark.broadcast.Broadcast<T> bcast
```
    - coder
```
Coder<T> coder
```
Package org.apache.beam.sdk
- Class org.apache.beam.sdk.Pipeline.PipelineExecutionException extends java.lang.RuntimeException implements Serializable
Package org.apache.beam.sdk.coders
- Class org.apache.beam.sdk.coders.AtomicCoder extends StructuredCoder<T> implements Serializable
- Class org.apache.beam.sdk.coders.AvroCoder extends CustomCoder<T> implements Serializable
  - Serialized Fields
    - type
```
java.lang.Class<T> type
```
    - schemaSupplier
```
org.apache.beam.sdk.coders.AvroCoder.SerializableSchemaSupplier schemaSupplier
```
    - typeDescriptor
```
TypeDescriptor<T> typeDescriptor
```
    - nonDeterministicReasons
```
java.util.List<E> nonDeterministicReasons
```
    - decoder
```
org.apache.beam.sdk.util.EmptyOnDeserializationThreadLocal<T> decoder
```
    - encoder
```
org.apache.beam.sdk.util.EmptyOnDeserializationThreadLocal<T> encoder
```
    - writer
```
org.apache.beam.sdk.util.EmptyOnDeserializationThreadLocal<T> writer
```
    - reader
```
org.apache.beam.sdk.util.EmptyOnDeserializationThreadLocal<T> reader
```
    - reflectData
```
org.apache.beam.vendor.guava.v20_0.com.google.common.base.Supplier<T> reflectData
```
- Class org.apache.beam.sdk.coders.BigDecimalCoder extends AtomicCoder<java.math.BigDecimal> implements Serializable
- Class org.apache.beam.sdk.coders.BigEndianIntegerCoder extends AtomicCoder<java.lang.Integer> implements Serializable
- Class org.apache.beam.sdk.coders.BigEndianLongCoder extends AtomicCoder<java.lang.Long> implements Serializable
- Class org.apache.beam.sdk.coders.BigEndianShortCoder extends AtomicCoder<java.lang.Short> implements Serializable
- Class org.apache.beam.sdk.coders.BigIntegerCoder extends AtomicCoder<java.math.BigInteger> implements Serializable
- Class org.apache.beam.sdk.coders.BitSetCoder extends AtomicCoder<java.util.BitSet> implements Serializable
- Class org.apache.beam.sdk.coders.BooleanCoder extends AtomicCoder<java.lang.Boolean> implements Serializable
- Class org.apache.beam.sdk.coders.ByteArrayCoder extends AtomicCoder<byte[]> implements Serializable
- Class org.apache.beam.sdk.coders.ByteCoder extends AtomicCoder<java.lang.Byte> implements Serializable
- Class org.apache.beam.sdk.coders.CannotProvideCoderException extends java.lang.Exception implements Serializable
  - Serialized Fields
    - reason
```
CannotProvideCoderException.ReasonCode reason
```
- Class org.apache.beam.sdk.coders.Coder extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.coders.Coder.NonDeterministicException extends java.lang.Exception implements Serializable
  - Serialized Fields
    - coder
```
Coder<T> coder
```
    - reasons
```
java.util.List<E> reasons
```
- Class org.apache.beam.sdk.coders.CoderException extends java.io.IOException implements Serializable
- Class org.apache.beam.sdk.coders.CollectionCoder extends IterableLikeCoder<T,java.util.Collection<T>> implements Serializable
- Class org.apache.beam.sdk.coders.CustomCoder extends Coder<T> implements Serializable
- Class org.apache.beam.sdk.coders.DelegateCoder extends CustomCoder<T> implements Serializable
  - Serialized Fields
    - coder
```
Coder<T> coder
```
    - toFn
```
DelegateCoder.CodingFunction<InputT,OutputT> toFn
```
    - fromFn
```
DelegateCoder.CodingFunction<InputT,OutputT> fromFn
```
    - typeDescriptor
```
TypeDescriptor<T> typeDescriptor
```
- Class org.apache.beam.sdk.coders.DoubleCoder extends AtomicCoder<java.lang.Double> implements Serializable
- Class org.apache.beam.sdk.coders.DurationCoder extends AtomicCoder<ReadableDuration> implements Serializable
- Class org.apache.beam.sdk.coders.FloatCoder extends AtomicCoder<java.lang.Float> implements Serializable
- Class org.apache.beam.sdk.coders.InstantCoder extends AtomicCoder<Instant> implements Serializable
- Class org.apache.beam.sdk.coders.IterableCoder extends IterableLikeCoder<T,java.lang.Iterable<T>> implements Serializable
- Class org.apache.beam.sdk.coders.IterableLikeCoder extends StructuredCoder<IterableT extends java.lang.Iterable<T>> implements Serializable
  - Serialized Fields
    - elementCoder
```
Coder<T> elementCoder
```
    - iterableName
```
java.lang.String iterableName
```
- Class org.apache.beam.sdk.coders.KvCoder extends StructuredCoder<KV<K,V>> implements Serializable
  - Serialized Fields
    - keyCoder
```
Coder<T> keyCoder
```
    - valueCoder
```
Coder<T> valueCoder
```
- Class org.apache.beam.sdk.coders.LengthPrefixCoder extends StructuredCoder<T> implements Serializable
  - Serialized Fields
    - valueCoder
```
Coder<T> valueCoder
```
- Class org.apache.beam.sdk.coders.ListCoder extends IterableLikeCoder<T,java.util.List<T>> implements Serializable
- Class org.apache.beam.sdk.coders.MapCoder extends StructuredCoder<java.util.Map<K,V>> implements Serializable
  - Serialized Fields
    - keyCoder
```
Coder<T> keyCoder
```
    - valueCoder
```
Coder<T> valueCoder
```
- Class org.apache.beam.sdk.coders.NullableCoder extends StructuredCoder<T> implements Serializable
  - Serialized Fields
    - valueCoder
```
Coder<T> valueCoder
```
- Class org.apache.beam.sdk.coders.RowCoder extends CustomCoder<Row> implements Serializable
  - Serialized Fields
    - schema
```
Schema schema
```
    - id
```
java.util.UUID id
```
- Class org.apache.beam.sdk.coders.SerializableCoder extends CustomCoder<T extends java.io.Serializable> implements Serializable
  - Serialized Fields
    - type
```
java.lang.Class<T> type
```
- Class org.apache.beam.sdk.coders.SetCoder extends IterableLikeCoder<T,java.util.Set<T>> implements Serializable
- Class org.apache.beam.sdk.coders.ShardedKeyCoder extends StructuredCoder<ShardedKey<KeyT>> implements Serializable
  - Serialized Fields
    - keyCoder
```
Coder<T> keyCoder
```
    - shardNumberCoder
```
VarIntCoder shardNumberCoder
```
- Class org.apache.beam.sdk.coders.SnappyCoder extends StructuredCoder<T> implements Serializable
  - Serialized Fields
    - innerCoder
```
Coder<T> innerCoder
```
- Class org.apache.beam.sdk.coders.StringDelegateCoder extends CustomCoder<T> implements Serializable
  - Serialized Fields
    - delegateCoder
```
DelegateCoder<T,IntermediateT> delegateCoder
```
    - clazz
```
java.lang.Class<T> clazz
```
- Class org.apache.beam.sdk.coders.StringUtf8Coder extends AtomicCoder<java.lang.String> implements Serializable
- Class org.apache.beam.sdk.coders.StructuredCoder extends Coder<T> implements Serializable
- Class org.apache.beam.sdk.coders.TextualIntegerCoder extends AtomicCoder<java.lang.Integer> implements Serializable
- Class org.apache.beam.sdk.coders.VarIntCoder extends AtomicCoder<java.lang.Integer> implements Serializable
- Class org.apache.beam.sdk.coders.VarLongCoder extends StructuredCoder<java.lang.Long> implements Serializable
- Class org.apache.beam.sdk.coders.VoidCoder extends AtomicCoder<java.lang.Void> implements Serializable
Package org.apache.beam.sdk.extensions.gcp.options
- Class org.apache.beam.sdk.extensions.gcp.options.GoogleApiDebugOptions.GoogleApiTracer extends java.util.HashMap<java.lang.String,java.lang.String> implements Serializable
Package org.apache.beam.sdk.extensions.gcp.storage
- Class org.apache.beam.sdk.extensions.gcp.storage.GcsResourceId extends java.lang.Object implements Serializable
  - Serialized Fields
    - gcsPath
```
GcsPath gcsPath
```
Package org.apache.beam.sdk.extensions.gcp.util
- Class org.apache.beam.sdk.extensions.gcp.util.CustomHttpErrors.MatcherAndError extends java.lang.Object implements Serializable
Package org.apache.beam.sdk.extensions.gcp.util.gcsfs
- Class org.apache.beam.sdk.extensions.gcp.util.gcsfs.GcsPath extends java.lang.Object implements Serializable
  - Serialized Fields
    - bucket
```
java.lang.String bucket
```
    - object
```
java.lang.String object
```
Package org.apache.beam.sdk.extensions.jackson
- Class org.apache.beam.sdk.extensions.jackson.AsJsons extends PTransform<PCollection<InputT>,PCollection<java.lang.String>> implements Serializable
  - Serialized Fields
    - inputClass
```
java.lang.Class<T> inputClass
```
    - customMapper
```
ObjectMapper customMapper
```
- Class org.apache.beam.sdk.extensions.jackson.ParseJsons extends PTransform<PCollection<java.lang.String>,PCollection<OutputT>> implements Serializable
  - Serialized Fields
    - outputClass
```
java.lang.Class<T> outputClass
```
    - customMapper
```
ObjectMapper customMapper
```
Package org.apache.beam.sdk.extensions.joinlibrary
- Class org.apache.beam.sdk.extensions.joinlibrary.Join.FullOuterJoin extends PTransform<PCollection<KV<K,V1>>,PCollection<KV<K,KV<V1,V2>>>> implements Serializable
  - Serialized Fields
    - leftNullValue
```
java.lang.Object leftNullValue
```
    - rightNullValue
```
java.lang.Object rightNullValue
```
- Class org.apache.beam.sdk.extensions.joinlibrary.Join.InnerJoin extends PTransform<PCollection<KV<K,V1>>,PCollection<KV<K,KV<V1,V2>>>> implements Serializable
- Class org.apache.beam.sdk.extensions.joinlibrary.Join.LeftOuterJoin extends PTransform<PCollection<KV<K,V1>>,PCollection<KV<K,KV<V1,V2>>>> implements Serializable
  - Serialized Fields
    - nullValue
```
java.lang.Object nullValue
```
- Class org.apache.beam.sdk.extensions.joinlibrary.Join.RightOuterJoin extends PTransform<PCollection<KV<K,V1>>,PCollection<KV<K,KV<V1,V2>>>> implements Serializable
  - Serialized Fields
    - nullValue
```
java.lang.Object nullValue
```
Package org.apache.beam.sdk.extensions.protobuf
- Class org.apache.beam.sdk.extensions.protobuf.ByteStringCoder extends AtomicCoder<com.google.protobuf.ByteString> implements Serializable
- Class org.apache.beam.sdk.extensions.protobuf.ProtoCoder extends CustomCoder<T extends com.google.protobuf.Message> implements Serializable
  - Serialized Fields
    - protoMessageClass
```
java.lang.Class<T> protoMessageClass
```
      The Message type to be coded.
    - extensionHostClasses
```
java.util.Set<E> extensionHostClasses
```
      All extension host classes included in this ProtoCoder. The extensions from these classes will be included in the ExtensionRegistry used during encoding and decoding.
Package org.apache.beam.sdk.extensions.sketching
- Class org.apache.beam.sdk.extensions.sketching.ApproximateDistinct.ApproximateDistinctFn extends Combine.CombineFn<InputT,com.clearspring.analytics.stream.cardinality.HyperLogLogPlus,com.clearspring.analytics.stream.cardinality.HyperLogLogPlus> implements Serializable
  - Serialized Fields
    - p
```
int p
```
    - sp
```
int sp
```
    - inputCoder
```
Coder<T> inputCoder
```
- Class org.apache.beam.sdk.extensions.sketching.ApproximateDistinct.GloballyDistinct extends PTransform<PCollection<InputT>,PCollection<java.lang.Long>> implements Serializable
- Class org.apache.beam.sdk.extensions.sketching.ApproximateDistinct.HyperLogLogPlusCoder extends CustomCoder<com.clearspring.analytics.stream.cardinality.HyperLogLogPlus> implements Serializable
- Class org.apache.beam.sdk.extensions.sketching.ApproximateDistinct.PerKeyDistinct extends PTransform<PCollection<KV<K,V>>,PCollection<KV<K,java.lang.Long>>> implements Serializable
- Class org.apache.beam.sdk.extensions.sketching.SketchFrequencies.CountMinSketchFn extends Combine.CombineFn<InputT,SketchFrequencies.Sketch<InputT>,SketchFrequencies.Sketch<InputT>> implements Serializable
  - Serialized Fields
    - inputCoder
```
Coder<T> inputCoder
```
    - depth
```
int depth
```
    - width
```
int width
```
    - epsilon
```
double epsilon
```
    - confidence
```
double confidence
```
- Class org.apache.beam.sdk.extensions.sketching.SketchFrequencies.GlobalSketch extends PTransform<PCollection<InputT>,PCollection<SketchFrequencies.Sketch<InputT>>> implements Serializable
- Class org.apache.beam.sdk.extensions.sketching.SketchFrequencies.PerKeySketch extends PTransform<PCollection<KV<K,V>>,PCollection<KV<K,SketchFrequencies.Sketch<V>>>> implements Serializable
- Class org.apache.beam.sdk.extensions.sketching.SketchFrequencies.Sketch extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.extensions.sketching.TDigestQuantiles.GlobalDigest extends PTransform<PCollection<java.lang.Double>,PCollection<com.tdunning.math.stats.MergingDigest>> implements Serializable
- Class org.apache.beam.sdk.extensions.sketching.TDigestQuantiles.PerKeyDigest extends PTransform<PCollection<KV<K,java.lang.Double>>,PCollection<KV<K,com.tdunning.math.stats.MergingDigest>>> implements Serializable
- Class org.apache.beam.sdk.extensions.sketching.TDigestQuantiles.TDigestQuantilesFn extends Combine.CombineFn<java.lang.Double,com.tdunning.math.stats.MergingDigest,com.tdunning.math.stats.MergingDigest> implements Serializable
  - Serialized Fields
    - compression
```
double compression
```
Package org.apache.beam.sdk.extensions.sorter
- Class org.apache.beam.sdk.extensions.sorter.BufferedExternalSorter.Options extends java.lang.Object implements Serializable
  - Serialized Fields
    - tempLocation
```
java.lang.String tempLocation
```
    - memoryMB
```
int memoryMB
```
- Class org.apache.beam.sdk.extensions.sorter.ExternalSorter.Options extends java.lang.Object implements Serializable
  - Serialized Fields
    - tempLocation
```
java.lang.String tempLocation
```
    - memoryMB
```
int memoryMB
```
- Class org.apache.beam.sdk.extensions.sorter.InMemorySorter.Options extends java.lang.Object implements Serializable
  - Serialized Fields
    - memoryMB
```
long memoryMB
```
- Class org.apache.beam.sdk.extensions.sorter.SortValues extends PTransform<PCollection<KV<PrimaryKeyT,java.lang.Iterable<KV<SecondaryKeyT,ValueT>>>>,PCollection<KV<PrimaryKeyT,java.lang.Iterable<KV<SecondaryKeyT,ValueT>>>>> implements Serializable
  - Serialized Fields
    - sorterOptions
```
BufferedExternalSorter.Options sorterOptions
```
Package org.apache.beam.sdk.extensions.sql
- Class org.apache.beam.sdk.extensions.sql.SqlTransform extends PTransform<PInput,PCollection<Row>> implements Serializable
Package org.apache.beam.sdk.extensions.sql.example.model
- Class org.apache.beam.sdk.extensions.sql.example.model.Customer extends java.lang.Object implements Serializable
  - Serialized Fields
    - name
```
java.lang.String name
```
    - id
```
int id
```
    - countryOfResidence
```
java.lang.String countryOfResidence
```
- Class org.apache.beam.sdk.extensions.sql.example.model.Order extends java.lang.Object implements Serializable
  - Serialized Fields
    - id
```
int id
```
    - customerId
```
int customerId
```
Package org.apache.beam.sdk.extensions.sql.impl
- Class org.apache.beam.sdk.extensions.sql.impl.ParseException extends java.lang.RuntimeException implements Serializable
- Class org.apache.beam.sdk.extensions.sql.impl.SqlConversionException extends java.lang.RuntimeException implements Serializable
- Class org.apache.beam.sdk.extensions.sql.impl.UdafImpl extends java.lang.Object implements Serializable
  - Serialized Fields
    - combineFn
```
Combine.CombineFn<InputT,AccumT,OutputT> combineFn
```
Package org.apache.beam.sdk.extensions.sql.impl.rel
- Class org.apache.beam.sdk.extensions.sql.impl.rel.BeamSetOperatorRelBase extends PTransform<PCollectionList<Row>,PCollection<Row>> implements Serializable
  - Serialized Fields
    - beamRelNode
```
BeamRelNode beamRelNode
```
    - all
```
boolean all
```
    - opType
```
BeamSetOperatorRelBase.OpType opType
```
Package org.apache.beam.sdk.extensions.sql.impl.schema
- Class org.apache.beam.sdk.extensions.sql.impl.schema.BaseBeamTable extends java.lang.Object implements Serializable
  - Serialized Fields
    - schema
```
Schema schema
```
- Class org.apache.beam.sdk.extensions.sql.impl.schema.BeamPCollectionTable extends BaseBeamTable implements Serializable
Package org.apache.beam.sdk.extensions.sql.impl.transform
- Class org.apache.beam.sdk.extensions.sql.impl.transform.BeamJoinTransforms.ExtractJoinFields extends SimpleFunction<Row,KV<Row,Row>> implements Serializable
  - Serialized Fields
    - joinColumns
```
java.util.List<E> joinColumns
```
    - schema
```
Schema schema
```
    - leftRowColumnCount
```
int leftRowColumnCount
```
- Class org.apache.beam.sdk.extensions.sql.impl.transform.BeamJoinTransforms.JoinAsLookup extends PTransform<PCollection<Row>,PCollection<Row>> implements Serializable
  - Serialized Fields
    - seekableTable
```
BeamSqlSeekableTable seekableTable
```
    - lkpSchema
```
Schema lkpSchema
```
    - factColOffset
```
int factColOffset
```
    - joinSubsetType
```
Schema joinSubsetType
```
    - outputSchema
```
Schema outputSchema
```
    - factJoinIdx
```
java.util.List<E> factJoinIdx
```
- Class org.apache.beam.sdk.extensions.sql.impl.transform.BeamJoinTransforms.JoinParts2WholeRow extends SimpleFunction<KV<Row,KV<Row,Row>>,Row> implements Serializable
  - Serialized Fields
    - schema
```
Schema schema
```
- Class org.apache.beam.sdk.extensions.sql.impl.transform.BeamJoinTransforms.SideInputJoinDoFn extends DoFn<KV<Row,Row>,Row> implements Serializable
  - Serialized Fields
    - sideInputView
```
PCollectionView<T> sideInputView
```
    - joinType
```
org.apache.calcite.rel.core.JoinRelType joinType
```
    - rightNullRow
```
Row rightNullRow
```
    - swap
```
boolean swap
```
    - schema
```
Schema schema
```
- Class org.apache.beam.sdk.extensions.sql.impl.transform.BeamSetOperatorsTransforms.BeamSqlRow2KvFn extends SimpleFunction<Row,KV<Row,Row>> implements Serializable
- Class org.apache.beam.sdk.extensions.sql.impl.transform.BeamSetOperatorsTransforms.SetOperatorFilteringDoFn extends DoFn<KV<Row,CoGbkResult>,Row> implements Serializable
  - Serialized Fields
    - leftTag
```
TupleTag<V> leftTag
```
    - rightTag
```
TupleTag<V> rightTag
```
    - opType
```
BeamSetOperatorRelBase.OpType opType
```
    - all
```
boolean all
```
- Class org.apache.beam.sdk.extensions.sql.impl.transform.BeamSqlOutputToConsoleFn extends DoFn<Row,java.lang.Void> implements Serializable
  - Serialized Fields
    - stepName
```
java.lang.String stepName
```
Package org.apache.beam.sdk.extensions.sql.impl.transform.agg
- Class org.apache.beam.sdk.extensions.sql.impl.transform.agg.CovarianceFn extends Combine.CombineFn<Row,org.apache.beam.sdk.extensions.sql.impl.transform.agg.CovarianceAccumulator,T extends java.lang.Number> implements Serializable
  - Serialized Fields
    - isSample
```
boolean isSample
```
    - decimalConverter
```
SerializableFunction<InputT,OutputT> decimalConverter
```
- Class org.apache.beam.sdk.extensions.sql.impl.transform.agg.VarianceFn extends Combine.CombineFn<T extends java.lang.Number,org.apache.beam.sdk.extensions.sql.impl.transform.agg.VarianceAccumulator,T extends java.lang.Number> implements Serializable
  - Serialized Fields
    - isSample
```
boolean isSample
```
    - decimalConverter
```
SerializableFunction<InputT,OutputT> decimalConverter
```
Package org.apache.beam.sdk.extensions.sql.impl.utils
- Class org.apache.beam.sdk.extensions.sql.impl.utils.CalciteUtils.CharType extends LogicalTypes.PassThroughLogicalType<java.lang.String> implements Serializable
- Class org.apache.beam.sdk.extensions.sql.impl.utils.CalciteUtils.DateType extends LogicalTypes.PassThroughLogicalType<Instant> implements Serializable
- Class org.apache.beam.sdk.extensions.sql.impl.utils.CalciteUtils.TimestampWithLocalTzType extends LogicalTypes.PassThroughLogicalType<Instant> implements Serializable
- Class org.apache.beam.sdk.extensions.sql.impl.utils.CalciteUtils.TimeType extends LogicalTypes.PassThroughLogicalType<Instant> implements Serializable
- Class org.apache.beam.sdk.extensions.sql.impl.utils.CalciteUtils.TimeWithLocalTzType extends LogicalTypes.PassThroughLogicalType<Instant> implements Serializable
- Class org.apache.beam.sdk.extensions.sql.impl.utils.SerializableRexFieldAccess extends SerializableRexNode implements Serializable
  - Serialized Fields
    - indexes
```
java.util.List<E> indexes
```
- Class org.apache.beam.sdk.extensions.sql.impl.utils.SerializableRexInputRef extends SerializableRexNode implements Serializable
  - Serialized Fields
    - index
```
int index
```
- Class org.apache.beam.sdk.extensions.sql.impl.utils.SerializableRexNode extends java.lang.Object implements Serializable
Package org.apache.beam.sdk.extensions.sql.meta
- Class org.apache.beam.sdk.extensions.sql.meta.Table extends java.lang.Object implements Serializable
Package org.apache.beam.sdk.extensions.sql.meta.provider.hcatalog
- Class org.apache.beam.sdk.extensions.sql.meta.provider.hcatalog.HCatalogTableProvider extends java.lang.Object implements Serializable
  - Serialized Fields
    - configuration
```
java.util.HashMap<K,V> configuration
```
Package org.apache.beam.sdk.extensions.sql.meta.provider.kafka
- Class org.apache.beam.sdk.extensions.sql.meta.provider.kafka.BeamKafkaCSVTable extends BeamKafkaTable implements Serializable
  - Serialized Fields
    - csvFormat
```
org.apache.commons.csv.CSVFormat csvFormat
```
- Class org.apache.beam.sdk.extensions.sql.meta.provider.kafka.BeamKafkaCSVTable.CsvRecorderDecoder extends PTransform<PCollection<KV<byte[],byte[]>>,PCollection<Row>> implements Serializable
  - Serialized Fields
    - schema
```
Schema schema
```
    - format
```
org.apache.commons.csv.CSVFormat format
```
- Class org.apache.beam.sdk.extensions.sql.meta.provider.kafka.BeamKafkaCSVTable.CsvRecorderEncoder extends PTransform<PCollection<Row>,PCollection<KV<byte[],byte[]>>> implements Serializable
  - Serialized Fields
    - schema
```
Schema schema
```
    - format
```
org.apache.commons.csv.CSVFormat format
```
- Class org.apache.beam.sdk.extensions.sql.meta.provider.kafka.BeamKafkaTable extends BaseBeamTable implements Serializable
  - Serialized Fields
    - bootstrapServers
```
java.lang.String bootstrapServers
```
    - topics
```
java.util.List<E> topics
```
    - topicPartitions
```
java.util.List<E> topicPartitions
```
    - configUpdates
```
java.util.Map<K,V> configUpdates
```
Package org.apache.beam.sdk.extensions.sql.meta.provider.pubsub
- Class org.apache.beam.sdk.extensions.sql.meta.provider.pubsub.PubsubMessageToRow extends DoFn<PubsubMessage,Row> implements Serializable
Package org.apache.beam.sdk.extensions.sql.meta.provider.test
- Class org.apache.beam.sdk.extensions.sql.meta.provider.test.TestBoundedTable extends TestTable implements Serializable
  - Serialized Fields
    - rows
```
java.util.List<E> rows
```
      rows flow out from this table.
- Class org.apache.beam.sdk.extensions.sql.meta.provider.test.TestTable extends BaseBeamTable implements Serializable
- Class org.apache.beam.sdk.extensions.sql.meta.provider.test.TestTableProvider.TableWithRows extends java.lang.Object implements Serializable
  - Serialized Fields
    - table
```
Table table
```
    - rows
```
java.util.List<E> rows
```
    - tableProviderInstanceId
```
long tableProviderInstanceId
```
- Class org.apache.beam.sdk.extensions.sql.meta.provider.test.TestUnboundedTable extends TestTable implements Serializable
  - Serialized Fields
    - timestampedRows
```
java.util.List<E> timestampedRows
```
      rows flow out from this table with the specified watermark instant.
    - timestampField
```
int timestampField
```
      specify the index of column in the row which stands for the event time field.
Package org.apache.beam.sdk.extensions.sql.meta.provider.text
- Class org.apache.beam.sdk.extensions.sql.meta.provider.text.TextTable extends BaseBeamTable implements Serializable
  - Serialized Fields
    - readConverter
```
PTransform<InputT extends PInput,OutputT extends POutput> readConverter
```
    - writeConverter
```
PTransform<InputT extends PInput,OutputT extends POutput> writeConverter
```
    - filePattern
```
java.lang.String filePattern
```
- Class org.apache.beam.sdk.extensions.sql.meta.provider.text.TextTableProvider.CsvToRow extends PTransform<PCollection<java.lang.String>,PCollection<Row>> implements Serializable
  - Serialized Fields
    - schema
```
Schema schema
```
    - csvFormat
```
org.apache.commons.csv.CSVFormat csvFormat
```
- Class org.apache.beam.sdk.extensions.sql.meta.provider.text.TextTableProvider.LinesReadConverter extends PTransform<PCollection<java.lang.String>,PCollection<Row>> implements Serializable
- Class org.apache.beam.sdk.extensions.sql.meta.provider.text.TextTableProvider.LinesWriteConverter extends PTransform<PCollection<Row>,PCollection<java.lang.String>> implements Serializable
Package org.apache.beam.sdk.fn.windowing
- Class org.apache.beam.sdk.fn.windowing.EncodedBoundedWindow.Coder extends AtomicCoder<EncodedBoundedWindow> implements Serializable
Package org.apache.beam.sdk.io
- Class org.apache.beam.sdk.io.AvroIO.Parse extends PTransform<PBegin,PCollection<T>> implements Serializable
- Class org.apache.beam.sdk.io.AvroIO.ParseAll extends PTransform<PCollection<java.lang.String>,PCollection<T>> implements Serializable
- Class org.apache.beam.sdk.io.AvroIO.ParseFiles extends PTransform<PCollection<FileIO.ReadableFile>,PCollection<T>> implements Serializable
- Class org.apache.beam.sdk.io.AvroIO.Read extends PTransform<PBegin,PCollection<T>> implements Serializable
- Class org.apache.beam.sdk.io.AvroIO.ReadAll extends PTransform<PCollection<java.lang.String>,PCollection<T>> implements Serializable
- Class org.apache.beam.sdk.io.AvroIO.ReadFiles extends PTransform<PCollection<FileIO.ReadableFile>,PCollection<T>> implements Serializable
- Class org.apache.beam.sdk.io.AvroIO.Sink extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.io.AvroIO.TypedWrite extends PTransform<PCollection<UserT>,WriteFilesResult<DestinationT>> implements Serializable
- Class org.apache.beam.sdk.io.AvroIO.Write extends PTransform<PCollection<T>,PDone> implements Serializable
  - Serialized Fields
    - inner
```
AvroIO.TypedWrite<UserT,DestinationT,OutputT> inner
```
- Class org.apache.beam.sdk.io.AvroSource extends BlockBasedSource<T> implements Serializable
  - Serialization Methods
    - readResolve
```
private java.lang.Object readResolve()
                              throws java.io.ObjectStreamException
```
      Throws:
      
      java.io.ObjectStreamException
  - Serialized Fields
    - mode
```
org.apache.beam.sdk.io.AvroSource.Mode<T> mode
```
- Class org.apache.beam.sdk.io.BlockBasedSource extends FileBasedSource<T> implements Serializable
- Class org.apache.beam.sdk.io.BoundedReadFromUnboundedSource extends PTransform<PBegin,PCollection<T>> implements Serializable
  - Serialized Fields
    - source
```
UnboundedSource<OutputT,CheckpointMarkT extends UnboundedSource.CheckpointMark> source
```
    - maxNumRecords
```
long maxNumRecords
```
    - maxReadTime
```
Duration maxReadTime
```
- Class org.apache.beam.sdk.io.BoundedSource extends Source<T> implements Serializable
- Class org.apache.beam.sdk.io.CompressedSource extends FileBasedSource<T> implements Serializable
  - Serialized Fields
    - sourceDelegate
```
FileBasedSource<T> sourceDelegate
```
    - channelFactory
```
CompressedSource.DecompressingChannelFactory channelFactory
```
- Class org.apache.beam.sdk.io.DefaultFilenamePolicy extends FileBasedSink.FilenamePolicy implements Serializable
  - Serialized Fields
    - params
```
DefaultFilenamePolicy.Params params
```
- Class org.apache.beam.sdk.io.DefaultFilenamePolicy.Params extends java.lang.Object implements Serializable
  - Serialized Fields
    - baseFilename
```
ValueProvider<T> baseFilename
```
    - shardTemplate
```
java.lang.String shardTemplate
```
    - explicitTemplate
```
boolean explicitTemplate
```
    - suffix
```
java.lang.String suffix
```
- Class org.apache.beam.sdk.io.DefaultFilenamePolicy.ParamsCoder extends AtomicCoder<DefaultFilenamePolicy.Params> implements Serializable
  - Serialized Fields
    - stringCoder
```
Coder<T> stringCoder
```
- Class org.apache.beam.sdk.io.DynamicAvroDestinations extends FileBasedSink.DynamicDestinations<UserT,DestinationT,OutputT> implements Serializable
- Class org.apache.beam.sdk.io.FileBasedSink extends java.lang.Object implements Serializable
  - Serialized Fields
    - dynamicDestinations
```
FileBasedSink.DynamicDestinations<UserT,DestinationT,OutputT> dynamicDestinations
```
    - writableByteChannelFactory
```
FileBasedSink.WritableByteChannelFactory writableByteChannelFactory
```
      The FileBasedSink.WritableByteChannelFactory that is used to wrap the raw data output to the underlying channel. The default is to not compress the output using Compression.UNCOMPRESSED.
    - tempDirectoryProvider
```
ValueProvider<T> tempDirectoryProvider
```
      The directory to which files will be written.
- Class org.apache.beam.sdk.io.FileBasedSink.DynamicDestinations extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.io.FileBasedSink.FilenamePolicy extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.io.FileBasedSink.FileResultCoder extends StructuredCoder<FileBasedSink.FileResult<DestinationT>> implements Serializable
  - Serialized Fields
    - windowCoder
```
Coder<T> windowCoder
```
    - destinationCoder
```
Coder<T> destinationCoder
```
- Class org.apache.beam.sdk.io.FileBasedSink.WriteOperation extends java.lang.Object implements Serializable
  - Serialized Fields
    - sink
```
FileBasedSink<UserT,DestinationT,OutputT> sink
```
      The Sink that this WriteOperation will write to.
    - tempDirectory
```
ValueProvider<T> tempDirectory
```
      Directory for temporary output files.
    - windowedWrites
```
boolean windowedWrites
```
      Whether windowed writes are being used.
- Class org.apache.beam.sdk.io.FileBasedSource extends OffsetBasedSource<T> implements Serializable
  - Serialized Fields
    - fileOrPatternSpec
```
ValueProvider<T> fileOrPatternSpec
```
    - emptyMatchTreatment
```
EmptyMatchTreatment emptyMatchTreatment
```
    - singleFileMetadata
```
MatchResult.Metadata singleFileMetadata
```
    - mode
```
FileBasedSource.Mode mode
```
- Class org.apache.beam.sdk.io.FileIO.Match extends PTransform<PBegin,PCollection<MatchResult.Metadata>> implements Serializable
- Class org.apache.beam.sdk.io.FileIO.MatchAll extends PTransform<PCollection<java.lang.String>,PCollection<MatchResult.Metadata>> implements Serializable
- Class org.apache.beam.sdk.io.FileIO.MatchConfiguration extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.io.FileIO.ReadMatches extends PTransform<PCollection<MatchResult.Metadata>,PCollection<FileIO.ReadableFile>> implements Serializable
- Class org.apache.beam.sdk.io.FileIO.Write extends PTransform<PCollection<UserT>,WriteFilesResult<DestinationT>> implements Serializable
- Class org.apache.beam.sdk.io.GenerateSequence extends PTransform<PBegin,PCollection<java.lang.Long>> implements Serializable
- Class org.apache.beam.sdk.io.OffsetBasedSource extends BoundedSource<T> implements Serializable
  - Serialized Fields
    - startOffset
```
long startOffset
```
    - endOffset
```
long endOffset
```
    - minBundleSize
```
long minBundleSize
```
- Class org.apache.beam.sdk.io.Read.Bounded extends PTransform<PBegin,PCollection<T>> implements Serializable
  - Serialized Fields
    - source
```
BoundedSource<T> source
```
- Class org.apache.beam.sdk.io.Read.Unbounded extends PTransform<PBegin,PCollection<T>> implements Serializable
  - Serialized Fields
    - source
```
UnboundedSource<OutputT,CheckpointMarkT extends UnboundedSource.CheckpointMark> source
```
- Class org.apache.beam.sdk.io.ReadableFileCoder extends AtomicCoder<FileIO.ReadableFile> implements Serializable
- Class org.apache.beam.sdk.io.ReadAllViaFileBasedSource extends PTransform<PCollection<FileIO.ReadableFile>,PCollection<T>> implements Serializable
  - Serialized Fields
    - desiredBundleSizeBytes
```
long desiredBundleSizeBytes
```
    - createSource
```
SerializableFunction<InputT,OutputT> createSource
```
    - coder
```
Coder<T> coder
```
- Class org.apache.beam.sdk.io.Source extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.io.TextIO.Read extends PTransform<PBegin,PCollection<java.lang.String>> implements Serializable
- Class org.apache.beam.sdk.io.TextIO.ReadAll extends PTransform<PCollection<java.lang.String>,PCollection<java.lang.String>> implements Serializable
- Class org.apache.beam.sdk.io.TextIO.ReadFiles extends PTransform<PCollection<FileIO.ReadableFile>,PCollection<java.lang.String>> implements Serializable
- Class org.apache.beam.sdk.io.TextIO.Sink extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.io.TextIO.TypedWrite extends PTransform<PCollection<UserT>,WriteFilesResult<DestinationT>> implements Serializable
- Class org.apache.beam.sdk.io.TextIO.Write extends PTransform<PCollection<java.lang.String>,PDone> implements Serializable
  - Serialized Fields
    - inner
```
TextIO.TypedWrite<UserT,DestinationT> inner
```
- Class org.apache.beam.sdk.io.TFRecordIO.Read extends PTransform<PBegin,PCollection<byte[]>> implements Serializable
- Class org.apache.beam.sdk.io.TFRecordIO.Sink extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.io.TFRecordIO.Write extends PTransform<PCollection<byte[]>,PDone> implements Serializable
- Class org.apache.beam.sdk.io.UnboundedSource extends Source<OutputT> implements Serializable
- Class org.apache.beam.sdk.io.WriteFiles extends PTransform<PCollection<UserT>,WriteFilesResult<DestinationT>> implements Serializable
  - Serialized Fields
    - writeOperation
```
FileBasedSink.WriteOperation<DestinationT,OutputT> writeOperation
```
Package org.apache.beam.sdk.io.amqp
- Class org.apache.beam.sdk.io.amqp.AmqpIO.Read extends PTransform<PBegin,PCollection<org.apache.qpid.proton.message.Message>> implements Serializable
- Class org.apache.beam.sdk.io.amqp.AmqpIO.Write extends PTransform<PCollection<org.apache.qpid.proton.message.Message>,PDone> implements Serializable
- Class org.apache.beam.sdk.io.amqp.AmqpMessageCoder extends CustomCoder<org.apache.qpid.proton.message.Message> implements Serializable
Package org.apache.beam.sdk.io.aws.options
- Class org.apache.beam.sdk.io.aws.options.AwsModule extends SimpleModule implements Serializable
Package org.apache.beam.sdk.io.aws.sns
- Class org.apache.beam.sdk.io.aws.sns.PublishResultCoder extends Coder<com.amazonaws.services.sns.model.PublishResult> implements Serializable
- Class org.apache.beam.sdk.io.aws.sns.SnsIO.RetryConfiguration extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.io.aws.sns.SnsIO.Write extends PTransform<PCollection<com.amazonaws.services.sns.model.PublishRequest>,PCollectionTuple> implements Serializable
Package org.apache.beam.sdk.io.aws.sqs
- Class org.apache.beam.sdk.io.aws.sqs.SqsIO.Read extends PTransform<PBegin,PCollection<com.amazonaws.services.sqs.model.Message>> implements Serializable
- Class org.apache.beam.sdk.io.aws.sqs.SqsIO.Write extends PTransform<PCollection<com.amazonaws.services.sqs.model.SendMessageRequest>,PDone> implements Serializable
Package org.apache.beam.sdk.io.cassandra
- Class org.apache.beam.sdk.io.cassandra.CassandraIO.Read extends PTransform<PBegin,PCollection<T>> implements Serializable
- Class org.apache.beam.sdk.io.cassandra.CassandraIO.Write extends PTransform<PCollection<T>,PDone> implements Serializable
Package org.apache.beam.sdk.io.clickhouse
- Class org.apache.beam.sdk.io.clickhouse.ClickHouseIO.Write extends PTransform<PCollection<T>,PDone> implements Serializable
- Class org.apache.beam.sdk.io.clickhouse.TableSchema extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.io.clickhouse.TableSchema.Column extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.io.clickhouse.TableSchema.ColumnType extends java.lang.Object implements Serializable
Package org.apache.beam.sdk.io.elasticsearch
- Class org.apache.beam.sdk.io.elasticsearch.ElasticsearchIO.BoundedElasticsearchSource extends BoundedSource<java.lang.String> implements Serializable
  - Serialized Fields
    - backendVersion
```
int backendVersion
```
    - spec
```
ElasticsearchIO.Read spec
```
    - shardPreference
```
java.lang.String shardPreference
```
    - numSlices
```
java.lang.Integer numSlices
```
    - sliceId
```
java.lang.Integer sliceId
```
- Class org.apache.beam.sdk.io.elasticsearch.ElasticsearchIO.ConnectionConfiguration extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.io.elasticsearch.ElasticsearchIO.Read extends PTransform<PBegin,PCollection<java.lang.String>> implements Serializable
- Class org.apache.beam.sdk.io.elasticsearch.ElasticsearchIO.RetryConfiguration extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.io.elasticsearch.ElasticsearchIO.Write extends PTransform<PCollection<java.lang.String>,PDone> implements Serializable
Package org.apache.beam.sdk.io.fs
- Class org.apache.beam.sdk.io.fs.MatchResult.Metadata extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.io.fs.MetadataCoder extends AtomicCoder<MatchResult.Metadata> implements Serializable
- Class org.apache.beam.sdk.io.fs.MetadataCoderV2 extends AtomicCoder<MatchResult.Metadata> implements Serializable
- Class org.apache.beam.sdk.io.fs.ResourceIdCoder extends AtomicCoder<ResourceId> implements Serializable
Package org.apache.beam.sdk.io.gcp.bigquery
- Class org.apache.beam.sdk.io.gcp.bigquery.BigQueryInsertErrorCoder extends AtomicCoder<BigQueryInsertError> implements Serializable
- Class org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.Read extends PTransform<PBegin,PCollection<TableRow>> implements Serializable
  - Serialized Fields
    - inner
```
BigQueryIO.TypedRead<T> inner
```
- Class org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.Write extends PTransform<PCollection<T>,WriteResult> implements Serializable
- Class org.apache.beam.sdk.io.gcp.bigquery.BigQueryStorageQuerySource extends org.apache.beam.sdk.io.gcp.bigquery.BigQueryStorageSourceBase<T> implements Serializable
  - Serialization Methods
    - readObject
```
private void readObject(java.io.ObjectInputStream in)
                 throws java.lang.ClassNotFoundException,
                        java.io.IOException
```
      Throws:
      
      java.lang.ClassNotFoundException
      
      java.io.IOException
  - Serialized Fields
    - stepUuid
```
java.lang.String stepUuid
```
    - queryProvider
```
ValueProvider<T> queryProvider
```
    - flattenResults
```
java.lang.Boolean flattenResults
```
    - useLegacySql
```
java.lang.Boolean useLegacySql
```
    - priority
```
BigQueryIO.TypedRead.QueryPriority priority
```
    - location
```
java.lang.String location
```
    - kmsKey
```
java.lang.String kmsKey
```
- Class org.apache.beam.sdk.io.gcp.bigquery.BigQueryStorageStreamSource extends OffsetBasedSource<T> implements Serializable
  - Serialized Fields
    - readSession
```
com.google.cloud.bigquery.storage.v1beta1.Storage.ReadSession readSession
```
    - stream
```
com.google.cloud.bigquery.storage.v1beta1.Storage.Stream stream
```
    - jsonTableSchema
```
java.lang.String jsonTableSchema
```
    - parseFn
```
SerializableFunction<InputT,OutputT> parseFn
```
    - outputCoder
```
Coder<T> outputCoder
```
    - bqServices
```
BigQueryServices bqServices
```
- Class org.apache.beam.sdk.io.gcp.bigquery.BigQueryStorageTableSource extends org.apache.beam.sdk.io.gcp.bigquery.BigQueryStorageSourceBase<T> implements Serializable
  - Serialization Methods
    - readObject
```
private void readObject(java.io.ObjectInputStream in)
                 throws java.lang.ClassNotFoundException,
                        java.io.IOException
```
      Throws:
      
      java.lang.ClassNotFoundException
      
      java.io.IOException
  - Serialized Fields
    - tableReferenceProvider
```
ValueProvider<T> tableReferenceProvider
```
- Class org.apache.beam.sdk.io.gcp.bigquery.BigQueryUtils.ConversionOptions extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.io.gcp.bigquery.CreateTables extends PTransform<PCollection<KV<DestinationT,ElementT>>,PCollection<KV<TableDestination,ElementT>>> implements Serializable
  - Serialized Fields
    - createDisposition
```
BigQueryIO.Write.CreateDisposition createDisposition
```
    - bqServices
```
BigQueryServices bqServices
```
    - dynamicDestinations
```
DynamicDestinations<T,DestinationT> dynamicDestinations
```
    - kmsKey
```
java.lang.String kmsKey
```
- Class org.apache.beam.sdk.io.gcp.bigquery.DynamicDestinations extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.io.gcp.bigquery.InsertRetryPolicy extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.io.gcp.bigquery.PrepareWrite extends PTransform<PCollection<InputT>,PCollection<KV<DestinationT,OutputT>>> implements Serializable
  - Serialized Fields
    - dynamicDestinations
```
DynamicDestinations<T,DestinationT> dynamicDestinations
```
    - formatFunction
```
SerializableFunction<InputT,OutputT> formatFunction
```
- Class org.apache.beam.sdk.io.gcp.bigquery.ReifyAsIterable extends PTransform<PCollection<T>,PCollection<java.lang.Iterable<T>>> implements Serializable
- Class org.apache.beam.sdk.io.gcp.bigquery.StreamingInserts extends PTransform<PCollection<KV<DestinationT,ElementT>>,WriteResult> implements Serializable
  - Serialized Fields
    - bigQueryServices
```
BigQueryServices bigQueryServices
```
    - createDisposition
```
BigQueryIO.Write.CreateDisposition createDisposition
```
    - dynamicDestinations
```
DynamicDestinations<T,DestinationT> dynamicDestinations
```
    - retryPolicy
```
InsertRetryPolicy retryPolicy
```
    - extendedErrorInfo
```
boolean extendedErrorInfo
```
    - skipInvalidRows
```
boolean skipInvalidRows
```
    - ignoreUnknownValues
```
boolean ignoreUnknownValues
```
    - kmsKey
```
java.lang.String kmsKey
```
    - elementCoder
```
Coder<T> elementCoder
```
    - toTableRow
```
SerializableFunction<InputT,OutputT> toTableRow
```
- Class org.apache.beam.sdk.io.gcp.bigquery.StreamingWriteTables extends PTransform<PCollection<KV<TableDestination,ElementT>>,WriteResult> implements Serializable
  - Serialized Fields
    - bigQueryServices
```
BigQueryServices bigQueryServices
```
    - retryPolicy
```
InsertRetryPolicy retryPolicy
```
    - extendedErrorInfo
```
boolean extendedErrorInfo
```
    - skipInvalidRows
```
boolean skipInvalidRows
```
    - ignoreUnknownValues
```
boolean ignoreUnknownValues
```
    - elementCoder
```
Coder<T> elementCoder
```
    - toTableRow
```
SerializableFunction<InputT,OutputT> toTableRow
```
- Class org.apache.beam.sdk.io.gcp.bigquery.TableDestination extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - tableSpec
```
java.lang.String tableSpec
```
    - tableDescription
```
java.lang.String tableDescription
```
    - jsonTimePartitioning
```
java.lang.String jsonTimePartitioning
```
- Class org.apache.beam.sdk.io.gcp.bigquery.TableDestinationCoder extends AtomicCoder<TableDestination> implements Serializable
- Class org.apache.beam.sdk.io.gcp.bigquery.TableDestinationCoderV2 extends AtomicCoder<TableDestination> implements Serializable
- Class org.apache.beam.sdk.io.gcp.bigquery.TableRowJsonCoder extends AtomicCoder<TableRow> implements Serializable
- Class org.apache.beam.sdk.io.gcp.bigquery.WriteBundlesToFiles.ResultCoder extends StructuredCoder<org.apache.beam.sdk.io.gcp.bigquery.WriteBundlesToFiles.Result<DestinationT>> implements Serializable
  - Serialized Fields
    - destinationCoder
```
Coder<T> destinationCoder
```
Package org.apache.beam.sdk.io.gcp.bigtable
- Class org.apache.beam.sdk.io.gcp.bigtable.BigtableIO.Read extends PTransform<PBegin,PCollection<com.google.bigtable.v2.Row>> implements Serializable
- Class org.apache.beam.sdk.io.gcp.bigtable.BigtableIO.Write extends PTransform<PCollection<KV<com.google.protobuf.ByteString,java.lang.Iterable<com.google.bigtable.v2.Mutation>>>,PDone> implements Serializable
Package org.apache.beam.sdk.io.gcp.datastore
- Class org.apache.beam.sdk.io.gcp.datastore.DatastoreV1.DeleteEntity extends org.apache.beam.sdk.io.gcp.datastore.DatastoreV1.Mutate<com.google.datastore.v1.Entity> implements Serializable
- Class org.apache.beam.sdk.io.gcp.datastore.DatastoreV1.DeleteKey extends org.apache.beam.sdk.io.gcp.datastore.DatastoreV1.Mutate<com.google.datastore.v1.Key> implements Serializable
- Class org.apache.beam.sdk.io.gcp.datastore.DatastoreV1.Read extends PTransform<PBegin,PCollection<com.google.datastore.v1.Entity>> implements Serializable
- Class org.apache.beam.sdk.io.gcp.datastore.DatastoreV1.Write extends org.apache.beam.sdk.io.gcp.datastore.DatastoreV1.Mutate<com.google.datastore.v1.Entity> implements Serializable
Package org.apache.beam.sdk.io.gcp.pubsub
- Class org.apache.beam.sdk.io.gcp.pubsub.PubsubClient.OutgoingMessage extends java.lang.Object implements Serializable
  - Serialized Fields
    - elementBytes
```
byte[] elementBytes
```
      Underlying (encoded) element.
    - attributes
```
java.util.Map<K,V> attributes
```
    - timestampMsSinceEpoch
```
long timestampMsSinceEpoch
```
      Timestamp for element (ms since epoch).
    - recordId
```
java.lang.String recordId
```
      If using an id attribute, the record id to associate with this record's metadata so the receiver can reject duplicates. Otherwise null.
- Class org.apache.beam.sdk.io.gcp.pubsub.PubsubClient.ProjectPath extends java.lang.Object implements Serializable
  - Serialized Fields
    - projectId
```
java.lang.String projectId
```
- Class org.apache.beam.sdk.io.gcp.pubsub.PubsubClient.SubscriptionPath extends java.lang.Object implements Serializable
  - Serialized Fields
    - projectId
```
java.lang.String projectId
```
    - subscriptionName
```
java.lang.String subscriptionName
```
- Class org.apache.beam.sdk.io.gcp.pubsub.PubsubClient.TopicPath extends java.lang.Object implements Serializable
  - Serialized Fields
    - path
```
java.lang.String path
```
- Class org.apache.beam.sdk.io.gcp.pubsub.PubsubIO.PubsubSubscription extends java.lang.Object implements Serializable
  - Serialized Fields
    - type
```
org.apache.beam.sdk.io.gcp.pubsub.PubsubIO.PubsubSubscription.Type type
```
    - project
```
java.lang.String project
```
    - subscription
```
java.lang.String subscription
```
- Class org.apache.beam.sdk.io.gcp.pubsub.PubsubIO.PubsubTopic extends java.lang.Object implements Serializable
  - Serialized Fields
    - type
```
org.apache.beam.sdk.io.gcp.pubsub.PubsubIO.PubsubTopic.Type type
```
    - project
```
java.lang.String project
```
    - topic
```
java.lang.String topic
```
- Class org.apache.beam.sdk.io.gcp.pubsub.PubsubIO.Read extends PTransform<PBegin,PCollection<T>> implements Serializable
- Class org.apache.beam.sdk.io.gcp.pubsub.PubsubIO.Write extends PTransform<PCollection<T>,PDone> implements Serializable
- Class org.apache.beam.sdk.io.gcp.pubsub.PubsubIO.Write.PubsubBoundedWriter extends DoFn<T,java.lang.Void> implements Serializable
  - Serialized Fields
    - maxPublishBatchByteSize
```
int maxPublishBatchByteSize
```
    - maxPublishBatchSize
```
int maxPublishBatchSize
```
- Class org.apache.beam.sdk.io.gcp.pubsub.PubsubMessagePayloadOnlyCoder extends CustomCoder<PubsubMessage> implements Serializable
- Class org.apache.beam.sdk.io.gcp.pubsub.PubsubMessageWithAttributesCoder extends CustomCoder<PubsubMessage> implements Serializable
- Class org.apache.beam.sdk.io.gcp.pubsub.PubsubUnboundedSink extends PTransform<PCollection<PubsubMessage>,PDone> implements Serializable
  - Serialized Fields
    - pubsubFactory
```
PubsubClient.PubsubClientFactory pubsubFactory
```
      Which factory to use for creating Pubsub transport.
    - topic
```
ValueProvider<T> topic
```
      Pubsub topic to publish to.
    - timestampAttribute
```
java.lang.String timestampAttribute
```
      Pubsub metadata field holding timestamp of each element, or null if should use Pubsub message publish timestamp instead.
    - idAttribute
```
java.lang.String idAttribute
```
      Pubsub metadata field holding id for each element, or null if need to generate a unique id ourselves.
    - numShards
```
int numShards
```
      Number of 'shards' to use so that latency in Pubsub publish can be hidden. Generally this should be a small multiple of the number of available cores. Too smoll a number results in too much time lost to blocking Pubsub calls. To large a number results in too many single-element batches being sent to Pubsub with high per-batch overhead.
    - publishBatchSize
```
int publishBatchSize
```
      Maximum number of messages per publish.
    - publishBatchBytes
```
int publishBatchBytes
```
      Maximum size of a publish batch, in bytes.
    - maxLatency
```
Duration maxLatency
```
      Longest delay between receiving a message and pushing it to Pubsub.
    - recordIdMethod
```
org.apache.beam.sdk.io.gcp.pubsub.PubsubUnboundedSink.RecordIdMethod recordIdMethod
```
      How record ids should be generated for each record (if PubsubUnboundedSink.idAttribute is non-null).
- Class org.apache.beam.sdk.io.gcp.pubsub.PubsubUnboundedSource extends PTransform<PBegin,PCollection<PubsubMessage>> implements Serializable
  - Serialized Fields
    - clock
```
com.google.api.client.util.Clock clock
```
      For testing only: Clock to use for all timekeeping. If null use system clock.
    - pubsubFactory
```
PubsubClient.PubsubClientFactory pubsubFactory
```
      Factory for creating underlying Pubsub transport.
    - project
```
ValueProvider<T> project
```
      Project under which to create a subscription if only the PubsubUnboundedSource.topic was given.
    - topic
```
ValueProvider<T> topic
```
      Topic to read from. If null, then PubsubUnboundedSource.subscription must be given. Otherwise PubsubUnboundedSource.subscription must be null.
    - subscription
```
ValueProvider<T> subscription
```
      Subscription to read from. If null then PubsubUnboundedSource.topic must be given. Otherwise PubsubUnboundedSource.topic must be null.
      If no subscription is given a random one will be created when the transorm is applied. This field will be update with that subscription's path. The created subscription is never deleted.
    - timestampAttribute
```
java.lang.String timestampAttribute
```
      Pubsub metadata field holding timestamp of each element, or null if should use Pubsub message publish timestamp instead.
    - idAttribute
```
java.lang.String idAttribute
```
      Pubsub metadata field holding id for each element, or null if need to generate a unique id ourselves.
    - needsAttributes
```
boolean needsAttributes
```
      Whether this source should load the attributes of the PubsubMessage, or only the payload.
Package org.apache.beam.sdk.io.gcp.spanner
- Class org.apache.beam.sdk.io.gcp.spanner.MutationGroup extends java.lang.Object implements Serializable
  - Serialized Fields
    - mutations
```
org.apache.beam.vendor.guava.v20_0.com.google.common.collect.ImmutableList<E> mutations
```
- Class org.apache.beam.sdk.io.gcp.spanner.ReadOperation extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.io.gcp.spanner.SpannerConfig extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.io.gcp.spanner.SpannerIO.CreateTransaction extends PTransform<PBegin,PCollectionView<Transaction>> implements Serializable
- Class org.apache.beam.sdk.io.gcp.spanner.SpannerIO.Read extends PTransform<PBegin,PCollection<com.google.cloud.spanner.Struct>> implements Serializable
- Class org.apache.beam.sdk.io.gcp.spanner.SpannerIO.ReadAll extends PTransform<PCollection<ReadOperation>,PCollection<com.google.cloud.spanner.Struct>> implements Serializable
- Class org.apache.beam.sdk.io.gcp.spanner.SpannerIO.Write extends PTransform<PCollection<com.google.cloud.spanner.Mutation>,SpannerWriteResult> implements Serializable
- Class org.apache.beam.sdk.io.gcp.spanner.Transaction extends java.lang.Object implements Serializable
Package org.apache.beam.sdk.io.gcp.testing
- Class org.apache.beam.sdk.io.gcp.testing.BigqueryMatcher extends TypeSafeMatcher<PipelineResult> implements Serializable
  - Serialized Fields
    - projectId
```
java.lang.String projectId
```
    - query
```
java.lang.String query
```
    - expectedChecksum
```
java.lang.String expectedChecksum
```
    - actualChecksum
```
java.lang.String actualChecksum
```
    - bigqueryClient
```
BigqueryClient bigqueryClient
```
Package org.apache.beam.sdk.io.hadoop
- Class org.apache.beam.sdk.io.hadoop.SerializableConfiguration extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - readExternal
```
public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException,
                         java.lang.ClassNotFoundException
```
      Throws:
      
      java.io.IOException
      
      java.lang.ClassNotFoundException
    - writeExternal
```
public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException
```
      Throws:
      
      java.io.IOException
- Class org.apache.beam.sdk.io.hadoop.WritableCoder extends CustomCoder<T extends org.apache.hadoop.io.Writable> implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - type
```
java.lang.Class<T> type
```
Package org.apache.beam.sdk.io.hadoop.format
- Class org.apache.beam.sdk.io.hadoop.format.HadoopFormatIO.HadoopInputFormatBoundedSource extends BoundedSource<KV<K,V>> implements Serializable
  - Serialized Fields
    - conf
```
SerializableConfiguration conf
```
    - keyCoder
```
Coder<T> keyCoder
```
    - valueCoder
```
Coder<T> valueCoder
```
    - keyTranslationFunction
```
SimpleFunction<InputT,OutputT> keyTranslationFunction
```
    - valueTranslationFunction
```
SimpleFunction<InputT,OutputT> valueTranslationFunction
```
    - inputSplit
```
HadoopFormatIO.SerializableSplit inputSplit
```
    - boundedSourceEstimatedSize
```
long boundedSourceEstimatedSize
```
- Class org.apache.beam.sdk.io.hadoop.format.HadoopFormatIO.Read extends PTransform<PBegin,PCollection<KV<K,V>>> implements Serializable
- Class org.apache.beam.sdk.io.hadoop.format.HadoopFormatIO.SerializableSplit extends java.lang.Object implements Serializable
  - Serialization Methods
    - readObject
```
private void readObject(java.io.ObjectInputStream in)
                 throws java.io.IOException
```
      Throws:
      
      java.io.IOException
    - writeObject
```
private void writeObject(java.io.ObjectOutputStream out)
                  throws java.io.IOException
```
      Throws:
      
      java.io.IOException
  - Serialized Fields
    - inputSplit
```
org.apache.hadoop.mapreduce.InputSplit inputSplit
```
- Class org.apache.beam.sdk.io.hadoop.format.HadoopFormatIO.Write extends PTransform<PCollection<KV<KeyT,ValueT>>,PDone> implements Serializable
  - Serialized Fields
    - configTransform
```
PTransform<InputT extends PInput,OutputT extends POutput> configTransform
```
    - externalSynchronization
```
ExternalSynchronization externalSynchronization
```
    - withPartitioning
```
boolean withPartitioning
```
- Class org.apache.beam.sdk.io.hadoop.format.HDFSSynchronization extends java.lang.Object implements Serializable
  - Serialized Fields
    - locksDir
```
java.lang.String locksDir
```
    - fileSystemFactory
```
HDFSSynchronization.ThrowingFunction<T1,T2,X extends java.lang.Exception> fileSystemFactory
```
Package org.apache.beam.sdk.io.hbase
- Class org.apache.beam.sdk.io.hbase.HBaseIO.Read extends PTransform<PBegin,PCollection<org.apache.hadoop.hbase.client.Result>> implements Serializable
  - Serialized Fields
    - serializableConfiguration
```
SerializableConfiguration serializableConfiguration
```
    - tableId
```
java.lang.String tableId
```
    - serializableScan
```
org.apache.beam.sdk.io.hbase.SerializableScan serializableScan
```
- Class org.apache.beam.sdk.io.hbase.HBaseIO.ReadAll extends PTransform<PCollection<HBaseQuery>,PCollection<org.apache.hadoop.hbase.client.Result>> implements Serializable
  - Serialized Fields
    - serializableConfiguration
```
SerializableConfiguration serializableConfiguration
```
- Class org.apache.beam.sdk.io.hbase.HBaseIO.Write extends PTransform<PCollection<org.apache.hadoop.hbase.client.Mutation>,PDone> implements Serializable
  - Serialized Fields
    - tableId
```
java.lang.String tableId
```
    - serializableConfiguration
```
SerializableConfiguration serializableConfiguration
```
Package org.apache.beam.sdk.io.hcatalog
- Class org.apache.beam.sdk.io.hcatalog.HCatalogIO.Read extends PTransform<PBegin,PCollection<org.apache.hive.hcatalog.data.HCatRecord>> implements Serializable
- Class org.apache.beam.sdk.io.hcatalog.HCatalogIO.Write extends PTransform<PCollection<org.apache.hive.hcatalog.data.HCatRecord>,PDone> implements Serializable
Package org.apache.beam.sdk.io.hdfs
- Class org.apache.beam.sdk.io.hdfs.HadoopFileSystemModule extends SimpleModule implements Serializable
Package org.apache.beam.sdk.io.jdbc
- Class org.apache.beam.sdk.io.jdbc.JdbcIO.DataSourceConfiguration extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.io.jdbc.JdbcIO.DefaultRetryStrategy extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.io.jdbc.JdbcIO.PoolableDataSourceProvider extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.io.jdbc.JdbcIO.Read extends PTransform<PBegin,PCollection<T>> implements Serializable
- Class org.apache.beam.sdk.io.jdbc.JdbcIO.ReadAll extends PTransform<PCollection<ParameterT>,PCollection<OutputT>> implements Serializable
- Class org.apache.beam.sdk.io.jdbc.JdbcIO.Write extends PTransform<PCollection<T>,PDone> implements Serializable
  - Serialized Fields
    - inner
```
JdbcIO.WriteVoid<T> inner
```
- Class org.apache.beam.sdk.io.jdbc.JdbcIO.WriteVoid extends PTransform<PCollection<T>,PCollection<java.lang.Void>> implements Serializable
Package org.apache.beam.sdk.io.jms
- Class org.apache.beam.sdk.io.jms.JmsIO.Read extends PTransform<PBegin,PCollection<T>> implements Serializable
- Class org.apache.beam.sdk.io.jms.JmsIO.UnboundedJmsSource extends UnboundedSource<T,JmsCheckpointMark> implements Serializable
  - Serialized Fields
    - spec
```
JmsIO.Read<T> spec
```
- Class org.apache.beam.sdk.io.jms.JmsIO.Write extends PTransform<PCollection<java.lang.String>,PDone> implements Serializable
- Class org.apache.beam.sdk.io.jms.JmsRecord extends java.lang.Object implements Serializable
  - Serialized Fields
    - jmsMessageID
```
java.lang.String jmsMessageID
```
    - jmsTimestamp
```
long jmsTimestamp
```
    - jmsCorrelationID
```
java.lang.String jmsCorrelationID
```
    - jmsReplyTo
```
javax.jms.Destination jmsReplyTo
```
    - jmsDestination
```
javax.jms.Destination jmsDestination
```
    - jmsDeliveryMode
```
int jmsDeliveryMode
```
    - jmsRedelivered
```
boolean jmsRedelivered
```
    - jmsType
```
java.lang.String jmsType
```
    - jmsExpiration
```
long jmsExpiration
```
    - jmsPriority
```
int jmsPriority
```
    - properties
```
java.util.Map<K,V> properties
```
    - text
```
java.lang.String text
```
Package org.apache.beam.sdk.io.kafka
- Class org.apache.beam.sdk.io.kafka.KafkaCheckpointMark.PartitionMark extends java.lang.Object implements Serializable
  - Serialized Fields
    - topic
```
java.lang.String topic
```
    - partition
```
int partition
```
    - nextOffset
```
long nextOffset
```
    - watermarkMillis
```
long watermarkMillis
```
- Class org.apache.beam.sdk.io.kafka.KafkaIO.Read extends PTransform<PBegin,PCollection<KafkaRecord<K,V>>> implements Serializable
- Class org.apache.beam.sdk.io.kafka.KafkaIO.TypedWithoutMetadata extends PTransform<PBegin,PCollection<KV<K,V>>> implements Serializable
  - Serialized Fields
    - read
```
KafkaIO.Read<K,V> read
```
- Class org.apache.beam.sdk.io.kafka.KafkaIO.Write extends PTransform<PCollection<KV<K,V>>,PDone> implements Serializable
- Class org.apache.beam.sdk.io.kafka.KafkaIO.WriteRecords extends PTransform<PCollection<org.apache.kafka.clients.producer.ProducerRecord<K,V>>,PDone> implements Serializable
- Class org.apache.beam.sdk.io.kafka.KafkaRecordCoder extends StructuredCoder<KafkaRecord<K,V>> implements Serializable
  - Serialized Fields
    - kvCoder
```
KvCoder<K,V> kvCoder
```
- Class org.apache.beam.sdk.io.kafka.ProducerRecordCoder extends StructuredCoder<org.apache.kafka.clients.producer.ProducerRecord<K,V>> implements Serializable
  - Serialized Fields
    - kvCoder
```
KvCoder<K,V> kvCoder
```
Package org.apache.beam.sdk.io.kinesis
- Class org.apache.beam.sdk.io.kinesis.KinesisIO.Read extends PTransform<PBegin,PCollection<KinesisRecord>> implements Serializable
- Class org.apache.beam.sdk.io.kinesis.KinesisIO.Write extends PTransform<PCollection<byte[]>,PDone> implements Serializable
Package org.apache.beam.sdk.io.mongodb
- Class org.apache.beam.sdk.io.mongodb.AggregationQuery extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.io.mongodb.FindQuery extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.io.mongodb.MongoDbGridFSIO.ConnectionConfiguration extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.io.mongodb.MongoDbGridFSIO.Read extends PTransform<PBegin,PCollection<T>> implements Serializable
- Class org.apache.beam.sdk.io.mongodb.MongoDbGridFSIO.Read.BoundedGridFSSource extends BoundedSource<org.bson.types.ObjectId> implements Serializable
  - Serialized Fields
    - spec
```
MongoDbGridFSIO.Read<T> spec
```
    - objectIds
```
java.util.List<E> objectIds
```
- Class org.apache.beam.sdk.io.mongodb.MongoDbGridFSIO.Write extends PTransform<PCollection<T>,PDone> implements Serializable
- Class org.apache.beam.sdk.io.mongodb.MongoDbIO.Read extends PTransform<PBegin,PCollection<org.bson.Document>> implements Serializable
- Class org.apache.beam.sdk.io.mongodb.MongoDbIO.Write extends PTransform<PCollection<org.bson.Document>,PDone> implements Serializable
Package org.apache.beam.sdk.io.mqtt
- Class org.apache.beam.sdk.io.mqtt.MqttIO.ConnectionConfiguration extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.io.mqtt.MqttIO.Read extends PTransform<PBegin,PCollection<byte[]>> implements Serializable
- Class org.apache.beam.sdk.io.mqtt.MqttIO.Write extends PTransform<PCollection<byte[]>,PDone> implements Serializable
Package org.apache.beam.sdk.io.parquet
- Class org.apache.beam.sdk.io.parquet.ParquetIO.Read extends PTransform<PBegin,PCollection<GenericRecord>> implements Serializable
- Class org.apache.beam.sdk.io.parquet.ParquetIO.ReadFiles extends PTransform<PCollection<FileIO.ReadableFile>,PCollection<GenericRecord>> implements Serializable
- Class org.apache.beam.sdk.io.parquet.ParquetIO.Sink extends java.lang.Object implements Serializable
Package org.apache.beam.sdk.io.range
- Class org.apache.beam.sdk.io.range.ByteKey extends java.lang.Object implements Serializable
  - Serialized Fields
    - value
```
com.google.protobuf.ByteString value
```
- Class org.apache.beam.sdk.io.range.ByteKeyRange extends java.lang.Object implements Serializable
  - Serialized Fields
    - startKey
```
ByteKey startKey
```
    - endKey
```
ByteKey endKey
```
- Class org.apache.beam.sdk.io.range.OffsetRange extends java.lang.Object implements Serializable
  - Serialized Fields
    - from
```
long from
```
    - to
```
long to
```
- Class org.apache.beam.sdk.io.range.OffsetRange.Coder extends AtomicCoder<OffsetRange> implements Serializable
Package org.apache.beam.sdk.io.redis
- Class org.apache.beam.sdk.io.redis.RedisConnectionConfiguration extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.io.redis.RedisIO.Read extends PTransform<PBegin,PCollection<KV<java.lang.String,java.lang.String>>> implements Serializable
- Class org.apache.beam.sdk.io.redis.RedisIO.ReadAll extends PTransform<PCollection<java.lang.String>,PCollection<KV<java.lang.String,java.lang.String>>> implements Serializable
- Class org.apache.beam.sdk.io.redis.RedisIO.Write extends PTransform<PCollection<KV<java.lang.String,java.lang.String>>,PDone> implements Serializable
Package org.apache.beam.sdk.io.solr
- Class org.apache.beam.sdk.io.solr.SolrIO.ConnectionConfiguration extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.io.solr.SolrIO.Read extends PTransform<PBegin,PCollection<org.apache.solr.common.SolrDocument>> implements Serializable
- Class org.apache.beam.sdk.io.solr.SolrIO.RetryConfiguration extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.io.solr.SolrIO.Write extends PTransform<PCollection<org.apache.solr.common.SolrInputDocument>,PDone> implements Serializable
Package org.apache.beam.sdk.io.tika
- Class org.apache.beam.sdk.io.tika.ParseResult extends java.lang.Object implements Serializable
  - Serialized Fields
    - fileLocation
```
java.lang.String fileLocation
```
    - content
```
java.lang.String content
```
    - metadata
```
org.apache.tika.metadata.Metadata metadata
```
    - metadataNames
```
java.lang.String[] metadataNames
```
    - error
```
org.apache.beam.sdk.util.SerializableThrowable error
```
- Class org.apache.beam.sdk.io.tika.TikaIO.Parse extends PTransform<PBegin,PCollection<ParseResult>> implements Serializable
- Class org.apache.beam.sdk.io.tika.TikaIO.ParseFiles extends PTransform<PCollection<FileIO.ReadableFile>,PCollection<ParseResult>> implements Serializable
Package org.apache.beam.sdk.io.xml
- Class org.apache.beam.sdk.io.xml.JAXBCoder extends CustomCoder<T> implements Serializable
  - Serialized Fields
    - jaxbClass
```
java.lang.Class<T> jaxbClass
```
    - jaxbMarshaller
```
org.apache.beam.sdk.util.EmptyOnDeserializationThreadLocal<T> jaxbMarshaller
```
    - jaxbUnmarshaller
```
org.apache.beam.sdk.util.EmptyOnDeserializationThreadLocal<T> jaxbUnmarshaller
```
- Class org.apache.beam.sdk.io.xml.XmlIO.Read extends PTransform<PBegin,PCollection<T>> implements Serializable
- Class org.apache.beam.sdk.io.xml.XmlIO.ReadFiles extends PTransform<PCollection<FileIO.ReadableFile>,PCollection<T>> implements Serializable
- Class org.apache.beam.sdk.io.xml.XmlIO.Sink extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.io.xml.XmlIO.Write extends PTransform<PCollection<T>,PDone> implements Serializable
- Class org.apache.beam.sdk.io.xml.XmlSource extends FileBasedSource<T> implements Serializable
  - Serialized Fields
    - configuration
```
org.apache.beam.sdk.io.xml.XmlIO.MappingConfiguration<T> configuration
```
Package org.apache.beam.sdk.metrics
- Class org.apache.beam.sdk.metrics.DelegatingCounter extends java.lang.Object implements Serializable
  - Serialized Fields
    - name
```
MetricName name
```
- Class org.apache.beam.sdk.metrics.MetricKey extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.metrics.MetricName extends java.lang.Object implements Serializable
Package org.apache.beam.sdk.options
- Class org.apache.beam.sdk.options.SdkHarnessOptions.SdkHarnessLogLevelOverrides extends java.util.HashMap<java.lang.String,SdkHarnessOptions.LogLevel> implements Serializable
- Class org.apache.beam.sdk.options.ValueProvider.NestedValueProvider extends java.lang.Object implements Serializable
  - Serialized Fields
    - value
```
ValueProvider<T> value
```
    - translator
```
SerializableFunction<InputT,OutputT> translator
```
- Class org.apache.beam.sdk.options.ValueProvider.RuntimeValueProvider extends java.lang.Object implements Serializable
  - Serialized Fields
    - klass
```
java.lang.Class<T> klass
```
    - methodName
```
java.lang.String methodName
```
    - propertyName
```
java.lang.String propertyName
```
    - defaultValue
```
java.lang.Object defaultValue
```
    - optionsId
```
java.lang.Long optionsId
```
- Class org.apache.beam.sdk.options.ValueProvider.StaticValueProvider extends java.lang.Object implements Serializable
  - Serialized Fields
    - value
```
java.lang.Object value
```
Package org.apache.beam.sdk.schemas
- Class org.apache.beam.sdk.schemas.AutoValueSchema extends GetterBasedSchemaProvider implements Serializable
- Class org.apache.beam.sdk.schemas.AutoValueSchema.AbstractGetterTypeSupplier extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.schemas.AvroRecordSchema extends GetterBasedSchemaProvider implements Serializable
- Class org.apache.beam.sdk.schemas.FieldAccessDescriptor extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.schemas.FieldAccessDescriptor.FieldDescriptor extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.schemas.FieldAccessDescriptor.FieldDescriptor.Qualifier extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.schemas.FieldValueTypeInformation extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.schemas.GetterBasedSchemaProvider extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.schemas.JavaBeanSchema extends GetterBasedSchemaProvider implements Serializable
- Class org.apache.beam.sdk.schemas.JavaBeanSchema.GetterTypeSupplier extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.schemas.JavaBeanSchema.JavaBeanSetterFactory extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.schemas.JavaBeanSchema.SetterTypeSupplier extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.schemas.JavaFieldSchema extends GetterBasedSchemaProvider implements Serializable
- Class org.apache.beam.sdk.schemas.JavaFieldSchema.JavaFieldTypeSupplier extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.schemas.LogicalTypes.FixedBytes extends java.lang.Object implements Serializable
  - Serialized Fields
    - byteArraySize
```
int byteArraySize
```
- Class org.apache.beam.sdk.schemas.LogicalTypes.PassThroughLogicalType extends java.lang.Object implements Serializable
  - Serialized Fields
    - identifier
```
java.lang.String identifier
```
    - argument
```
java.lang.String argument
```
    - fieldType
```
Schema.FieldType fieldType
```
- Class org.apache.beam.sdk.schemas.NoSuchSchemaException extends java.lang.Exception implements Serializable
- Class org.apache.beam.sdk.schemas.Schema extends java.lang.Object implements Serializable
  - Serialized Fields
    - fieldIndices
```
org.apache.beam.vendor.guava.v20_0.com.google.common.collect.BiMap<K,V> fieldIndices
```
    - encodingPositions
```
java.util.Map<K,V> encodingPositions
```
    - fields
```
java.util.List<E> fields
```
    - hashCode
```
int hashCode
```
    - uuid
```
java.util.UUID uuid
```
- Class org.apache.beam.sdk.schemas.Schema.Field extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.schemas.Schema.FieldType extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.schemas.SchemaCoder extends CustomCoder<T> implements Serializable
  - Serialized Fields
    - rowCoder
```
RowCoder rowCoder
```
    - toRowFunction
```
SerializableFunction<InputT,OutputT> toRowFunction
```
    - fromRowFunction
```
SerializableFunction<InputT,OutputT> fromRowFunction
```
- Class org.apache.beam.sdk.schemas.SchemaUserTypeConstructorCreator extends java.lang.Object implements Serializable
  - Serialized Fields
    - clazz
```
java.lang.Class<T> clazz
```
Package org.apache.beam.sdk.schemas.annotations
- Class org.apache.beam.sdk.schemas.annotations.DefaultSchema.DefaultSchemaProvider extends java.lang.Object implements Serializable
  - Serialized Fields
    - cachedProviders
```
java.util.Map<K,V> cachedProviders
```
Package org.apache.beam.sdk.schemas.transforms
- Class org.apache.beam.sdk.schemas.transforms.Cast extends PTransform<PCollection<T>,PCollection<Row>> implements Serializable
- Class org.apache.beam.sdk.schemas.transforms.Cast.CompatibilityError extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.schemas.transforms.Cast.Narrowing extends java.lang.Object implements Serializable
  - Serialized Fields
    - fold
```
org.apache.beam.sdk.schemas.transforms.Cast.Narrowing.Fold fold
```
- Class org.apache.beam.sdk.schemas.transforms.Cast.Widening extends java.lang.Object implements Serializable
  - Serialized Fields
    - fold
```
org.apache.beam.sdk.schemas.transforms.Cast.Widening.Fold fold
```
- Class org.apache.beam.sdk.schemas.transforms.CoGroup.By extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.schemas.transforms.CoGroup.ExpandCrossProduct extends PTransform<PCollectionTuple,PCollection<Row>> implements Serializable
  - Serialized Fields
    - joinArgs
```
org.apache.beam.sdk.schemas.transforms.CoGroup.JoinArguments joinArgs
```
- Class org.apache.beam.sdk.schemas.transforms.CoGroup.Impl extends PTransform<PCollectionTuple,PCollection<KV<Row,Row>>> implements Serializable
  - Serialized Fields
    - joinArgs
```
org.apache.beam.sdk.schemas.transforms.CoGroup.JoinArguments joinArgs
```
- Class org.apache.beam.sdk.schemas.transforms.Filter.Inner extends PTransform<PCollection<T>,PCollection<T>> implements Serializable
  - Serialized Fields
    - fieldNameFilters
```
java.util.Map<K,V> fieldNameFilters
```
    - fieldIdFilters
```
java.util.Map<K,V> fieldIdFilters
```
    - fieldNamesFilters
```
java.util.Map<K,V> fieldNamesFilters
```
    - fieldIdsFilters
```
java.util.Map<K,V> fieldIdsFilters
```
- Class org.apache.beam.sdk.schemas.transforms.Group.ByFields extends PTransform<PCollection<InputT>,PCollection<KV<Row,java.lang.Iterable<InputT>>>> implements Serializable
  - Serialized Fields
    - fieldAccessDescriptor
```
FieldAccessDescriptor fieldAccessDescriptor
```
    - keySchema
```
Schema keySchema
```
- Class org.apache.beam.sdk.schemas.transforms.Group.CombineByFields extends PTransform<PCollection<InputT>,PCollection<KV<Row,OutputT>>> implements Serializable
  - Serialized Fields
    - byFields
```
Group.ByFields<InputT> byFields
```
    - combineFn
```
Combine.CombineFn<InputT,AccumT,OutputT> combineFn
```
- Class org.apache.beam.sdk.schemas.transforms.Group.CombineFieldsByFields extends PTransform<PCollection<InputT>,PCollection<KV<Row,Row>>> implements Serializable
  - Serialized Fields
    - byFields
```
Group.ByFields<InputT> byFields
```
    - schemaAggregateFn
```
org.apache.beam.sdk.schemas.transforms.SchemaAggregateFn.Inner<T> schemaAggregateFn
```
- Class org.apache.beam.sdk.schemas.transforms.Group.CombineFieldsGlobally extends PTransform<PCollection<InputT>,PCollection<Row>> implements Serializable
  - Serialized Fields
    - schemaAggregateFn
```
org.apache.beam.sdk.schemas.transforms.SchemaAggregateFn.Inner<T> schemaAggregateFn
```
- Class org.apache.beam.sdk.schemas.transforms.Group.CombineGlobally extends PTransform<PCollection<InputT>,PCollection<OutputT>> implements Serializable
  - Serialized Fields
    - combineFn
```
Combine.CombineFn<InputT,AccumT,OutputT> combineFn
```
- Class org.apache.beam.sdk.schemas.transforms.Group.Global extends PTransform<PCollection<InputT>,PCollection<java.lang.Iterable<InputT>>> implements Serializable
- Class org.apache.beam.sdk.schemas.transforms.Join.FieldsEqual.Impl extends java.lang.Object implements Serializable
  - Serialized Fields
    - lhs
```
FieldAccessDescriptor lhs
```
    - rhs
```
FieldAccessDescriptor rhs
```
- Class org.apache.beam.sdk.schemas.transforms.Join.Impl extends PTransform<PCollection<LhsT>,PCollection<Row>> implements Serializable
  - Serialized Fields
    - joinType
```
org.apache.beam.sdk.schemas.transforms.Join.JoinType joinType
```
    - predicate
```
Join.FieldsEqual.Impl predicate
```
- Class org.apache.beam.sdk.schemas.transforms.Select extends PTransform<PCollection<T>,PCollection<Row>> implements Serializable
  - Serialized Fields
    - fieldAccessDescriptor
```
FieldAccessDescriptor fieldAccessDescriptor
```
- Class org.apache.beam.sdk.schemas.transforms.Unnest.Inner extends PTransform<PCollection<T>,PCollection<Row>> implements Serializable
Package org.apache.beam.sdk.schemas.utils
- Class org.apache.beam.sdk.schemas.utils.ConvertHelpers.ConvertedSchemaInformation extends java.lang.Object implements Serializable
  - Serialized Fields
    - outputSchemaCoder
```
SchemaCoder<T> outputSchemaCoder
```
    - unboxedType
```
Schema.FieldType unboxedType
```
- Class org.apache.beam.sdk.schemas.utils.SchemaZipFold extends java.lang.Object implements Serializable
Package org.apache.beam.sdk.state
Package org.apache.beam.sdk.testing
- Class org.apache.beam.sdk.testing.FileChecksumMatcher extends TypeSafeMatcher<PipelineResult> implements Serializable
  - Serialized Fields
    - expectedChecksum
```
java.lang.String expectedChecksum
```
    - shardedFile
```
org.apache.beam.sdk.util.ShardedFile shardedFile
```
    - actualChecksum
```
java.lang.String actualChecksum
```
      Access via FileChecksumMatcher.getActualChecksum().
- Class org.apache.beam.sdk.testing.PAssert.DefaultConcludeTransform extends PTransform<PCollection<SuccessOrFailure>,PCollection<java.lang.Void>> implements Serializable
- Class org.apache.beam.sdk.testing.PAssert.GroupThenAssert extends PTransform<PCollection<T>,PDone> implements Serializable
  - Serialized Fields
    - checkerFn
```
SerializableFunction<InputT,OutputT> checkerFn
```
    - rewindowingStrategy
```
org.apache.beam.sdk.testing.PAssert.AssertionWindows rewindowingStrategy
```
    - paneExtractor
```
SimpleFunction<InputT,OutputT> paneExtractor
```
    - site
```
PAssert.PAssertionSite site
```
- Class org.apache.beam.sdk.testing.PAssert.GroupThenAssertForSingleton extends PTransform<PCollection<T>,PDone> implements Serializable
  - Serialized Fields
    - checkerFn
```
SerializableFunction<InputT,OutputT> checkerFn
```
    - rewindowingStrategy
```
org.apache.beam.sdk.testing.PAssert.AssertionWindows rewindowingStrategy
```
    - paneExtractor
```
SimpleFunction<InputT,OutputT> paneExtractor
```
    - site
```
PAssert.PAssertionSite site
```
- Class org.apache.beam.sdk.testing.PAssert.OneSideInputAssert extends PTransform<PBegin,PDone> implements Serializable
  - Serialized Fields
    - checkerFn
```
SerializableFunction<InputT,OutputT> checkerFn
```
    - site
```
PAssert.PAssertionSite site
```
- Class org.apache.beam.sdk.testing.PAssert.PAssertionSite extends java.lang.Object implements Serializable
  - Serialized Fields
    - message
```
java.lang.String message
```
    - creationStackTrace
```
java.lang.StackTraceElement[] creationStackTrace
```
- Class org.apache.beam.sdk.testing.PAssert.PCollectionContentsAssert.MatcherCheckerFn extends java.lang.Object implements Serializable
  - Serialized Fields
    - matcher
```
SerializableMatcher<T> matcher
```
- Class org.apache.beam.sdk.testing.SerializableMatchers extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.testing.SuccessOrFailure extends java.lang.Object implements Serializable
  - Serialized Fields
    - isSuccess
```
boolean isSuccess
```
    - site
```
PAssert.PAssertionSite site
```
    - throwable
```
org.apache.beam.sdk.util.SerializableThrowable throwable
```
- Class org.apache.beam.sdk.testing.TestPipeline.AbandonedNodeException extends java.lang.RuntimeException implements Serializable
- Class org.apache.beam.sdk.testing.TestPipeline.PipelineRunMissingException extends java.lang.RuntimeException implements Serializable
- Class org.apache.beam.sdk.testing.TestPipelineOptions.AlwaysPassMatcher extends BaseMatcher<PipelineResult> implements Serializable
- Class org.apache.beam.sdk.testing.TestStream extends PTransform<PBegin,PCollection<T>> implements Serializable
  - Serialized Fields
    - events
```
java.util.List<E> events
```
    - coder
```
Coder<T> coder
```
- Class org.apache.beam.sdk.testing.TestStream.TestStreamCoder extends StructuredCoder<TestStream<T>> implements Serializable
  - Serialized Fields
    - elementCoder
```
TimestampedValue.TimestampedValueCoder<T> elementCoder
```
Package org.apache.beam.sdk.transforms
- Class org.apache.beam.sdk.transforms.ApproximateQuantiles.ApproximateQuantilesCombineFn extends Combine.AccumulatingCombineFn<T,org.apache.beam.sdk.transforms.ApproximateQuantiles.QuantileState<T,ComparatorT extends java.util.Comparator<T> & java.io.Serializable>,java.util.List<T>> implements Serializable
  - Serialized Fields
    - compareFn
```
java.util.Comparator<T> compareFn
```
      The comparison function to use.
    - numQuantiles
```
int numQuantiles
```
      Number of quantiles to produce. The size of the final output list, including the minimum and maximum, is numQuantiles.
    - bufferSize
```
int bufferSize
```
      The size of the buffers, corresponding to k in the referenced paper.
    - numBuffers
```
int numBuffers
```
      The number of buffers, corresponding to b in the referenced paper.
    - maxNumElements
```
long maxNumElements
```
- Class org.apache.beam.sdk.transforms.ApproximateUnique.ApproximateUniqueCombineFn extends Combine.CombineFn<T,ApproximateUnique.ApproximateUniqueCombineFn.LargestUnique,java.lang.Long> implements Serializable
  - Serialized Fields
    - sampleSize
```
long sampleSize
```
    - coder
```
Coder<T> coder
```
- Class org.apache.beam.sdk.transforms.ApproximateUnique.ApproximateUniqueCombineFn.LargestUnique extends java.lang.Object implements Serializable
  - Serialized Fields
    - heap
```
java.util.TreeSet<E> heap
```
    - minHash
```
long minHash
```
    - sampleSize
```
long sampleSize
```
- Class org.apache.beam.sdk.transforms.Combine.AccumulatingCombineFn extends Combine.CombineFn<InputT,AccumT extends Combine.AccumulatingCombineFn.Accumulator<InputT,AccumT,OutputT>,OutputT> implements Serializable
- Class org.apache.beam.sdk.transforms.Combine.BinaryCombineDoubleFn extends Combine.CombineFn<java.lang.Double,double[],java.lang.Double> implements Serializable
- Class org.apache.beam.sdk.transforms.Combine.BinaryCombineFn extends Combine.CombineFn<V,Combine.Holder<V>,V> implements Serializable
- Class org.apache.beam.sdk.transforms.Combine.BinaryCombineIntegerFn extends Combine.CombineFn<java.lang.Integer,int[],java.lang.Integer> implements Serializable
- Class org.apache.beam.sdk.transforms.Combine.BinaryCombineLongFn extends Combine.CombineFn<java.lang.Long,long[],java.lang.Long> implements Serializable
- Class org.apache.beam.sdk.transforms.Combine.CombineFn extends org.apache.beam.sdk.transforms.CombineFnBase.AbstractGlobalCombineFn<InputT,AccumT,OutputT> implements Serializable
- Class org.apache.beam.sdk.transforms.Combine.Globally extends PTransform<PCollection<InputT>,PCollection<OutputT>> implements Serializable
  - Serialized Fields
    - fn
```
CombineFnBase.GlobalCombineFn<InputT,AccumT,OutputT> fn
```
    - fnDisplayData
```
DisplayData.ItemSpec<T> fnDisplayData
```
    - insertDefault
```
boolean insertDefault
```
    - fanout
```
int fanout
```
    - sideInputs
```
java.util.List<E> sideInputs
```
- Class org.apache.beam.sdk.transforms.Combine.GloballyAsSingletonView extends PTransform<PCollection<InputT>,PCollectionView<OutputT>> implements Serializable
  - Serialized Fields
    - fn
```
CombineFnBase.GlobalCombineFn<InputT,AccumT,OutputT> fn
```
    - fnDisplayData
```
DisplayData.ItemSpec<T> fnDisplayData
```
    - insertDefault
```
boolean insertDefault
```
    - fanout
```
int fanout
```
- Class org.apache.beam.sdk.transforms.Combine.GroupedValues extends PTransform<PCollection<? extends KV<K,? extends java.lang.Iterable<InputT>>>,PCollection<KV<K,OutputT>>> implements Serializable
  - Serialized Fields
    - fn
```
CombineFnBase.GlobalCombineFn<InputT,AccumT,OutputT> fn
```
    - fnDisplayData
```
DisplayData.ItemSpec<T> fnDisplayData
```
    - sideInputs
```
java.util.List<E> sideInputs
```
- Class org.apache.beam.sdk.transforms.Combine.IterableCombineFn extends Combine.CombineFn<V,java.util.List<V>,V> implements Serializable
  - Serialized Fields
    - combiner
```
SerializableFunction<InputT,OutputT> combiner
```
      The combiner function.
    - bufferSize
```
int bufferSize
```
      The number of values to accumulate before invoking the combiner function to combine them.
- Class org.apache.beam.sdk.transforms.Combine.PerKey extends PTransform<PCollection<KV<K,InputT>>,PCollection<KV<K,OutputT>>> implements Serializable
  - Serialized Fields
    - fn
```
CombineFnBase.GlobalCombineFn<InputT,AccumT,OutputT> fn
```
    - fnDisplayData
```
DisplayData.ItemSpec<T> fnDisplayData
```
    - fewKeys
```
boolean fewKeys
```
    - sideInputs
```
java.util.List<E> sideInputs
```
- Class org.apache.beam.sdk.transforms.Combine.PerKeyWithHotKeyFanout extends PTransform<PCollection<KV<K,InputT>>,PCollection<KV<K,OutputT>>> implements Serializable
  - Serialized Fields
    - fn
```
CombineFnBase.GlobalCombineFn<InputT,AccumT,OutputT> fn
```
    - fnDisplayData
```
DisplayData.ItemSpec<T> fnDisplayData
```
    - hotKeyFanout
```
SerializableFunction<InputT,OutputT> hotKeyFanout
```
- Class org.apache.beam.sdk.transforms.Combine.SimpleCombineFn extends Combine.IterableCombineFn<V> implements Serializable
- Class org.apache.beam.sdk.transforms.CombineFns.CoCombineResult extends java.lang.Object implements Serializable
  - Serialized Fields
    - valuesMap
```
java.util.Map<K,V> valuesMap
```
- Class org.apache.beam.sdk.transforms.CombineFns.ComposedCombineFn extends Combine.CombineFn<DataT,java.lang.Object[],CombineFns.CoCombineResult> implements Serializable
  - Serialized Fields
    - combineFns
```
java.util.List<E> combineFns
```
    - combineInputCoders
```
java.util.List<E> combineInputCoders
```
    - extractInputFns
```
java.util.List<E> extractInputFns
```
    - outputTags
```
java.util.List<E> outputTags
```
    - combineFnCount
```
int combineFnCount
```
- Class org.apache.beam.sdk.transforms.CombineFns.ComposedCombineFnWithContext extends CombineWithContext.CombineFnWithContext<DataT,java.lang.Object[],CombineFns.CoCombineResult> implements Serializable
  - Serialized Fields
    - extractInputFns
```
java.util.List<E> extractInputFns
```
    - combineInputCoders
```
java.util.List<E> combineInputCoders
```
    - combineFnWithContexts
```
java.util.List<E> combineFnWithContexts
```
    - outputTags
```
java.util.List<E> outputTags
```
    - combineFnCount
```
int combineFnCount
```
- Class org.apache.beam.sdk.transforms.CombineWithContext.CombineFnWithContext extends org.apache.beam.sdk.transforms.CombineFnBase.AbstractGlobalCombineFn<InputT,AccumT,OutputT> implements Serializable
- Class org.apache.beam.sdk.transforms.Contextful extends java.lang.Object implements Serializable
  - Serialized Fields
    - closure
```
java.lang.Object closure
```
    - requirements
```
Requirements requirements
```
- Class org.apache.beam.sdk.transforms.Create.OfValueProvider extends PTransform<PBegin,PCollection<T>> implements Serializable
  - Serialized Fields
    - provider
```
ValueProvider<T> provider
```
    - coder
```
Coder<T> coder
```
- Class org.apache.beam.sdk.transforms.Create.TimestampedValues extends PTransform<PBegin,PCollection<T>> implements Serializable
- Class org.apache.beam.sdk.transforms.Create.Values extends PTransform<PBegin,PCollection<T>> implements Serializable
- Class org.apache.beam.sdk.transforms.Distinct extends PTransform<PCollection<T>,PCollection<T>> implements Serializable
- Class org.apache.beam.sdk.transforms.Distinct.WithRepresentativeValues extends PTransform<PCollection<T>,PCollection<T>> implements Serializable
  - Serialized Fields
    - fn
```
SerializableFunction<InputT,OutputT> fn
```
    - representativeType
```
TypeDescriptor<T> representativeType
```
- Class org.apache.beam.sdk.transforms.DoFn extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.transforms.DoFnSchemaInformation extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.transforms.Filter extends PTransform<PCollection<T>,PCollection<T>> implements Serializable
  - Serialized Fields
    - predicate
```
ProcessFunction<InputT,OutputT> predicate
```
    - predicateDescription
```
java.lang.String predicateDescription
```
- Class org.apache.beam.sdk.transforms.FlatMapElements extends PTransform<PCollection<? extends InputT>,PCollection<OutputT>> implements Serializable
  - Serialized Fields
    - fn
```
Contextful<ClosureT> fn
```
- Class org.apache.beam.sdk.transforms.FlatMapElements.FlatMapWithFailures extends PTransform<PCollection<InputT>,WithFailures.Result<PCollection<OutputT>,FailureT>> implements Serializable
  - Serialized Fields
    - fn
```
Contextful<ClosureT> fn
```
    - exceptionHandler
```
ProcessFunction<InputT,OutputT> exceptionHandler
```
- Class org.apache.beam.sdk.transforms.Flatten.Iterables extends PTransform<PCollection<? extends java.lang.Iterable<T>>,PCollection<T>> implements Serializable
- Class org.apache.beam.sdk.transforms.Flatten.PCollections extends PTransform<PCollectionList<T>,PCollection<T>> implements Serializable
- Class org.apache.beam.sdk.transforms.GroupByKey extends PTransform<PCollection<KV<K,V>>,PCollection<KV<K,java.lang.Iterable<V>>>> implements Serializable
  - Serialized Fields
    - fewKeys
```
boolean fewKeys
```
- Class org.apache.beam.sdk.transforms.GroupIntoBatches extends PTransform<PCollection<KV<K,InputT>>,PCollection<KV<K,java.lang.Iterable<InputT>>>> implements Serializable
  - Serialized Fields
    - batchSize
```
long batchSize
```
- Class org.apache.beam.sdk.transforms.Impulse extends PTransform<PBegin,PCollection<byte[]>> implements Serializable
- Class org.apache.beam.sdk.transforms.InferableFunction extends java.lang.Object implements Serializable
  - Serialized Fields
    - fn
```
ProcessFunction<InputT,OutputT> fn
```
- Class org.apache.beam.sdk.transforms.Keys extends PTransform<PCollection<? extends KV<K,?>>,PCollection<K>> implements Serializable
- Class org.apache.beam.sdk.transforms.KvSwap extends PTransform<PCollection<KV<K,V>>,PCollection<KV<V,K>>> implements Serializable
- Class org.apache.beam.sdk.transforms.MapElements extends PTransform<PCollection<? extends InputT>,PCollection<OutputT>> implements Serializable
  - Serialized Fields
    - fn
```
Contextful<ClosureT> fn
```
- Class org.apache.beam.sdk.transforms.MapElements.MapWithFailures extends PTransform<PCollection<InputT>,WithFailures.Result<PCollection<OutputT>,FailureT>> implements Serializable
  - Serialized Fields
    - fn
```
Contextful<ClosureT> fn
```
    - exceptionHandler
```
ProcessFunction<InputT,OutputT> exceptionHandler
```
- Class org.apache.beam.sdk.transforms.ParDo.MultiOutput extends PTransform<PCollection<? extends InputT>,PCollectionTuple> implements Serializable
  - Serialized Fields
    - sideInputs
```
java.util.List<E> sideInputs
```
    - mainOutputTag
```
TupleTag<V> mainOutputTag
```
    - additionalOutputTags
```
TupleTagList additionalOutputTags
```
    - fnDisplayData
```
DisplayData.ItemSpec<T> fnDisplayData
```
    - fn
```
DoFn<InputT,OutputT> fn
```
- Class org.apache.beam.sdk.transforms.ParDo.SingleOutput extends PTransform<PCollection<? extends InputT>,PCollection<OutputT>> implements Serializable
  - Serialized Fields
    - sideInputs
```
java.util.List<E> sideInputs
```
    - fn
```
DoFn<InputT,OutputT> fn
```
    - fnDisplayData
```
DisplayData.ItemSpec<T> fnDisplayData
```
- Class org.apache.beam.sdk.transforms.Partition extends PTransform<PCollection<T>,PCollectionList<T>> implements Serializable
- Class org.apache.beam.sdk.transforms.PTransform extends java.lang.Object implements Serializable
  - Serialization Methods
    - readObject
```
private void readObject(java.io.ObjectInputStream oos)
```
    - writeObject
```
private void writeObject(java.io.ObjectOutputStream oos)
```
- Class org.apache.beam.sdk.transforms.Regex.AllMatches extends PTransform<PCollection<java.lang.String>,PCollection<java.util.List<java.lang.String>>> implements Serializable
  - Serialized Fields
    - pattern
```
java.util.regex.Pattern pattern
```
- Class org.apache.beam.sdk.transforms.Regex.Find extends PTransform<PCollection<java.lang.String>,PCollection<java.lang.String>> implements Serializable
  - Serialized Fields
    - pattern
```
java.util.regex.Pattern pattern
```
    - group
```
int group
```
- Class org.apache.beam.sdk.transforms.Regex.FindAll extends PTransform<PCollection<java.lang.String>,PCollection<java.util.List<java.lang.String>>> implements Serializable
  - Serialized Fields
    - pattern
```
java.util.regex.Pattern pattern
```
- Class org.apache.beam.sdk.transforms.Regex.FindKV extends PTransform<PCollection<java.lang.String>,PCollection<KV<java.lang.String,java.lang.String>>> implements Serializable
  - Serialized Fields
    - pattern
```
java.util.regex.Pattern pattern
```
    - keyGroup
```
int keyGroup
```
    - valueGroup
```
int valueGroup
```
- Class org.apache.beam.sdk.transforms.Regex.FindName extends PTransform<PCollection<java.lang.String>,PCollection<java.lang.String>> implements Serializable
  - Serialized Fields
    - pattern
```
java.util.regex.Pattern pattern
```
    - groupName
```
java.lang.String groupName
```
- Class org.apache.beam.sdk.transforms.Regex.FindNameKV extends PTransform<PCollection<java.lang.String>,PCollection<KV<java.lang.String,java.lang.String>>> implements Serializable
  - Serialized Fields
    - pattern
```
java.util.regex.Pattern pattern
```
    - keyGroupName
```
java.lang.String keyGroupName
```
    - valueGroupName
```
java.lang.String valueGroupName
```
- Class org.apache.beam.sdk.transforms.Regex.Matches extends PTransform<PCollection<java.lang.String>,PCollection<java.lang.String>> implements Serializable
  - Serialized Fields
    - pattern
```
java.util.regex.Pattern pattern
```
    - group
```
int group
```
- Class org.apache.beam.sdk.transforms.Regex.MatchesKV extends PTransform<PCollection<java.lang.String>,PCollection<KV<java.lang.String,java.lang.String>>> implements Serializable
  - Serialized Fields
    - pattern
```
java.util.regex.Pattern pattern
```
    - keyGroup
```
int keyGroup
```
    - valueGroup
```
int valueGroup
```
- Class org.apache.beam.sdk.transforms.Regex.MatchesName extends PTransform<PCollection<java.lang.String>,PCollection<java.lang.String>> implements Serializable
  - Serialized Fields
    - pattern
```
java.util.regex.Pattern pattern
```
    - groupName
```
java.lang.String groupName
```
- Class org.apache.beam.sdk.transforms.Regex.MatchesNameKV extends PTransform<PCollection<java.lang.String>,PCollection<KV<java.lang.String,java.lang.String>>> implements Serializable
  - Serialized Fields
    - pattern
```
java.util.regex.Pattern pattern
```
    - keyGroupName
```
java.lang.String keyGroupName
```
    - valueGroupName
```
java.lang.String valueGroupName
```
- Class org.apache.beam.sdk.transforms.Regex.ReplaceAll extends PTransform<PCollection<java.lang.String>,PCollection<java.lang.String>> implements Serializable
  - Serialized Fields
    - pattern
```
java.util.regex.Pattern pattern
```
    - replacement
```
java.lang.String replacement
```
- Class org.apache.beam.sdk.transforms.Regex.ReplaceFirst extends PTransform<PCollection<java.lang.String>,PCollection<java.lang.String>> implements Serializable
  - Serialized Fields
    - pattern
```
java.util.regex.Pattern pattern
```
    - replacement
```
java.lang.String replacement
```
- Class org.apache.beam.sdk.transforms.Regex.Split extends PTransform<PCollection<java.lang.String>,PCollection<java.lang.String>> implements Serializable
  - Serialized Fields
    - pattern
```
java.util.regex.Pattern pattern
```
    - outputEmpty
```
boolean outputEmpty
```
- Class org.apache.beam.sdk.transforms.Requirements extends java.lang.Object implements Serializable
  - Serialized Fields
    - sideInputs
```
java.util.Collection<E> sideInputs
```
- Class org.apache.beam.sdk.transforms.Reshuffle extends PTransform<PCollection<KV<K,V>>,PCollection<KV<K,V>>> implements Serializable
- Class org.apache.beam.sdk.transforms.Reshuffle.ViaRandomKey extends PTransform<PCollection<T>,PCollection<T>> implements Serializable
- Class org.apache.beam.sdk.transforms.Sample.FixedSizedSampleFn extends Combine.CombineFn<T,org.apache.beam.sdk.transforms.Top.BoundedHeap<KV<java.lang.Integer,T>,SerializableComparator<KV<java.lang.Integer,T>>>,java.lang.Iterable<T>> implements Serializable
  - Serialized Fields
    - sampleSize
```
int sampleSize
```
    - topCombineFn
```
Top.TopCombineFn<T,ComparatorT extends java.util.Comparator<T> & java.io.Serializable> topCombineFn
```
    - rand
```
java.util.Random rand
```
- Class org.apache.beam.sdk.transforms.SimpleFunction extends InferableFunction<InputT,OutputT> implements Serializable
  - Serialized Fields
    - fn
```
SerializableFunction<InputT,OutputT> fn
```
- Class org.apache.beam.sdk.transforms.Top.Largest extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.transforms.Top.Natural extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.transforms.Top.Reversed extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.transforms.Top.Smallest extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.transforms.Top.TopCombineFn extends Combine.AccumulatingCombineFn<T,org.apache.beam.sdk.transforms.Top.BoundedHeap<T,ComparatorT extends java.util.Comparator<T> & java.io.Serializable>,java.util.List<T>> implements Serializable
  - Serialized Fields
    - count
```
int count
```
    - compareFn
```
java.util.Comparator<T> compareFn
```
- Class org.apache.beam.sdk.transforms.Values extends PTransform<PCollection<? extends KV<?,V>>,PCollection<V>> implements Serializable
- Class org.apache.beam.sdk.transforms.View.AsIterable extends PTransform<PCollection<T>,PCollectionView<java.lang.Iterable<T>>> implements Serializable
- Class org.apache.beam.sdk.transforms.View.AsList extends PTransform<PCollection<T>,PCollectionView<java.util.List<T>>> implements Serializable
- Class org.apache.beam.sdk.transforms.View.AsMap extends PTransform<PCollection<KV<K,V>>,PCollectionView<java.util.Map<K,V>>> implements Serializable
- Class org.apache.beam.sdk.transforms.View.AsMultimap extends PTransform<PCollection<KV<K,V>>,PCollectionView<java.util.Map<K,java.lang.Iterable<V>>>> implements Serializable
- Class org.apache.beam.sdk.transforms.View.AsSingleton extends PTransform<PCollection<T>,PCollectionView<T>> implements Serializable
  - Serialized Fields
    - defaultValue
```
java.lang.Object defaultValue
```
    - hasDefault
```
boolean hasDefault
```
- Class org.apache.beam.sdk.transforms.View.CreatePCollectionView extends PTransform<PCollection<ElemT>,PCollection<ElemT>> implements Serializable
  - Serialized Fields
    - view
```
PCollectionView<T> view
```
- Class org.apache.beam.sdk.transforms.ViewFn extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.transforms.Wait.OnSignal extends PTransform<PCollection<T>,PCollection<T>> implements Serializable
- Class org.apache.beam.sdk.transforms.Watch.Growth extends PTransform<<any>,<any>> implements Serializable
- Class org.apache.beam.sdk.transforms.Watch.Growth.PollFn extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.transforms.WithFailures.ExceptionAsMapHandler extends SimpleFunction<WithFailures.ExceptionElement<T>,KV<T,java.util.Map<java.lang.String,java.lang.String>>> implements Serializable
- Class org.apache.beam.sdk.transforms.WithKeys extends PTransform<PCollection<V>,PCollection<KV<K,V>>> implements Serializable
  - Serialized Fields
    - fn
```
SerializableFunction<InputT,OutputT> fn
```
- Class org.apache.beam.sdk.transforms.WithTimestamps extends PTransform<PCollection<T>,PCollection<T>> implements Serializable
  - Serialized Fields
    - fn
```
SerializableFunction<InputT,OutputT> fn
```
    - allowedTimestampSkew
```
Duration allowedTimestampSkew
```
Package org.apache.beam.sdk.transforms.display
- Class org.apache.beam.sdk.transforms.display.DisplayData extends java.lang.Object implements Serializable
  - Serialized Fields
    - entries
```
org.apache.beam.vendor.guava.v20_0.com.google.common.collect.ImmutableMap<K,V> entries
```
- Class org.apache.beam.sdk.transforms.display.DisplayData.Identifier extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.transforms.display.DisplayData.Item extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.transforms.display.DisplayData.ItemSpec extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.transforms.display.DisplayData.Path extends java.lang.Object implements Serializable
  - Serialized Fields
    - components
```
org.apache.beam.vendor.guava.v20_0.com.google.common.collect.ImmutableList<E> components
```
Package org.apache.beam.sdk.transforms.join
- Class org.apache.beam.sdk.transforms.join.CoGbkResult.CoGbkResultCoder extends CustomCoder<CoGbkResult> implements Serializable
  - Serialized Fields
    - schema
```
CoGbkResultSchema schema
```
    - unionCoder
```
UnionCoder unionCoder
```
- Class org.apache.beam.sdk.transforms.join.CoGbkResultSchema extends java.lang.Object implements Serializable
  - Serialized Fields
    - tupleTagList
```
TupleTagList tupleTagList
```
    - tagMap
```
java.util.HashMap<K,V> tagMap
```
      Maps TupleTags to union tags. This avoids needing to encode the tags themselves.
- Class org.apache.beam.sdk.transforms.join.CoGroupByKey extends PTransform<KeyedPCollectionTuple<K>,PCollection<KV<K,CoGbkResult>>> implements Serializable
- Class org.apache.beam.sdk.transforms.join.UnionCoder extends StructuredCoder<RawUnionValue> implements Serializable
  - Serialized Fields
    - elementCoders
```
java.util.List<E> elementCoders
```
Package org.apache.beam.sdk.transforms.windowing
- Class org.apache.beam.sdk.transforms.windowing.AfterAll extends Trigger.OnceTrigger implements Serializable
- Class org.apache.beam.sdk.transforms.windowing.AfterEach extends Trigger implements Serializable
- Class org.apache.beam.sdk.transforms.windowing.AfterFirst extends Trigger.OnceTrigger implements Serializable
- Class org.apache.beam.sdk.transforms.windowing.AfterPane extends Trigger.OnceTrigger implements Serializable
  - Serialized Fields
    - countElems
```
int countElems
```
- Class org.apache.beam.sdk.transforms.windowing.AfterProcessingTime extends Trigger.OnceTrigger implements Serializable
  - Serialized Fields
    - timestampTransforms
```
java.util.List<E> timestampTransforms
```
- Class org.apache.beam.sdk.transforms.windowing.AfterSynchronizedProcessingTime extends Trigger.OnceTrigger implements Serializable
- Class org.apache.beam.sdk.transforms.windowing.AfterWatermark.AfterWatermarkEarlyAndLate extends Trigger implements Serializable
  - Serialized Fields
    - earlyTrigger
```
Trigger.OnceTrigger earlyTrigger
```
    - lateTrigger
```
Trigger.OnceTrigger lateTrigger
```
- Class org.apache.beam.sdk.transforms.windowing.AfterWatermark.FromEndOfWindow extends Trigger.OnceTrigger implements Serializable
- Class org.apache.beam.sdk.transforms.windowing.CalendarWindows.DaysWindows extends PartitioningWindowFn<java.lang.Object,IntervalWindow> implements Serializable
  - Serialized Fields
    - number
```
int number
```
    - startDate
```
DateTime startDate
```
    - timeZone
```
DateTimeZone timeZone
```
- Class org.apache.beam.sdk.transforms.windowing.CalendarWindows.MonthsWindows extends PartitioningWindowFn<java.lang.Object,IntervalWindow> implements Serializable
  - Serialized Fields
    - number
```
int number
```
    - dayOfMonth
```
int dayOfMonth
```
    - startDate
```
DateTime startDate
```
    - timeZone
```
DateTimeZone timeZone
```
- Class org.apache.beam.sdk.transforms.windowing.CalendarWindows.YearsWindows extends PartitioningWindowFn<java.lang.Object,IntervalWindow> implements Serializable
  - Serialized Fields
    - number
```
int number
```
    - monthOfYear
```
int monthOfYear
```
    - dayOfMonth
```
int dayOfMonth
```
    - startDate
```
DateTime startDate
```
    - timeZone
```
DateTimeZone timeZone
```
- Class org.apache.beam.sdk.transforms.windowing.DefaultTrigger extends Trigger implements Serializable
- Class org.apache.beam.sdk.transforms.windowing.FixedWindows extends PartitioningWindowFn<java.lang.Object,IntervalWindow> implements Serializable
  - Serialized Fields
    - size
```
Duration size
```
      Size of this window.
    - offset
```
Duration offset
```
      Offset of this window. Windows start at time N * size + offset, where 0 is the epoch.
- Class org.apache.beam.sdk.transforms.windowing.GlobalWindow.Coder extends StructuredCoder<GlobalWindow> implements Serializable
- Class org.apache.beam.sdk.transforms.windowing.GlobalWindows extends NonMergingWindowFn<java.lang.Object,GlobalWindow> implements Serializable
- Class org.apache.beam.sdk.transforms.windowing.IncompatibleWindowException extends java.lang.Exception implements Serializable
  - Serialized Fields
    - givenWindowFn
```
WindowFn<T,W extends BoundedWindow> givenWindowFn
```
    - reason
```
java.lang.String reason
```
- Class org.apache.beam.sdk.transforms.windowing.IntervalWindow.IntervalWindowCoder extends StructuredCoder<IntervalWindow> implements Serializable
- Class org.apache.beam.sdk.transforms.windowing.InvalidWindows extends WindowFn<java.lang.Object,W extends BoundedWindow> implements Serializable
  - Serialized Fields
    - cause
```
java.lang.String cause
```
    - originalWindowFn
```
WindowFn<T,W extends BoundedWindow> originalWindowFn
```
- Class org.apache.beam.sdk.transforms.windowing.Never.NeverTrigger extends Trigger.OnceTrigger implements Serializable
- Class org.apache.beam.sdk.transforms.windowing.NonMergingWindowFn extends WindowFn<T,W extends BoundedWindow> implements Serializable
- Class org.apache.beam.sdk.transforms.windowing.OrFinallyTrigger extends Trigger implements Serializable
- Class org.apache.beam.sdk.transforms.windowing.PaneInfo.PaneInfoCoder extends AtomicCoder<PaneInfo> implements Serializable
- Class org.apache.beam.sdk.transforms.windowing.PartitioningWindowFn extends NonMergingWindowFn<T,W extends BoundedWindow> implements Serializable
- Class org.apache.beam.sdk.transforms.windowing.Repeatedly extends Trigger implements Serializable
  - Serialized Fields
    - repeatedTrigger
```
Trigger repeatedTrigger
```
- Class org.apache.beam.sdk.transforms.windowing.ReshuffleTrigger extends Trigger implements Serializable
- Class org.apache.beam.sdk.transforms.windowing.Sessions extends WindowFn<java.lang.Object,IntervalWindow> implements Serializable
  - Serialized Fields
    - gapDuration
```
Duration gapDuration
```
      Duration of the gaps between sessions.
- Class org.apache.beam.sdk.transforms.windowing.SlidingWindows extends NonMergingWindowFn<java.lang.Object,IntervalWindow> implements Serializable
  - Serialized Fields
    - period
```
Duration period
```
      Amount of time between generated windows.
    - size
```
Duration size
```
      Size of the generated windows.
    - offset
```
Duration offset
```
      Offset of the generated windows. Windows start at time N * start + offset, where 0 is the epoch.
- Class org.apache.beam.sdk.transforms.windowing.TimestampTransform extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.transforms.windowing.TimestampTransform.AlignTo extends TimestampTransform implements Serializable
- Class org.apache.beam.sdk.transforms.windowing.TimestampTransform.Delay extends TimestampTransform implements Serializable
- Class org.apache.beam.sdk.transforms.windowing.Trigger extends java.lang.Object implements Serializable
  - Serialized Fields
    - subTriggers
```
java.util.List<E> subTriggers
```
- Class org.apache.beam.sdk.transforms.windowing.Trigger.OnceTrigger extends Trigger implements Serializable
- Class org.apache.beam.sdk.transforms.windowing.Window extends PTransform<PCollection<T>,PCollection<T>> implements Serializable
- Class org.apache.beam.sdk.transforms.windowing.Window.Assign extends PTransform<PCollection<T>,PCollection<T>> implements Serializable
  - Serialized Fields
    - original
```
Window<T> original
```
    - updatedStrategy
```
WindowingStrategy<T,W extends BoundedWindow> updatedStrategy
```
- Class org.apache.beam.sdk.transforms.windowing.WindowFn extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.transforms.windowing.WindowMappingFn extends java.lang.Object implements Serializable
  - Serialized Fields
    - maximumLookback
```
Duration maximumLookback
```
Package org.apache.beam.sdk.values
- Class org.apache.beam.sdk.values.KV extends java.lang.Object implements Serializable
  - Serialized Fields
    - key
```
java.lang.Object key
```
    - value
```
java.lang.Object value
```
- Class org.apache.beam.sdk.values.KV.OrderByKey extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.values.KV.OrderByValue extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.values.PCollectionViews.IterableViewFn extends ViewFn<Materializations.MultimapView<java.lang.Void,T>,java.lang.Iterable<T>> implements Serializable
- Class org.apache.beam.sdk.values.PCollectionViews.ListViewFn extends ViewFn<Materializations.MultimapView<java.lang.Void,T>,java.util.List<T>> implements Serializable
- Class org.apache.beam.sdk.values.PCollectionViews.MapViewFn extends ViewFn<Materializations.MultimapView<java.lang.Void,KV<K,V>>,java.util.Map<K,V>> implements Serializable
- Class org.apache.beam.sdk.values.PCollectionViews.MultimapViewFn extends ViewFn<Materializations.MultimapView<java.lang.Void,KV<K,V>>,java.util.Map<K,java.lang.Iterable<V>>> implements Serializable
- Class org.apache.beam.sdk.values.PCollectionViews.SimplePCollectionView extends PValueBase implements Serializable
  - Serialized Fields
    - tag
```
TupleTag<V> tag
```
      A unique tag for the view, typed according to the elements underlying the view.
    - windowMappingFn
```
WindowMappingFn<TargetWindowT extends BoundedWindow> windowMappingFn
```
    - windowingStrategy
```
WindowingStrategy<T,W extends BoundedWindow> windowingStrategy
```
      The windowing strategy for the PCollection underlying the view.
    - coder
```
Coder<T> coder
```
      The coder for the elements underlying the view.
    - viewFn
```
ViewFn<PrimitiveViewT,ViewT> viewFn
```
      The typed ViewFn for this view.
- Class org.apache.beam.sdk.values.PCollectionViews.SingletonViewFn extends ViewFn<Materializations.MultimapView<java.lang.Void,T>,T> implements Serializable
  - Serialized Fields
    - encodedDefaultValue
```
byte[] encodedDefaultValue
```
    - valueCoder
```
Coder<T> valueCoder
```
    - hasDefault
```
boolean hasDefault
```
- Class org.apache.beam.sdk.values.Row extends java.lang.Object implements Serializable
  - Serialized Fields
    - schema
```
Schema schema
```
- Class org.apache.beam.sdk.values.RowWithGetters extends Row implements Serializable
  - Serialized Fields
    - fieldValueGetterFactory
```
Factory<T> fieldValueGetterFactory
```
    - getterTarget
```
java.lang.Object getterTarget
```
    - getters
```
java.util.List<E> getters
```
    - cachedLists
```
java.util.Map<K,V> cachedLists
```
    - cachedMaps
```
java.util.Map<K,V> cachedMaps
```
- Class org.apache.beam.sdk.values.RowWithStorage extends Row implements Serializable
  - Serialized Fields
    - values
```
java.util.List<E> values
```
- Class org.apache.beam.sdk.values.ShardedKey extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - key
```
java.lang.Object key
```
    - shardNumber
```
int shardNumber
```
- Class org.apache.beam.sdk.values.TimestampedValue.TimestampedValueCoder extends StructuredCoder<TimestampedValue<T>> implements Serializable
  - Serialized Fields
    - valueCoder
```
Coder<T> valueCoder
```
- Class org.apache.beam.sdk.values.TupleTag extends java.lang.Object implements Serializable
  - Serialized Fields
    - id
```
java.lang.String id
```
    - generated
```
boolean generated
```
- Class org.apache.beam.sdk.values.TupleTagList extends java.lang.Object implements Serializable
  - Serialized Fields
    - tupleTags
```
java.util.List<E> tupleTags
```
- Class org.apache.beam.sdk.values.TypeDescriptor extends java.lang.Object implements Serializable
  - Serialized Fields
    - token
```
org.apache.beam.vendor.guava.v20_0.com.google.common.reflect.TypeToken<T> token
```
- Class org.apache.beam.sdk.values.ValueInSingleWindow.Coder extends StructuredCoder<ValueInSingleWindow<T>> implements Serializable
  - Serialized Fields
    - valueCoder
```
Coder<T> valueCoder
```
    - windowCoder
```
Coder<T> windowCoder
```
- Class org.apache.beam.sdk.values.ValueWithRecordId.StripIdsDoFn extends DoFn<ValueWithRecordId<T>,T> implements Serializable
- Class org.apache.beam.sdk.values.ValueWithRecordId.ValueWithRecordIdCoder extends StructuredCoder<ValueWithRecordId<ValueT>> implements Serializable
  - Serialized Fields
    - valueCoder
```
Coder<T> valueCoder
```
    - idCoder
```
ByteArrayCoder idCoder
```
- Class org.apache.beam.sdk.values.WindowingStrategy extends java.lang.Object implements Serializable
  - Serialized Fields
    - windowFn
```
WindowFn<T,W extends BoundedWindow> windowFn
```
    - trigger
```
Trigger trigger
```
    - mode
```
WindowingStrategy.AccumulationMode mode
```
    - allowedLateness
```
Duration allowedLateness
```
    - closingBehavior
```
Window.ClosingBehavior closingBehavior
```
    - onTimeBehavior
```
Window.OnTimeBehavior onTimeBehavior
```
    - timestampCombiner
```
TimestampCombiner timestampCombiner
```
    - triggerSpecified
```
boolean triggerSpecified
```
    - modeSpecified
```
boolean modeSpecified
```
    - allowedLatenessSpecified
```
boolean allowedLatenessSpecified
```
    - timestampCombinerSpecified
```
boolean timestampCombinerSpecified
```

Serialized Form

Package org.apache.beam.runners.apex

Class org.apache.beam.runners.apex.ApexRunner.CreateApexPCollectionView extends PTransform<PCollection<ElemT>,PCollection<ElemT>> implements Serializable

Serialized Fields

view

Class org.apache.beam.runners.apex.ApexYarnLauncher.LaunchParams extends java.lang.Object implements Serializable

Serialized Fields

dag

launchAttributes

configProperties

env

cmd

Package org.apache.beam.runners.dataflow

Class org.apache.beam.runners.dataflow.BatchStatefulParDoOverrides.BatchStatefulDoFn extends DoFn<KV<K,java.lang.Iterable<KV<Instant,org.apache.beam.sdk.util.WindowedValue<KV<K,V>>>>>,OutputT> implements Serializable

Serialized Fields

underlyingDoFn

Class org.apache.beam.runners.dataflow.CreateDataflowView extends PTransform<PCollection<ElemT>,PCollection<ElemT>> implements Serializable

Serialized Fields

view

streaming

Class org.apache.beam.runners.dataflow.DataflowJobAlreadyExistsException extends DataflowJobException implements Serializable

Class org.apache.beam.runners.dataflow.DataflowJobAlreadyUpdatedException extends DataflowJobException implements Serializable

Class org.apache.beam.runners.dataflow.DataflowJobException extends java.lang.RuntimeException implements Serializable

Serialized Fields

job

Class org.apache.beam.runners.dataflow.DataflowRunner.StreamingPCollectionViewWriterFn extends DoFn<java.lang.Iterable<T>,T> implements Serializable

Serialized Fields

view

dataCoder

Class org.apache.beam.runners.dataflow.DataflowRunnerInfo extends org.apache.beam.sdk.util.ReleaseInfo implements Serializable

Serialized Fields

properties

Class org.apache.beam.runners.dataflow.DataflowServiceException extends DataflowJobException implements Serializable

Class org.apache.beam.runners.dataflow.PrimitiveParDoSingleFactory.ParDoSingle extends org.apache.beam.runners.core.construction.ForwardingPTransform<PCollection<? extends InputT>,PCollection<OutputT>> implements Serializable

Serialized Fields

original

onlyOutputTag

outputCoder

Package org.apache.beam.runners.dataflow.options

Class org.apache.beam.runners.dataflow.options.DataflowProfilingOptions.DataflowProfilingAgentConfiguration extends java.util.HashMap<java.lang.String,java.lang.Object> implements Serializable

Class org.apache.beam.runners.dataflow.options.DataflowWorkerLoggingOptions.WorkerLogLevelOverrides extends java.util.HashMap<java.lang.String,DataflowWorkerLoggingOptions.Level> implements Serializable

Package org.apache.beam.runners.dataflow.util

Class org.apache.beam.runners.dataflow.util.MonitoringUtil.TimeStampComparator extends java.lang.Object implements Serializable

Class org.apache.beam.runners.dataflow.util.RandomAccessData.RandomAccessDataCoder extends AtomicCoder<RandomAccessData> implements Serializable

Class org.apache.beam.runners.dataflow.util.RandomAccessData.UnsignedLexicographicalComparator extends java.lang.Object implements Serializable

Package org.apache.beam.runners.flink

Class org.apache.beam.runners.flink.CreateStreamingFlinkView.CreateFlinkPCollectionView extends PTransform<PCollection<java.util.List<ElemT>>,PCollection<java.util.List<ElemT>>> implements Serializable

Serialized Fields

view

Class org.apache.beam.runners.flink.FlinkStreamingTransformTranslators.StripIdsMap extends java.lang.Object implements Serializable

Class org.apache.beam.runners.flink.FlinkStreamingTransformTranslators.ToRawUnion extends java.lang.Object implements Serializable

Serialized Fields

intTag

Package org.apache.beam.runners.flink.metrics

Class org.apache.beam.runners.flink.metrics.MetricsAccumulator extends java.lang.Object implements Serializable

Serialized Fields

metricsContainers

Package org.apache.beam.runners.fnexecution.provisioning

Class org.apache.beam.runners.fnexecution.provisioning.JobInfo extends java.lang.Object implements Serializable

Package org.apache.beam.runners.gearpump.translators

Class org.apache.beam.runners.gearpump.translators.CreateGearpumpPCollectionViewTranslator extends java.lang.Object implements Serializable

Class org.apache.beam.runners.gearpump.translators.CreateStreamingGearpumpView.CreateGearpumpPCollectionView extends PTransform<PCollection<java.util.List<ElemT>>,PCollection<java.util.List<ElemT>>> implements Serializable

Serialized Fields

view

Class org.apache.beam.runners.gearpump.translators.FlattenPCollectionsTranslator extends java.lang.Object implements Serializable

Class org.apache.beam.runners.gearpump.translators.GroupByKeyTranslator extends java.lang.Object implements Serializable

Class org.apache.beam.runners.gearpump.translators.GroupByKeyTranslator.GearpumpWindowFn extends java.lang.Object implements Serializable

Serialized Fields

isNonMerging

Class org.apache.beam.runners.gearpump.translators.GroupByKeyTranslator.GroupByFn extends io.gearpump.streaming.dsl.javaapi.functions.GroupByFunction<org.apache.beam.sdk.util.WindowedValue<KV<K,V>>,java.nio.ByteBuffer> implements Serializable

Serialized Fields

keyCoder

Class org.apache.beam.runners.gearpump.translators.GroupByKeyTranslator.KeyedByTimestamp extends io.gearpump.streaming.dsl.api.functions.MapFunction<org.apache.beam.sdk.util.WindowedValue<KV<K,V>>,KV<Instant,org.apache.beam.sdk.util.WindowedValue<KV<K,V>>>> implements Serializable

Serialized Fields

windowFn

timestampCombiner

Class org.apache.beam.runners.gearpump.translators.GroupByKeyTranslator.Merge extends io.gearpump.streaming.dsl.api.functions.FoldFunction<KV<Instant,org.apache.beam.sdk.util.WindowedValue<KV<K,V>>>,KV<Instant,org.apache.beam.sdk.util.WindowedValue<KV<K,java.util.List<V>>>>> implements Serializable

Serialized Fields

windowFn

timestampCombiner