Description:
Currently, the @attributes annotation cannot be used with sinks the same way they can be used with sources.
For instance, this mapping
@map(type='json', enclosing.element="$ @attributes(symbol = "company.symbol", price = "price", volume = "volume"))
would correctly parse the following json, when used on a source:
{
"company" : {
"symbol": "AAPL"
},
"price": 1234,
"volume": 1000
}
but does not work when used one a sink, to produce the same json from for instance the following stream:
define stream TestStream(symbol string, price int, volume int)
Description:
Currently, the
@attributesannotation cannot be used with sinks the same way they can be used with sources.For instance, this mapping
would correctly parse the following json, when used on a source:
but does not work when used one a sink, to produce the same json from for instance the following stream: