package com.sony.etl;

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

public interface CloudBigtableOptions extends DataflowPipelineOptions {
	@Description("The Google Cloud project ID for the Cloud Bigtable instance.")
	@Default.String("dsp-automation")
	String getBigtableProjectId();

	void setBigtableProjectId(String bigtableProjectId);

	@Description("The Google Cloud Bigtable instance ID .")
	@Default.String("bigtable-dsp-automation-demo")
	String getBigtableInstanceId();

	void setBigtableInstanceId(String bigtableInstanceId);

	@Description("The Cloud Bigtable table ID in the instance.")
	@Default.String("spotify_aggregation")
	String getBigtableTableId();

	void setBigtableTableId(String bigtableTableId);

	@Description("Query for BigQuery")
	@Default.String("select * from `dsp-automation.spotify.aggregation`")
	ValueProvider<String> getBqQuery();

	void setBqQuery(ValueProvider<String> value);
}