simple transformation

ParDoSimpleTransform.java

@ProcessElement
public void processElement(@Element JsonNode> element, OutputReceiver<TableRowWithEvent> out) {
  
  TableRow convertedRow = new TableRow();

  insertLong(element.get("server_time"), "server_time", convertedRow);
  insertFloat(element.get("screen_dpi"), "screen_dpi", convertedRow);
  
  // more transformation to come

  context.output(output);

}  


private void insertLong(JsonNode value, String key, TableRow convertedRow) {
        String valueToInsert = value.asText();
        if (valueToInsert != null && !valueToInsert.isEmpty()) {
            long longValue = Long.parseLong(valueToInsert);
            convertedRow.set(key, longValue);
        }
}
  
private void insertFloat(JsonNode value, String key, TableRow convertedRow) {
        String valueToInsert = getStringValue(value);
        if (valueToInsert != null )  {
            float floatValue = Float.parseFloat(valueToInsert);
            convertedRow.set(key, floatValue);
        }
}