private CompletableFuture < KvStateResponse > getKvState ( final JobID jobId , final String queryableStateName , final int keyHashCode , final byte [ ] serializedKeyAndNamespace ) { LOG . debug ( "Sending State Request to {}." , remoteAddress ) ; try { KvStateRequest request = new KvStateRequest ( jobId , queryableStateName , keyHashCode , serializedKeyAndNamespace ) ; return client . sendRequest ( remoteAddress , request ) ; } catch ( Exception e ) { LOG . error ( "Unable to send KVStateRequest: " , e ) ; return FutureUtils . getFailedFuture ( e ) ; } }
Returns a future holding the serialized request result .