我正在尝试根据运行时可用的某些配置，使用 Byte Buddy 在其中生成一个类和方法。该类正在尝试创建一个 Hazelcast Jet 管道来加入多个 IMap。
根据提供的配置，要加入的 IMaps 的编号可能会有所不同。在下面的示例中，我正在尝试加入三个 IMap。
private Pipeline getPipeline(IMap<String, Object1> object1Map, IMap<String, Object2> object2Map,
IMap<String, Object3> object3Map) {
Pipeline p = Pipeline.create();
BatchStage<Entry<String, Object1>> obj1 = p.drawFrom(Sources.map(object1Map));
BatchStage<Entry<String, Object2>> obj2 = p.drawFrom(Sources.map(object2Map));
BatchStage<Entry<String, Object3>> obj3 = p.drawFrom(Sources.map(object3Map));
DistributedFunction<Tuple2<Object1, Object2>, String> obj1Obj2JoinFunc = entry -> entry.f1().getField31();
DistributedBiFunction<Tuple2<Object1, Object2>, Object3, Tuple2<Tuple2<Object1, Object2>, Object3>> output = (
in1, in2) -> (Tuple2.tuple2(in1, in2));
BatchStage<Tuple2<Object1, Object2>> obj1_obj2 = obj1.map(entry -> entry.getValue())
.hashJoin(obj2.map(entry -> entry.getValue()),
JoinClause.onKeys(Object1::getField11, Object2::getField21), Tuple2::tuple2).filter(entry -> entry.getValue() != null);
BatchStage<Tuple2<Tuple2<Object1, Object2>, Object3>> obj1_obj2_obj3 = obj1_obj2.hashJoin(
obj3.map(entry -> entry.getValue()),
JoinClause.onKeys(obj1Obj2JoinFunc, Object3::getField31), output)
.filter(entry -> entry.getValue() != null);
// the transformResult method will get the required fields from above operation and create object of AllObjectJoinClass
BatchStage<Entry<String, AllObjectJoinClass>> result = transformResult(obj1_obj2_obj3);
result.drainTo(Sinks.map("obj1_obj2_obj3"));
return p;
}
这里的问题是，我的方法的参数的编号取决于运行时配置，这也决定了方法主体。 我能够使用TypeDescription.Generic.Builder.parameterizedType生成方法签名。 但是，我在生成方法主体时遇到问题。我尝试使用MethodDelegation.to以便该方法驻留在单独的类中。这种方法的问题在于，单独类中的方法需要非常通用，以便它可以采用任意 no。不同类型的参数，还需要了解 IMap 中每个对象的字段。
我想知道是否有另一种方法可以使用某种类型的模板来实现这一点，以便可以为此主体的每个管道生成一个单独的类。我没有找到任何用于生成具有已定义主体的方法的文档(也许我错过了一些东西)。
-- 阿诺普
这在很大程度上取决于您要做什么：
- 使用
Advice，可以将模板编写为内联到方法中的字节码。 - 使用
StackManipulations，您可以编写单独的字节码指令。
在我看来，选项(2)就是您的目标。对于单独编写的代码，这通常是最简单的选择。
编写单个字节代码当然不是最方便的选择，但如果您可以轻松编写每个输入的处理，则可以编写多个Advice类以避免直接使用字节码指令。