Package org.springframework.data.redis.connection.stream

Interface ByteBufferRecord

All Superinterfaces:

Iterable<Map.Entry<ByteBuffer,ByteBuffer>>, MapRecord<ByteBuffer,ByteBuffer,ByteBuffer>, Record<ByteBuffer,Map<ByteBuffer,ByteBuffer>>

public interface ByteBufferRecord
extends MapRecord<ByteBuffer,ByteBuffer,ByteBuffer>

A Record within the stream backed by a collection of binary field/value pairs.

Author:

Christoph Strobl

Method Summary

Modifier and Type	Method	Description
default <K, HK, HV> MapRecord<K,HK,HV>	deserialize(RedisSerializer<? extends K> streamSerializer, RedisSerializer<? extends HK> fieldSerializer, RedisSerializer<? extends HV> valueSerializer)	Deserialize key with the streamSerializer, field names with the fieldSerializer and values with the valueSerializer.
default <T> MapRecord<T,T,T>	deserialize(RedisSerializer<T> serializer)	Deserialize key and field/value pairs with the given RedisSerializer.
static ByteBufferRecord	of(MapRecord<ByteBuffer,ByteBuffer,ByteBuffer> source)	Convert a binary MapRecord into a ByteRecord.
default <OV> ObjectRecord<ByteBuffer,OV>	toObjectRecord(HashMapper<? super OV,? super ByteBuffer,? super ByteBuffer> mapper)	Convert a binary MapRecord into an ObjectRecord.
ByteBufferRecord	withId(RecordId id)	Create a new instance of Record with the given RecordId.
ByteBufferRecord	withStreamKey(ByteBuffer key)	Create a new ByteBufferRecord with the associated stream key.

Methods inherited from interface java.lang.Iterable

forEach, iterator, spliterator

Methods inherited from interface org.springframework.data.redis.connection.stream.MapRecord

map, mapEntries, serialize, serialize, withStreamKey

Methods inherited from interface org.springframework.data.redis.connection.stream.Record

getId, getRequiredStream, getStream, getValue

Method Details

withId

ByteBufferRecord withId(RecordId id)

Description copied from interface: Record

Create a new instance of Record with the given RecordId.

Specified by:

withId in interface MapRecord<ByteBuffer,ByteBuffer,ByteBuffer>

Specified by:

withId in interface Record<ByteBuffer,Map<ByteBuffer,ByteBuffer>>

Parameters:

id - must not be null.

Returns:

new instance of Record.

withStreamKey

ByteBufferRecord withStreamKey(ByteBuffer key)

Create a new ByteBufferRecord with the associated stream key.

Parameters:

key - the binary stream key.

Returns:

a new ByteBufferRecord.

deserialize

default <T> MapRecord<T,T,T> deserialize(@Nullable
 RedisSerializer<T> serializer)

Deserialize key and field/value pairs with the given RedisSerializer. An already assigned id is carried over to the new instance.

Parameters:

serializer - can be null if the Record only holds binary data.

Returns:

new MapRecord holding the deserialized values.

deserialize

default <K,
HK,
HV> MapRecord<K,HK,HV> deserialize(@Nullable
 RedisSerializer<? extends K> streamSerializer,
 @Nullable
 RedisSerializer<? extends HK> fieldSerializer,
 @Nullable
 RedisSerializer<? extends HV> valueSerializer)

Deserialize 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.

Parameters:

streamSerializer - can be null if the key suites already the target format.

fieldSerializer - can be null if the fields suite already the target format.

valueSerializer - can be null if the values suite already the target format.

Returns:

new MapRecord holding the deserialized values.

of

static ByteBufferRecord of(MapRecord<ByteBuffer,ByteBuffer,ByteBuffer> source)

Convert a binary MapRecord into a ByteRecord.

Parameters:

source - must not be null.

Returns:

new instance of ByteRecord.

toObjectRecord

default <OV> ObjectRecord<ByteBuffer,OV> toObjectRecord(HashMapper<? super OV,? super ByteBuffer,? super ByteBuffer> mapper)

Convert a binary MapRecord into an ObjectRecord.

Specified by:

toObjectRecord in interface MapRecord<ByteBuffer,ByteBuffer,ByteBuffer>

Type Parameters:

OV - type of the value backing the ObjectRecord.

Parameters:

mapper - must not be null.

Returns:

new instance of ByteRecord.