Minor refactor to OperatorContext.DecoratedLocalMemoryContext
@@ -613,13 +613,13 @@ public class OperatorContext
}
}
- class DecoratedLocalMemoryContext
+ static class DecoratedLocalMemoryContext
implements LocalMemoryContext
{
private final LocalMemoryContext delegate;
private final AtomicReference<SettableFuture<?>> memoryFuture;
- public DecoratedLocalMemoryContext(LocalMemoryContext delegate, AtomicReference<SettableFuture<?>> memoryFuture)
+ DecoratedLocalMemoryContext(LocalMemoryContext delegate, AtomicReference<SettableFuture<?>> memoryFuture)
{
this.delegate = requireNonNull(delegate, "delegate is null");
this.memoryFuture = requireNonNull(memoryFuture, "memoryFuture is null");
