in pipelines/etl_integration_java/src/main/java/com/google/cloud/dataflow/solutions/transform/TaxiEventProcessor.java [280:291]
private JsonNode sanitizeSingleNode(JsonNode node, FieldType type) {
TypeName name = type.getTypeName();
if (name == TypeName.DOUBLE || name == TypeName.FLOAT) {
return JsonNodeFactory.instance.numberNode(Double.valueOf(node.asText()));
} else if (name == TypeName.INT64 || name == TypeName.INT32 || name == TypeName.INT16) {
return JsonNodeFactory.instance.numberNode(Integer.valueOf(node.asText()));
} else if (name == TypeName.BOOLEAN) {
return JsonNodeFactory.instance.booleanNode(Boolean.parseBoolean(node.asText()));
}
return node;
}