Custom Dataflow PipelineOptions

AppOptions.java

package com.sandboxws.beam;

import org.apache.beam.runners.dataflow.options.DataflowPipelineOptions;
import org.apache.beam.sdk.options.Default;
import org.apache.beam.sdk.options.Description;

/**
 * App specific Apache Beam pipeline options.
 *
 * @author Ahmed Elhossaini
 */
public interface AppOptions extends DataflowPipelineOptions {
  @Description("PostgreSQL Host")
  @Default.String("localhost")
  String getPgHost();
  void setPgHost(String value);

  @Description("PostgresSQL port")
  @Default.Integer(5432)
  int getPgPort();
  void setPgPort(int value);

  @Description("PostgreSQL Username")
  String getPgUsername();
  void setPgUsername(String value);

  @Description("PostgreSQL Password")
  String getPgPassword();
  void setPgPassword(String value);

  @Description("PostgreSQL Database")
  String getPgDatabase();
  void setPgDatabase(String value);

  @Description("BigQuery output table")
  String getOutputTable();
  void setOutputTable(String value);
}