Anyone have info/tips?
On Wednesday, December 4, 2019, 11:08:36 AM EST, joe smith
<[email protected]> 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
