import com.google.cloud.dataflow.sdk.options.Validation; //导入依赖的package包/类
@Description("Last day of precipitation data to upload. "
             + "Should be in the format \"YYYYMMD\".\n"
             + "If left blank, all data after the start date will "
             + "be included")
@Default.String("")
@Validation.Required
String getEndDate();
 

import com.google.cloud.dataflow.sdk.options.Validation; //导入依赖的package包/类
@Description("Pub/Sub topic to read from")
@Validation.Required
String getTopic();
 

import com.google.cloud.dataflow.sdk.options.Validation; //导入依赖的package包/类
@Description("Pub/Sub play events topic to read from")
@Validation.Required
String getPlayEventsTopic();
 

import com.google.cloud.dataflow.sdk.options.Validation; //导入依赖的package包/类
@Description("BigQuery Dataset to write tables to. Must already exist.")
@Validation.Required
String getOutputDataset();
 

import com.google.cloud.dataflow.sdk.options.Validation; //导入依赖的package包/类
@Description("The BigQuery table name. Should not already exist.")
@Validation.Required
String getOutputTableName();
 

import com.google.cloud.dataflow.sdk.options.Validation; //导入依赖的package包/类
@Description("ProjectId where data source topic lives")
@Default.String("pubsub-public-data")
@Validation.Required
String getSourceProject();
 

import com.google.cloud.dataflow.sdk.options.Validation; //导入依赖的package包/类
@Description("TopicId of source topic")
@Default.String("taxirides-realtime")
@Validation.Required
String getSourceTopic();
 

import com.google.cloud.dataflow.sdk.options.Validation; //导入依赖的package包/类
@Description("ProjectId where data sink topic lives")
@Validation.Required
String getSinkProject();
 

import com.google.cloud.dataflow.sdk.options.Validation; //导入依赖的package包/类
@Description("TopicId of sink topic")
@Default.String("visualizer")
@Validation.Required
String getSinkTopic();
 

import com.google.cloud.dataflow.sdk.options.Validation; //导入依赖的package包/类
@Description("GCS location of files.")
@Validation.Required
String getInput();
 

import com.google.cloud.dataflow.sdk.options.Validation; //导入依赖的package包/类
@Description("Topic to publish on.")
@Validation.Required
String getOutputTopic();
 

import com.google.cloud.dataflow.sdk.options.Validation; //导入依赖的package包/类
@Description("Number of Shards to create for the correlation calculations")
@Validation.Required
int getShards();
 

import com.google.cloud.dataflow.sdk.options.Validation; //导入依赖的package包/类
@Description("When outputing correlations should the underlying values be included. "
    + "Warning this will generate a lot of extra work and should only be used for testing / demos")
@Validation.Required
boolean getIncludeUnderlying();
 

import com.google.cloud.dataflow.sdk.options.Validation; //导入依赖的package包/类
@Description("The lowest ABS(correlation value) to emit. If there are 1000 FX instrements there will be (N^2-N)/2 "
    + "correlations very slide of the window. If you are consuming this in a UI downstream you need to be aware"
    + "of not swamping the downstream systems with values that have little importance. 0.5 is a good starting point."
    + "important to note that 0.5 is not the median there is normally a heavey skew towards 0 ")
@Validation.Required
double getMinCorrelationValue();
 

import com.google.cloud.dataflow.sdk.options.Validation; //导入依赖的package包/类
@Description("Should NAN values be propogated forward")
@Validation.Required
boolean getPropogateNAN();
 

import com.google.cloud.dataflow.sdk.options.Validation; //导入依赖的package包/类
@Description("Datastore entity kind")
@Validation.Required
String getDatastoreEntityKind();
 

import com.google.cloud.dataflow.sdk.options.Validation; //导入依赖的package包/类
@Description("Output GCS Filename Prefix")
@Validation.Required
String getBackupGCSPrefix();
 

import com.google.cloud.dataflow.sdk.options.Validation; //导入依赖的package包/类
@Description("BQ dataset")
@Validation.Required
String getBQDataset();
 

import com.google.cloud.dataflow.sdk.options.Validation; //导入依赖的package包/类
@Description("GCS Datastore Backup Prefix")
@Validation.Required
String getBackupGCSPrefix();
 

import com.google.cloud.dataflow.sdk.options.Validation; //导入依赖的package包/类
@Description("Set to true when appending to existing table, "
             + "false when overriding existing table")
@Default.Boolean(true)
@Validation.Required
boolean getAppend();