ManagedTimeStateImpl extends AbstractManagedStateImpl implements TimeSlicedBucketedState { @Min(1) @Override public long getNumBuckets() { return numBuckets; } ManagedTimeStateImpl(); @Override void put(long bucketId, long time, @NotNull Slice key, @NotNull Slice value); @Override Slice getSync(long bucketId, @NotNull Slice key); @Override Slice getSync(long bucketId, long time, @NotNull Slice key); @Override Future<Slice> getAsync(long bucketId, Slice key); @Override Future<Slice> getAsync(long bucketId, long time, Slice key); @Min(1) @Override long getNumBuckets(); @Override void setup(Context.OperatorContext context); void setNumBuckets(int numBuckets);  }
@Test public void testSerde() throws IOException { ManagedTimeStateImpl deserialized = KryoCloneUtils.cloneObject(testMeta.managedState); Assert.assertEquals("num buckets", deserialized.getNumBuckets(), testMeta.managedState.getNumBuckets()); }