Hazelcast Jet -如何在Jet管道中使用非静态方法

public class MyProcessor implements Processor {
    private SomeClass someObject;

    public MyProcessor(SomeClass someObject) {
        this.someObject = someObject;
    }

    @Override
    public void init(Context context) {
        // 初始化方法，可以在这里进行一些准备工作
    }

    @Override
    public boolean tryProcess(int ordinal, Object item) {
        // 在这里使用非静态方法处理数据
        someObject.someMethod(item);
        return true;
    }

    @Override
    public boolean complete() {
        // 在这里进行一些清理工作
        return true;
    }
}

Pipeline pipeline = Pipeline.create();
SomeClass someObject = new SomeClass();
pipeline.drawFrom(Sources.<Object>list("inputList"))
        .customProcessor("myProcessor", () -> new MyProcessor(someObject))
        .drawTo(Sinks.logger());

JetInstance jet = Jet.newJetInstance();
jet.newJob(pipeline).join();