次の方法で共有


ReliableHashMap<K,V> クラス

  • java.lang.Object
    • microsoft.servicefabric.data.collections.ReliableCollectionsNativeAPIs
      • microsoft.servicefabric.data.collections.ReliableHashMap<K,V>

型パラメーター

K
V

public class ReliableHashMap<K extends String,V> implements ReliableCollection

コンストラクターの概要

コンストラクター 説明
ReliableHashMap(long store, long replicaId, String name, String traceId)

メソッドの概要

修飾子と型 メソッドと説明
CompletableFuture<Void> clearAsync()

レプリケートされたストアと永続化されたストアを ReliableCollection含む、 からすべての状態を削除します。

void close()
CompletableFuture<V> computeAsync(Transaction txn, K key, BiFunction<? super K, ? super V, ? extends V> remappingFunction)

指定したキーとその現在のマップされた値のマッピングの計算を試みます (または、現在のマッピングがない場合は null)。

CompletableFuture<V> computeAsync(Transaction txn, K key, BiFunction<? super K, ? super V, ? extends V> remappingFunction, Duration timeout, CancellationToken cancellationToken)

指定したキーとその現在のマップされた値のマッピングの計算を試みます (または、現在のマッピングがない場合は null)。

CompletableFuture<V> computeIfAbsentAsync(Transaction txn, K key, Function<? super K, ? extends V> mappingFunction)

指定したキーがまだ値に関連付けられていない場合は、指定されたマッピング関数を使用してその値の計算を試み、null でない限り、このマップに入力します。

CompletableFuture<V> computeIfAbsentAsync(Transaction txn, K key, Function<? super K, ? extends V> mappingFunction, Duration timeout, CancellationToken cancellationToken)

指定したキーがまだ値に関連付けられていない場合は、指定されたマッピング関数を使用してその値の計算を試み、null でない限り、このマップに入力します。

CompletableFuture<V> computeIfPresentAsync(Transaction txn, K key, BiFunction<? super K, ? super V, ? extends V> remappingFunction)

指定したキーの値が存在する場合は、キーとその現在のマップされた値を指定して、新しいマッピングの計算を試みます。

CompletableFuture<V> computeIfPresentAsync(Transaction txn, K key, BiFunction<? super K, ? super V, ? extends V> remappingFunction, Duration timeout, CancellationToken cancellationToken)

指定したキーの値が存在する場合は、キーとその現在のマップされた値を指定して、新しいマッピングの計算を試みます。

CompletableFuture<Boolean> containsKeyAsync(Transaction txn, K key)

指定したオブジェクトがこのテーブルのキーであるかどうかをテストします。

CompletableFuture<Boolean> containsKeyAsync(Transaction txn, K key, Duration timeout, CancellationToken cancellationToken)

指定したオブジェクトがこのテーブルのキーであるかどうかをテストします。

CompletableFuture<Boolean> containsKeyAsync(Transaction txn, K key, LockMode lockMode)

指定したオブジェクトがこのテーブルのキーであるかどうかをテストします。

CompletableFuture<Boolean> containsKeyAsync(Transaction txn, K key, LockMode lockMode, Duration timeout, CancellationToken cancellationToken)

指定したオブジェクトがこのテーブルのキーであるかどうかをテストします。

CompletableFuture<AsyncEnumeration<V>> elementsAsync(Transaction txn)

このテーブル内の値の列挙を返します。

CompletableFuture<V> getAsync(Transaction txn, K key)

指定したキーのマッピング先の値を返します。このマップにキーのマッピングが含まれない場合は null を返します。

CompletableFuture<V> getAsync(Transaction txn, K key, Duration timeout, CancellationToken cancellationToken)

指定したキーのマッピング先の値を返します。このマップにキーのマッピングが含まれない場合は null を返します。

long getCount()

に含まれる要素の数を取得します。 ReliableCollection

URI getName()

Reliable HashMap の一意の URI 名を取得します

CompletableFuture<AsyncEnumeration<K>> keysAsync(Transaction txn)

このテーブル内のキーの列挙を返します。

CompletableFuture<AsyncEnumeration<KeyValuePair<K, V>>> keyValuesAsync(Transaction txn)

このテーブル内のキーと値のペアの列挙を返します。

CompletableFuture<Boolean> putAsync(Transaction txn, K key, V value)

指定したキーを、このテーブル内の指定した値にマップします。 キーも値も null にすることはできません。

CompletableFuture<Boolean> putAsync(Transaction txn, K key, V value, Duration timeout, CancellationToken cancellationToken)

指定したキーを、このテーブル内の指定した値にマップします。 キーも値も null にすることはできません。

CompletableFuture<Boolean> putIfAbsentAsync(Transaction txn, K key, V value)

指定したキーがまだ値に関連付けられていない場合は、指定した値に関連付けます。

CompletableFuture<Boolean> putIfAbsentAsync(Transaction txn, K key, V value, Duration timeout, CancellationToken cancellationToken)

指定したキーがまだ値に関連付けられていない場合は、指定した値に関連付けます。

CompletableFuture<Boolean> removeAsync(Transaction txn, K key)

このマップからキー (およびその対応する値) を削除します。 キーがマップ内にない場合、このメソッドは何も実行しません。

CompletableFuture<Boolean> removeAsync(Transaction txn, K key, Duration timeout, CancellationToken cancellationToken)

このマップからキー (およびその対応する値) を削除します。 キーがマップ内にない場合、このメソッドは何も実行しません。

CompletableFuture<Boolean> replaceAsync(Transaction txn, K key, V value)

キーのエントリは、現在何らかの値にマップされている場合にのみ置き換えます。

CompletableFuture<Boolean> replaceAsync(Transaction txn, K key, V value, Duration timeout, CancellationToken cancellationToken)

キーのエントリは、現在何らかの値にマップされている場合にのみ置き換えます。

long size()

マッピングの数を返します。

継承メンバー

microsoft.servicefabric.data.collections.ReliableCollectionsNativeAPIs.freeTStore(long) microsoft.servicefabric.data.collections.ReliableCollectionsNativeAPIs.nativeAddAsync(long,long,String,byte [],int,long,long,int,int,CancellationToken) microsoft.servicefabric.data.collections.ReliableCollectionsNativeAPIs.nativeContainsKeyAsync(long,long,String,int,long,long,int,CancellationToken) microsoft.servicefabric.data.collections.ReliableCollectionsNativeAPIs.nativeEnumeratorAsync(long,long,long,int) microsoft.servicefabric.data.collections.ReliableCollectionsNativeAPIs.nativeGetAsync(long,long,String,long,long,int,CancellationToken) microsoft.servicefabric.data.collections.ReliableCollectionsNativeAPIs.nativeGetCount(long) microsoft.servicefabric.data.collections.ReliableCollectionsNativeAPIs.nativeKeyEnumeratorAsync(long,long,long,int) microsoft.servicefabric.data.collections.ReliableCollectionsNativeAPIs.nativePutAsync(long,long,String,byte [],int,long,long,int,int,CancellationToken) microsoft.servicefabric.data.collections.ReliableCollectionsNativeAPIs.nativePutIfAbsentAsync(long,long,String,byte [],int,long,long,int,int,CancellationToken) microsoft.servicefabric.data.collections.ReliableCollectionsNativeAPIs.nativeRemoveAsync(long,long,String,long,long,int,CancellationToken) microsoft.servicefabric.data.collections.ReliableCollectionsNativeAPIs.nativeUpdateAsync(long,long,String,byte [],int,long,long,int,int,CancellationToken)

コンストラクターの詳細

ReliableHashMap

public ReliableHashMap(long store, long replicaId, String name, String traceId)

パラメーター:

store
replicaId
name
traceId

メソッドの詳細

clearAsync

public CompletableFuture clearAsync()

レプリケートされたストアと永続化されたストアを ReliableCollection含む、 からすべての状態を削除します。

上書き:

ReliableHashMap<K,V>.clearAsync()

戻り値:

非同期クリア操作を表す完了可能な未来。

close

public void close()

computeAsync

public CompletableFuture computeAsync(Transaction txn, K key, BiFunction remappingFunction)

指定したキーとその現在のマップされた値のマッピングの計算を試みます (または、現在のマッピングがない場合は null)。

パラメーター:

txn - この操作に関連付けられているトランザクション ID。
key - 指定した値を関連付けるキー
remappingFunction - 値を計算する関数

戻り値:

CompletableFuture 指定したキーに関連付けられた new(computed) 値を使用する場合は 。計算値が null の場合は null。 将来は、ファブリック関連の障害に対して例外的に FabricException 完了します。

スロー:

IllegalArgumentException - key、remappingFunction、または txn が null の場合。

computeAsync

public CompletableFuture computeAsync(Transaction txn, K key, BiFunction remappingFunction, Duration timeout, CancellationToken cancellationToken)

指定したキーとその現在のマップされた値のマッピングの計算を試みます (または、現在のマッピングがない場合は null)。

パラメーター:

txn - この操作に関連付けられているトランザクション ID。
key - 指定した値を関連付けるキー。
remappingFunction - 値を計算する 関数。
timeout - 操作が完了するまでのタイムアウト。 null が渡された場合、既定のタイムアウト (4 秒) が使用されます。
cancellationToken -

CancellationToken 操作の取り消し状態を示す オブジェクト。

戻り値:

CompletableFuture 指定したキーに関連付けられた new(computed) 値を使用する場合は 。計算値が null の場合は null。 将来は、ファブリック関連の障害に対して例外的に FabricException 完了します。

スロー:

IllegalArgumentException - key、remappingFunction、または txn が null の場合。

computeIfAbsentAsync

public CompletableFuture computeIfAbsentAsync(Transaction txn, K key, Function mappingFunction)

指定したキーがまだ値に関連付けられていない場合は、指定されたマッピング関数を使用してその値の計算を試み、null でない限り、このマップに入力します。

パラメーター:

txn - この操作に関連付けられているトランザクション ID。
key - 指定した値を関連付けるキー
mappingFunction - 値を計算する関数

戻り値:

CompletableFuture 以前のマッピングがない場合は new(computed) 値、計算値が null の場合は null、または指定したキーのマッピングが既に存在する場合は null。 将来は、ファブリック関連の障害に対して例外的に FabricException 完了します。

スロー:

IllegalArgumentException - key、mappingFunction、または txn が null の場合。

computeIfAbsentAsync

public CompletableFuture computeIfAbsentAsync(Transaction txn, K key, Function mappingFunction, Duration timeout, CancellationToken cancellationToken)

指定したキーがまだ値に関連付けられていない場合は、指定されたマッピング関数を使用してその値の計算を試み、null でない限り、このマップに入力します。

パラメーター:

txn - この操作に関連付けられているトランザクション ID。
key - 指定した値を関連付けるキー
mappingFunction - 値を計算する関数
timeout - 操作が完了するまでのタイムアウト。 null が渡された場合、既定のタイムアウト (4 秒) が使用されます。
cancellationToken -

CancellationToken 操作の取り消し状態を示す オブジェクト。

戻り値:

CompletableFuture 以前のマッピングがない場合は new(computed) 値、計算値が null の場合は null、または指定したキーのマッピングが既に存在する場合は null。 将来は、ファブリック関連の障害に対して例外的に FabricException 完了します。

スロー:

IllegalArgumentException - key、mappingFunction、または txn が null の場合。

computeIfPresentAsync

public CompletableFuture computeIfPresentAsync(Transaction txn, K key, BiFunction remappingFunction)

指定したキーの値が存在する場合は、キーとその現在のマップされた値を指定して、新しいマッピングの計算を試みます。

パラメーター:

txn - この操作に関連付けられているトランザクション ID。
key - キーを使用して値を関連付ける可能性があります。
remappingFunction - 値を計算する 関数。

戻り値:

CompletableFuture 前のマッピングがある場合は new(computed) 値、計算値が null の場合は null、指定したキーにマッピングが存在しない場合は null。 将来は、ファブリック関連の障害に対して非常に FabricException 完了します。

スロー:

IllegalArgumentException - key、remappingFunction、txn が null の場合。

computeIfPresentAsync

public CompletableFuture computeIfPresentAsync(Transaction txn, K key, BiFunction remappingFunction, Duration timeout, CancellationToken cancellationToken)

指定したキーの値が存在する場合は、キーとその現在のマップされた値を指定して、新しいマッピングの計算を試みます。

パラメーター:

txn - この操作に関連付けられているトランザクション ID。
key - キーを使用して値を関連付ける可能性があります。
remappingFunction - 値を計算する 関数。
timeout - 操作が完了するまでのタイムアウト。 null が渡された場合、既定のタイムアウト (4 秒) が使用されます。
cancellationToken -

CancellationToken オブジェクトを使用して、操作のキャンセル状態を示します。

戻り値:

CompletableFuture 前のマッピングがある場合は new(computed) 値、計算値が null の場合は null、指定したキーにマッピングが存在しない場合は null。 将来は、ファブリック関連の障害に対して非常に FabricException 完了します。

スロー:

IllegalArgumentException - key、remappingFunction、txn が null の場合。

containsKeyAsync

public CompletableFuture containsKeyAsync(Transaction txn, K key)

指定したオブジェクトがこのテーブルのキーであるかどうかをテストします。

パラメーター:

txn - この操作に関連付けられているトランザクション ID。
key - 使用可能なキー

戻り値:

CompletableFuture この Map でキーが見つかった場合は result true、それ以外の場合は false。 将来は、ファブリック関連の障害に対して非常に FabricException 完了します。

スロー:

IllegalArgumentException - key または txn が null の場合は 。

containsKeyAsync

public CompletableFuture containsKeyAsync(Transaction txn, K key, Duration timeout, CancellationToken cancellationToken)

指定したオブジェクトがこのテーブルのキーであるかどうかをテストします。

パラメーター:

txn - この操作に関連付けられているトランザクション ID。
key - 使用可能なキー
timeout - 操作が完了するまでのタイムアウト。 null が渡された場合、既定のタイムアウト (4 秒) が使用されます。
cancellationToken -

CancellationToken オブジェクトを使用して、操作のキャンセル状態を示します。

戻り値:

CompletableFuture この Map でキーが見つかった場合は result true、それ以外の場合は false。 将来は、ファブリック関連の障害に対して非常に FabricException 完了します。

スロー:

IllegalArgumentException - key または txn が null の場合は 。

containsKeyAsync

public CompletableFuture containsKeyAsync(Transaction txn, K key, LockMode lockMode)

指定したオブジェクトがこのテーブルのキーであるかどうかをテストします。

パラメーター:

txn - この操作に関連付けられているトランザクション ID。
key - 使用可能なキー
lockMode - キーの存在を確認するときに取得するロック モード。

戻り値:

CompletableFuture この Map でキーが見つかった場合は result true、それ以外の場合は false。 将来は、ファブリック関連の障害に対して非常に FabricException 完了します。

スロー:

IllegalArgumentException - key または txn が null の場合は 。

containsKeyAsync

public CompletableFuture containsKeyAsync(Transaction txn, K key, LockMode lockMode, Duration timeout, CancellationToken cancellationToken)

指定したオブジェクトがこのテーブルのキーであるかどうかをテストします。

パラメーター:

txn - この操作に関連付けられているトランザクション ID。
key - 使用可能なキー
lockMode - キーの存在を確認するときに取得するロック モード。
timeout - 操作が完了するまでのタイムアウト。 null が渡された場合、既定のタイムアウト (4 秒) が使用されます。
cancellationToken -

CancellationToken オブジェクトを使用して、操作のキャンセル状態を示します。

戻り値:

CompletableFuture この Map でキーが見つかった場合は result true、それ以外の場合は false。 将来は、ファブリック関連の障害に対して非常に FabricException 完了します。

スロー:

IllegalArgumentException - key または txn が null の場合は 。

elementsAsync

public CompletableFuture> elementsAsync(Transaction txn)

このテーブル内の値の列挙を返します。

パラメーター:

txn - この操作に関連付けられているトランザクション ID。

戻り値:

CompletableFuture この Map 内の値の列挙を使用します。 将来は、ファブリック関連の障害に対して非常に FabricException 完了します。

スロー:

IllegalArgumentException - txn が null の場合は 。

getAsync

public CompletableFuture getAsync(Transaction txn, K key)

指定したキーのマッピング先の値を返します。このマップにキーのマッピングが含まれない場合は null を返します。

パラメーター:

txn - この操作に関連付けられているトランザクション ID。
key - 関連付けられた値が返されるキー

戻り値:

CompletableFuture 指定したキーのマッピング先の値を指定します。そのようなマッピングが存在しない場合は null。 将来は、ファブリック関連の障害に対して、逆シリアル化エラーを伴う IOException 場合と ClassNotFoundExceptionFabricException シリアル化エラーの場合に例外的に完了します。

スロー:

IllegalArgumentException - key または txn が null の場合は 。

getAsync

public CompletableFuture getAsync(Transaction txn, K key, Duration timeout, CancellationToken cancellationToken)

指定したキーのマッピング先の値を返します。このマップにキーのマッピングが含まれない場合は null を返します。

パラメーター:

txn - この操作に関連付けられているトランザクション ID。
key - 関連付けられた値が返されるキー
timeout - 操作が完了するまでのタイムアウト。 null が渡された場合、既定のタイムアウト (4 秒) が使用されます。
cancellationToken -

CancellationToken オブジェクトを使用して、操作のキャンセル状態を示します。

戻り値:

CompletableFuture 指定したキーのマッピング先の値を指定します。そのようなマッピングが存在しない場合は null。 将来は、ファブリック関連の障害に対して、逆シリアル化エラーを伴う IOException 場合と ClassNotFoundExceptionFabricException シリアル化エラーの場合に例外的に完了します。

スロー:

IllegalArgumentException - key または txn が null の場合は 。

getCount

public long getCount()

に含まれる要素の数を取得します。 ReliableCollection

上書き:

ReliableHashMap<K,V>.getCount()

戻り値:

要素の数。

getName

public URI getName()

Reliable HashMap の一意の URI 名を取得します

上書き:

ReliableHashMap<K,V>.getName()

keysAsync

public CompletableFuture> keysAsync(Transaction txn)

このテーブル内のキーの列挙を返します。

パラメーター:

txn - この操作に関連付けられているトランザクション ID。

戻り値:

CompletableFuture この Map 内のキーの列挙を使用します。 将来は、ファブリック関連の障害に対して非常に FabricException 完了します。

スロー:

IllegalArgumentException - txn が null の場合は 。

keyValuesAsync

public CompletableFuture>> keyValuesAsync(Transaction txn)

このテーブル内のキーと値のペアの列挙を返します。

パラメーター:

txn - この操作に関連付けられているトランザクション ID。

戻り値:

CompletableFuture この Map の の KeyValuePair 列挙を使用します。 将来は、ファブリック関連の障害に対して非常に FabricException 完了します。

スロー:

IllegalArgumentException - txn が null の場合は 。

putAsync

public CompletableFuture putAsync(Transaction txn, K key, V value)

指定したキーを、このテーブル内の指定した値にマップします。 キーも値も null にすることはできません。

パラメーター:

txn - この操作に関連付けられているトランザクション ID。
key - 指定した値を関連付けるキー
value - 指定したキーに関連付ける値

戻り値:

CompletableFuture 前のマッピングがある場合は result true、それ以外の場合は false。 将来は、ファブリック関連の障害に対して、FabricExceptionシリアル化エラーの場合は を使用して例外的にIOException完了します。

スロー:

IllegalArgumentException - key、value、または txn が null の場合。

putAsync

public CompletableFuture putAsync(Transaction txn, K key, V value, Duration timeout, CancellationToken cancellationToken)

指定したキーを、このテーブル内の指定した値にマップします。 キーも値も null にすることはできません。

パラメーター:

txn - この操作に関連付けられているトランザクション ID。
key - 指定した値を関連付けるキー
value - 指定したキーに関連付ける値
timeout - 操作が完了するまでのタイムアウト。 null が渡された場合、既定のタイムアウト (4 秒) が使用されます。
cancellationToken -

CancellationToken オブジェクトを使用して、操作のキャンセル状態を示します。

戻り値:

CompletableFuture 前のマッピングがある場合は result true、それ以外の場合は false。 将来は、ファブリック関連の障害に対して、FabricExceptionシリアル化エラーの場合は を使用して例外的にIOException完了します。

スロー:

IllegalArgumentException - key、value、または txn が null の場合。

putIfAbsentAsync

public CompletableFuture putIfAbsentAsync(Transaction txn, K key, V value)

指定したキーがまだ値に関連付けられていない場合は、指定した値に関連付けます。

パラメーター:

txn - この操作に関連付けられているトランザクション ID。
key - 指定した値を関連付けるキー
value - 指定したキーに関連付ける値

戻り値:

CompletableFuture 値が適用されている場合は結果が true、それ以外の場合は false。 将来は、ファブリック関連の障害に対して、FabricExceptionシリアル化エラーの場合は を使用して例外的にIOException完了します。

スロー:

IllegalArgumentException - key、value、または txn が null の場合。

putIfAbsentAsync

public CompletableFuture putIfAbsentAsync(Transaction txn, K key, V value, Duration timeout, CancellationToken cancellationToken)

指定したキーがまだ値に関連付けられていない場合は、指定した値に関連付けます。

パラメーター:

txn - この操作に関連付けられているトランザクション ID。
key - 指定した値を関連付けるキー
value - 指定したキーに関連付ける値
timeout - 操作が完了するまでのタイムアウト。 null が渡された場合、既定のタイムアウト (4 秒) が使用されます。
cancellationToken -

CancellationToken オブジェクトを使用して、操作のキャンセル状態を示します。

戻り値:

CompletableFuture 値が適用されている場合は結果が true、それ以外の場合は false。 将来は、ファブリック関連の障害に対して、FabricExceptionシリアル化エラーの場合は を使用して例外的にIOException完了します。

スロー:

IllegalArgumentException - key、value、または txn が null の場合。

removeAsync

public CompletableFuture removeAsync(Transaction txn, K key)

このマップからキー (およびその対応する値) を削除します。 キーがマップ内にない場合、このメソッドは何も実行しません。

パラメーター:

txn - この操作に関連付けられているトランザクション ID。
key - 削除する必要があるキー。

戻り値:

CompletableFuture キーが見つかり、削除が成功した場合は結果が true、それ以外の場合は false。 将来は、ファブリック関連の障害に対して非常に FabricException 完了します。

スロー:

IllegalArgumentException - key または txn が null の場合は 。

removeAsync

public CompletableFuture removeAsync(Transaction txn, K key, Duration timeout, CancellationToken cancellationToken)

このマップからキー (およびその対応する値) を削除します。 キーがマップ内にない場合、このメソッドは何も実行しません。

パラメーター:

txn - この操作に関連付けられているトランザクション ID。
key - 削除する必要があるキー。
timeout - 操作が完了するまでのタイムアウト。 null が渡された場合、既定のタイムアウト (4 秒) が使用されます。
cancellationToken -

CancellationToken オブジェクトを使用して、操作のキャンセル状態を示します。

戻り値:

CompletableFuture キーが見つかり、削除が成功した場合は結果が true、それ以外の場合は false。 将来は、ファブリック関連の障害に対して非常に FabricException 完了します。

スロー:

IllegalArgumentException - key または txn が null の場合は 。

replaceAsync

public CompletableFuture replaceAsync(Transaction txn, K key, V value)

キーのエントリは、現在何らかの値にマップされている場合にのみ置き換えます。

パラメーター:

txn - この操作に関連付けられているトランザクション ID。
key - 指定した値が関連付けられているキー
value - 指定したキーに関連付ける値

戻り値:

CompletableFuture キーが見つかり、置換が成功した場合は result true、それ以外の場合は false。 将来は、ファブリック関連の障害に対して、FabricExceptionシリアル化エラーの場合は を使用して例外的にIOException完了します。

スロー:

IllegalArgumentException - key、value、または txn が null の場合。

replaceAsync

public CompletableFuture replaceAsync(Transaction txn, K key, V value, Duration timeout, CancellationToken cancellationToken)

キーのエントリは、現在何らかの値にマップされている場合にのみ置き換えます。

パラメーター:

txn - この操作に関連付けられているトランザクション ID。
key - 指定した値が関連付けられているキー
value - 指定したキーに関連付ける値
timeout - 操作が完了するまでのタイムアウト。 null が渡された場合、既定のタイムアウト (4 秒) が使用されます。
cancellationToken -

CancellationToken オブジェクトを使用して、操作のキャンセル状態を示します。

戻り値:

CompletableFuture キーが見つかり、置換が成功した場合は result true、それ以外の場合は false。 将来は、ファブリック関連の障害に対して、FabricExceptionシリアル化エラーの場合は を使用して例外的にIOException完了します。

スロー:

IllegalArgumentException - key、value、または txn が null の場合。

size

public long size()

マッピングの数を返します。

戻り値:

このメソッドは、マップ内のマッピングの数を返します。 これは非同期呼び出しではありません。 これは、マッピングのベスト エフォート数を提供します。

適用対象