本文整理汇总了Java中com.google.cloud.dataflow.sdk.options.Default类的典型用法代码示例。如果您正苦于以下问题:Java Default类的具体用法?Java Default怎么用?Java Default使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
Default类属于com.google.cloud.dataflow.sdk.options包,在下文中一共展示了Default类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: getEndDate
import com.google.cloud.dataflow.sdk.options.Default; //导入依赖的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();
开发者ID:GoogleCloudPlatform,项目名称:dataflow-precipitation-pipeline,代码行数:8,代码来源:PrecipitationOptions.java
示例2: getSessionGap
import com.google.cloud.dataflow.sdk.options.Default; //导入依赖的package包/类
@Description("Numeric value of gap between user sessions, in minutes")
@Default.Integer(1)
Integer getSessionGap();
开发者ID:mdvorsky,项目名称:DataflowSME,代码行数:4,代码来源:Exercise6.java
示例3: getUserActivityWindowDuration
import com.google.cloud.dataflow.sdk.options.Default; //导入依赖的package包/类
@Description(
"Numeric value of fixed window for finding mean of user session duration, " + "in minutes")
@Default.Integer(5)
Integer getUserActivityWindowDuration();
开发者ID:mdvorsky,项目名称:DataflowSME,代码行数:5,代码来源:Exercise6.java
示例4: getTeamWindowDuration
import com.google.cloud.dataflow.sdk.options.Default; //导入依赖的package包/类
@Description("Numeric value of fixed window duration for team analysis, in minutes")
@Default.Integer(1)
Integer getTeamWindowDuration();
开发者ID:mdvorsky,项目名称:DataflowSME,代码行数:4,代码来源:Exercise4.java
示例5: getAllowedLateness
import com.google.cloud.dataflow.sdk.options.Default; //导入依赖的package包/类
@Description("Numeric value of allowed data lateness, in minutes")
@Default.Integer(2)
Integer getAllowedLateness();
开发者ID:mdvorsky,项目名称:DataflowSME,代码行数:4,代码来源:Exercise4.java
示例6: getFixedWindowDuration
import com.google.cloud.dataflow.sdk.options.Default; //导入依赖的package包/类
@Description("Numeric value of fixed window duration for user analysis, in minutes")
@Default.Integer(5)
Integer getFixedWindowDuration();
开发者ID:mdvorsky,项目名称:DataflowSME,代码行数:4,代码来源:Exercise5.java
示例7: getSessionGap
import com.google.cloud.dataflow.sdk.options.Default; //导入依赖的package包/类
@Description("Numeric value of gap between user sessions, in minutes")
@Default.Integer(5)
Integer getSessionGap();
开发者ID:mdvorsky,项目名称:DataflowSME,代码行数:4,代码来源:Exercise8.java
示例8: getInputFile
import com.google.cloud.dataflow.sdk.options.Default; //导入依赖的package包/类
@Description("Path of the file to read from")
@Default.String("gs://retail-dataflow-demo/dataflow/resources/product_master.csv")
String getInputFile();
开发者ID:topgate,项目名称:retail-demo,代码行数:4,代码来源:StorageToDatastore.java
示例9: getSourceProject
import com.google.cloud.dataflow.sdk.options.Default; //导入依赖的package包/类
@Description("ProjectId where data source topic lives")
@Default.String("pubsub-public-data")
@Validation.Required
String getSourceProject();
开发者ID:googlecodelabs,项目名称:cloud-dataflow-nyc-taxi-tycoon,代码行数:5,代码来源:CustomPipelineOptions.java
示例10: getSourceTopic
import com.google.cloud.dataflow.sdk.options.Default; //导入依赖的package包/类
@Description("TopicId of source topic")
@Default.String("taxirides-realtime")
@Validation.Required
String getSourceTopic();
开发者ID:googlecodelabs,项目名称:cloud-dataflow-nyc-taxi-tycoon,代码行数:5,代码来源:CustomPipelineOptions.java
示例11: getSinkTopic
import com.google.cloud.dataflow.sdk.options.Default; //导入依赖的package包/类
@Description("TopicId of sink topic")
@Default.String("visualizer")
@Validation.Required
String getSinkTopic();
开发者ID:googlecodelabs,项目名称:cloud-dataflow-nyc-taxi-tycoon,代码行数:5,代码来源:CustomPipelineOptions.java
示例12: getInputTable
import com.google.cloud.dataflow.sdk.options.Default; //导入依赖的package包/类
@Description("Path of the bigquery table to read from")
@Default.String("cpb101demo1:samples.table")
ValueProvider<String> getInputTable();
开发者ID:sinmetal,项目名称:iron-hippo,代码行数:4,代码来源:BigQueryToDatastore.java
示例13: getOutputProjectID
import com.google.cloud.dataflow.sdk.options.Default; //导入依赖的package包/类
@Description("Output destination Datastore ProjectID")
@Default.String("cpb101demo1")
ValueProvider<String> getOutputProjectID();
开发者ID:sinmetal,项目名称:iron-hippo,代码行数:4,代码来源:BigQueryToDatastore.java
示例14: getOutputKind
import com.google.cloud.dataflow.sdk.options.Default; //导入依赖的package包/类
@Description("Output destination Datastore Kind")
@Default.String("hogeKind")
ValueProvider<String> getOutputKind();
开发者ID:sinmetal,项目名称:iron-hippo,代码行数:4,代码来源:BigQueryToDatastore.java
示例15: getInputFile
import com.google.cloud.dataflow.sdk.options.Default; //导入依赖的package包/类
@Description("Path of the file to read from")
@Default.String("gs://dataflow-samples/shakespeare/kinglear.txt")
String getInputFile();
开发者ID:sinmetal,项目名称:iron-hippo,代码行数:4,代码来源:WordCount.java
示例16: getOutput
import com.google.cloud.dataflow.sdk.options.Default; //导入依赖的package包/类
@Description("Path of the file to write to")
@Default.InstanceFactory(OutputFactory.class)
String getOutput();
开发者ID:sinmetal,项目名称:iron-hippo,代码行数:4,代码来源:WordCount.java
示例17: getFilterPattern
import com.google.cloud.dataflow.sdk.options.Default; //导入依赖的package包/类
@Description("Regex filter pattern to use in DebuggingWordCount. "
+ "Only words matching this pattern will be counted.")
@Default.String("Flourish|stomach")
String getFilterPattern();
开发者ID:sinmetal,项目名称:iron-hippo,代码行数:5,代码来源:DebuggingWordCount.java
示例18: getWindowSize
import com.google.cloud.dataflow.sdk.options.Default; //导入依赖的package包/类
@Description("Fixed window duration, in minutes")
@Default.Integer(WINDOW_SIZE)
Integer getWindowSize();
开发者ID:sinmetal,项目名称:iron-hippo,代码行数:4,代码来源:WindowedWordCount.java
示例19: getKeepJobsRunning
import com.google.cloud.dataflow.sdk.options.Default; //导入依赖的package包/类
@Description("Whether to keep jobs running on the Dataflow service after local process exit")
@Default.Boolean(false)
boolean getKeepJobsRunning();
开发者ID:sinmetal,项目名称:iron-hippo,代码行数:4,代码来源:DataflowExampleOptions.java
示例20: getPubsubTopic
import com.google.cloud.dataflow.sdk.options.Default; //导入依赖的package包/类
@Description("Pub/Sub topic")
@Default.InstanceFactory(PubsubTopicFactory.class)
String getPubsubTopic();
开发者ID:sinmetal,项目名称:iron-hippo,代码行数:4,代码来源:ExamplePubsubTopicOptions.java
注:本文中的com.google.cloud.dataflow.sdk.options.Default类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论