クラス StreamReceiver.StreamReceiverOptions<K, V は Record <K, ?>> を継承します。

メソッドの詳細

• builder

  public static StreamReceiver.StreamReceiverOptionsBuilder<StringSE,MapRecord<StringSE,StringSE,StringSE>> builder()

  戻り値:

  StreamReceiver.StreamReceiverOptions の新しいビルダー。

• builder

  public static <T> StreamReceiver.StreamReceiverOptionsBuilder<StringSE,ObjectRecord<StringSE,T>> builder(HashMapper<T,byte[],byte[]> hashMapper)

  戻り値:

  StreamReceiver.StreamReceiverOptions の新しいビルダー。

• getPollTimeout

  public DurationSE getPollTimeout()

  読み取り中に BLOCK オプションを使用してポーリングをブロックするためのタイムアウト。

  戻り値:

  実際のタイムアウト。

• getBatchSize

  public OptionalIntSE getBatchSize()

  読み取り中に COUNT オプションを使用したバッチサイズのポーリング。

  戻り値:

  バッチサイズ。

• getResumeFunction

  public FunctionSE<? super ThrowableSE,? extends org.reactivestreams.Publisher<VoidSE>> getResumeFunction()

• getKeySerializer

  public RedisSerializationContext.SerializationPair<K> getKeySerializer()

• getHashKeySerializer

  public RedisSerializationContext.SerializationPair<ObjectSE> getHashKeySerializer()

• getHashValueSerializer

  public RedisSerializationContext.SerializationPair<ObjectSE> getHashValueSerializer()

• getHashMapper

  @Nullable public HashMapper<ObjectSE,ObjectSE,ObjectSE> getHashMapper()

• getRequiredHashMapper

  public HashMapper<ObjectSE,ObjectSE,ObjectSE> getRequiredHashMapper()

• hasHashMapper

  public boolean hasHashMapper()

• getTargetType

  public ClassSE<ObjectSE> getTargetType()