org.apache.accumulo.core.iterators.Filter.init()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(7.7k)|赞(0)|评价(0)|浏览(148)

本文整理了Java中org.apache.accumulo.core.iterators.Filter.init()方法的一些代码示例，展示了Filter.init()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Filter.init()方法的具体详情如下：
包路径：org.apache.accumulo.core.iterators.Filter
类名称：Filter
方法名：init

Filter.init介绍

暂无

代码示例

代码示例来源：origin: apache/accumulo

@Override
public void init(SortedKeyValueIterator<Key,Value> source, Map<String,String> options,
  IteratorEnvironment env) throws IOException {
 super.init(source, options, env);
 term = options.get("term").getBytes(UTF_8);
 for (int i = 0; i < right.length; i++) {
  right[i] = -1;
 }
 for (int i = 0; i < term.length; i++) {
  right[term[i] & 0xff] = i;
 }
}

代码示例来源：origin: apache/accumulo

@Override
public void init(SortedKeyValueIterator<Key,Value> source, Map<String,String> options,
  IteratorEnvironment env) throws IOException {
 super.init(source, options, env);
 this.ttls = new TTLSet(options);
 currentTime = System.currentTimeMillis();
}

代码示例来源：origin: apache/accumulo

@Override
public void init(SortedKeyValueIterator<Key,Value> source, Map<String,String> options,
  IteratorEnvironment env) throws IOException {
 super.init(source, options, env);
 cso = new CfCqSliceOpts(options);
}

代码示例来源：origin: apache/accumulo

@Override
public void init(SortedKeyValueIterator<Key,Value> source, Map<String,String> options,
  IteratorEnvironment env) throws IOException {
 if (options == null)
  throw new IllegalArgumentException(TTL + " must be set for AgeOffFilter");
 String ttl = options.get(TTL);
 if (ttl == null)
  throw new IllegalArgumentException(TTL + " must be set for AgeOffFilter");
 super.init(source, options, env);
 threshold = Long.parseLong(ttl);
 String time = options.get(CURRENT_TIME);
 if (time != null)
  currentTime = Long.parseLong(time);
 else
  currentTime = System.currentTimeMillis();
 // add sanity checks for threshold and currentTime?
}

代码示例来源：origin: apache/accumulo

@Override
public void init(SortedKeyValueIterator<Key,Value> source, Map<String,String> options,
  IteratorEnvironment env) throws IOException {
 super.init(source, options, env);
 if (options.containsKey(START_BOUND)) {
  startBound = options.get(START_BOUND);
 } else {
  startBound = null;
 }
 if (options.containsKey(START_INCLUSIVE)) {
  startInclusive = Boolean.parseBoolean(options.get(START_INCLUSIVE));
 } else {
  startInclusive = true;
 }
 if (options.containsKey(END_BOUND)) {
  endBound = options.get(END_BOUND);
 } else {
  endBound = null;
 }
 if (options.containsKey(END_INCLUSIVE)) {
  endInclusive = Boolean.parseBoolean(options.get(END_INCLUSIVE));
 } else {
  endInclusive = false;
 }
}

代码示例来源：origin: apache/accumulo

@Override
public void init(SortedKeyValueIterator<Key,Value> source, Map<String,String> options,
  IteratorEnvironment env) throws IOException {
 super.init(source, options, env);
 if (env.getIteratorScope() == IteratorScope.scan) {
  throw new IOException("This iterator not intended for use at scan time");
 }
 bulkTxStatusCache = new HashMap<>();
 arbitrator = getArbitrator(((SystemIteratorEnvironment) env).getServerContext());
}

代码示例来源：origin: apache/accumulo

@Override
public void init(SortedKeyValueIterator<Key,Value> source, Map<String,String> options,
  IteratorEnvironment env) throws IOException {
 super.init(source, options, env);
 if (options.containsKey(ROW_REGEX)) {
  rowMatcher = Pattern.compile(options.get(ROW_REGEX)).matcher("");

代码示例来源：origin: apache/accumulo

"start and/or end must be set for " + TimestampFilter.class.getName());
super.init(source, options, env);

代码示例来源：origin: apache/accumulo

@Override
public void init(SortedKeyValueIterator<Key,Value> source, Map<String,String> options,
  IteratorEnvironment env) throws IOException {
 super.init(source, options, env);
 validateOptions(options);
 this.filterInvalid = Boolean.parseBoolean(options.get(FILTER_INVALID_ONLY));
 if (!filterInvalid) {
  String auths = options.get(AUTHS);
  Authorizations authObj = auths == null || auths.isEmpty() ? new Authorizations()
    : new Authorizations(auths.getBytes(UTF_8));
  this.ve = new VisibilityEvaluator(authObj);
 }
 this.cache = new LRUMap(1000);
}

代码示例来源：origin: NationalSecurityAgency/datawave

@Override
  public void init(SortedKeyValueIterator<Key,Value> source, Map<String,String> options, IteratorEnvironment env) throws IOException {
    super.init(source, options, env);
    
    this.currentTime = System.currentTimeMillis();
  }
}

代码示例来源：origin: org.apache.accumulo/accumulo-core

@Override
public void init(SortedKeyValueIterator<Key,Value> source, Map<String,String> options,
  IteratorEnvironment env) throws IOException {
 super.init(source, options, env);
 term = options.get("term").getBytes(UTF_8);
 for (int i = 0; i < right.length; i++) {
  right[i] = -1;
 }
 for (int i = 0; i < term.length; i++) {
  right[term[i] & 0xff] = i;
 }
}

代码示例来源：origin: apache/fluo

@Override
public void init(SortedKeyValueIterator<Key, Value> source, Map<String, String> options,
  IteratorEnvironment env) throws IOException {
 super.init(source, options, env);
 this.divisor = Integer.parseInt(options.get(DIVISOR_OPT));
 this.remainder = Integer.parseInt(options.get(REMAINDER_OPT));
}

代码示例来源：origin: NationalSecurityAgency/datawave

@Override
public void init(SortedKeyValueIterator<Key,Value> source, Map<String,String> options, IteratorEnvironment env) throws IOException {
  super.init(source, options, env);
  
  readOptions(options);
}

代码示例来源：origin: visallo/vertexium

@Override
public void init(SortedKeyValueIterator<Key, Value> source, Map<String, String> options, IteratorEnvironment env) throws IOException {
  super.init(source, options, env);
  this.vertexIdsSet = SetOfStringsEncoder.decodeFromString(options.get(SETTING_VERTEX_IDS));
}

代码示例来源：origin: org.apache.accumulo/accumulo-core

@Override
public void init(SortedKeyValueIterator<Key,Value> source, Map<String,String> options,
  IteratorEnvironment env) throws IOException {
 super.init(source, options, env);
 cso = new CfCqSliceOpts(options);
}

代码示例来源：origin: org.vertexium/vertexium-accumulo-iterators

@Override
public void init(SortedKeyValueIterator<Key, Value> source, Map<String, String> options, IteratorEnvironment env) throws IOException {
  super.init(source, options, env);
  this.vertexIdsSet = SetOfStringsEncoder.decodeFromString(options.get(SETTING_VERTEX_IDS));
}

代码示例来源：origin: org.apache.accumulo/accumulo-core

@Override
public void init(SortedKeyValueIterator<Key,Value> source, Map<String,String> options,
  IteratorEnvironment env) throws IOException {
 super.init(source, options, env);
 this.ttls = new TTLSet(options);
 currentTime = System.currentTimeMillis();
}

代码示例来源：origin: Accla/graphulo

@Override
public void init(SortedKeyValueIterator<Key, Value> source, Map<String, String> options, IteratorEnvironment env) throws IOException {
 super.init(source, options, env);
 if (options.containsKey(MathTwoScalar.SCALAR_TYPE))
  scalarType = MathTwoScalar.ScalarType.valueOf(options.get(MathTwoScalar.SCALAR_TYPE));
 if (scalarType == MathTwoScalar.ScalarType.LONG_OR_DOUBLE)
  scalarType = MathTwoScalar.ScalarType.DOUBLE;
 handleOptions(options);
 log.debug("minValue="+minValue+" maxValue="+maxValue+" useColQ="+useColQ+" prefixColQ="+
   (new String(prefixColQ, StandardCharsets.UTF_8)));
}

代码示例来源：origin: org.apache.accumulo/accumulo-server-base

@Override
public void init(SortedKeyValueIterator<Key,Value> source, Map<String,String> options,
  IteratorEnvironment env) throws IOException {
 super.init(source, options, env);
 if (env.getIteratorScope() == IteratorScope.scan) {
  throw new IOException("This iterator not intended for use at scan time");
 }
 bulkTxStatusCache = new HashMap<>();
 arbitrator = getArbitrator();
}

代码示例来源：origin: org.apache.accumulo/accumulo-server

@Override
public void init(SortedKeyValueIterator<Key,Value> source, Map<String,String> options, IteratorEnvironment env) throws IOException {
 super.init(source, options, env);
 if (env.getIteratorScope() == IteratorScope.scan) {
  throw new IOException("This iterator not intended for use at scan time");
 }
 bulkTxStatusCache = new HashMap<Long,MetadataBulkLoadFilter.Status>();
 arbitrator = getArbitrator();
}

内容来源于网络，如有侵权，请联系作者删除！

Filter

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com