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(@NonNull MapRecord<K,HK,HV> record, @NonNull Class<V> targetType)	Map records from MapRecord to ObjectRecord.
default <V> ObjectRecord<K,V>	StreamOperations.map(@NonNull MapRecord<K,HK,HV> record, @NonNull 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<@NonNull ObjectRecord<K,V>>	StreamOperations.map(@NonNull List<@NonNull MapRecord<K,HK,HV>> records, @NonNull Class<V> targetType)	Map records from MapRecord to ObjectRecords.
default <V> Flux<ObjectRecord<K,V>>	ReactiveStreamOperations.range(@NonNull Class<V> targetType, @NonNull K key, @NonNull Range<String> range)	Read all records from a stream within a specific Range.
default <V> Flux<ObjectRecord<K,V>>	ReactiveStreamOperations.range(@NonNull Class<V> targetType, @NonNull K key, @NonNull Range<String> range, @NonNull Limit limit)	Read records from a stream within a specific Range applying a Limit.
default <V> List<@NonNull ObjectRecord<K,V>>	StreamOperations.range(@NonNull Class<V> targetType, @NonNull K key, @NonNull Range<String> range)	Read all records from a stream within a specific Range as ObjectRecord.
default <V> List<@NonNull ObjectRecord<K,V>>	StreamOperations.range(@NonNull Class<V> targetType, @NonNull K key, @NonNull Range<String> range, @NonNull Limit limit)	Read records from a stream within a specific Range applying a Limit as ObjectRecord.
default <V> Flux<ObjectRecord<K,V>>	ReactiveStreamOperations.read(@NonNull Class<V> targetType, @NonNull Consumer consumer, @NonNull StreamOffset<K> @NonNull ... streams)	Read records from one or more StreamOffsets using a consumer group as ObjectRecord.
default <V> Flux<ObjectRecord<K,V>>	ReactiveStreamOperations.read(@NonNull Class<V> targetType, @NonNull Consumer consumer, @NonNull StreamReadOptions readOptions, @NonNull StreamOffset<K> @NonNull ... streams)	Read records from one or more StreamOffsets using a consumer group as ObjectRecord.
default <V> Flux<ObjectRecord<K,V>>	ReactiveStreamOperations.read(@NonNull Class<V> targetType, @NonNull StreamOffset<K> stream)	Read records from a StreamOffset as ObjectRecord.
default <V> Flux<ObjectRecord<K,V>>	ReactiveStreamOperations.read(@NonNull Class<V> targetType, @NonNull StreamOffset<K>... streams)	Read records from one or more StreamOffsets as ObjectRecord.
default <V> Flux<ObjectRecord<K,V>>	ReactiveStreamOperations.read(@NonNull Class<V> targetType, @NonNull StreamReadOptions readOptions, @NonNull StreamOffset<K> @NonNull ... streams)	Read records from one or more StreamOffsets as ObjectRecord.
default <V> List<ObjectRecord<K,V>>	StreamOperations.read(@NonNull Class<V> targetType, @NonNull Consumer consumer, @NonNull StreamReadOptions readOptions, StreamOffset<@NonNull K> @NonNull ... streams)	Read records from one or more StreamOffsets using a consumer group as ObjectRecord.
default <V> List<ObjectRecord<K,V>>	StreamOperations.read(@NonNull Class<V> targetType, @NonNull Consumer consumer, StreamOffset<@NonNull K> @NonNull ... streams)	Read records from one or more StreamOffsets using a consumer group as ObjectRecord.
default <V> List<@NonNull ObjectRecord<K,V>>	StreamOperations.read(@NonNull Class<V> targetType, @NonNull StreamReadOptions readOptions, StreamOffset<@NonNull K> @NonNull ... streams)	Read records from one or more StreamOffsets as ObjectRecord.
default <V> List<@NonNull ObjectRecord<K,V>>	StreamOperations.read(@NonNull Class<V> targetType, StreamOffset<@NonNull K> @NonNull ... streams)	Read records from one or more StreamOffsets as ObjectRecord.
default <V> Flux<ObjectRecord<K,V>>	ReactiveStreamOperations.reverseRange(@NonNull Class<V> targetType, @NonNull K key, @NonNull Range<String> range)	Read records from a stream within a specific Range in reverse order as ObjectRecord.
default <V> Flux<ObjectRecord<K,V>>	ReactiveStreamOperations.reverseRange(@NonNull Class<V> targetType, @NonNull K key, @NonNull Range<String> range, @NonNull Limit limit)	Read records from a stream within a specific Range applying a Limit in reverse order as ObjectRecord.
default <V> List<@NonNull ObjectRecord<K,V>>	StreamOperations.reverseRange(@NonNull Class<V> targetType, @NonNull K key, @NonNull Range<String> range)	Read records from a stream within a specific Range in reverse order as ObjectRecord.
default <V> List<@NonNull ObjectRecord<K,V>>	StreamOperations.reverseRange(@NonNull Class<V> targetType, @NonNull K key, @NonNull Range<String> range, @NonNull 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.