例如,如果我有一个5分钟窗口的数据流流媒体作业从PubSub读取,我理解如果我将一个超过两天的时间戳分配给一个元素,将会有一个带有此元素的窗口,如果我使用的示例将每日表输出到BigQueryIO.java中描述的BigQuery,该作业将使用实际日期在BigQuery表中写入过去两天的元素 .

我想将过去的元素写入BigQuery表中,并使用窗口元素的时间戳而不是当前窗口的时间,是否可能?

现在我按照DataflowJavaSDK / sdk / src / main / java / com / google / cloud / dataflow / sdk / io / BigQueryIO.java中描述的示例:

PCollection quotes = ...

quotes.apply(Window.info(CalendarWindows.days(1)))

.apply(BigQueryIO.Write

.named("Write")

.withSchema(schema)

.to(new SerializableFunction() {

public String apply(BoundedWindow window) {

String dayString = DateTimeFormat.forPattern("yyyy_MM_dd").parseDateTime(

((DaysWindow) window).getStartDate());

return "my-project:output.output_table_" + dayString;

}

}));

java时间戳动态,是否可以根据窗口元素的时间戳动态生成BigQuery表名?相关推荐

  1. 2.27√ 2.25的条件下作两点修改:表AB可能存在值相同的元素,但新生成的表C的元素值各不相同;利用A表空间存放表C

    #include<stdio.h> #include<malloc.h> #include <stdlib.h> #define maxsize 10typedef ...

  2. Java动态初始化数组,元素默认值规则

    1.动态初始化数组: 定义数组的时候,只确定元素的类型和数组的长度,之后再存入具体数据. 2.动态初始化数组的基本原理: 当你赋值后,数组的默认值0,就会变成你赋的值. 3.数组的动态初始化格式: 格 ...

  3. java list遍历添加元素_【转】:java遍历List时动态添加和删除元素

    遍历元素最常见的三种方法: // 1.最普通的一种方式 for(int i = 0;i < size;i++) //2.for each方式 for(BEAN b: BEANLIST) //3. ...

  4. imu与gps之间的时间戳_TCP 窗口缩放、时间戳和 SACK(2) | Linux 中国

    导读:有很多文章出于各种"性能调优"或"安全性"原因,建议禁用 TCP 扩展,本文提供了这些扩展功能的背景,为什么会默认启用,它们之间是如何关联的,以及为什么通 ...

  5. 【Java高级程序设计学习笔记】深入理解jdk动态代理

    java的设计模式中有一项设计模式叫做代理模式,所谓代理模式,就是通过代理方来操作目标对象,而不是自己直接调用.代理又分为静态代理和动态代理,静态代理就是针对每个被代理对象写一个代理类,操作不够优雅: ...

  6. java 动态二维数组_Java数组、动态数组、二维数组的应用

    一.认识数组 1.容器的概念 ​用于存储数据的一块内存称为容器,生活中有很多容器,例如水杯,衣柜,以及存放"东西" ​存放在容器中的数据,称为"元素" 2.为什 ...

  7. mybatis动态sql,常用元素介绍

    mybatis动态sql,常用元素介绍 if元素 choose.when.otherwise foreach元素 bing元素 if元素 <select id="findRole1&q ...

  8. Java List 更换指定位置的元素

    Java List 更换指定位置的元素 使用的方法是list.set() 方法 下面写一个list 说下具体的使用 List<String> list = new ArrayList< ...

  9. php控件不显示,解决控件遮挡问题:关于有窗口元素和无窗口元素

    解决控件遮挡问题:关于有窗口元素和无窗口元素 更新时间:2007年01月28日 00:00:00   作者: 不知道朋友们有没有碰到过控件的遮挡问题,最典型的就是DropdownList和Active ...

最新文章

  1. 有了链路日志增强,排查Bug小意思啦!
  2. 6.1 无监督学习-机器学习笔记-斯坦福吴恩达教授
  3. 单模光电转换器怎么接_行业观察 | 硅基光电子与微电子单片集成研究进展
  4. Graphviz之DT:手把手教你使用可视化工具Graphviz将dot文件转为结构图的png文件
  5. python socket发送数组_利用pyprocessing初步探索数组排序算法可视化
  6. java filter注入_如何使用Filter过滤请求中的SQL注入攻击
  7. IIS6文件权限不对触发了Windows身份认证问题解决方法
  8. linux卸载openjdk_Linux系列(七)——linux其他指令【rpm、yum、sudo】
  9. 利用Nmap对MS-SQLSERVER进行渗透
  10. Skype For Business Server 2015 离线消息
  11. 制作登录注册密码找回网站常用控件
  12. BZOJ 3831 POI2014 Litter Bird
  13. 1053 Path of Equal Weight (30 分)一般树的遍历 DFS+vector容器+sort排序
  14. 《多媒体技术与应用》练习题
  15. 最小平方误差算法(LMSE) python实现
  16. 如何免费申请js.org二级域名
  17. form中action属性
  18. System.Core, Version=2.0.5.0, Culture=neutral, PublicKeyToken=7cec85d7bea7798e, Retargetable=Yes”
  19. 安防行业安全产品分类、趋势分析
  20. python中unicode函数的包_Python unicodeutil包_程序模块 - PyPI - Python中文网

热门文章

  1. mysql select from user_mysql查询[select * from user limit 0, 10;]
  2. python 使用进程池Pool进行并发编程
  3. android另开进程,android在一个app程序中,打开另一个app的方法
  4. loglevel python 不输出_Python 通过 Celery 框架实现分布式任务队列!
  5. arm ffmpeg报错:Invalid data found when processing input(没解决)(在ubuntu上能正常运行)(重新交叉编译后问题解决)
  6. 【哲学】《哲学的故事》笔记
  7. cudnn问题 cudnnCreate 延时长 见效慢 要卡十几分钟才能过 如何解决?(229)
  8. Divan and Kostomuksha (easy version) dp,gcd(2100)
  9. Java进阶:default方法说明
  10. linux环境下安装mysql 8.0