org.apache.beam.sdk.values

Interfaces

• PCollectionView
• PCollectionViews.HasDefaultValue
• PCollectionViews.TypeDescriptorSupplier
• PInput
• POutput
• PValue
• TypeDescriptors.TypeVariableExtractor

Classes

• EncodableThrowable
• FailsafeValueInSingleWindow
• FailsafeValueInSingleWindow.Coder
• KV
• KV.OrderByKey
• KV.OrderByValue
• PBegin
• PCollection
• PCollectionList
• PCollectionRowTuple
• PCollectionTuple
• PCollectionViews
• PCollectionViews.IterableViewFn
• PCollectionViews.IterableViewFn2
• PCollectionViews.ListViewFn
• PCollectionViews.ListViewFn2
• PCollectionViews.MapViewFn
• PCollectionViews.MapViewFn2
• PCollectionViews.MultimapViewFn
• PCollectionViews.MultimapViewFn2
• PCollectionViews.SimplePCollectionView
• PCollectionViews.SingletonViewFn
• PCollectionViews.SingletonViewFn2
• PCollectionViews.ValueOrMetadata
• PCollectionViews.ValueOrMetadataCoder
• PDone
• PValueBase
• PValues
• Row
• Row.Builder
• Row.Equals
• Row.FieldValueBuilder
• RowWithGetters
• RowWithStorage
• SchemaVerification
• ShardedKey
• TaggedPValue
• TimestampedValue
• TimestampedValue.TimestampedValueCoder
• TupleTag
• TupleTagList
• TypeDescriptor
• TypeDescriptors
• TypeParameter
• ValueInSingleWindow
• ValueInSingleWindow.Coder
• ValueWithRecordId
• ValueWithRecordId.StripIdsDoFn
• ValueWithRecordId.ValueWithRecordIdCoder
• WindowingStrategy

Enums

• PCollection.IsBounded
• WindowingStrategy.AccumulationMode