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(@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.
default <T> MapRecord<T,T,T>	deserialize(@Nullable 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 Iterable

forEach, iterator, spliterator

Methods inherited from interface MapRecord

map, mapEntries, serialize, serialize, withStreamKey

Methods inherited from interface 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.