ManagedStateImpl extends AbstractManagedStateImpl implements BucketedState { @Override public Future<Slice> getAsync(long bucketId, @NotNull Slice key) { return getValueFromBucketAsync(bucketId, -1, key); } ManagedStateImpl(); @Override void setup(Context.OperatorContext context); @Override void put(long bucketId, @NotNull Slice key, @NotNull Slice value); @Override Slice getSync(long bucketId, @NotNull Slice key); @Override Future<Slice> getAsync(long bucketId, @NotNull Slice key); @Override void endWindow(); @Min(1) @Override long getNumBuckets(); void setNumBuckets(int numBuckets);  }
@Test public void testAsyncGetFromCommitted() throws ExecutionException, InterruptedException { Slice one = ManagedStateTestUtils.getSliceFor("1"); Slice two = ManagedStateTestUtils.getSliceFor("2"); commitHelper(one, two); Future<Slice> valFuture = testMeta.managedState.getAsync(0, one); Assert.assertEquals("value of one", one, valFuture.get()); }