public static class RangeStreamer.FailureDetectorSourceFilter extends java.lang.Object implements RangeStreamer.SourceFilter
Constructor and Description |
---|
FailureDetectorSourceFilter(IFailureDetector fd) |
Modifier and Type | Method and Description |
---|---|
boolean |
apply(Replica replica) |
java.lang.String |
message(Replica replica) |
public FailureDetectorSourceFilter(IFailureDetector fd)
public boolean apply(Replica replica)
apply
in interface RangeStreamer.SourceFilter
public java.lang.String message(Replica replica)
message
in interface RangeStreamer.SourceFilter
Copyright © 2009-2020 The Apache Software Foundation