Serialized Form

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
```
- 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.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
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
```
    - maxNumWritersPerBundle
```
int maxNumWritersPerBundle
```
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.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
- Class org.apache.beam.sdk.io.cassandra.CassandraServiceImpl extends java.lang.Object implements Serializable
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.InsertRetryPolicy extends java.lang.Object implements Serializable
- 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
```
    - retryPolicy
```
InsertRetryPolicy retryPolicy
```
- 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
```
    - retryPolicy
```
InsertRetryPolicy retryPolicy
```
- 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
- 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.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.gcp.spanner
- Class org.apache.beam.sdk.io.gcp.spanner.MutationGroup extends java.lang.Object implements Serializable
  - Serialized Fields
    - mutations
```
ImmutableList<E> mutations
```
- 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.Write extends PTransform<PCollection<com.google.cloud.spanner.Mutation>,PDone> implements Serializable
- Class org.apache.beam.sdk.io.gcp.spanner.SpannerIO.WriteGrouped extends PTransform<PCollection<MutationGroup>,PDone> implements Serializable
  - Serialized Fields
    - spec
```
SpannerIO.Write spec
```
- Class org.apache.beam.sdk.io.gcp.spanner.Transaction extends java.lang.Object implements Serializable
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
```
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.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<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.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.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.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.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<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
```
    - 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

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

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