Interface DoFn.OutputReceiver<T>

  • Enclosing class:
    DoFn<InputT extends @Nullable java.lang.Object,​OutputT extends @Nullable java.lang.Object>

    public static interface DoFn.OutputReceiver<T>
    Receives values of the given type.
    • Method Detail

      • output

        void output​(T output)
      • outputWithTimestamp

        void outputWithTimestamp​(T output,
                                 org.joda.time.Instant timestamp)