Class DoFn.ProcessContext

    • Constructor Detail

      • ProcessContext

        public ProcessContext()
    • Method Detail

      • element

        @Pure
        public abstract InputT element()
        Returns the input element to be processed.

        The element will not be changed -- it is safe to cache, etc. without copying. Implementation of DoFn.ProcessElement method should not mutate the element.

      • timestamp

        @Pure
        public abstract org.joda.time.Instant timestamp()
        Returns the timestamp of the input element.

        See Window for more information.

      • pane

        @Pure
        public abstract PaneInfo pane()
        Returns information about the pane within this window into which the input element has been assigned.

        Generally all data is in a single, uninteresting pane unless custom triggering and/or late data has been explicitly requested. See Window for more information.