PCollection : A PCollection represents a distributed data set that your Beam pipeline operates on. The data set can be bounded, meaning it comes from a fixed source like a file, or unbounded, meaning it comes from a continuously updating source via a subscription or other mechanism.

What is PCollection in beam?

A PCollection<T> is an immutable collection of values of type T . A PCollection can contain either a bounded or unbounded number of elements.

What is an element in a PCollection?

Each element in a PCollection has an associated timestamp. … UnboundedReader for more information on how these readers produce timestamps and watermarks. Additionally, a PCollection has an associated WindowFn and each element is assigned to a set of windows.