Uses of Interface
org.springframework.data.redis.connection.stream.ObjectRecord

Packages that use ObjectRecord

Package	Description
org.springframework.data.redis.connection.stream	Data structures and interfaces to interact with Redis Streams.
org.springframework.data.redis.core	Core package for integrating Redis with Spring concepts.
org.springframework.data.redis.stream

Uses of ObjectRecord in org.springframework.data.redis.connection.stream

Methods in org.springframework.data.redis.connection.stream that return ObjectRecord

Modifier and Type	Method	Description
static <S, V> ObjectRecord<S,V>	ObjectRecord.create(S stream, V value)	Creates a new ObjectRecord associated with the stream key and value.
static <S, V> ObjectRecord<S,V>	StreamRecords.objectBacked(V value)	Create new ObjectRecord backed by the given value.
static <S, V> ObjectRecord<S,V>	Record.of(V value)	Create a new ObjectRecord instance backed by the given value.
<V> ObjectRecord<S,V>	StreamRecords.RecordBuilder.ofObject(V value)	Create an ObjectRecord.
default <OV> ObjectRecord<ByteBuffer,OV>	ByteBufferRecord.toObjectRecord(HashMapper<? super OV,? super ByteBuffer,? super ByteBuffer> mapper)	Convert a binary MapRecord into an ObjectRecord.
default <OV> ObjectRecord<S,OV>	MapRecord.toObjectRecord(HashMapper<? super OV,? super K,? super V> mapper)	Apply the given HashMapper to the backing value to create a new MapRecord.
ObjectRecord<S,V>	ObjectRecord.withId(RecordId id)
<SK> ObjectRecord<SK,V>	ObjectRecord.withStreamKey(SK key)

Uses of ObjectRecord in org.springframework.data.redis.core

Methods in org.springframework.data.redis.core that return ObjectRecord

Modifier and Type	Method	Description
default <V> ObjectRecord<K,V>	ReactiveStreamOperations.map(MapRecord<K,HK,HV> record, Class<V> targetType)	Map records from MapRecord to ObjectRecord.
default <V> ObjectRecord<K,V>	StreamOperations.map(MapRecord<K,HK,HV> record, Class<V> targetType)	Map record from MapRecord to ObjectRecord.

Methods in org.springframework.data.redis.core that return types with arguments of type ObjectRecord

Modifier and Type	Method	Description
default <V> List<ObjectRecord<K,V>>	StreamOperations.map(List<MapRecord<K,HK,HV>> records, Class<V> targetType)	Map records from MapRecord to ObjectRecords.
default <V> reactor.core.publisher.Flux<ObjectRecord<K,V>>	ReactiveStreamOperations.range(Class<V> targetType, K key, Range<String> range)	Read all records from a stream within a specific Range.
default <V> reactor.core.publisher.Flux<ObjectRecord<K,V>>	ReactiveStreamOperations.range(Class<V> targetType, K key, Range<String> range, Limit limit)	Read records from a stream within a specific Range applying a Limit.
default <V> List<ObjectRecord<K,V>>	StreamOperations.range(Class<V> targetType, K key, Range<String> range)	Read all records from a stream within a specific Range as ObjectRecord.
default <V> List<ObjectRecord<K,V>>	StreamOperations.range(Class<V> targetType, K key, Range<String> range, Limit limit)	Read records from a stream within a specific Range applying a Limit as ObjectRecord.
default <V> reactor.core.publisher.Flux<ObjectRecord<K,V>>	ReactiveStreamOperations.read(Class<V> targetType, Consumer consumer, StreamOffset<K>... streams)	Read records from one or more StreamOffsets using a consumer group as ObjectRecord.
default <V> reactor.core.publisher.Flux<ObjectRecord<K,V>>	ReactiveStreamOperations.read(Class<V> targetType, Consumer consumer, StreamReadOptions readOptions, StreamOffset<K>... streams)	Read records from one or more StreamOffsets using a consumer group as ObjectRecord.
default <V> reactor.core.publisher.Flux<ObjectRecord<K,V>>	ReactiveStreamOperations.read(Class<V> targetType, StreamOffset<K> stream)	Read records from a StreamOffset as ObjectRecord.
default <V> reactor.core.publisher.Flux<ObjectRecord<K,V>>	ReactiveStreamOperations.read(Class<V> targetType, StreamOffset<K>... streams)	Read records from one or more StreamOffsets as ObjectRecord.
default <V> reactor.core.publisher.Flux<ObjectRecord<K,V>>	ReactiveStreamOperations.read(Class<V> targetType, StreamReadOptions readOptions, StreamOffset<K>... streams)	Read records from one or more StreamOffsets as ObjectRecord.
default <V> List<ObjectRecord<K,V>>	StreamOperations.read(Class<V> targetType, Consumer consumer, StreamOffset<K>... streams)	Read records from one or more StreamOffsets using a consumer group as ObjectRecord.
default <V> List<ObjectRecord<K,V>>	StreamOperations.read(Class<V> targetType, Consumer consumer, StreamReadOptions readOptions, StreamOffset<K>... streams)	Read records from one or more StreamOffsets using a consumer group as ObjectRecord.
default <V> List<ObjectRecord<K,V>>	StreamOperations.read(Class<V> targetType, StreamOffset<K>... streams)	Read records from one or more StreamOffsets as ObjectRecord.
default <V> List<ObjectRecord<K,V>>	StreamOperations.read(Class<V> targetType, StreamReadOptions readOptions, StreamOffset<K>... streams)	Read records from one or more StreamOffsets as ObjectRecord.
default <V> reactor.core.publisher.Flux<ObjectRecord<K,V>>	ReactiveStreamOperations.reverseRange(Class<V> targetType, K key, Range<String> range)	Read records from a stream within a specific Range in reverse order as ObjectRecord.
default <V> reactor.core.publisher.Flux<ObjectRecord<K,V>>	ReactiveStreamOperations.reverseRange(Class<V> targetType, K key, Range<String> range, Limit limit)	Read records from a stream within a specific Range applying a Limit in reverse order as ObjectRecord.
default <V> List<ObjectRecord<K,V>>	StreamOperations.reverseRange(Class<V> targetType, K key, Range<String> range)	Read records from a stream within a specific Range in reverse order as ObjectRecord.
default <V> List<ObjectRecord<K,V>>	StreamOperations.reverseRange(Class<V> targetType, K key, Range<String> range, Limit limit)	Read records from a stream within a specific Range applying a Limit in reverse order as ObjectRecord.

Uses of ObjectRecord in org.springframework.data.redis.stream

Methods in org.springframework.data.redis.stream that return types with arguments of type ObjectRecord

Modifier and Type	Method	Description
static <T> StreamReceiver.StreamReceiverOptionsBuilder<String,ObjectRecord<String,T>>	StreamReceiver.StreamReceiverOptions.builder(HashMapper<T,byte[],byte[]> hashMapper)
<NV> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,ObjectRecord<K,NV>>	StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder.objectMapper(HashMapper<NV,?,?> hashMapper)	Configure a hash mapper.
<NV> StreamReceiver.StreamReceiverOptionsBuilder<K,ObjectRecord<K,NV>>	StreamReceiver.StreamReceiverOptionsBuilder.objectMapper(HashMapper<NV,?,?> hashMapper)	Configure a hash mapper.
<NV> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,ObjectRecord<K,NV>>	StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder.targetType(Class<NV> targetType)	Configure a hash target type.
<NV> StreamReceiver.StreamReceiverOptionsBuilder<K,ObjectRecord<K,NV>>	StreamReceiver.StreamReceiverOptionsBuilder.targetType(Class<NV> targetType)	Configure a hash target type.