private JsonNode sanitizeSingleNode()

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;
        }