• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java Default类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了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;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java ClassRealm类代码示例发布时间:2022-05-22
下一篇:
Java MessageCollector类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap