gistfile1.txt

package clojure_dataflow;

import com.google.cloud.dataflow.sdk.transforms.DoFnWithContext;
import com.google.cloud.dataflow.sdk.transforms.windowing.BoundedWindow;

/**
 * This class exists because DoFn relies on overriding abstract methods,
 * but DoFnWithContext relies on overriding and annotating abstract methods,
 * since annotating classmethods in clojure is a pain, we made this class.
 * To use this class, extend it using `proxy` and override the abstract methods.
 */


public abstract class CljDoFnWithContext<InputT, OutputT> extends DoFnWithContext<InputT, OutputT> {
  @ProcessElement
  public void processElement(ProcessContext context, BoundedWindow window) {
    cljProcessElement(context, window);
  }

  @StartBundle
  public void startBundle(Context context) {
    cljStartBundle(context);
  }

  public abstract void cljProcessElement(ProcessContext context, BoundedWindow window);

  public abstract void cljStartBundle(Context context);
}