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

x33g5p2x  于2022-02-03 转载在 其他  
字(8.0k)|赞(0)|评价(0)|浏览(119)

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

WrappingIterator.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);
 negate = Boolean.parseBoolean(options.get(NEGATE));
}

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

@Override
public void init(SortedKeyValueIterator<Key,Value> source, Map<String,String> options,
  IteratorEnvironment env) throws IOException {
 log.debug("init({}, {}, {})", source, options, env);
 if (prefix == null) {
  prefix = String.format("0x%08X", this.hashCode());
 }
 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);
 this.numVersions = 0;
 String maxVerString = options.get("maxVersions");
 if (maxVerString != null)
  this.maxVersions = Integer.parseInt(maxVerString);
 else
  this.maxVersions = 1;
 if (maxVersions < 1)
  throw new IllegalArgumentException("maxVersions for versioning iterator must be >= 1");
}

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

@Override
public void init(SortedKeyValueIterator<Key,Value> source, Map<String,String> options,
  IteratorEnvironment env) throws IOException {
 super.init(source, options, env);
 negate = false;
 if (options.get(NEGATE) != null) {
  negate = Boolean.parseBoolean(options.get(NEGATE));
 }
}

代码示例来源：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.decisionIterator = new RowIterator(source.deepCopy(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);
 combineAllColumns = false;
 if (options.containsKey(ALL_OPTION)) {
  combineAllColumns = Boolean.parseBoolean(options.get(ALL_OPTION));
  if (combineAllColumns)
   return;
 }
 if (!options.containsKey(COLUMNS_OPTION))
  throw new IllegalArgumentException("Must specify " + COLUMNS_OPTION + " option");
 String encodedColumns = options.get(COLUMNS_OPTION);
 if (encodedColumns.length() == 0)
  throw new IllegalArgumentException("The " + COLUMNS_OPTION + " must not be empty");
 combiners = new ColumnSet(Lists.newArrayList(Splitter.on(",").split(encodedColumns)));
 isMajorCompaction = env.getIteratorScope() == IteratorScope.majc;
 String rofco = options.get(REDUCE_ON_FULL_COMPACTION_ONLY_OPTION);
 if (rofco != null) {
  reduceOnFullCompactionOnly = Boolean.parseBoolean(rofco);
 } else {
  reduceOnFullCompactionOnly = false;
 }
 if (reduceOnFullCompactionOnly && isMajorCompaction && !env.isFullMajorCompaction()) {
  // adjust configuration so that no columns are combined for a partial major compaction
  combineAllColumns = false;
  combiners = new ColumnSet();
 }
}

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

@Override
public void init(SortedKeyValueIterator<Key,Value> source, Map<String,String> options,
  IteratorEnvironment env) throws IOException {
 super.init(source, options, env);
 scanning = IteratorScope.scan.equals(env.getIteratorScope());
 if (scanning) {
  String auths = options.get(AUTH_OPT);
  if (auths != null && !auths.isEmpty()) {
   ve = new VisibilityEvaluator(new Authorizations(auths.getBytes(UTF_8)));
   visibleCache = new LRUMap(100);
  }
 }
 if (options.containsKey(MAX_BUFFER_SIZE_OPT)) {
  maxBufferSize = ConfigurationTypeHelper
    .getFixedMemoryAsBytes(options.get(MAX_BUFFER_SIZE_OPT));
 } else {
  maxBufferSize = DEFAULT_MAX_BUFFER_SIZE;
 }
 parsedVisibilitiesCache = new LRUMap(100);
}

代码示例来源：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.initEnv = env;
}

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

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

代码示例来源：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);
 negate = Boolean.parseBoolean(options.get(NEGATE));
}

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

@Override
public void init(SortedKeyValueIterator<Key,Value> source, Map<String,String> options,
  IteratorEnvironment env) throws IOException {
 log.debug("init(" + source + ", " + options + ", " + env + ")");
 if (null == prefix) {
  prefix = String.format("0x%08X", this.hashCode());
 }
 super.init(source, options, env);
}

代码示例来源：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);
 negate = false;
 if (options.get(NEGATE) != null) {
  negate = Boolean.parseBoolean(options.get(NEGATE));
 }
}

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

@Override
public void init(SortedKeyValueIterator<Key, Value> source, Map<String, String> options, IteratorEnvironment env) throws IOException {
 log.info("init(" + source + ", " + options + ", " + env + ")");
 if (null == prefix) {
  prefix = String.format("0x%08X", this.hashCode());
 }
 super.init(source, options, env);
}

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

@Override
public void init(SortedKeyValueIterator<Key,Value> source, Map<String,String> options,
  IteratorEnvironment env) throws IOException {
 super.init(source, options, env);
 if (options.containsKey(SLEEP_TIME))
  sleepTime = Long.parseLong(options.get(SLEEP_TIME));
 if (options.containsKey(SEEK_SLEEP_TIME))
  seekSleepTime = Long.parseLong(options.get(SEEK_SLEEP_TIME));
}

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

@Override
public void init(SortedKeyValueIterator<Key,Value> source, Map<String,String> options, IteratorEnvironment env) throws IOException {
  super.init(source, options, env);
  if (options.containsKey(MAX_AGGREGATE_OPT)) {
    try {
      maxRecordCount = Long.parseLong(options.get(MAX_AGGREGATE_OPT));
    } catch (NumberFormatException e) {
      log.error("Invalid value (" + options.get(MAX_AGGREGATE_OPT) + ") for " + MAX_AGGREGATE_OPT + " option: " + e.getMessage());
      throw e;
    }
  }
}

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

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

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

@Override
public void init(SortedKeyValueIterator<Key,Value> source, Map<String,String> options, IteratorEnvironment env) throws IOException {
  super.init(source, options, env);
  if (options.containsKey(PRETTY_PRINT_OPT)) {
    prettyPrint = Boolean.parseBoolean(options.get(PRETTY_PRINT_OPT));
  }
  gson = initializeGson();
}

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

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

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

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

代码示例来源：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.decisionIterator = new RowIterator(source.deepCopy(env));
}

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

WrappingIterator

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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