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

Class StreamRecords

java.lang.Object

org.springframework.data.redis.connection.stream.StreamRecords

public class StreamRecords
extends Object

StreamRecords provides utilities to create specific Record instances.

Since:

2.2

Author:

Christoph Strobl

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	StreamRecords.RecordBuilder<S>	Builder for Record.

Method Summary

Modifier and Type	Method	Description
static <S, K, V> MapRecord<S,K,V>	mapBacked(Map<K,V> map)	Create a new MapRecord backed by the field/value pairs of the given Map.
static StreamRecords.RecordBuilder<?>	newRecord()	Obtain new instance of StreamRecords.RecordBuilder to fluently create records.
static <S, V> ObjectRecord<S,V>	objectBacked(V value)	Create new ObjectRecord backed by the given value.
static ByteBufferRecord	rawBuffer(Map<ByteBuffer,ByteBuffer> raw)	Create a new ByteBufferRecord for the given raw field/value pairs.
static ByteRecord	rawBytes(Map<byte[],byte[]> raw)	Create a new ByteRecord for the given raw field/value pairs.
static StringRecord	string(Map<String,String> raw)	Create a new ByteBufferRecord for the given raw field/value pairs.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

rawBytes

public static ByteRecord rawBytes(Map<byte[],byte[]> raw)

Create a new ByteRecord for the given raw field/value pairs.

Parameters:

raw - must not be null.

Returns:

new instance of ByteRecord.

rawBuffer

public static ByteBufferRecord rawBuffer(Map<ByteBuffer,ByteBuffer> raw)

Create a new ByteBufferRecord for the given raw field/value pairs.

Parameters:

raw - must not be null.

Returns:

new instance of ByteBufferRecord.

string

public static StringRecord string(Map<String,String> raw)

Create a new ByteBufferRecord for the given raw field/value pairs.

Parameters:

raw - must not be null.

Returns:

new instance of ByteBufferRecord.

mapBacked

public static <S,
K,
V> MapRecord<S,K,V> mapBacked(Map<K,V> map)

Create a new MapRecord backed by the field/value pairs of the given Map.

Type Parameters:

S - type of the stream key.

K - type of the map key.

V - type of the map value.

Parameters:

map - must not be null.

Returns:

new instance of MapRecord.

objectBacked

public static <S,
V> ObjectRecord<S,V> objectBacked(V value)

Create new ObjectRecord backed by the given value.

Type Parameters:

S - the stream key type

V - the value type.

Parameters:

value - must not be null.

Returns:

new instance of ObjectRecord.

newRecord

public static StreamRecords.RecordBuilder<?> newRecord()

Obtain new instance of StreamRecords.RecordBuilder to fluently create records.

Returns:

new instance of StreamRecords.RecordBuilder.