Serialized Form

Package org.apache.beam.runners.apex
- Class org.apache.beam.runners.apex.ApexRunner.CreateApexPCollectionView extends PTransform<PCollection<java.util.List<ElemT>>,PCollectionView<ViewT>> 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>,PCollectionView<ViewT>> implements Serializable
  - Serialized Fields
    - view
```
PCollectionView<T> view
```
- 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
```
      Deprecated.
    - dataCoder
```
Coder<T> dataCoder
```
      Deprecated.
- 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
```
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.DoFnInfo extends java.lang.Object implements Serializable
  - Serialized Fields
    - doFn
```
DoFn<InputT,OutputT> doFn
```
    - windowingStrategy
```
WindowingStrategy<T,W extends BoundedWindow> windowingStrategy
```
    - sideInputViews
```
java.lang.Iterable<T> sideInputViews
```
    - inputCoder
```
Coder<T> inputCoder
```
    - mainOutput
```
long mainOutput
```
    - outputMap
```
java.util.Map<K,V> outputMap
```
- Class org.apache.beam.runners.dataflow.util.RandomAccessData.RandomAccessDataCoder extends AtomicCoder<RandomAccessData> implements Serializable
Package org.apache.beam.runners.flink
- Class org.apache.beam.runners.flink.FlinkStreamingTransformTranslators.StripIdsMap extends java.lang.Object implements Serializable
- Class org.apache.beam.runners.flink.FlinkStreamingViewOverrides.CreateFlinkPCollectionView extends PTransform<PCollection<java.util.List<ElemT>>,PCollectionView<ViewT>> implements Serializable
  - Serialized Fields
    - view
```
PCollectionView<T> view
```
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.spark.aggregators
- Class org.apache.beam.runners.spark.aggregators.AggAccumParam extends java.lang.Object implements Serializable
- 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.NamedAggregators.CombineFunctionState extends java.lang.Object implements Serializable
  - Serialization Methods
    - readObject
```
private void readObject(java.io.ObjectInputStream ois)
                 throws java.io.IOException,
                        java.lang.ClassNotFoundException
```
      Throws:
      
      java.io.IOException
      
      java.lang.ClassNotFoundException
    - writeObject
```
private void writeObject(java.io.ObjectOutputStream oos)
                  throws java.io.IOException
```
      Throws:
      
      java.io.IOException
  - Serialized Fields
    - combineFn
```
Combine.CombineFn<InputT,AccumT,OutputT> combineFn
```
    - inCoder
```
Coder<T> inCoder
```
    - ctxt
```
org.apache.beam.runners.spark.translation.SparkRuntimeContext ctxt
```
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
    - batchInterval
```
Duration batchInterval
```
    - batches
```
java.util.Queue<E> batches
```
    - times
```
java.util.Deque<E> times
```
    - coder
```
Coder<T> coder
```
    - initialSystemTime
```
Instant initialSystemTime
```
    - 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
```
    - runtimeContext
```
org.apache.beam.runners.spark.translation.SparkRuntimeContext runtimeContext
```
    - numPartitions
```
int numPartitions
```
    - stepName
```
java.lang.String stepName
```
    - metricsAccum
```
org.apache.spark.Accumulator<T> 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
```
    - runtimeContext
```
org.apache.beam.runners.spark.translation.SparkRuntimeContext runtimeContext
```
    - 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.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
```
- Class org.apache.beam.runners.spark.util.SinglePrimitiveOutputPTransform extends PTransform<PInput,PCollection<T>> implements Serializable
  - Serialized Fields
    - transform
```
PTransform<InputT extends PInput,OutputT extends POutput> transform
```
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
```
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.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.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.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.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.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
```
org.apache.beam.sdk.util.gcsfs.GcsPath gcsPath
```
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.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.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.io
- Class org.apache.beam.sdk.io.AvroIO.Read extends PTransform<PBegin,PCollection<T>> implements Serializable
- Class org.apache.beam.sdk.io.AvroIO.Write extends PTransform<PCollection<T>,PDone> implements Serializable
- 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
    - readSchemaString
```
java.lang.String readSchemaString
```
    - fileSchemaString
```
java.lang.String fileSchemaString
```
    - type
```
java.lang.Class<T> type
```
    - codec
```
java.lang.String codec
```
    - syncMarker
```
byte[] syncMarker
```
- 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
```
    - adaptedSource
```
BoundedSource<T> adaptedSource
```
- 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
    - prefix
```
ValueProvider<T> prefix
```
    - shardTemplate
```
java.lang.String shardTemplate
```
    - suffix
```
java.lang.String suffix
```
- Class org.apache.beam.sdk.io.FileBasedSink extends java.lang.Object implements Serializable
  - Serialized Fields
    - 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 FileBasedSink.CompressionType.UNCOMPRESSED.
    - filenamePolicy
```
FileBasedSink.FilenamePolicy filenamePolicy
```
      The policy used to generate names of files to be produced.
    - baseOutputDirectoryProvider
```
ValueProvider<T> baseOutputDirectoryProvider
```
      The directory to which files will be written.
- 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> implements Serializable
  - Serialized Fields
    - windowCoder
```
Coder<T> windowCoder
```
- Class org.apache.beam.sdk.io.FileBasedSink.WriteOperation extends java.lang.Object implements Serializable
  - Serialized Fields
    - sink
```
FileBasedSink<T> 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
```
    - singleFileMetadata
```
MatchResult.Metadata singleFileMetadata
```
    - mode
```
FileBasedSource.Mode mode
```
- 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.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.Write extends PTransform<PCollection<java.lang.String>,PDone> implements Serializable
- Class org.apache.beam.sdk.io.TFRecordIO.Read extends PTransform<PBegin,PCollection<byte[]>> 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<T>,PDone> implements Serializable
  - Serialized Fields
    - sink
```
FileBasedSink<T> sink
```
    - writeOperation
```
FileBasedSink.WriteOperation<T> writeOperation
```
    - computeNumShards
```
PTransform<InputT extends PInput,OutputT extends POutput> computeNumShards
```
    - numShardsProvider
```
ValueProvider<T> numShardsProvider
```
    - windowedWrites
```
boolean windowedWrites
```
Package org.apache.beam.sdk.io.elasticsearch
- 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.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
Package org.apache.beam.sdk.io.gcp.bigquery
- Class org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.Read extends PTransform<PBegin,PCollection<TableRow>> implements Serializable
- 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.CreateTables extends PTransform<PCollection<KV<DestinationT,TableRow>>,PCollection<KV<TableDestination,TableRow>>> implements Serializable
  - Serialized Fields
    - createDisposition
```
BigQueryIO.Write.CreateDisposition createDisposition
```
    - bqServices
```
org.apache.beam.sdk.io.gcp.bigquery.BigQueryServices bqServices
```
    - dynamicDestinations
```
DynamicDestinations<T,DestinationT> dynamicDestinations
```
- Class org.apache.beam.sdk.io.gcp.bigquery.DynamicDestinations extends java.lang.Object implements Serializable
  - Serialized Fields
    - sideInputAccessor
```
org.apache.beam.sdk.io.gcp.bigquery.DynamicDestinations.SideInputAccessor sideInputAccessor
```
- Class org.apache.beam.sdk.io.gcp.bigquery.PrepareWrite extends PTransform<PCollection<T>,PCollection<KV<DestinationT,TableRow>>> implements Serializable
  - Serialized Fields
    - dynamicDestinations
```
DynamicDestinations<T,DestinationT> dynamicDestinations
```
    - formatFunction
```
SerializableFunction<InputT,OutputT> formatFunction
```
- Class org.apache.beam.sdk.io.gcp.bigquery.StreamingInserts extends PTransform<PCollection<KV<DestinationT,TableRow>>,WriteResult> implements Serializable
  - Serialized Fields
    - bigQueryServices
```
org.apache.beam.sdk.io.gcp.bigquery.BigQueryServices bigQueryServices
```
    - createDisposition
```
BigQueryIO.Write.CreateDisposition createDisposition
```
    - dynamicDestinations
```
DynamicDestinations<T,DestinationT> dynamicDestinations
```
- Class org.apache.beam.sdk.io.gcp.bigquery.StreamingWriteTables extends PTransform<PCollection<KV<TableDestination,TableRow>>,WriteResult> implements Serializable
  - Serialized Fields
    - bigQueryServices
```
org.apache.beam.sdk.io.gcp.bigquery.BigQueryServices bigQueryServices
```
- 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
```
- Class org.apache.beam.sdk.io.gcp.bigquery.TableDestinationCoder 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.Result extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - filename
```
java.lang.String filename
```
    - fileByteSize
```
java.lang.Long fileByteSize
```
    - destination
```
java.lang.Object destination
```
- Class org.apache.beam.sdk.io.gcp.bigquery.WriteBundlesToFiles.ResultCoder extends StructuredCoder<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
  - Serialized Fields
    - options
```
com.google.cloud.bigtable.config.BigtableOptions options
```
      Used to define the Cloud Bigtable instance and any options for the networking layer. Cannot actually be null at validation time, but may start out null while source is being built.
    - tableId
```
java.lang.String tableId
```
    - keyRange
```
ByteKeyRange keyRange
```
    - filter
```
com.google.bigtable.v2.RowFilter filter
```
    - bigtableService
```
org.apache.beam.sdk.io.gcp.bigtable.BigtableService bigtableService
```
- 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
  - Serialized Fields
    - options
```
com.google.cloud.bigtable.config.BigtableOptions options
```
      Used to define the Cloud Bigtable instance and any options for the networking layer. Cannot actually be null at validation time, but may start out null while source is being built.
    - tableId
```
java.lang.String tableId
```
    - bigtableService
```
org.apache.beam.sdk.io.gcp.bigtable.BigtableService bigtableService
```
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.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
- 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.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.inputformat
- Class org.apache.beam.sdk.io.hadoop.inputformat.HadoopInputFormatIO.HadoopInputFormatBoundedSource extends BoundedSource<KV<K,V>> implements Serializable
  - Serialized Fields
    - conf
```
HadoopInputFormatIO.SerializableConfiguration conf
```
    - keyCoder
```
Coder<T> keyCoder
```
    - valueCoder
```
Coder<T> valueCoder
```
    - keyTranslationFunction
```
SimpleFunction<InputT,OutputT> keyTranslationFunction
```
    - valueTranslationFunction
```
SimpleFunction<InputT,OutputT> valueTranslationFunction
```
    - inputSplit
```
HadoopInputFormatIO.SerializableSplit inputSplit
```
    - boundedSourceEstimatedSize
```
long boundedSourceEstimatedSize
```
- Class org.apache.beam.sdk.io.hadoop.inputformat.HadoopInputFormatIO.Read extends PTransform<PBegin,PCollection<KV<K,V>>> implements Serializable
- Class org.apache.beam.sdk.io.hadoop.inputformat.HadoopInputFormatIO.SerializableConfiguration extends java.lang.Object implements Serializable
  - 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.inputformat.HadoopInputFormatIO.SerializableSplit extends java.lang.Object implements Serializable
  - Serialization Methods
    - readObject
```
private void readObject(java.io.ObjectInputStream in)
                 throws java.io.IOException,
                        java.lang.ClassNotFoundException
```
      Throws:
      
      java.io.IOException
      
      java.lang.ClassNotFoundException
    - 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
```
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.Write extends PTransform<PCollection<KV<byte[],java.lang.Iterable<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.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.Read extends PTransform<PBegin,PCollection<T>> implements Serializable
- Class org.apache.beam.sdk.io.jdbc.JdbcIO.Write extends PTransform<PCollection<T>,PDone> implements Serializable
Package org.apache.beam.sdk.io.jms
- Class org.apache.beam.sdk.io.jms.JmsIO.Read extends PTransform<PBegin,PCollection<JmsRecord>> implements Serializable
- Class org.apache.beam.sdk.io.jms.JmsIO.UnboundedJmsSource extends UnboundedSource<JmsRecord,JmsCheckpointMark> implements Serializable
  - Serialized Fields
    - spec
```
JmsIO.Read 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
```
- 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.KafkaRecord extends java.lang.Object implements Serializable
  - Serialized Fields
    - topic
```
java.lang.String topic
```
    - partition
```
int partition
```
    - offset
```
long offset
```
    - kv
```
KV<K,V> kv
```
    - timestamp
```
long timestamp
```
- Class org.apache.beam.sdk.io.kafka.KafkaRecordCoder extends StructuredCoder<KafkaRecord<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
Package org.apache.beam.sdk.io.mongodb
- 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.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
```
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.Write extends PTransform<PCollection<T>,PDone> implements Serializable
- Class org.apache.beam.sdk.io.xml.XmlSink.XmlWriteOperation extends FileBasedSink.WriteOperation<T> implements Serializable
- Class org.apache.beam.sdk.io.xml.XmlSource extends FileBasedSource<T> implements Serializable
  - Serialized Fields
    - spec
```
XmlIO.Read<T> spec
```
Package org.apache.beam.sdk.metrics
- 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.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.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
```
    - actualChecksum
```
java.lang.String actualChecksum
```
    - shardedFile
```
org.apache.beam.sdk.util.ShardedFile shardedFile
```
- 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<java.lang.Iterable<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.SuccessOrFailure extends java.lang.Object implements Serializable
  - Serialized Fields
    - isSuccess
```
boolean isSuccess
```
    - site
```
PAssert.PAssertionSite site
```
    - message
```
java.lang.String message
```
- 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
```
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.PriorityQueue<E> heap
```
    - 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
```
    - 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
```
    - 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.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.Filter extends PTransform<PCollection<T>,PCollection<T>> implements Serializable
  - Serialized Fields
    - predicate
```
SerializableFunction<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
```
SimpleFunction<InputT,OutputT> fn
```
      Non-null on a fully specified transform - is null only when constructed using FlatMapElements.into(TypeDescriptor), until the fn is specified using FlatMapElements.via(SerializableFunction).
    - fnClassDisplayData
```
DisplayData.ItemSpec<T> fnClassDisplayData
```
- 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.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
```
SimpleFunction<InputT,OutputT> fn
```
      Non-null on a fully specified transform - is null only when constructed using MapElements.into(TypeDescriptor), until the fn is specified using MapElements.via(SerializableFunction).
    - fnClassDisplayData
```
DisplayData.ItemSpec<T> fnClassDisplayData
```
- 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.Reshuffle extends PTransform<PCollection<KV<K,V>>,PCollection<KV<K,V>>> 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 java.lang.Object 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.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>,PCollectionView<ViewT>> 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.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
```
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
```
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.splittabledofn
- Class org.apache.beam.sdk.transforms.splittabledofn.OffsetRange extends java.lang.Object implements Serializable
  - Serialized Fields
    - from
```
long from
```
    - to
```
long to
```
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.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<java.lang.Iterable<org.apache.beam.sdk.util.WindowedValue<T>>,java.lang.Iterable<T>> implements Serializable
- Class org.apache.beam.sdk.values.PCollectionViews.ListViewFn extends ViewFn<java.lang.Iterable<org.apache.beam.sdk.util.WindowedValue<T>>,java.util.List<T>> implements Serializable
- Class org.apache.beam.sdk.values.PCollectionViews.MapViewFn extends ViewFn<java.lang.Iterable<org.apache.beam.sdk.util.WindowedValue<KV<K,V>>>,java.util.Map<K,V>> implements Serializable
- Class org.apache.beam.sdk.values.PCollectionViews.MultimapViewFn extends ViewFn<java.lang.Iterable<org.apache.beam.sdk.util.WindowedValue<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<java.lang.Iterable<org.apache.beam.sdk.util.WindowedValue<T>>,T> implements Serializable
  - Serialized Fields
    - encodedDefaultValue
```
byte[] encodedDefaultValue
```
      Deprecated.
    - valueCoder
```
Coder<T> valueCoder
```
      Deprecated.
    - hasDefault
```
boolean hasDefault
```
      Deprecated.
- 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
```
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
```
    - 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<java.util.List<ElemT>>,PCollectionView<ViewT>> 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>,PCollectionView<ViewT>> implements Serializable

Serialized Fields

view

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.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

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.DoFnInfo extends java.lang.Object implements Serializable

Serialized Fields

doFn

windowingStrategy

sideInputViews

inputCoder

mainOutput

outputMap

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

Package org.apache.beam.runners.flink

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

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

Serialized Fields

view

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.spark.aggregators

Class org.apache.beam.runners.spark.aggregators.AggAccumParam extends java.lang.Object implements Serializable

Class org.apache.beam.runners.spark.aggregators.NamedAggregators extends java.lang.Object implements Serializable

Serialized Fields

mNamedAggregators

Class org.apache.beam.runners.spark.aggregators.NamedAggregators.CombineFunctionState extends java.lang.Object implements Serializable

Serialization Methods

readObject

writeObject

Serialized Fields

combineFn

inCoder

ctxt

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

Class org.apache.beam.runners.spark.io.CreateStream extends PTransform<PBegin,PCollection<T>> implements Serializable

Serialized Fields

batchInterval

batches

times

coder

initialSystemTime

lowWatermark

Class org.apache.beam.runners.spark.io.EmptyCheckpointMark extends java.lang.Object implements Serializable