クラス StreamOffset<K>

方法の詳細

• create

  public static <K> StreamOffset<K> create(K stream, ReadOffset readOffset)

  key と ReadOffset を指定して StreamOffset を作成します。

  パラメーター:

  stream - ストリームキー。

  readOffset - 使用する ReadOffset。

  戻り値:

  StreamOffset の新しいインスタンス。

• latest

  public static <K> StreamOffset<K> latest(K stream)

  ReadOffset.latest() で始まる key を指定して StreamOffset を作成します。

  型パラメーター:

  K -

  パラメーター:

  stream - ストリームキー。

  戻り値:

  StreamOffset の新しいインスタンス。

• fromStart

  public static <K> StreamOffset<K> fromStart(K stream)

  ReadOffset#from("0-0") で始まる stream を指定して StreamOffset を作成します。

  型パラメーター:

  K -

  パラメーター:

  stream - ストリームキー。

  戻り値:

  StreamOffset の新しいインスタンス。

• from

  public static <K> StreamOffset<K> from(Record<K,?> reference)

  ReadOffset.from(String) を作成するための参照として、指定された record id から StreamOffset を作成します。

  型パラメーター:

  K -

  パラメーター:

  reference - 参照ポイントとして使用されるレコード。

  戻り値:

  StreamOffset の新しいインスタンス。

• getKey

  public K getKey()

• getOffset

  public ReadOffset getOffset()

• toString

  public StringSE toString()

  オーバーライド:

  クラス ObjectSE の toString 

• equals

  public boolean equals(@Nullable ObjectSE o)

  オーバーライド:

  クラス ObjectSE の equalsSE 

• hashCode

  public int hashCode()

  オーバーライド:

  クラス ObjectSE の hashCode