DoFnWithContext.ProcessContext (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

Class DoFnWithContext.ProcessContext

    • Constructor Detail

      • ProcessContext

        public ProcessContext()
    • Method Detail

      • element

        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.

      • timestamp

        public abstract Instant timestamp()
        Returns the timestamp of the input element.

        See Window for more information.

      • pane

        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.