Я пытался работать над пользовательским ограничением в Accumulo. Я создал ограничение, внедрив org.apache.accumulo.core.constraints.Constraint .
Но при применении его к таблице я получаю следующую ошибку
Ошибки ограничения: ConstraintViolationSummary (constrainClass: org.apache.accumulo.tserver.constraints.UnsatisfiableConstraint, violationCode: -1, ViolationDescription: не удалось загрузить ограничения, не принимая мутации., numberOfViolatingMutations: 1)
ниже мой фрагмент кода
package samplepackageforconstraints;
import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
import org.apache.accumulo.core.constraints.Constraint;
import org.apache.accumulo.core.data.ColumnUpdate;
import org.apache.accumulo.core.data.Mutation;
public class LengthConstraintsTest implements Constraint{
private static final short NOT_ENOUGH_LENGTH = 1;
@Override
public List<Short> check(Environment env, Mutation mutation) {
List<Short> violations = null;
Collection<ColumnUpdate> updates = mutation.getUpdates();
for (ColumnUpdate columnUpdate : updates) {
if (!isLessThanThree(columnUpdate.getValue()))
violations = addViolation(violations, NOT_ENOUGH_LENGTH);
}
return violations;
}
@Override
public String getViolationDescription(short violationCode) {
switch (violationCode) {
case NOT_ENOUGH_LENGTH:
return "Value should be more than 3 character";
}
return null;
}
private List<Short> addViolation(List<Short> violations, short violation) {
if (violations == null) {
violations = new ArrayList<Short>();
violations.add(violation);
} else if (!violations.contains(violation)) {
violations.add(violation);
}
return violations;
}
private boolean isLessThanThree(byte[] value) {
if(value.length <3)
return false;
else
return true;
}
}
Я выполнил шаги, указанные в руководстве пользователя accumulo версии 1.7, а также cloudera для загрузки ограничения
Я использую версию: 1.6.0-cdh5.1.4 accumulo
Заранее спасибо :)