Serialized Form
-
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
-
decoder
EmptyOnDeserializationThreadLocal<org.apache.avro.io.BinaryDecoder> decoder
-
encoder
EmptyOnDeserializationThreadLocal<org.apache.avro.io.BinaryEncoder> encoder
-
nonDeterministicReasons
java.util.List<java.lang.String> nonDeterministicReasons
-
reader
EmptyOnDeserializationThreadLocal<org.apache.avro.io.DatumReader<T>> reader
-
reflectData
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.base.Supplier<org.apache.avro.reflect.ReflectData> reflectData
-
schemaSupplier
org.apache.beam.sdk.coders.AvroCoder.SerializableSchemaSupplier schemaSupplier
-
type
java.lang.Class<T> type
-
typeDescriptor
TypeDescriptor<T> typeDescriptor
-
useReflectApi
boolean useReflectApi
-
writer
EmptyOnDeserializationThreadLocal<org.apache.avro.io.DatumWriter<T>> writer
-
-
-
Class org.apache.beam.sdk.coders.AvroGenericCoder extends AvroCoder<org.apache.avro.generic.GenericRecord> implements Serializable
-
Class org.apache.beam.sdk.coders.BigDecimalCoder extends AtomicCoder<java.math.BigDecimal> implements Serializable
-
Class org.apache.beam.sdk.coders.BigEndianIntegerCoder extends AtomicCoder<java.lang.Integer> implements Serializable
-
Class org.apache.beam.sdk.coders.BigEndianLongCoder extends AtomicCoder<java.lang.Long> implements Serializable
-
Class org.apache.beam.sdk.coders.BigEndianShortCoder extends AtomicCoder<java.lang.Short> implements Serializable
-
Class org.apache.beam.sdk.coders.BigIntegerCoder extends AtomicCoder<java.math.BigInteger> implements Serializable
-
Class org.apache.beam.sdk.coders.BitSetCoder extends AtomicCoder<java.util.BitSet> implements Serializable
-
Class org.apache.beam.sdk.coders.BooleanCoder extends AtomicCoder<java.lang.Boolean> implements Serializable
-
Class org.apache.beam.sdk.coders.ByteArrayCoder extends AtomicCoder<byte[]> implements Serializable
-
Class org.apache.beam.sdk.coders.ByteCoder extends AtomicCoder<java.lang.Byte> implements Serializable
-
Class org.apache.beam.sdk.coders.CannotProvideCoderException extends java.lang.Exception implements Serializable
-
Serialized Fields
-
reason
CannotProvideCoderException.ReasonCode reason
-
-
-
Class org.apache.beam.sdk.coders.Coder extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.coders.Coder.NonDeterministicException extends java.lang.Exception implements Serializable
-
Serialized Fields
-
coder
Coder<?> coder
-
reasons
java.util.List<java.lang.String> 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<IntermediateT> coder
-
fromFn
DelegateCoder.CodingFunction<IntermediateT,T> fromFn
-
toFn
DelegateCoder.CodingFunction<T,IntermediateT> toFn
-
typeDescriptor
@Nullable TypeDescriptor<T> typeDescriptor
-
-
-
Class org.apache.beam.sdk.coders.DequeCoder extends IterableLikeCoder<T,java.util.Deque<T>> implements Serializable
-
Class org.apache.beam.sdk.coders.DoubleCoder extends AtomicCoder<java.lang.Double> implements Serializable
-
Class org.apache.beam.sdk.coders.DurationCoder extends AtomicCoder<org.joda.time.ReadableDuration> implements Serializable
-
Class org.apache.beam.sdk.coders.FloatCoder extends AtomicCoder<java.lang.Float> implements Serializable
-
Class org.apache.beam.sdk.coders.InstantCoder extends AtomicCoder<org.joda.time.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
-
Class org.apache.beam.sdk.coders.KvCoder extends StructuredCoder<KV<K extends @Nullable java.lang.Object,V extends @Nullable java.lang.Object>> implements Serializable
-
Class org.apache.beam.sdk.coders.LengthPrefixCoder extends StructuredCoder<T> implements Serializable
-
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
-
Class org.apache.beam.sdk.coders.NullableCoder extends StructuredCoder<@Nullable T> implements Serializable
-
Class org.apache.beam.sdk.coders.RowCoder extends SchemaCoder<Row> implements Serializable
-
Class org.apache.beam.sdk.coders.SerializableCoder extends CustomCoder<T extends java.io.Serializable> implements Serializable
-
Serialized Fields
-
type
java.lang.Class<T extends java.io.Serializable> type
-
-
-
Class org.apache.beam.sdk.coders.SetCoder extends IterableLikeCoder<T,java.util.Set<T>> implements Serializable
-
Class org.apache.beam.sdk.coders.ShardedKeyCoder extends StructuredCoder<ShardedKey<KeyT>> implements Serializable
-
Serialized Fields
-
keyCoder
Coder<KeyT> keyCoder
-
shardNumberCoder
VarIntCoder shardNumberCoder
-
-
-
Class org.apache.beam.sdk.coders.SnappyCoder extends StructuredCoder<T> implements Serializable
-
Class org.apache.beam.sdk.coders.SortedMapCoder extends StructuredCoder<java.util.SortedMap<K extends java.lang.Comparable<? super K>,V>> implements Serializable
-
Class org.apache.beam.sdk.coders.StringDelegateCoder extends CustomCoder<T> implements Serializable
-
Serialized Fields
-
clazz
java.lang.Class<T> clazz
-
delegateCoder
DelegateCoder<T,java.lang.String> delegateCoder
-
-
-
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.TimestampPrefixingWindowCoder extends StructuredCoder<T extends BoundedWindow> implements Serializable
-
Serialized Fields
-
windowCoder
Coder<T extends BoundedWindow> windowCoder
-
-
-
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<@Nullable java.lang.Void> implements Serializable
-
Class org.apache.beam.sdk.coders.ZstdCoder extends Coder<T> implements Serializable
-
-
Package org.apache.beam.sdk.io
-
Class org.apache.beam.sdk.io.AvroIO.Parse extends PTransform<PBegin,PCollection<T>> implements Serializable
-
Class org.apache.beam.sdk.io.AvroIO.ParseAll extends PTransform<PCollection<java.lang.String>,PCollection<T>> implements Serializable
-
Class org.apache.beam.sdk.io.AvroIO.ParseFiles extends PTransform<PCollection<FileIO.ReadableFile>,PCollection<T>> implements Serializable
-
Class org.apache.beam.sdk.io.AvroIO.Read extends PTransform<PBegin,PCollection<T>> implements Serializable
-
Class org.apache.beam.sdk.io.AvroIO.ReadAll extends PTransform<PCollection<java.lang.String>,PCollection<T>> implements Serializable
-
Class org.apache.beam.sdk.io.AvroIO.ReadFiles extends PTransform<PCollection<FileIO.ReadableFile>,PCollection<T>> implements Serializable
-
Class org.apache.beam.sdk.io.AvroIO.Sink extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.io.AvroIO.TypedWrite extends PTransform<PCollection<UserT>,WriteFilesResult<DestinationT>> implements Serializable
-
Class org.apache.beam.sdk.io.AvroIO.Write extends PTransform<PCollection<T>,PDone> implements Serializable
-
Serialized Fields
-
inner
AvroIO.TypedWrite<T,?,T> inner
-
-
-
Class org.apache.beam.sdk.io.AvroSink extends FileBasedSink<UserT,DestinationT,OutputT> implements Serializable
-
Serialized Fields
-
genericRecords
boolean genericRecords
-
-
-
Class org.apache.beam.sdk.io.AvroSource extends BlockBasedSource<T> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve() throws java.io.ObjectStreamException
- Throws:
java.io.ObjectStreamException
-
-
Serialized Fields
-
mode
org.apache.beam.sdk.io.AvroSource.Mode<T> mode
-
-
-
Class org.apache.beam.sdk.io.BlockBasedSource extends FileBasedSource<T> implements Serializable
-
Class org.apache.beam.sdk.io.BoundedReadFromUnboundedSource extends PTransform<PBegin,PCollection<T>> implements Serializable
-
Serialized Fields
-
maxNumRecords
long maxNumRecords
-
maxReadTime
@Nullable org.joda.time.Duration maxReadTime
-
source
UnboundedSource<T,?> source
-
-
-
Class org.apache.beam.sdk.io.BoundedSource extends Source<T> implements Serializable
-
Class org.apache.beam.sdk.io.ClassLoaderFileSystem.ClassLoaderResourceId extends java.lang.Object implements Serializable
-
Serialized Fields
-
path
java.lang.String path
-
-
-
Class org.apache.beam.sdk.io.CompressedSource extends FileBasedSource<T> implements Serializable
-
Serialized Fields
-
channelFactory
CompressedSource.DecompressingChannelFactory channelFactory
-
sourceDelegate
FileBasedSource<T> sourceDelegate
-
-
-
Class org.apache.beam.sdk.io.DefaultFilenamePolicy extends FileBasedSink.FilenamePolicy implements Serializable
-
Serialized Fields
-
params
DefaultFilenamePolicy.Params params
-
-
-
Class org.apache.beam.sdk.io.DefaultFilenamePolicy.Params extends java.lang.Object implements Serializable
-
Serialized Fields
-
baseFilename
@Nullable ValueProvider<ResourceId> baseFilename
-
explicitTemplate
boolean explicitTemplate
-
shardTemplate
java.lang.String shardTemplate
-
suffix
java.lang.String suffix
-
-
-
Class org.apache.beam.sdk.io.DefaultFilenamePolicy.ParamsCoder extends AtomicCoder<DefaultFilenamePolicy.Params> implements Serializable
-
Class org.apache.beam.sdk.io.DynamicAvroDestinations extends FileBasedSink.DynamicDestinations<UserT,DestinationT,OutputT> implements Serializable
-
Class org.apache.beam.sdk.io.FileBasedSink extends java.lang.Object implements Serializable
-
Serialized Fields
-
dynamicDestinations
FileBasedSink.DynamicDestinations<?,DestinationT,OutputT> dynamicDestinations
-
tempDirectoryProvider
ValueProvider<ResourceId> tempDirectoryProvider
The directory to which files will be written. -
writableByteChannelFactory
FileBasedSink.WritableByteChannelFactory writableByteChannelFactory
TheFileBasedSink.WritableByteChannelFactory
that is used to wrap the raw data output to the underlying channel. The default is to not compress the output usingCompression.UNCOMPRESSED
.
-
-
-
Class org.apache.beam.sdk.io.FileBasedSink.DynamicDestinations extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.io.FileBasedSink.FilenamePolicy extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.io.FileBasedSink.FileResultCoder extends StructuredCoder<FileBasedSink.FileResult<DestinationT>> implements Serializable
-
Serialized Fields
-
destinationCoder
Coder<DestinationT> destinationCoder
-
windowCoder
Coder<BoundedWindow> windowCoder
-
-
-
Class org.apache.beam.sdk.io.FileBasedSink.WriteOperation extends java.lang.Object implements Serializable
-
Serialized Fields
-
baseTempDirectory
ValueProvider<ResourceId> baseTempDirectory
Base directory for temporary output files. A subdirectory of this may be used based upon tempSubdirType. -
sink
FileBasedSink<?,DestinationT,OutputT> sink
The Sink that this WriteOperation will write to. -
subdirUUID
java.util.UUID subdirUUID
-
tempSubdirType
org.apache.beam.sdk.io.FileBasedSink.WriteOperation.TempSubDirType tempSubdirType
-
windowedWrites
boolean windowedWrites
Whether windowed writes are being used.
-
-
-
Class org.apache.beam.sdk.io.FileBasedSource extends OffsetBasedSource<T> implements Serializable
-
Serialized Fields
-
emptyMatchTreatment
EmptyMatchTreatment emptyMatchTreatment
-
fileOrPatternSpec
ValueProvider<java.lang.String> fileOrPatternSpec
-
mode
FileBasedSource.Mode mode
-
singleFileMetadata
@Nullable MatchResult.Metadata singleFileMetadata
-
-
-
Class org.apache.beam.sdk.io.FileIO.Match extends PTransform<PBegin,PCollection<MatchResult.Metadata>> implements Serializable
-
Class org.apache.beam.sdk.io.FileIO.MatchAll extends PTransform<PCollection<java.lang.String>,PCollection<MatchResult.Metadata>> implements Serializable
-
Class org.apache.beam.sdk.io.FileIO.MatchConfiguration extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.io.FileIO.ReadMatches extends PTransform<PCollection<MatchResult.Metadata>,PCollection<FileIO.ReadableFile>> implements Serializable
-
Class org.apache.beam.sdk.io.FileIO.Write extends PTransform<PCollection<UserT>,WriteFilesResult<DestinationT>> implements Serializable
-
Class org.apache.beam.sdk.io.GenerateSequence extends PTransform<PBegin,PCollection<java.lang.Long>> implements Serializable
-
Class org.apache.beam.sdk.io.OffsetBasedSource extends BoundedSource<T> implements Serializable
-
Serialized Fields
-
endOffset
long endOffset
-
minBundleSize
long minBundleSize
-
startOffset
long startOffset
-
-
-
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<T,UnboundedSource.CheckpointMark> source
-
-
-
Class org.apache.beam.sdk.io.ReadableFileCoder extends StructuredCoder<FileIO.ReadableFile> implements Serializable
-
Serialized Fields
-
metadataCoder
Coder<MatchResult.Metadata> metadataCoder
-
-
-
Class org.apache.beam.sdk.io.ReadAllViaFileBasedSource extends PTransform<PCollection<FileIO.ReadableFile>,PCollection<T>> implements Serializable
-
Serialized Fields
-
coder
Coder<T> coder
-
createSource
SerializableFunction<java.lang.String,? extends FileBasedSource<T>> createSource
-
desiredBundleSizeBytes
long desiredBundleSizeBytes
-
exceptionHandler
ReadAllViaFileBasedSource.ReadFileRangesFnExceptionHandler exceptionHandler
-
usesReshuffle
boolean usesReshuffle
-
-
-
Class org.apache.beam.sdk.io.ReadAllViaFileBasedSource.ReadFileRangesFnExceptionHandler extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.io.Source extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.io.TextIO.Read extends PTransform<PBegin,PCollection<java.lang.String>> implements Serializable
-
Class org.apache.beam.sdk.io.TextIO.ReadAll extends PTransform<PCollection<java.lang.String>,PCollection<java.lang.String>> implements Serializable
-
Class org.apache.beam.sdk.io.TextIO.ReadFiles extends PTransform<PCollection<FileIO.ReadableFile>,PCollection<java.lang.String>> implements Serializable
-
Class org.apache.beam.sdk.io.TextIO.Sink extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.io.TextIO.TypedWrite extends PTransform<PCollection<UserT>,WriteFilesResult<DestinationT>> implements Serializable
-
Class org.apache.beam.sdk.io.TextIO.Write extends PTransform<PCollection<java.lang.String>,PDone> implements Serializable
-
Serialized Fields
-
inner
TextIO.TypedWrite<java.lang.String,?> inner
-
-
-
Class org.apache.beam.sdk.io.TextRowCountEstimator.NoEstimationException extends java.lang.Exception implements Serializable
-
Class org.apache.beam.sdk.io.TFRecordIO.Read extends PTransform<PBegin,PCollection<byte[]>> implements Serializable
-
Class org.apache.beam.sdk.io.TFRecordIO.ReadFiles extends PTransform<PCollection<FileIO.ReadableFile>,PCollection<byte[]>> implements Serializable
-
Class org.apache.beam.sdk.io.TFRecordIO.Sink extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.io.TFRecordIO.Write extends PTransform<PCollection<byte[]>,PDone> implements Serializable
-
Class org.apache.beam.sdk.io.UnboundedSource extends Source<OutputT> implements Serializable
-
Class org.apache.beam.sdk.io.WriteFiles extends PTransform<PCollection<UserT>,WriteFilesResult<DestinationT>> implements Serializable
-
Serialized Fields
-
writeOperation
@Nullable FileBasedSink.WriteOperation<DestinationT,OutputT> writeOperation
-
-
-
-
Package org.apache.beam.sdk.io.fs
-
Class org.apache.beam.sdk.io.fs.MatchResult.Metadata extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.io.fs.MetadataCoder extends AtomicCoder<MatchResult.Metadata> implements Serializable
-
Class org.apache.beam.sdk.io.fs.MetadataCoderV2 extends AtomicCoder<MatchResult.Metadata> implements Serializable
-
Class org.apache.beam.sdk.io.fs.ResourceIdCoder extends AtomicCoder<ResourceId> implements Serializable
-
-
Package org.apache.beam.sdk.io.range
-
Class org.apache.beam.sdk.io.range.ByteKey extends java.lang.Object implements Serializable
-
Serialized Fields
-
value
org.apache.beam.vendor.grpc.v1p48p1.com.google.protobuf.ByteString value
-
-
-
Class org.apache.beam.sdk.io.range.ByteKeyRange extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.io.range.OffsetRange extends java.lang.Object implements Serializable
-
Serialized Fields
-
from
long from
-
to
long to
-
-
-
Class org.apache.beam.sdk.io.range.OffsetRange.Coder extends AtomicCoder<OffsetRange> implements Serializable
-
-
Package org.apache.beam.sdk.metrics
-
Class org.apache.beam.sdk.metrics.DelegatingCounter extends java.lang.Object implements Serializable
-
Serialized Fields
-
name
MetricName name
-
processWideContainer
boolean processWideContainer
-
-
-
Class org.apache.beam.sdk.metrics.DelegatingDistribution extends java.lang.Object implements Serializable
-
Serialized Fields
-
name
MetricName name
-
processWideContainer
boolean processWideContainer
-
-
-
Class org.apache.beam.sdk.metrics.DelegatingHistogram extends java.lang.Object implements Serializable
-
Serialized Fields
-
bucketType
HistogramData.BucketType bucketType
-
name
MetricName name
-
processWideContainer
boolean processWideContainer
-
-
-
Class org.apache.beam.sdk.metrics.MetricKey extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.metrics.MetricName extends java.lang.Object implements Serializable
-
-
Package org.apache.beam.sdk.options
-
Class org.apache.beam.sdk.options.SdkHarnessOptions.SdkHarnessLogLevelOverrides extends java.util.HashMap<java.lang.String,SdkHarnessOptions.LogLevel> implements Serializable
-
Class org.apache.beam.sdk.options.ValueProvider.NestedValueProvider extends java.lang.Object implements Serializable
-
Serialized Fields
-
translator
SerializableFunction<X,T> translator
-
value
ValueProvider<X> value
-
-
-
Class org.apache.beam.sdk.options.ValueProvider.RuntimeValueProvider extends java.lang.Object implements Serializable
-
Serialized Fields
-
defaultValue
@Nullable T defaultValue
-
klass
java.lang.Class<? extends PipelineOptions> klass
-
methodName
java.lang.String methodName
-
optionsId
java.lang.Long optionsId
-
propertyName
java.lang.String propertyName
-
-
-
Class org.apache.beam.sdk.options.ValueProvider.StaticValueProvider extends java.lang.Object implements Serializable
-
Serialized Fields
-
value
@Nullable T value
-
-
-
-
Package org.apache.beam.sdk.schemas
-
Class org.apache.beam.sdk.schemas.AutoValueSchema extends GetterBasedSchemaProvider implements Serializable
-
Class org.apache.beam.sdk.schemas.AutoValueSchema.AbstractGetterTypeSupplier extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.schemas.AvroRecordSchema extends GetterBasedSchemaProvider implements Serializable
-
Class org.apache.beam.sdk.schemas.CachingFactory extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.schemas.FieldAccessDescriptor extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.schemas.FieldAccessDescriptor.FieldDescriptor extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.schemas.FieldAccessDescriptor.FieldDescriptor.Qualifier extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.schemas.FieldValueTypeInformation extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.schemas.GetterBasedSchemaProvider extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.schemas.JavaBeanSchema extends GetterBasedSchemaProvider implements Serializable
-
Class org.apache.beam.sdk.schemas.JavaBeanSchema.GetterTypeSupplier extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.schemas.JavaBeanSchema.SetterTypeSupplier extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.schemas.JavaFieldSchema extends GetterBasedSchemaProvider implements Serializable
-
Class org.apache.beam.sdk.schemas.JavaFieldSchema.JavaFieldTypeSupplier extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.schemas.NoSuchSchemaException extends java.lang.Exception implements Serializable
-
Class org.apache.beam.sdk.schemas.Schema extends java.lang.Object implements Serializable
-
Serialized Fields
-
encodingPositions
java.util.Map<java.lang.String,java.lang.Integer> encodingPositions
-
encodingPositionsOverridden
boolean encodingPositionsOverridden
-
fieldIndices
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.collect.BiMap<java.lang.String,java.lang.Integer> fieldIndices
-
fields
java.util.List<Schema.Field> fields
-
hashCode
int hashCode
-
options
Schema.Options options
-
uuid
@Nullable java.util.UUID uuid
-
-
-
Class org.apache.beam.sdk.schemas.Schema.Field extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.schemas.Schema.FieldType extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.schemas.Schema.Options extends java.lang.Object implements Serializable
-
Serialized Fields
-
options
java.util.Map<java.lang.String,org.apache.beam.sdk.schemas.Schema.Options.Option> options
-
-
-
Class org.apache.beam.sdk.schemas.SchemaCoder extends CustomCoder<T> implements Serializable
-
Serialized Fields
-
fromRowFunction
SerializableFunction<Row,T> fromRowFunction
-
schema
Schema schema
-
toRowFunction
SerializableFunction<T,Row> toRowFunction
-
typeDescriptor
TypeDescriptor<T> typeDescriptor
-
-
-
-
Package org.apache.beam.sdk.schemas.annotations
-
Class org.apache.beam.sdk.schemas.annotations.DefaultSchema.DefaultSchemaProvider extends java.lang.Object implements Serializable
-
Serialized Fields
-
cachedProviders
java.util.Map<TypeDescriptor,org.apache.beam.sdk.schemas.annotations.DefaultSchema.DefaultSchemaProvider.ProviderAndDescriptor> cachedProviders
-
-
-
-
Package org.apache.beam.sdk.schemas.io
-
Class org.apache.beam.sdk.schemas.io.DeadLetteredTransform extends PTransform<PCollection<? extends InputT>,PCollection<OutputT>> implements Serializable
-
Serialized Fields
-
deadLetter
PTransform<PCollection<Failure>,PDone> deadLetter
-
transform
SimpleFunction<InputT,OutputT> transform
-
-
-
Class org.apache.beam.sdk.schemas.io.InvalidConfigurationException extends java.lang.IllegalArgumentException implements Serializable
-
Class org.apache.beam.sdk.schemas.io.InvalidLocationException extends java.lang.IllegalArgumentException implements Serializable
-
Class org.apache.beam.sdk.schemas.io.InvalidSchemaException extends java.lang.IllegalArgumentException implements Serializable
-
-
Package org.apache.beam.sdk.schemas.io.payloads
-
Package org.apache.beam.sdk.schemas.logicaltypes
-
Class org.apache.beam.sdk.schemas.logicaltypes.Date extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.schemas.logicaltypes.DateTime extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.schemas.logicaltypes.EnumerationType extends java.lang.Object implements Serializable
-
Serialized Fields
-
enumValues
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.collect.BiMap<java.lang.String,java.lang.Integer> enumValues
-
values
java.util.List<java.lang.String> values
-
-
-
Class org.apache.beam.sdk.schemas.logicaltypes.EnumerationType.Value extends java.lang.Object implements Serializable
-
Serialized Fields
-
value
int value
-
-
-
Class org.apache.beam.sdk.schemas.logicaltypes.FixedBytes extends PassThroughLogicalType<byte[]> implements Serializable
-
Serialized Fields
-
byteArrayLength
int byteArrayLength
-
name
@Nullable java.lang.String name
-
-
-
Class org.apache.beam.sdk.schemas.logicaltypes.FixedPrecisionNumeric extends PassThroughLogicalType<java.math.BigDecimal> implements Serializable
-
Serialized Fields
-
precision
int precision
-
scale
int scale
-
-
-
Class org.apache.beam.sdk.schemas.logicaltypes.FixedString extends PassThroughLogicalType<java.lang.String> implements Serializable
-
Serialized Fields
-
name
@Nullable java.lang.String name
-
stringLength
int stringLength
-
-
-
Class org.apache.beam.sdk.schemas.logicaltypes.MicrosInstant extends java.lang.Object implements Serializable
-
Serialized Fields
-
schema
Schema schema
-
-
-
Class org.apache.beam.sdk.schemas.logicaltypes.NanosDuration extends org.apache.beam.sdk.schemas.logicaltypes.NanosType<java.time.Duration> implements Serializable
-
Class org.apache.beam.sdk.schemas.logicaltypes.NanosInstant extends org.apache.beam.sdk.schemas.logicaltypes.NanosType<java.time.Instant> implements Serializable
-
Class org.apache.beam.sdk.schemas.logicaltypes.OneOfType extends java.lang.Object implements Serializable
-
Serialized Fields
-
enumerationType
EnumerationType enumerationType
-
oneOfSchema
Schema oneOfSchema
-
schemaProtoRepresentation
byte[] schemaProtoRepresentation
-
-
-
Class org.apache.beam.sdk.schemas.logicaltypes.PassThroughLogicalType extends java.lang.Object implements Serializable
-
Serialized Fields
-
argument
java.lang.Object argument
-
argumentType
Schema.FieldType argumentType
-
fieldType
Schema.FieldType fieldType
-
identifier
java.lang.String identifier
-
-
-
Class org.apache.beam.sdk.schemas.logicaltypes.PythonCallable extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.schemas.logicaltypes.SchemaLogicalType extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.schemas.logicaltypes.Time extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.schemas.logicaltypes.UnknownLogicalType extends PassThroughLogicalType<T> implements Serializable
-
Serialized Fields
-
payload
byte[] payload
-
-
-
Class org.apache.beam.sdk.schemas.logicaltypes.UuidLogicalType extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.schemas.logicaltypes.VariableBytes extends PassThroughLogicalType<byte[]> implements Serializable
-
Serialized Fields
-
maxByteArrayLength
int maxByteArrayLength
-
name
@Nullable java.lang.String name
-
-
-
Class org.apache.beam.sdk.schemas.logicaltypes.VariableString extends PassThroughLogicalType<java.lang.String> implements Serializable
-
Serialized Fields
-
maxStringLength
int maxStringLength
-
name
@Nullable java.lang.String name
-
-
-
-
Package org.apache.beam.sdk.schemas.transforms
-
Class org.apache.beam.sdk.schemas.transforms.AddFields.Inner extends PTransform<PCollection<T>,PCollection<Row>> implements Serializable
-
Serialized Fields
-
newFields
java.util.List<org.apache.beam.sdk.schemas.transforms.AddFields.Inner.NewField> newFields
-
-
-
Class org.apache.beam.sdk.schemas.transforms.Cast extends PTransform<PCollection<T>,PCollection<Row>> implements Serializable
-
Class org.apache.beam.sdk.schemas.transforms.Cast.CompatibilityError extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.schemas.transforms.Cast.Narrowing extends java.lang.Object implements Serializable
-
Serialized Fields
-
fold
org.apache.beam.sdk.schemas.transforms.Cast.Narrowing.Fold fold
-
-
-
Class org.apache.beam.sdk.schemas.transforms.Cast.Widening extends java.lang.Object implements Serializable
-
Serialized Fields
-
fold
org.apache.beam.sdk.schemas.transforms.Cast.Widening.Fold fold
-
-
-
Class org.apache.beam.sdk.schemas.transforms.CoGroup.By extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.schemas.transforms.CoGroup.ExpandCrossProduct extends PTransform<PCollectionTuple,PCollection<Row>> implements Serializable
-
Serialized Fields
-
joinArgs
org.apache.beam.sdk.schemas.transforms.CoGroup.JoinArguments joinArgs
-
-
-
Class org.apache.beam.sdk.schemas.transforms.CoGroup.Impl extends PTransform<PCollectionTuple,PCollection<Row>> implements Serializable
-
Serialized Fields
-
joinArgs
org.apache.beam.sdk.schemas.transforms.CoGroup.JoinArguments joinArgs
-
keyFieldName
java.lang.String keyFieldName
-
-
-
Class org.apache.beam.sdk.schemas.transforms.DropFields.Inner extends PTransform<PCollection<T>,PCollection<Row>> implements Serializable
-
Serialized Fields
-
fieldsToDrop
FieldAccessDescriptor fieldsToDrop
-
-
-
Class org.apache.beam.sdk.schemas.transforms.Filter.Inner extends PTransform<PCollection<T>,PCollection<T>> implements Serializable
-
Serialized Fields
-
filters
java.util.List<org.apache.beam.sdk.schemas.transforms.Filter.Inner.FilterDescription<?>> filters
-
-
-
Class org.apache.beam.sdk.schemas.transforms.Group.AggregateCombiner extends PTransform<PCollection<InputT>,PCollection<Row>> implements Serializable
-
Class org.apache.beam.sdk.schemas.transforms.Group.ByFields extends Group.AggregateCombiner<InputT> implements Serializable
-
Class org.apache.beam.sdk.schemas.transforms.Group.CombineFieldsByFields extends Group.AggregateCombiner<InputT> implements Serializable
-
Class org.apache.beam.sdk.schemas.transforms.Group.CombineFieldsGlobally extends Group.AggregateCombiner<InputT> implements Serializable
-
Serialized Fields
-
schemaAggregateFn
org.apache.beam.sdk.schemas.transforms.SchemaAggregateFn.Inner schemaAggregateFn
-
-
-
Class org.apache.beam.sdk.schemas.transforms.Group.CombineGlobally extends PTransform<PCollection<InputT>,PCollection<OutputT>> implements Serializable
-
Serialized Fields
-
combineFn
Combine.CombineFn<InputT,?,OutputT> combineFn
-
-
-
Class org.apache.beam.sdk.schemas.transforms.Group.Global extends PTransform<PCollection<InputT>,PCollection<java.lang.Iterable<InputT>>> implements Serializable
-
Class org.apache.beam.sdk.schemas.transforms.Join.FieldsEqual.Impl extends java.lang.Object implements Serializable
-
Serialized Fields
-
lhs
FieldAccessDescriptor lhs
-
rhs
FieldAccessDescriptor rhs
-
-
-
Class org.apache.beam.sdk.schemas.transforms.Join.Impl extends PTransform<PCollection<LhsT>,PCollection<Row>> implements Serializable
-
Serialized Fields
-
joinType
org.apache.beam.sdk.schemas.transforms.Join.JoinType joinType
-
predicate
@Nullable Join.FieldsEqual.Impl predicate
-
-
-
Class org.apache.beam.sdk.schemas.transforms.RenameFields.Inner extends PTransform<PCollection<T>,PCollection<Row>> implements Serializable
-
Serialized Fields
-
renames
java.util.List<org.apache.beam.sdk.schemas.transforms.RenameFields.RenamePair> renames
-
-
-
Class org.apache.beam.sdk.schemas.transforms.Select.Fields extends PTransform<PCollection<T>,PCollection<Row>> implements Serializable
-
Class org.apache.beam.sdk.schemas.transforms.Select.Flattened extends PTransform<PCollection<T>,PCollection<Row>> implements Serializable
-
Class org.apache.beam.sdk.schemas.transforms.WithKeys extends PTransform<PCollection<T>,PCollection<KV<Row,T>>> implements Serializable
-
Serialized Fields
-
fieldAccessDescriptor
FieldAccessDescriptor fieldAccessDescriptor
-
-
-
-
Package org.apache.beam.sdk.schemas.utils
-
Class org.apache.beam.sdk.schemas.utils.ConvertHelpers.ConvertedSchemaInformation extends java.lang.Object implements Serializable
-
Serialized Fields
-
outputSchemaCoder
@Nullable SchemaCoder<T> outputSchemaCoder
-
unboxedType
@Nullable Schema.FieldType unboxedType
-
-
-
Class org.apache.beam.sdk.schemas.utils.SchemaZipFold extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.schemas.utils.SelectHelpers.RowSelectorContainer extends java.lang.Object implements Serializable
-
Serialized Fields
-
fieldAccessDescriptor
FieldAccessDescriptor fieldAccessDescriptor
-
inputSchema
Schema inputSchema
-
optimized
boolean optimized
-
-
-
-
Package org.apache.beam.sdk.state
-
Package org.apache.beam.sdk.testing
-
Class org.apache.beam.sdk.testing.FileChecksumMatcher extends org.hamcrest.TypeSafeMatcher<ShardedFile> implements Serializable
-
Serialized Fields
-
actualChecksum
java.lang.String actualChecksum
-
expectedChecksum
java.lang.String expectedChecksum
-
-
-
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<java.lang.Iterable<T>,java.lang.Void> checkerFn
-
paneExtractor
SimpleFunction<java.lang.Iterable<ValueInSingleWindow<T>>,java.lang.Iterable<T>> paneExtractor
-
rewindowingStrategy
org.apache.beam.sdk.testing.PAssert.AssertionWindows rewindowingStrategy
-
site
PAssert.PAssertionSite site
-
-
-
Class org.apache.beam.sdk.testing.PAssert.GroupThenAssertForSingleton extends PTransform<PCollection<T>,PDone> implements Serializable
-
Serialized Fields
-
checkerFn
SerializableFunction<T,java.lang.Void> checkerFn
-
paneExtractor
SimpleFunction<java.lang.Iterable<ValueInSingleWindow<T>>,java.lang.Iterable<T>> paneExtractor
-
rewindowingStrategy
org.apache.beam.sdk.testing.PAssert.AssertionWindows rewindowingStrategy
-
site
PAssert.PAssertionSite site
-
-
-
Class org.apache.beam.sdk.testing.PAssert.MatcherCheckerFn extends java.lang.Object implements Serializable
-
Serialized Fields
-
matcher
SerializableMatcher<T> matcher
-
-
-
Class org.apache.beam.sdk.testing.PAssert.OneSideInputAssert extends PTransform<PBegin,PDone> implements Serializable
-
Serialized Fields
-
checkerFn
SerializableFunction<ActualT,java.lang.Void> checkerFn
-
site
PAssert.PAssertionSite site
-
-
-
Class org.apache.beam.sdk.testing.PAssert.PAssertionSite extends java.lang.Object implements Serializable
-
Serialized Fields
-
creationStackTrace
java.lang.StackTraceElement[] creationStackTrace
-
message
java.lang.String message
-
-
-
Class org.apache.beam.sdk.testing.SerializableMatchers extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.testing.SuccessOrFailure extends java.lang.Object implements Serializable
-
Serialized Fields
-
isSuccess
boolean isSuccess
-
site
@Nullable PAssert.PAssertionSite site
-
throwable
@Nullable SerializableThrowable throwable
-
-
-
Class org.apache.beam.sdk.testing.TestPipeline.AbandonedNodeException extends java.lang.RuntimeException implements Serializable
-
Class org.apache.beam.sdk.testing.TestPipeline.PipelineRunMissingException extends java.lang.RuntimeException implements Serializable
-
Class org.apache.beam.sdk.testing.TestPipelineOptions.AlwaysPassMatcher extends org.hamcrest.BaseMatcher<PipelineResult> implements Serializable
-
Class org.apache.beam.sdk.testing.TestStream extends PTransform<PBegin,PCollection<T>> implements Serializable
-
Serialized Fields
-
coder
Coder<T> coder
-
events
java.util.List<TestStream.Event<T>> events
-
-
-
Class org.apache.beam.sdk.testing.TestStream.TestStreamCoder extends StructuredCoder<TestStream<T>> implements Serializable
-
Serialized Fields
-
elementCoder
TimestampedValue.TimestampedValueCoder<T> elementCoder
-
-
-
-
Package org.apache.beam.sdk.transforms
-
Class org.apache.beam.sdk.transforms.ApproximateQuantiles.ApproximateQuantilesCombineFn extends Combine.AccumulatingCombineFn<T,org.apache.beam.sdk.transforms.ApproximateQuantiles.QuantileState<T,ComparatorT extends java.util.Comparator<T> & java.io.Serializable>,java.util.List<T>> implements Serializable
-
Serialized Fields
-
bufferSize
int bufferSize
The size of the buffers, corresponding to k in the referenced paper. -
compareFn
ComparatorT extends java.util.Comparator<T> & java.io.Serializable compareFn
The comparison function to use. -
maxNumElements
long maxNumElements
-
numBuffers
int numBuffers
The number of buffers, corresponding to b in the referenced paper. -
numQuantiles
int numQuantiles
Number of quantiles to produce. The size of the final output list, including the minimum and maximum, is numQuantiles.
-
-
-
Class org.apache.beam.sdk.transforms.ApproximateUnique.ApproximateUniqueCombineFn extends Combine.CombineFn<T,ApproximateUnique.ApproximateUniqueCombineFn.LargestUnique,java.lang.Long> implements Serializable
-
Class org.apache.beam.sdk.transforms.ApproximateUnique.ApproximateUniqueCombineFn.LargestUnique extends java.lang.Object implements Serializable
-
Serialized Fields
-
heap
java.util.TreeSet<java.lang.Long> heap
-
minHash
long minHash
-
sampleSize
long sampleSize
-
-
-
Class org.apache.beam.sdk.transforms.ApproximateUnique.Globally extends PTransform<PCollection<T>,PCollection<java.lang.Long>> implements Serializable
-
Serialized Fields
-
maximumEstimationError
@Nullable java.lang.Double maximumEstimationError
The desired maximum estimation error or null if not specified. -
sampleSize
long sampleSize
The number of entries in the statistical sample; the higher this number, the more accurate the estimate will be.
-
-
-
Class org.apache.beam.sdk.transforms.ApproximateUnique.PerKey extends PTransform<PCollection<KV<K,V>>,PCollection<KV<K,java.lang.Long>>> implements Serializable
-
Serialized Fields
-
maximumEstimationError
@Nullable java.lang.Double maximumEstimationError
The desired maximum estimation error or null if not specified. -
sampleSize
long sampleSize
The number of entries in the statistical sample; the higher this number, the more accurate the estimate will be.
-
-
-
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 extends @Nullable java.lang.Object,AccumT extends @Nullable java.lang.Object,OutputT extends @Nullable java.lang.Object> implements Serializable
-
Class org.apache.beam.sdk.transforms.Combine.Globally extends PTransform<PCollection<InputT>,PCollection<OutputT>> implements Serializable
-
Serialized Fields
-
fanout
int fanout
-
fn
CombineFnBase.GlobalCombineFn<? super InputT,?,OutputT> fn
-
fnDisplayData
DisplayData.ItemSpec<? extends java.lang.Class<?>> fnDisplayData
-
insertDefault
boolean insertDefault
-
sideInputs
java.util.List<PCollectionView<?>> sideInputs
-
-
-
Class org.apache.beam.sdk.transforms.Combine.GloballyAsSingletonView extends PTransform<PCollection<InputT>,PCollectionView<OutputT>> implements Serializable
-
Serialized Fields
-
fanout
int fanout
-
fn
CombineFnBase.GlobalCombineFn<? super InputT,?,OutputT> fn
-
fnDisplayData
DisplayData.ItemSpec<? extends java.lang.Class<?>> fnDisplayData
-
insertDefault
boolean insertDefault
-
-
-
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<? super InputT,?,OutputT> fn
-
fnDisplayData
DisplayData.ItemSpec<? extends java.lang.Class<?>> fnDisplayData
-
sideInputs
java.util.List<PCollectionView<?>> sideInputs
-
-
-
Class org.apache.beam.sdk.transforms.Combine.IterableCombineFn extends Combine.CombineFn<V,java.util.List<V>,V> implements Serializable
-
Serialized Fields
-
bufferSize
int bufferSize
The number of values to accumulate before invoking the combiner function to combine them. -
combiner
SerializableFunction<java.lang.Iterable<V>,V> combiner
The combiner function.
-
-
-
Class org.apache.beam.sdk.transforms.Combine.PerKey extends PTransform<PCollection<KV<K,InputT>>,PCollection<KV<K,OutputT>>> implements Serializable
-
Serialized Fields
-
fewKeys
boolean fewKeys
-
fn
CombineFnBase.GlobalCombineFn<? super InputT,?,OutputT> fn
-
fnDisplayData
DisplayData.ItemSpec<? extends java.lang.Class<?>> fnDisplayData
-
sideInputs
java.util.List<PCollectionView<?>> 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<? super InputT,?,OutputT> fn
-
fnDisplayData
DisplayData.ItemSpec<? extends java.lang.Class<?>> fnDisplayData
-
hotKeyFanout
SerializableFunction<? super K,java.lang.Integer> 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<TupleTag<?>,java.lang.Object> valuesMap
-
-
-
Class org.apache.beam.sdk.transforms.CombineFns.ComposedCombineFn extends Combine.CombineFn<DataT,java.lang.Object[],CombineFns.CoCombineResult> implements Serializable
-
Serialized Fields
-
combineFnCount
int combineFnCount
-
combineFns
java.util.List<Combine.CombineFn<java.lang.Object,java.lang.Object,java.lang.Object>> combineFns
-
combineInputCoders
java.util.List<org.apache.beam.vendor.guava.v26_0_jre.com.google.common.base.Optional<Coder>> combineInputCoders
-
extractInputFns
java.util.List<SerializableFunction<DataT,java.lang.Object>> extractInputFns
-
outputTags
java.util.List<TupleTag<?>> outputTags
-
-
-
Class org.apache.beam.sdk.transforms.CombineFns.ComposedCombineFnWithContext extends CombineWithContext.CombineFnWithContext<DataT,java.lang.Object[],CombineFns.CoCombineResult> implements Serializable
-
Serialized Fields
-
combineFnCount
int combineFnCount
-
combineFnWithContexts
java.util.List<CombineWithContext.CombineFnWithContext<java.lang.Object,java.lang.Object,java.lang.Object>> combineFnWithContexts
-
combineInputCoders
java.util.List<org.apache.beam.vendor.guava.v26_0_jre.com.google.common.base.Optional<Coder>> combineInputCoders
-
extractInputFns
java.util.List<SerializableFunction<DataT,java.lang.Object>> extractInputFns
-
outputTags
java.util.List<TupleTag<?>> outputTags
-
-
-
Class org.apache.beam.sdk.transforms.CombineWithContext.CombineFnWithContext extends org.apache.beam.sdk.transforms.CombineFnBase.AbstractGlobalCombineFn<InputT,AccumT,OutputT> implements Serializable
-
Class org.apache.beam.sdk.transforms.Contextful extends java.lang.Object implements Serializable
-
Serialized Fields
-
closure
ClosureT closure
-
requirements
Requirements requirements
-
-
-
Class org.apache.beam.sdk.transforms.Create.OfValueProvider extends PTransform<PBegin,PCollection<T>> implements Serializable
-
Serialized Fields
-
coder
Coder<T> coder
-
provider
ValueProvider<T> provider
-
-
-
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.Deduplicate.KeyedValues extends PTransform<PCollection<KV<K,V>>,PCollection<KV<K,V>>> implements Serializable
-
Serialized Fields
-
duration
org.joda.time.Duration duration
-
timeDomain
TimeDomain timeDomain
-
-
-
Class org.apache.beam.sdk.transforms.Deduplicate.Values extends PTransform<PCollection<T>,PCollection<T>> implements Serializable
-
Serialized Fields
-
duration
org.joda.time.Duration duration
-
timeDomain
TimeDomain timeDomain
-
-
-
Class org.apache.beam.sdk.transforms.Deduplicate.WithRepresentativeValues extends PTransform<PCollection<T>,PCollection<T>> implements Serializable
-
Serialized Fields
-
coder
@Nullable Coder<IdT> coder
-
duration
org.joda.time.Duration duration
-
fn
SerializableFunction<T,IdT> fn
-
timeDomain
TimeDomain timeDomain
-
type
@Nullable TypeDescriptor<IdT> type
-
-
-
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<T,IdT> fn
-
representativeType
TypeDescriptor<IdT> representativeType
-
-
-
Class org.apache.beam.sdk.transforms.DoFn extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.transforms.DoFnSchemaInformation extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.transforms.Filter extends PTransform<PCollection<T>,PCollection<T>> implements Serializable
-
Serialized Fields
-
predicate
ProcessFunction<T,java.lang.Boolean> 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
@Nullable Contextful<Contextful.Fn<InputT,java.lang.Iterable<OutputT>>> fn
-
-
-
Class org.apache.beam.sdk.transforms.FlatMapElements.FlatMapWithFailures extends PTransform<PCollection<InputT>,WithFailures.Result<PCollection<OutputT>,FailureT>> implements Serializable
-
Serialized Fields
-
exceptionHandler
@Nullable ProcessFunction<WithFailures.ExceptionElement<InputT>,FailureT> exceptionHandler
-
fn
@Nullable Contextful<Contextful.Fn<InputT,java.lang.Iterable<OutputT>>> fn
-
-
-
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
-
params
GroupIntoBatches.BatchingParams<InputT> params
-
-
-
Class org.apache.beam.sdk.transforms.GroupIntoBatches.BatchingParams extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.transforms.GroupIntoBatches.WithShardedKey extends PTransform<PCollection<KV<K,InputT>>,PCollection<KV<ShardedKey<K>,java.lang.Iterable<InputT>>>> implements Serializable
-
Class org.apache.beam.sdk.transforms.Impulse extends PTransform<PBegin,PCollection<byte[]>> implements Serializable
-
Class org.apache.beam.sdk.transforms.InferableFunction extends java.lang.Object implements Serializable
-
Serialized Fields
-
fn
@Nullable ProcessFunction<InputT,OutputT> fn
-
-
-
Class org.apache.beam.sdk.transforms.JsonToRow.JsonToRowWithErrFn extends PTransform<PCollection<java.lang.String>,JsonToRow.ParseResult> implements Serializable
-
Class org.apache.beam.sdk.transforms.JsonToRow.JsonToRowWithErrFn.ParseWithError extends DoFn<java.lang.String,Row> implements Serializable
-
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
@Nullable Contextful<Contextful.Fn<InputT,OutputT>> fn
-
-
-
Class org.apache.beam.sdk.transforms.MapElements.MapWithFailures extends PTransform<PCollection<InputT>,WithFailures.Result<PCollection<OutputT>,FailureT>> implements Serializable
-
Serialized Fields
-
exceptionHandler
@Nullable ProcessFunction<WithFailures.ExceptionElement<InputT>,FailureT> exceptionHandler
-
fn
Contextful<Contextful.Fn<InputT,OutputT>> fn
-
-
-
Class org.apache.beam.sdk.transforms.MapKeys extends PTransform<PCollection<KV<K1,V>>,PCollection<KV<K2,V>>> implements Serializable
-
Serialized Fields
-
fn
@Nullable Contextful<Contextful.Fn<KV<K1,V>,KV<K2,V>>> fn
-
-
-
Class org.apache.beam.sdk.transforms.MapValues extends PTransform<PCollection<KV<K,V1>>,PCollection<KV<K,V2>>> implements Serializable
-
Serialized Fields
-
fn
@Nullable Contextful<Contextful.Fn<KV<K,V1>,KV<K,V2>>> fn
-
-
-
Class org.apache.beam.sdk.transforms.ParDo.MultiOutput extends PTransform<PCollection<? extends InputT>,PCollectionTuple> implements Serializable
-
Serialized Fields
-
additionalOutputTags
TupleTagList additionalOutputTags
-
fn
DoFn<InputT,OutputT> fn
-
fnDisplayData
DisplayData.ItemSpec<? extends java.lang.Class<?>> fnDisplayData
-
mainOutputTag
TupleTag<OutputT> mainOutputTag
-
sideInputs
java.util.Map<java.lang.String,PCollectionView<?>> sideInputs
-
-
-
Class org.apache.beam.sdk.transforms.ParDo.SingleOutput extends PTransform<PCollection<? extends InputT>,PCollection<OutputT>> implements Serializable
-
Serialized Fields
-
fn
DoFn<InputT,OutputT> fn
-
fnDisplayData
DisplayData.ItemSpec<? extends java.lang.Class<?>> fnDisplayData
-
sideInputs
java.util.Map<java.lang.String,PCollectionView<?>> sideInputs
-
-
-
Class org.apache.beam.sdk.transforms.Partition extends PTransform<PCollection<T>,PCollectionList<T>> implements Serializable
-
Class org.apache.beam.sdk.transforms.PeriodicImpulse extends PTransform<PBegin,PCollection<org.joda.time.Instant>> implements Serializable
-
Serialized Fields
-
applyWindowing
boolean applyWindowing
-
fireInterval
org.joda.time.Duration fireInterval
-
startTimestamp
org.joda.time.Instant startTimestamp
-
stopTimestamp
org.joda.time.Instant stopTimestamp
-
-
-
Class org.apache.beam.sdk.transforms.PeriodicSequence extends PTransform<PCollection<PeriodicSequence.SequenceDefinition>,PCollection<org.joda.time.Instant>> 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
-
group
int group
-
pattern
java.util.regex.Pattern pattern
-
-
-
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
-
keyGroup
int keyGroup
-
pattern
java.util.regex.Pattern pattern
-
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
-
groupName
java.lang.String groupName
-
pattern
java.util.regex.Pattern pattern
-
-
-
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
-
keyGroupName
java.lang.String keyGroupName
-
pattern
java.util.regex.Pattern pattern
-
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
-
group
int group
-
pattern
java.util.regex.Pattern pattern
-
-
-
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
-
keyGroup
int keyGroup
-
pattern
java.util.regex.Pattern pattern
-
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
-
groupName
java.lang.String groupName
-
pattern
java.util.regex.Pattern pattern
-
-
-
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
-
keyGroupName
java.lang.String keyGroupName
-
pattern
java.util.regex.Pattern pattern
-
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
-
outputEmpty
boolean outputEmpty
-
pattern
java.util.regex.Pattern pattern
-
splitLimit
int splitLimit
-
-
-
Class org.apache.beam.sdk.transforms.Requirements extends java.lang.Object implements Serializable
-
Serialized Fields
-
sideInputs
java.util.Collection<PCollectionView<?>> sideInputs
-
-
-
Class org.apache.beam.sdk.transforms.Reshuffle extends PTransform<PCollection<KV<K,V>>,PCollection<KV<K,V>>> implements Serializable
-
Class org.apache.beam.sdk.transforms.Reshuffle.AssignShardFn extends DoFn<T,KV<java.lang.Integer,T>> implements Serializable
-
Serialized Fields
-
numBuckets
@Nullable java.lang.Integer numBuckets
-
shard
int shard
-
-
-
Class org.apache.beam.sdk.transforms.Reshuffle.ViaRandomKey extends PTransform<PCollection<T>,PCollection<T>> implements Serializable
-
Serialized Fields
-
numBuckets
@Nullable java.lang.Integer numBuckets
-
-
-
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
-
rand
java.util.Random rand
-
sampleSize
int sampleSize
-
topCombineFn
Top.TopCombineFn<KV<java.lang.Integer,T>,SerializableComparator<KV<java.lang.Integer,T>>> topCombineFn
-
-
-
Class org.apache.beam.sdk.transforms.SimpleFunction extends InferableFunction<InputT,OutputT> implements Serializable
-
Serialized Fields
-
fn
@Nullable SerializableFunction<InputT,OutputT> fn
-
-
-
Class org.apache.beam.sdk.transforms.ToJson extends PTransform<PCollection<T>,PCollection<java.lang.String>> implements Serializable
-
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
-
compareFn
ComparatorT extends java.util.Comparator<T> & java.io.Serializable compareFn
-
count
int count
-
-
-
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
@Nullable T defaultValue
-
hasDefault
boolean hasDefault
-
-
-
Class org.apache.beam.sdk.transforms.View.CreatePCollectionView extends PTransform<PCollection<ElemT>,PCollection<ElemT>> implements Serializable
-
Serialized Fields
-
view
PCollectionView<ViewT> view
-
-
-
Class org.apache.beam.sdk.transforms.View.ToListViewDoFn extends DoFn<T,KV<java.lang.Long,PCollectionViews.ValueOrMetadata<T,OffsetRange>>> implements Serializable
-
Serialized Fields
-
windowsToOffsets
java.util.Map<BoundedWindow,OffsetRange> windowsToOffsets
-
-
-
Class org.apache.beam.sdk.transforms.ViewFn extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.transforms.Wait.OnSignal extends PTransform<PCollection<T>,PCollection<T>> implements Serializable
-
Class org.apache.beam.sdk.transforms.Watch.Growth extends PTransform<PCollection<InputT>,PCollection<KV<InputT,OutputT>>> implements Serializable
-
Class org.apache.beam.sdk.transforms.Watch.Growth.PollFn extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.transforms.Watch.WatchGrowthFn extends DoFn<InputT,KV<InputT,java.util.List<TimestampedValue<OutputT>>>> implements Serializable
-
Class org.apache.beam.sdk.transforms.WithFailures.ExceptionAsMapHandler extends SimpleFunction<WithFailures.ExceptionElement<T>,KV<T,java.util.Map<java.lang.String,java.lang.String>>> implements Serializable
-
Class org.apache.beam.sdk.transforms.WithFailures.ThrowableHandler extends SimpleFunction<WithFailures.ExceptionElement<T>,KV<T,EncodableThrowable>> implements Serializable
-
Class org.apache.beam.sdk.transforms.WithKeys extends PTransform<PCollection<V>,PCollection<KV<K,V>>> implements Serializable
-
Serialized Fields
-
fn
SerializableFunction<V,K> fn
-
-
-
Class org.apache.beam.sdk.transforms.WithTimestamps extends PTransform<PCollection<T>,PCollection<T>> implements Serializable
-
Serialized Fields
-
allowedTimestampSkew
org.joda.time.Duration allowedTimestampSkew
-
fn
SerializableFunction<T,org.joda.time.Instant> fn
-
-
-
-
Package org.apache.beam.sdk.transforms.display
-
Class org.apache.beam.sdk.transforms.display.DisplayData extends java.lang.Object implements Serializable
-
Serialized Fields
-
entries
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.collect.ImmutableMap<DisplayData.Identifier,DisplayData.Item> entries
-
-
-
Class org.apache.beam.sdk.transforms.display.DisplayData.Identifier extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.transforms.display.DisplayData.Item extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.transforms.display.DisplayData.ItemSpec extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.transforms.display.DisplayData.Path extends java.lang.Object implements Serializable
-
Serialized Fields
-
components
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.collect.ImmutableList<java.lang.String> 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
-
tagMap
java.util.HashMap<TupleTag<?>,java.lang.Integer> tagMap
Maps TupleTags to union tags. This avoids needing to encode the tags themselves. -
tupleTagList
TupleTagList tupleTagList
-
-
-
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<Coder<?>> elementCoders
-
-
-
-
Package org.apache.beam.sdk.transforms.windowing
-
Class org.apache.beam.sdk.transforms.windowing.AfterAll extends Trigger.OnceTrigger implements Serializable
-
Class org.apache.beam.sdk.transforms.windowing.AfterEach extends Trigger implements Serializable
-
Class org.apache.beam.sdk.transforms.windowing.AfterFirst extends Trigger.OnceTrigger implements Serializable
-
Class org.apache.beam.sdk.transforms.windowing.AfterPane extends Trigger.OnceTrigger implements Serializable
-
Serialized Fields
-
countElems
int countElems
-
-
-
Class org.apache.beam.sdk.transforms.windowing.AfterProcessingTime extends Trigger.OnceTrigger implements Serializable
-
Serialized Fields
-
timestampTransforms
java.util.List<TimestampTransform> 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
@Nullable 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
org.joda.time.DateTime startDate
-
timeZone
org.joda.time.DateTimeZone timeZone
-
-
-
Class org.apache.beam.sdk.transforms.windowing.CalendarWindows.MonthsWindows extends PartitioningWindowFn<java.lang.Object,IntervalWindow> implements Serializable
-
Serialized Fields
-
dayOfMonth
int dayOfMonth
-
number
int number
-
startDate
org.joda.time.DateTime startDate
-
timeZone
org.joda.time.DateTimeZone timeZone
-
-
-
Class org.apache.beam.sdk.transforms.windowing.CalendarWindows.YearsWindows extends PartitioningWindowFn<java.lang.Object,IntervalWindow> implements Serializable
-
Serialized Fields
-
dayOfMonth
int dayOfMonth
-
monthOfYear
int monthOfYear
-
number
int number
-
startDate
org.joda.time.DateTime startDate
-
timeZone
org.joda.time.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
-
offset
org.joda.time.Duration offset
Offset of this window. Windows start at time N * size + offset, where 0 is the epoch. -
size
org.joda.time.Duration size
Size of this window.
-
-
-
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<?,?> 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.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
org.joda.time.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
-
offset
org.joda.time.Duration offset
Offset of the generated windows. Windows start at time N * start + offset, where 0 is the epoch. -
period
org.joda.time.Duration period
Amount of time between generated windows. -
size
org.joda.time.Duration size
Size of the generated windows.
-
-
-
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<Trigger> 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,?> 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
org.joda.time.Duration maximumLookback
-
-
-
-
Package org.apache.beam.sdk.util
-
Class org.apache.beam.sdk.util.AppliedCombineFn extends java.lang.Object implements Serializable
-
Serialized Fields
-
accumulatorCoder
Coder<AccumT> accumulatorCoder
-
fn
CombineFnBase.GlobalCombineFn<InputT,AccumT,OutputT> fn
-
kvCoder
KvCoder<K,InputT> kvCoder
-
sideInputViews
java.lang.Iterable<PCollectionView<?>> sideInputViews
-
windowingStrategy
WindowingStrategy<?,?> windowingStrategy
-
-
-
Class org.apache.beam.sdk.util.BitSetCoder extends AtomicCoder<java.util.BitSet> implements Serializable
-
Class org.apache.beam.sdk.util.DoFnInfo extends java.lang.Object implements Serializable
-
Serialized Fields
-
doFn
DoFn<InputT,OutputT> doFn
-
doFnSchemaInformation
DoFnSchemaInformation doFnSchemaInformation
-
inputCoder
Coder<InputT> inputCoder
-
mainOutput
TupleTag<OutputT> mainOutput
-
outputCoders
java.util.Map<TupleTag<?>,Coder<?>> outputCoders
-
sideInputMapping
java.util.Map<java.lang.String,PCollectionView<?>> sideInputMapping
-
sideInputViews
java.lang.Iterable<PCollectionView<?>> sideInputViews
-
windowingStrategy
WindowingStrategy<?,?> windowingStrategy
-
-
-
Class org.apache.beam.sdk.util.DoFnWithExecutionInformation extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.util.EmptyOnDeserializationThreadLocal extends java.lang.ThreadLocal<T> 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
-
readObjectNoData
private void readObjectNoData() throws java.io.ObjectStreamException
- Throws:
java.io.ObjectStreamException
-
writeObject
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException
- Throws:
java.io.IOException
-
-
-
Class org.apache.beam.sdk.util.ExplicitShardedFile extends java.lang.Object implements Serializable
-
Serialized Fields
-
files
java.util.List<MatchResult.Metadata> files
-
-
-
Class org.apache.beam.sdk.util.FilePatternMatchingShardedFile extends java.lang.Object implements Serializable
-
Serialized Fields
-
filePattern
java.lang.String filePattern
-
-
-
Class org.apache.beam.sdk.util.HistogramData extends java.lang.Object implements Serializable
-
Serialized Fields
-
buckets
long[] buckets
-
bucketType
HistogramData.BucketType bucketType
-
numBottomRecords
long numBottomRecords
-
numBoundedBucketRecords
long numBoundedBucketRecords
-
numTopRecords
long numTopRecords
-
-
-
Class org.apache.beam.sdk.util.HistogramData.LinearBuckets extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.util.IdentityWindowFn extends NonMergingWindowFn<T,BoundedWindow> implements Serializable
-
Serialized Fields
-
coder
Coder<BoundedWindow> coder
The coder of the type of windows of the inputPCollection
. This is not an arbitraryBoundedWindow
Coder
, but is safe to use for all windows assigned by this transform, as it should be the same coder used by theWindowFn
that initially assigned these windows.
-
-
-
Class org.apache.beam.sdk.util.IllegalMutationException extends java.lang.RuntimeException implements Serializable
-
Serialized Fields
-
newValue
java.lang.Object newValue
-
savedValue
java.lang.Object savedValue
-
-
-
Class org.apache.beam.sdk.util.NoopLock extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.util.NumberedShardedFile extends java.lang.Object implements Serializable
-
Serialized Fields
-
filePattern
java.lang.String filePattern
-
shardTemplate
java.util.regex.Pattern shardTemplate
-
-
-
Class org.apache.beam.sdk.util.PythonCallableSource extends java.lang.Object implements Serializable
-
Serialized Fields
-
pythonCallableCode
java.lang.String pythonCallableCode
-
-
-
Class org.apache.beam.sdk.util.ReleaseInfo extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.util.RowJson.RowJsonDeserializer extends com.fasterxml.jackson.databind.deser.std.StdDeserializer<Row> implements Serializable
-
Serialized Fields
-
nullBehavior
RowJson.RowJsonDeserializer.NullBehavior nullBehavior
-
schema
Schema schema
-
-
-
Class org.apache.beam.sdk.util.RowJson.RowJsonSerializer extends com.fasterxml.jackson.databind.ser.std.StdSerializer<Row> implements Serializable
-
Serialized Fields
-
dropNullsOnWrite
java.lang.Boolean dropNullsOnWrite
-
schema
Schema schema
-
-
-
Class org.apache.beam.sdk.util.RowJson.UnsupportedRowJsonException extends java.lang.RuntimeException implements Serializable
-
Class org.apache.beam.sdk.util.SerializableThrowable extends java.lang.Object implements Serializable
-
Serialization Methods
-
readObject
private void readObject(java.io.ObjectInputStream is) throws java.io.IOException, java.lang.ClassNotFoundException
- Throws:
java.io.IOException
java.lang.ClassNotFoundException
-
-
Serialized Fields
-
stackTrace
java.lang.StackTraceElement @Nullable [] stackTrace
-
throwable
@Nullable java.lang.Throwable throwable
-
-
-
Class org.apache.beam.sdk.util.ShardedKey.Coder extends StructuredCoder<ShardedKey<K>> implements Serializable
-
Serialized Fields
-
keyCoder
Coder<K> keyCoder
-
shardCoder
ByteArrayCoder shardCoder
-
-
-
Class org.apache.beam.sdk.util.UserCodeException extends java.lang.RuntimeException implements Serializable
-
Class org.apache.beam.sdk.util.WindowedValue.FullWindowedValueCoder extends WindowedValue.WindowedValueCoder<T> implements Serializable
-
Serialized Fields
-
windowCoder
Coder<? extends BoundedWindow> windowCoder
-
windowsCoder
Coder<java.util.Collection<? extends BoundedWindow>> windowsCoder
-
-
-
Class org.apache.beam.sdk.util.WindowedValue.ParamWindowedValueCoder extends WindowedValue.FullWindowedValueCoder<T> implements Serializable
- serialVersionUID:
- 1L
-
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
-
-
Class org.apache.beam.sdk.util.WindowedValue.ValueOnlyWindowedValueCoder extends WindowedValue.WindowedValueCoder<T> implements Serializable
-
Class org.apache.beam.sdk.util.WindowedValue.WindowedValueCoder extends StructuredCoder<WindowedValue<T>> implements Serializable
-
-
Package org.apache.beam.sdk.values
-
Class org.apache.beam.sdk.values.EncodableThrowable extends java.lang.Object implements Serializable
-
Serialized Fields
-
throwable
java.lang.Throwable throwable
-
-
-
Class org.apache.beam.sdk.values.FailsafeValueInSingleWindow.Coder extends StructuredCoder<FailsafeValueInSingleWindow<T,ErrorT>> implements Serializable
-
Class org.apache.beam.sdk.values.KV extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.values.KV.OrderByKey extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.values.KV.OrderByValue extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.values.PCollectionViews.IterableViewFn extends ViewFn<Materializations.MultimapView<java.lang.Void,T>,java.lang.Iterable<T>> implements Serializable
-
Serialized Fields
-
typeDescriptorSupplier
PCollectionViews.TypeDescriptorSupplier<T> typeDescriptorSupplier
Deprecated.
-
-
-
Class org.apache.beam.sdk.values.PCollectionViews.IterableViewFn2 extends ViewFn<Materializations.IterableView<T>,java.lang.Iterable<T>> implements Serializable
-
Serialized Fields
-
typeDescriptorSupplier
PCollectionViews.TypeDescriptorSupplier<T> typeDescriptorSupplier
-
-
-
Class org.apache.beam.sdk.values.PCollectionViews.ListViewFn extends ViewFn<Materializations.MultimapView<java.lang.Void,T>,java.util.List<T>> implements Serializable
-
Serialized Fields
-
typeDescriptorSupplier
PCollectionViews.TypeDescriptorSupplier<T> typeDescriptorSupplier
Deprecated.
-
-
-
Class org.apache.beam.sdk.values.PCollectionViews.ListViewFn2 extends ViewFn<Materializations.MultimapView<java.lang.Long,PCollectionViews.ValueOrMetadata<T,OffsetRange>>,java.util.List<T>> implements Serializable
-
Serialized Fields
-
typeDescriptorSupplier
PCollectionViews.TypeDescriptorSupplier<T> typeDescriptorSupplier
-
-
-
Class org.apache.beam.sdk.values.PCollectionViews.MapViewFn extends ViewFn<Materializations.MultimapView<java.lang.Void,KV<K,V>>,java.util.Map<K,V>> implements Serializable
-
Serialized Fields
-
keyTypeDescriptorSupplier
PCollectionViews.TypeDescriptorSupplier<K> keyTypeDescriptorSupplier
Deprecated. -
valueTypeDescriptorSupplier
PCollectionViews.TypeDescriptorSupplier<V> valueTypeDescriptorSupplier
Deprecated.
-
-
-
Class org.apache.beam.sdk.values.PCollectionViews.MapViewFn2 extends ViewFn<Materializations.MultimapView<K,V>,java.util.Map<K,V>> implements Serializable
-
Serialized Fields
-
keyTypeDescriptorSupplier
PCollectionViews.TypeDescriptorSupplier<K> keyTypeDescriptorSupplier
-
valueTypeDescriptorSupplier
PCollectionViews.TypeDescriptorSupplier<V> valueTypeDescriptorSupplier
-
-
-
Class org.apache.beam.sdk.values.PCollectionViews.MultimapViewFn extends ViewFn<Materializations.MultimapView<java.lang.Void,KV<K,V>>,java.util.Map<K,java.lang.Iterable<V>>> implements Serializable
-
Serialized Fields
-
keyTypeDescriptorSupplier
PCollectionViews.TypeDescriptorSupplier<K> keyTypeDescriptorSupplier
Deprecated. -
valueTypeDescriptorSupplier
PCollectionViews.TypeDescriptorSupplier<V> valueTypeDescriptorSupplier
Deprecated.
-
-
-
Class org.apache.beam.sdk.values.PCollectionViews.MultimapViewFn2 extends ViewFn<Materializations.MultimapView<K,V>,java.util.Map<K,java.lang.Iterable<V>>> implements Serializable
-
Serialized Fields
-
keyTypeDescriptorSupplier
PCollectionViews.TypeDescriptorSupplier<K> keyTypeDescriptorSupplier
-
valueTypeDescriptorSupplier
PCollectionViews.TypeDescriptorSupplier<V> valueTypeDescriptorSupplier
-
-
-
Class org.apache.beam.sdk.values.PCollectionViews.SimplePCollectionView extends PValueBase implements Serializable
-
Serialized Fields
-
coder
@Nullable Coder<ElemT> coder
The coder for the elements underlying the view. -
tag
TupleTag<PrimitiveViewT> tag
A unique tag for the view, typed according to the elements underlying the view. -
viewFn
ViewFn<PrimitiveViewT,ViewT> viewFn
The typedViewFn
for this view. -
windowingStrategy
WindowingStrategy<?,W extends BoundedWindow> windowingStrategy
The windowing strategy for the PCollection underlying the view. -
windowMappingFn
WindowMappingFn<W extends BoundedWindow> windowMappingFn
-
-
-
Class org.apache.beam.sdk.values.PCollectionViews.SingletonViewFn extends ViewFn<Materializations.MultimapView<java.lang.Void,T>,T> implements Serializable
-
Serialized Fields
-
encodedDefaultValue
byte @Nullable [] encodedDefaultValue
Deprecated. -
hasDefault
boolean hasDefault
Deprecated. -
typeDescriptorSupplier
PCollectionViews.TypeDescriptorSupplier<T> typeDescriptorSupplier
Deprecated. -
valueCoder
@Nullable Coder<T> valueCoder
Deprecated.
-
-
-
Class org.apache.beam.sdk.values.PCollectionViews.SingletonViewFn2 extends ViewFn<Materializations.IterableView<T>,T> implements Serializable
-
Serialized Fields
-
encodedDefaultValue
byte @Nullable [] encodedDefaultValue
-
hasDefault
boolean hasDefault
-
typeDescriptorSupplier
PCollectionViews.TypeDescriptorSupplier<T> typeDescriptorSupplier
-
valueCoder
@Nullable Coder<T> valueCoder
-
-
-
Class org.apache.beam.sdk.values.PCollectionViews.ValueOrMetadataCoder extends StructuredCoder<PCollectionViews.ValueOrMetadata<T,MetaT>> implements Serializable
-
Class org.apache.beam.sdk.values.Row extends java.lang.Object implements Serializable
-
Serialized Fields
-
schema
Schema schema
-
-
-
Class org.apache.beam.sdk.values.RowWithGetters extends Row implements Serializable
-
Serialized Fields
-
cache
@Nullable java.util.Map<java.lang.Integer,java.lang.Object> cache
-
getters
java.util.List<FieldValueGetter> getters
-
getterTarget
java.lang.Object getterTarget
-
-
-
Class org.apache.beam.sdk.values.RowWithStorage extends Row implements Serializable
-
Serialized Fields
-
values
java.util.List<@Nullable java.lang.Object> values
-
-
-
Class org.apache.beam.sdk.values.SchemaVerification extends java.lang.Object implements Serializable
-
Class org.apache.beam.sdk.values.ShardedKey extends java.lang.Object implements Serializable
- serialVersionUID:
- 1L
-
Serialized Fields
-
key
K key
-
shardNumber
int shardNumber
-
-
Class org.apache.beam.sdk.values.TimestampedValue.TimestampedValueCoder extends StructuredCoder<TimestampedValue<T>> implements Serializable
-
Class org.apache.beam.sdk.values.TupleTag extends java.lang.Object implements Serializable
-
Serialized Fields
-
generated
boolean generated
-
id
java.lang.String id
-
-
-
Class org.apache.beam.sdk.values.TupleTagList extends java.lang.Object implements Serializable
-
Serialized Fields
-
tupleTags
java.util.List<TupleTag<?>> tupleTags
-
-
-
Class org.apache.beam.sdk.values.TypeDescriptor extends java.lang.Object implements Serializable
-
Serialized Fields
-
token
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.reflect.TypeToken<T> token
-
-
-
Class org.apache.beam.sdk.values.ValueInSingleWindow.Coder extends StructuredCoder<ValueInSingleWindow<T>> implements Serializable
-
Serialized Fields
-
valueCoder
Coder<T> valueCoder
-
windowCoder
Coder<BoundedWindow> 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
-
idCoder
ByteArrayCoder idCoder
-
valueCoder
Coder<ValueT> valueCoder
-
-
-
Class org.apache.beam.sdk.values.WindowingStrategy extends java.lang.Object implements Serializable
-
Serialized Fields
-
allowedLateness
org.joda.time.Duration allowedLateness
-
allowedLatenessSpecified
boolean allowedLatenessSpecified
-
alreadyMerged
boolean alreadyMerged
-
closingBehavior
Window.ClosingBehavior closingBehavior
-
environmentId
java.lang.String environmentId
-
mode
WindowingStrategy.AccumulationMode mode
-
modeSpecified
boolean modeSpecified
-
onTimeBehavior
Window.OnTimeBehavior onTimeBehavior
-
timestampCombiner
TimestampCombiner timestampCombiner
-
timestampCombinerSpecified
boolean timestampCombinerSpecified
-
trigger
Trigger trigger
-
triggerSpecified
boolean triggerSpecified
-
windowFn
WindowFn<T,W extends BoundedWindow> windowFn
-
-
-