パッケージ org.springframework.data.redis.connection.stream

インターフェース MapRecord<S,K,V>

型パラメーター:
K - バッキングマップのフィールド型。
V - バッキングマップの値型。
すべてのスーパーインターフェース:
IterableSE<Map.EntrySE<K,V>>, Record<S,MapSE<K,V>>
すべての既知のサブインターフェース:
ByteBufferRecord、ByteRecord、StringRecord
public interface MapRecord<S,K,V> extends Record<S,MapSE<K,V>>, IterableSE<Map.EntrySE<K,V>>
フィールド / 値のペアのコレクションに基づくストリーム内の Record。
導入:
2.2
作成者:
Christoph Strobl, Mark Paluch, Romain Beghi

  • メソッドの詳細

    • create

      static <S, K, V> MapRecord<S,K,V> create(S stream, MapSE<K,V> map)
      stream キーと valueSE に関連付けられた新しい MapRecord を作成します。
      パラメーター:
      stream - ストリームキー。
      map - 値。
      戻り値:
      stream キーと value を保持している ObjectRecord。

    • withId

      MapRecord<S,K,V> withId(RecordId id)
      インターフェースからコピーされた説明: Record
      指定された RecordId を使用して Record の新しいインスタンスを作成します。
      次で指定:
      インターフェース Record<S,K> の withId 
      パラメーター:
      id - null であってはなりません。
      戻り値:
      Record の新しいインスタンス。

    • withStreamKey

      <SK> MapRecord<SK,K,V> withStreamKey(SK key)
      インターフェースからコピーされた説明: Record
      レコードを保存するために、指定されたキーを使用して Record の新しいインスタンスを作成します。
      次で指定:
      インターフェース Record<S,K> の withStreamKey 
      パラメーター:
      key - ストリームを識別する Redis キー。
      戻り値:
      Record の新しいインスタンス。

    • mapEntries

      default <HK, HV> MapRecord<S,HK,HV> mapEntries(FunctionSE<Map.EntrySE<K,V>,Map.EntrySE<HK,HV>> mapFunction)
      指定された mapFunctionSE をバッキングコレクションのすべてのエントリに適用して、新しい MapRecord を作成します。
      型パラメーター:
      HK - 新しいバッキングコレクションのフィールド型。
      HV - 新しいバッキングコレクションの値型。
      パラメーター:
      mapFunction - null であってはなりません。
      戻り値:
      MapRecord の新しいインスタンス。

    • map

      default <SK, HK, HV> MapRecord<SK,HK,HV> map(FunctionSE<MapRecord<S,K,V>,MapRecord<SK,HK,HV>> mapFunction)
      マッピング FunctionSE を適用して、この MapRecord をマッピングします。
      パラメーター:
      mapFunction - この MapRecord 要素に適用する関数。
      戻り値:
      マップされた MapRecord

    • serialize

      default ByteRecord serialize(@Nullable RedisSerializer<?> serializer)
      指定された RedisSerializer を使用して key および field/value pairs を直列化します。すでに割り当てられている id は、新しいインスタンスに引き継がれます。
      パラメーター:
      serializer - Record がバイナリデータのみを保持している場合は、null になる可能性があります。
      戻り値:
      直列化された値を保持する新しい ByteRecord。

    • serialize

      default ByteRecord serialize(@Nullable RedisSerializer<? super S> streamSerializer, @Nullable RedisSerializer<? super K> fieldSerializer, @Nullable RedisSerializer<? super V> valueSerializer)
      streamSerializer を使用して key を直列化し、fieldSerializer を使用してフィールド名を直列化し、valueSerializer を使用して値を直列化します。すでに割り当てられている id は、新しいインスタンスに引き継がれます。
      パラメーター:
      streamSerializer - キーがバイナリの場合は null になる可能性があります。
      fieldSerializer - フィールドがバイナリの場合は null になる可能性があります。
      valueSerializer - 値がバイナリの場合は null になる可能性があります。
      戻り値:
      直列化された値を保持する新しい ByteRecord。

    • toObjectRecord

      default <OV> ObjectRecord<S,OV> toObjectRecord(HashMapper<? super OV,? super K,? super V> mapper)
      指定された HashMapper をバッキング値に適用して、新しい MapRecord を作成します。すでに割り当てられている id は、新しいインスタンスに引き継がれます。
      型パラメーター:
      OV - ObjectRecord を裏付ける値の型。
      パラメーター:
      mapper - null であってはなりません。
      戻り値:
      ObjectRecord の新しいインスタンス。