如何从GAE java代码而不是Maven运行Dataflow pipline？

<dependency>
  <groupId>com.google.cloud.dataflow</groupId>
  <artifactId>google-cloud-dataflow-java-sdk-all</artifactId>
  <version>2.5.0</version>
</dependency>

import org.apache.beam.sdk.Pipeline;
import org.apache.beam.sdk.io.TextIO;
import org.apache.beam.sdk.options.PipelineOptions;
import org.apache.beam.sdk.options.PipelineOptionsFactory;
import org.apache.beam.sdk.transforms.Count;
import org.apache.beam.sdk.transforms.DoFn;
import org.apache.beam.sdk.transforms.ParDo;

public class DataflowPipeline {
  public static void main(String[] args) {
    PipelineOptions options = PipelineOptionsFactory.create();
    Pipeline pipeline = Pipeline.create(options);

    pipeline
      .apply(TextIO.read().from("gs://bucket/input.txt"))
      .apply(ParDo.of(new CountWords()))
      .apply(Count.perElement())
      .apply(ParDo.of(new FormatResult()))
      .apply(TextIO.write().to("gs://bucket/output.txt"));

    pipeline.run();
  }

  public static class CountWords extends DoFn<String, String> {
    @ProcessElement
    public void processElement(ProcessContext c) {
      String[] words = c.element().split(" ");
      for (String word : words) {
        c.output(word);
      }
    }
  }

  public static class FormatResult extends DoFn<KV<String, Long>, String> {
    @ProcessElement
    public void processElement(ProcessContext c) {
      String result = c.element().getKey() + ": " + c.element().getValue();
      c.output(result);
    }
  }
}

import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.apache.beam.sdk.PipelineResult;

@WebServlet("/rundataflow")
public class RunDataflowServlet extends HttpServlet {
  @Override
  protected void doGet(HttpServletRequest req, HttpServletResponse resp) {
    PipelineResult result = DataflowPipeline.main(new String[]{});
    // 处理Dataflow pipline的结果
  }
}