public interface DDLWatchChecker
Modifier and Type | Method and Description |
---|---|
com.splicemachine.ddl.DDLMessage.DDLChange |
getChange(java.lang.String changeId) |
java.util.Collection<java.lang.String> |
getCurrentChangeIds() |
boolean |
initialize(CommunicationListener listener) |
void |
killDDLTransaction(java.lang.String key) |
void |
notifyProcessed(java.util.Collection<Pair<com.splicemachine.ddl.DDLMessage.DDLChange,java.lang.String>> processedChanges) |
boolean initialize(CommunicationListener listener) throws java.io.IOException
java.io.IOException
java.util.Collection<java.lang.String> getCurrentChangeIds() throws java.io.IOException
java.io.IOException
com.splicemachine.ddl.DDLMessage.DDLChange getChange(java.lang.String changeId) throws java.io.IOException
java.io.IOException
void notifyProcessed(java.util.Collection<Pair<com.splicemachine.ddl.DDLMessage.DDLChange,java.lang.String>> processedChanges) throws java.io.IOException
java.io.IOException
void killDDLTransaction(java.lang.String key)