org.apache.accumulo.core.data.Key.toStringNoTime()方法的使用及代码示例

x33g5p2x  于2022-01-23 转载在 其他  
字(7.9k)|赞(0)|评价(0)|浏览(108)

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

Key.toStringNoTime介绍

[英]Converts this key to a string, not including timestamp or delete marker.
[中]将此键转换为字符串，不包括时间戳或删除标记。

代码示例

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

@Override
public Key getTopKey() {
  if (log.isTraceEnabled()) {
    log.trace("Returning " + matchingKey.toStringNoTime());
  }
  return matchingKey;
}

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

public void PrintTable(String table) throws TableNotFoundException {
  Scanner scanner;
//    try {
   scanner = connector.createScanner(table, Authorizations.EMPTY);
//    } catch (TableNotFoundException e) {
//      log.error("error scaning table "+table, e);
//      throw new RuntimeException(e);
//    }

  for (Map.Entry<Key, Value> entry : scanner) {
   System.out.println(entry.getKey().toStringNoTime()+"    "+entry.getValue());
  }
  scanner.close();
 }

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

@Override
public String next() {
 final Entry<Key,Value> entry = iter.next();
 String key;
 // Observe the timestamps
 if (config.willPrintTimestamps()) {
  key = entry.getKey().toString();
 } else {
  key = entry.getKey().toStringNoTime();
 }
 final Value v = entry.getValue();
 // Approximate how much space we'll need
 final StringBuilder sb = new StringBuilder(key.length() + v.getSize() * 5);
 sb.append(key).append(tab);
 for (byte b : v.get()) {
  if ((b >= 48 && b <= 57) || (b >= 97 && b <= 102)) {
   sb.append(String.format("0x%x ", Integer.valueOf(b)));
  }
 }
 return sb.toString().trim() + newline;
}

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

public HashMap<String,Double> scanResults(Iterable<Entry<Key,Value>> data) {
  HashMap<String,Double> fieldWeights = new HashMap<>();
  final DoubleWritable vWeight = new DoubleWritable();
  for (Entry<Key,Value> kv : data) {
    if (log.isDebugEnabled()) {
      log.debug("Received key " + kv.getKey().toStringNoTime());
    }
    Text field = kv.getKey().getRow();
    Double weight = null;
    try {
      vWeight.readFields(new DataInputStream(new ByteArrayInputStream(kv.getValue().get())));
      weight = vWeight.get();
    } catch (IOException e) {
      log.error("Could not parse value for " + field, e);
      continue;
    }
    fieldWeights.put(field.toString(), weight);
  }
  return fieldWeights;
}

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

public void PrintTableDebug(String table) throws TableNotFoundException {
  Scanner scanner;
//    try {
   scanner = connector.createScanner(table, Authorizations.EMPTY);
//    } catch (TableNotFoundException e) {
//      log.error("error scaning table "+table, e);
//      throw new RuntimeException(e);
//    }

  for (Map.Entry<Key, Value> entry : scanner) {
   byte[] b = entry.getValue().get();
   System.out.println(entry.getKey().toStringNoTime()+"    "+
     Key.toPrintableString(b, 0, b.length, 300));
  }
  scanner.close();
 }

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

public void compareResults(BaseQueryLogic<Map.Entry<Key,Value>> logic, List<String> expected) {
  int recordsFound = 0;
  List<Key> foundKeys = new ArrayList<>();
  for (Map.Entry<Key,Value> entry : logic) {
    foundKeys.add(entry.getKey());
    Key k = entry.getKey();
    System.out.println("key = " + k.toStringNoTime());
    Assert.assertTrue(UNEXPECTED_RECORD + " : " + k.toStringNoTime(), expected.contains(k.toStringNoTime()));
    recordsFound++;
  }
  
  Assert.assertEquals(UNEXPECTED_NUM_RECORDS, expected.size(), recordsFound);
}

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

sb.append("retrieved document from host:").append(host).append(" at key:").append(documentKey.toStringNoTime()).append(" stageTimers:")
        .append(stageTimers);
sb.append(" sourceCount:").append(currentSourceCount).append(" nextCount:").append(currentNextCount).append(" seekCount:")

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

public LinkedList<FieldStat> scanResults(Iterable<Entry<Key,Value>> data) {
  LinkedList<FieldStat> stats = new LinkedList<>();
  IndexStatsRecord tuple = new IndexStatsRecord();
  for (Entry<Key,Value> kv : data) {
    if (log.isDebugEnabled()) {
      log.debug("Received key " + kv.getKey().toStringNoTime());
    }
    String field = kv.getKey().getRow().toString();
    long unique, total;
    double selectivity;
    try {
      tuple.readFields(new DataInputStream(new ByteArrayInputStream(kv.getValue().get())));
    } catch (IOException e) {
      log.error("Could not parse value for " + field, e);
      continue;
    }
    unique = tuple.getNumberOfUniqueWords().get();
    total = tuple.getWordCount().get();
    selectivity = ((double) unique) / ((double) total);
    
    FieldStat fs = new FieldStat();
    fs.field = field;
    fs.unique = unique;
    fs.observed = total;
    fs.selectivity = selectivity;
    stats.add(fs);
  }
  return stats;
}

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

Key startKey = new Key(new Text(start_row));
LOG.trace("Start key for metric {} and time {} is {}", metric, beginRangeRounded,
    startKey.toStringNoTime());
final byte[] end_row = MetricAdapter.encodeRowKey(metric, beginRangeRounded);
Key endKey = new Key(new Text(end_row));
LOG.trace("End key for metric {} and time {} is {}", metric, MetricAdapter.roundTimestampToNextHour(end),
    endKey.toStringNoTime());
Range range = new Range(startKey, true, endKey, false);
LOG.trace("Set query range to {}", range);
          beginRangeTimestamp);
      LOG.trace("Start key for metric {} and time {} is {}", metric, beginRangeTimestamp,
          startKey.toStringNoTime());
      final byte[] end_row = MetricAdapter.encodeRowKey(metric, beginRangeRounded);
      Key endKey = new Key(new Text(end_row), new Text(t.join().getBytes(Charset.forName("UTF-8"))),
          endRangeTimestamp);
      LOG.trace("End key for metric {} and time {} is {}", metric, beginRangeTimestamp,
          endKey.toStringNoTime());
      Range range = new Range(startKey, true, endKey, false);
      LOG.trace("Set query range to {}", range);

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

LOG.debug("Validating version based on range start key " + range.getStartKey().toStringNoTime());
  final String message = "Unable to validate version for range " + startKey.toStringNoTime()
          + " due to an invalid field index (fi) column qualifier " + topKey.toStringNoTime();
  LOG.warn(message, e);

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

public static void printTable(final Connector conn, final Authorizations authorizations, final String tableName, final PrintStream out)
        throws TableNotFoundException {
  final SimpleDateFormat dateFormat = new SimpleDateFormat("yyyyMMdd HHmmss");
  
  final StringBuilder sb = new StringBuilder("--Begin entire " + tableName + " table--");
  
  sb.append("\n");
  
  final Scanner scanner = conn.createScanner(tableName, authorizations);
  for (final Entry<Key,Value> e : scanner) {
    sb.append(e.getKey().toStringNoTime());
    sb.append(' ');
    sb.append(dateFormat.format(new Date(e.getKey().getTimestamp())));
    sb.append('\t');
    sb.append(getPrintableValue(e.getValue()));
    sb.append("\n");
  }
  
  sb.append("--End entire ").append(tableName).append(" table--").append("\n");
  
  out.println(sb);
}

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

sb.append(e.getKey().toStringNoTime());
sb.append(' ');
sb.append(dateFormat.format(new Date(e.getKey().getTimestamp())));

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

log.debug(entry.getKey().toStringNoTime() + " -> " + thisEntries + " entries processed");
 numEntries += thisEntries;
} else {

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

log.debug(entry.getKey().toStringNoTime() + " -> " + thisEntries + " entries processed");
 numEntries += thisEntries;
} else {

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

log.trace("Setting matching key to " + src.getTopKey().toStringNoTime());

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

log.debug("t2 entry is " + actual.getKey().toStringNoTime() + " -> " + actual.getValue());
Assert.assertTrue(actual.getKey().equals(k, PartialKey.ROW_COLFAM_COLQUAL));
Assert.assertEquals(numEntriesToWritePerEntry, Integer.parseInt(actual.getValue().toString()));

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

if (log.isTraceEnabled()) {
  log.trace("Doc size: " + this.document.size());
  log.trace("Returning pointer " + tk.toStringNoTime());

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

Key

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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