Package com.here.platform.dal.custom
Interface SplittedUDF
- All Superinterfaces:
UDF
The user of this interface has precise control over selecting indexing attributes with single value for each message that can be
splitted.
- Since:
- 0.1.0
- See Also:
-
Method Summary
Modifier and TypeMethodDescriptiongetSplittedKeys
(Map<MetadataName, String> metadata, byte[] message) The purpose of this method is similar toSimpleUDF.getKeys(Map, byte[])
with following differences.Methods inherited from interface com.here.platform.dal.custom.UDF
aggregate, open, transformForDeadLetter
-
Method Details
-
getSplittedKeys
The purpose of this method is similar toSimpleUDF.getKeys(Map, byte[])
with following differences.For this method,
- The developer should be able to deserialize the message and split it into multiple smaller messages.
- For each smaller message, this indexing attributes should be retrieved.
- The indexing attributes for each message will be the key of returned
Map
with each smaller message being its corresponding value. Each key (indexing attributes) is also represented asMap
. - For each key
Map
, the constraints are same as defined forSimpleUDF.getKeys(Map, byte[])
.
- Parameters:
metadata
- collection (Map
) containing metadata information. Any metadata information can also be used to select one/more indexing attributes for the message. The keys of the metadata map can be found hereMetadataName
.message
- message which should be splitted in smaller messages and for each smaller message, indexing attributes are supposed to be selected.The deserialized message can be used to retrieve any specific characteristic for indexing.
- Returns:
- the collection (
Map
) containing indexing attributes for splitted messages.
-