this.customRaftPolicyImplementationClass = customRaftPolicyImplementationClass;
}
+ @Override
+ public String getCustomRaftPolicyImplementationClass() {
+ return customRaftPolicyImplementationClass;
+ }
+
@Override
public long getSnapshotBatchCount() {
return snapshotBatchCount;
try {
String className = DefaultConfigParamsImpl.this.customRaftPolicyImplementationClass;
LOG.info("Trying to use custom RaftPolicy {}", className);
- Class c = Class.forName(className);
+ Class<?> c = Class.forName(className);
RaftPolicy obj = (RaftPolicy)c.newInstance();
return obj;
} catch (Exception e) {