|
|
@ -29,9 +29,6 @@ import java.util.List;
|
|
|
|
|
|
|
|
|
|
|
|
public abstract class Reducer<Element, Result> {
|
|
|
|
public abstract class Reducer<Element, Result> {
|
|
|
|
|
|
|
|
|
|
|
|
@Getter
|
|
|
|
|
|
|
|
private boolean hasBreak = false;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Getter
|
|
|
|
@Getter
|
|
|
|
private Result result;
|
|
|
|
private Result result;
|
|
|
|
|
|
|
|
|
|
|
@ -47,18 +44,4 @@ public abstract class Reducer<Element, Result> {
|
|
|
|
|
|
|
|
|
|
|
|
public abstract Result reduce();
|
|
|
|
public abstract Result reduce();
|
|
|
|
|
|
|
|
|
|
|
|
public boolean willBreak() {
|
|
|
|
|
|
|
|
return false;
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public void setResult(Result result) {
|
|
|
|
|
|
|
|
this.result = result;
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public abstract ReduceType reducerType();
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public String reduceName() {
|
|
|
|
|
|
|
|
return this.getClass().getSimpleName();
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|