Wenlong Lyu created FLINK-4443:
----------------------------------
Summary: Add support in RpcCompletenessTest for inheritance of
RpcGateway and RpcEndpoint
Key: FLINK-4443
URL: https://issues.apache.org/jira/browse/FLINK-4443
Project: Flink
Issue Type: Sub-task
Reporter: Wenlong Lyu
Assignee: Wenlong Lyu
RpcCompletenessTest needs to support RpcGateway which is composited by some
basic functions like the example following:
{code:java}
public interface ExecutionStateListener extends RpcGateway {
public void notifyExecutionStateChanges();
}
public interface JobStateListener extends RpcGateway {
public void notifyJobStateChanges();
}
public interface JobWatcher extends ExecutionStateListener, JobStateListener,
RpcGateway {
}
public class JobWatcherEndpoint extends RpcEndpoint<JobWatcher> {
protected JobWatcherEndpoint(RpcService rpcService) {
super(rpcService);
}
@RpcMethod
public void notifyExecutionStateChanges() {
}
@RpcMethod
public void notifyJobStateChanges() {
}
}
public class AttachedJobClient extends JobWatcherEndpoint {
protected JobClient(RpcService rpcService) {
super(rpcService);
}
}
{code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
