如何在Apache梁中进行SQL转换时将int转换为boolean

import org.apache.beam.sdk.Pipeline;
import org.apache.beam.sdk.io.TextIO;
import org.apache.beam.sdk.options.PipelineOptionsFactory;
import org.apache.beam.sdk.transforms.DoFn;
import org.apache.beam.sdk.transforms.ParDo;
import org.apache.beam.sdk.transforms.SimpleFunction;
import org.apache.beam.sdk.values.PCollection;
import org.apache.beam.sdk.values.Row;
import org.apache.beam.sdk.extensions.sql.SqlTransform;

public class IntToBooleanTransformation {
  public static void main(String[] args) {
    PipelineOptions options = PipelineOptionsFactory.fromArgs(args).create();
    Pipeline pipeline = Pipeline.create(options);

    PCollection<Row> input = pipeline.apply(TextIO.read().from("input.csv"))
        .apply(ParDo.of(new ParseCsvFn()));

    PCollection<Row> output = input.apply(SqlTransform.query(
        "SELECT id, CASE WHEN value = 1 THEN true ELSE false END AS is_true FROM PCOLLECTION"));

    output.apply(ParDo.of(new FormatOutputFn()))
        .apply(TextIO.write().to("output.txt").withoutSharding());

    pipeline.run().waitUntilFinish();
  }

  static class ParseCsvFn extends DoFn<String, Row> {
    @ProcessElement
    public void processElement(ProcessContext c) {
      String[] parts = c.element().split(",");
      int id = Integer.parseInt(parts[0]);
      int value = Integer.parseInt(parts[1]);
      Row row = Row.withSchema(/* Define your schema here */)
          .addValue(id)
          .addValue(value)
          .build();
      c.output(row);
    }
  }

  static class FormatOutputFn extends DoFn<Row, String> {
    @ProcessElement
    public void processElement(ProcessContext c) {
      int id = c.element().getInt64("id").intValue();
      boolean isTrue = c.element().getBoolean("is_true");
      String output = String.format("ID: %d, Is True: %b", id, isTrue);
      c.output(output);
    }
  }
}