Anyone have info/tips?
On Wednesday, December 4, 2019, 11:08:36 AM EST, joe smith <water4...@yahoo.com> wrote: Hi, Would like to know if there is a way to write a lambda expression in storm flux so it can be used to create/define a component. For example: - id: kafkaSpoutFields className: org.apache.storm.tuple.Fields constructorArgs: - [ key, value ] - id: byTopicRecordTranslator className: org.apache.storm.kafka.spout.ByTopicRecordTranslator constructorArgs: - "lambda r: new Values(r.key(), r.value())" - ref: kafkaSpoutFields But the error returned saying it could not find a suitable constructor: Couldn't find a suitable constructor for class 'org.apache.storm.kafka.spout.ByTopicRecordTranslator' with arguments '[lambda r: new Values(r.key(), r.value()), [key, value]]'. Thanks