class JsonToRow {

  public static PTransform<PCollection<String>, PCollection<Row>> withSchema(Schema rowSchema) {
    RowJson.verifySchemaSupported(rowSchema);
    return new JsonToRowFn(rowSchema, NullBehavior.ACCEPT_MISSING_OR_NULL);
  }

}