Custom Dataflow PipelineOptions
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);
}