public class TestingMemoryArchivist extends MemoryArchivist
Constructor and Description |
---|
TestingMemoryArchivist(int maxEntries) |
Modifier and Type | Method and Description |
---|---|
scala.PartialFunction<Object,scala.runtime.BoxedUnit> |
handleMessage()
Handle incoming messages
|
scala.PartialFunction<Object,scala.runtime.BoxedUnit> |
handleTestingMessage() |
graphs, log, preStart, unhandled
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
receive
decorateMessage
public scala.PartialFunction<Object,scala.runtime.BoxedUnit> handleMessage()
FlinkActor
handleMessage
in interface FlinkActor
handleMessage
in class MemoryArchivist
public scala.PartialFunction<Object,scala.runtime.BoxedUnit> handleTestingMessage()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.