如何在Java中创建对象集合Spark Dataset？

SparkSession spark = SparkSession.builder()
    .appName("Java Spark Dataset Example")
    .config("spark.some.config.option", "some-value")
    .getOrCreate();

public class MyObject {
    private String field1;
    private int field2;

    public String getField1() {
        return field1;
    }

    public void setField1(String field1) {
        this.field1 = field1;
    }

    public int getField2() {
        return field2;
    }

    public void setField2(int field2) {
        this.field2 = field2;
    }
}

List<MyObject> myObjects = new ArrayList<>();

MyObject obj1 = new MyObject();
obj1.setField1("Value 1");
obj1.setField2(1);
myObjects.add(obj1);

MyObject obj2 = new MyObject();
obj2.setField1("Value 2");
obj2.setField2(2);
myObjects.add(obj2);

Dataset<MyObject> dataset = spark.createDataset(myObjects, Encoders.bean(MyObject.class));

// 过滤出field2大于1的对象
Dataset<MyObject> filteredDataset = dataset.filter(obj -> obj.getField2() > 1);

// 显示Dataset中的内容
filteredDataset.show();