fdiazgon created BEAM-9424:
------------------------------
Summary: Grouping By LogicalTypes is not supported
Key: BEAM-9424
URL: https://issues.apache.org/jira/browse/BEAM-9424
Project: Beam
Issue Type: Bug
Components: sdk-java-core
Affects Versions: 2.19.0
Reporter: fdiazgon
Creating a schema from a BQ schema that has either TIME, DATE or DATETIME
columns, and grouping by one of these fields throws NullPointerException.
{code:java}
Pipeline pipeline = Pipeline.create();
Schema beamSchemaWithLogicalTypes =
BigQueryUtils.fromTableSchema(
new TableSchema()
.setFields(
Arrays.asList(
new TableFieldSchema().setName("fTime").setType("TIME"),
new TableFieldSchema().setName("fDate").setType("DATE"),
new
TableFieldSchema().setName("fDatetime").setType("DATETIME"))));
Row row =
Row.withSchema(beamSchemaWithLogicalTypes)
.addValues(
DateTime.parse("2020-02-02"),
DateTime.parse("2020-02-02"),
DateTime.parse("2020-02-02T00:00:00"))
.build();
PCollection<Row> outputRow =
pipeline
.apply(Create.of(row))
.setRowSchema(beamSchemaWithLogicalTypes)
.apply(
SqlTransform.query(
"SELECT fTime, fDate, fDatetime FROM PCOLLECTION GROUP BY
fTime, fDate, fDatetime"));
pipeline.run();
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
