Package com.redis.vl.storage

Class HashStorage

java.lang.Object

com.redis.vl.storage.BaseStorage

com.redis.vl.storage.HashStorage

public class HashStorage
extends BaseStorage

Internal subclass of BaseStorage for the Redis hash data type.

Implements hash-specific logic for validation and read/write operations in Redis.

Nested Class Summary

Nested classes/interfaces inherited from class com.redis.vl.storage.BaseStorage

BaseStorage.KeyValuePair

Field Summary

Fields inherited from class com.redis.vl.storage.BaseStorage

defaultBatchSize, indexSchema

Constructor Summary

Constructors

Constructor	Description
HashStorage(IndexSchema indexSchema)	Creates a new HashStorage instance for managing Redis hash data structures.

Method Summary

Modifier and Type	Method	Description
protected Map<String,Object>	convertBytes(Map<String,Object> map)	Convert byte arrays in the map to appropriate types.
List<Map<String,Object>>	get(UnifiedJedis redisClient, Collection<String> keys, Integer batchSize)	Retrieve objects from Redis by keys.
protected Response<Map<String,Object>>	getResponse(Pipeline pipeline, String key)	Get a response for retrieving a value from Redis using a pipeline.
protected void	set(Pipeline pipeline, String key, Map<String,Object> obj)	Set a key-value pair in Redis using a pipeline.

Methods inherited from class com.redis.vl.storage.BaseStorage

createKey, createKeyForObject, get, getIndexSchema, getKeys, preprocessAndValidateObjects, preprocessObject, validate, write, write, write, write, write, write

Methods inherited from class java.lang.Object

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

Constructor Details

HashStorage

public HashStorage(IndexSchema indexSchema)

Creates a new HashStorage instance for managing Redis hash data structures.

Parameters:

indexSchema - The index schema defining the structure of data to be stored

Method Details

set

protected void set(Pipeline pipeline,
 String key,
 Map<String,Object> obj)

Description copied from class: BaseStorage

Set a key-value pair in Redis using a pipeline.

Specified by:

set in class BaseStorage

Parameters:

pipeline - The Redis pipeline to use

key - The Redis key

obj - The object to store

getResponse

protected Response<Map<String,Object>> getResponse(Pipeline pipeline,
 String key)

Description copied from class: BaseStorage

Get a response for retrieving a value from Redis using a pipeline.

Specified by:

getResponse in class BaseStorage

Parameters:

pipeline - The Redis pipeline to use

key - The Redis key

Returns:

Response containing the retrieved object

get

public List<Map<String,Object>> get(UnifiedJedis redisClient,
 Collection<String> keys,
 Integer batchSize)

Description copied from class: BaseStorage

Retrieve objects from Redis by keys.

Overrides:

get in class BaseStorage

Parameters:

redisClient - Synchronous Redis client

keys - Keys to retrieve from Redis

batchSize - Number of objects to retrieve in a single Redis pipeline execution

Returns:

List of objects pulled from redis

convertBytes

protected Map<String,Object> convertBytes(Map<String,Object> map)

Description copied from class: BaseStorage

Convert byte arrays in the map to appropriate types.

Overrides:

convertBytes in class BaseStorage

Parameters:

map - Map with potential byte arrays

Returns:

Map with converted values