K
- the field type of the backing map.V
- the value type of the backing map.public interface MapRecord<S,K,V> extends Record<S,Map<K,V>>, Iterable<Map.Entry<K,V>>
Record
within the stream backed by a collection of field/value paris.Modifier and Type | Method and Description |
---|---|
static <S,K,V> MapRecord<S,K,V> |
create(S stream,
Map<K,V> map)
|
default <SK,HK,HV> MapRecord<SK,HK,HV> |
map(Function<MapRecord<S,K,V>,MapRecord<SK,HK,HV>> mapFunction)
|
default <HK,HV> MapRecord<S,HK,HV> |
mapEntries(Function<Map.Entry<K,V>,Map.Entry<HK,HV>> mapFunction)
Apply the given
mapFunction to each and every entry in the backing collection to create a new
MapRecord . |
default ByteRecord |
serialize(RedisSerializer<?> serializer)
|
default ByteRecord |
serialize(RedisSerializer<? super S> streamSerializer,
RedisSerializer<? super K> fieldSerializer,
RedisSerializer<? super V> valueSerializer)
Serialize
key with the streamSerializer, field names with the
fieldSerializer and values with the valueSerializer. |
default <OV> ObjectRecord<S,OV> |
toObjectRecord(HashMapper<? super OV,? super K,? super V> mapper)
Apply the given
HashMapper to the backing value to create a new MapRecord . |
MapRecord<S,K,V> |
withId(RecordId id)
|
<SK> MapRecord<SK,K,V> |
withStreamKey(SK key)
Create a new instance of
Record with the given key to store the record at. |
getId, getStream, getValue, of, of
forEach, iterator, spliterator
static <S,K,V> MapRecord<S,K,V> create(S stream, Map<K,V> map)
stream
- the stream key.map
- the value.ObjectRecord
holding the stream
key and value
.<SK> MapRecord<SK,K,V> withStreamKey(SK key)
Record
Record
with the given key to store the record at.default <HK,HV> MapRecord<S,HK,HV> mapEntries(Function<Map.Entry<K,V>,Map.Entry<HK,HV>> mapFunction)
mapFunction
to each and every entry in the backing collection to create a new
MapRecord
.HK
- the field type of the new backing collection.HV
- the value type of the new backing collection.mapFunction
- must not be null.MapRecord
.default <SK,HK,HV> MapRecord<SK,HK,HV> map(Function<MapRecord<S,K,V>,MapRecord<SK,HK,HV>> mapFunction)
default ByteRecord serialize(@Nullable RedisSerializer<?> serializer)
key
and field/value pairs
with the given
RedisSerializer
. An already assigned id
is carried over to the new instance.serializer
- can be null if the Record
only holds binary data.ByteRecord
holding the serialized values.default ByteRecord serialize(@Nullable RedisSerializer<? super S> streamSerializer, @Nullable RedisSerializer<? super K> fieldSerializer, @Nullable RedisSerializer<? super V> valueSerializer)
key
with the streamSerializer, field names with the
fieldSerializer and values with the valueSerializer. An already assigned id
is carried over to the new instance.streamSerializer
- can be null if the key is binary.fieldSerializer
- can be null if the fields are binary.valueSerializer
- can be null if the values are binary.ByteRecord
holding the serialized values.default <OV> ObjectRecord<S,OV> toObjectRecord(HashMapper<? super OV,? super K,? super V> mapper)
HashMapper
to the backing value to create a new MapRecord
. An already assigned
id
is carried over to the new instance.OV
- type of the value backing the ObjectRecord
.mapper
- must not be null.ObjectRecord
.Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.