使用 Dataflow 将 DATE 类型加载到 Google BigQuery

Question

上下文

我对 Google Cloud Platform 还很陌生，我正在尝试 Google Dataflow。我读取了一个 CSV 文件并模拟了流数据。 CSV 行发布到主题 (PubSub) 中，Dataflow 读取它并将数据插入到 BigQuery 表中。

问题

当我的文件包含 STRING、FLOAT、INTEGER 类型时，我的流程已成功完成并且数据已加载到 BigQuery。但是，如果我将以下类型之一添加到我的流程中：DATETIME、TIME、DATE，它总是会失败。有很多代码示例，但我没有找到说明如何处理它的代码示例。

数据示例

2017-01-23 - 将其加载到 DATE 类型中

14:10:12 - 将其加载到 TIME 类型中

我希望你们能帮我解决这个问题......

Answer 1

我尝试了几件事：

//1
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
  String dateInString = info.getEventDate();
  Date date = sdf.parse(dateInString);

row.set("EventDate", date);


//2
row.set("EventDate", new DateTime("2017-01-23")); 


//3
public String getEventDate() {
return get(Field.EventDate);  }
...
...
...
row.set("EventDate", info.getEventDate());


//4
private static DateTimeFormatter dmt = DateTimeFormat.forPattern("yyyy-MM-dd");
....
....
....
DateTime ds = dmt.parseDateTime(info.getEventDate());