org.elasticsearch.common.collect.Tuple.<init>()方法的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(9.4k)|赞(0)|评价(0)|浏览(63)

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

Tuple.<init>介绍

暂无

代码示例

代码示例来源：origin: NLPchina/elasticsearch-sql

public static Tuple<String, String> split(String strColumn, String pattern, String valueName) {
  String name = "split_" + random();
  if (valueName == null) {
    return new Tuple(name, "def " + name + " = doc['" + strColumn + "'].value.split('" + pattern + "')" );
  } else {
    return new Tuple(name, strColumn + "; def " + name + " = " + valueName + ".split('" + pattern + "')");
  }
}

代码示例来源：origin: NLPchina/elasticsearch-sql

private static Tuple<String, String> mathSingleValueTemplate(String methodName, String fieldName, String strColumn, String valueName) {
  String name = fieldName + "_" + random();
  if (valueName == null) {
    return new Tuple<>(name, "def " + name + " = " + methodName + "(doc['" + strColumn + "'].value)");
  } else {
    return new Tuple<>(name, strColumn + ";def " + name + " = " + methodName + "(" + valueName + ")");
  }
}

代码示例来源：origin: NLPchina/elasticsearch-sql

public static Tuple<String, String> strSingleValueTemplate(String methodName, String strColumn, String valueName) {
  String name = methodName + "_" + random();
  if (valueName == null) {
    return new Tuple(name, "def " + name + " = doc['" + strColumn + "'].value." + methodName + "()" );
  } else {
    return new Tuple(name, strColumn + "; def " + name + " = " + valueName + "." + methodName + "()");
  }
}

代码示例来源：origin: NLPchina/elasticsearch-sql

public static Tuple<String, String> substring(String strColumn, int pos, int len, String valueName) {
  String name = "substring_" + random();
  if (valueName == null) {
    return new Tuple(name, "def " + name + " = doc['" + strColumn + "'].value.substring(" + pos + "," + len + ")");
  } else {
    return new Tuple(name, strColumn + ";def " + name + " = " + valueName + ".substring(" + pos + "," + len + ")");
  }
}

代码示例来源：origin: NLPchina/elasticsearch-sql

private static Tuple<String, String> date_format(String strColumn, String pattern, String zoneId, String valueName) {
  String name = "date_format_" + random();
  if (valueName == null) {
    return new Tuple<>(name, "def " + name + " = DateTimeFormatter.ofPattern('" + pattern + "').withZone(" +
        (zoneId != null ? "ZoneId.of('" + zoneId + "')" : "ZoneId.systemDefault()") +
        ").format(Instant.ofEpochMilli(doc['" + strColumn + "'].value.getMillis()))");
  } else {
    return new Tuple<>(name, strColumn + "; def " + name + " = new SimpleDateFormat('" + pattern + "').format(new Date(" + valueName + " - 8*1000*60*60))");
  }
}

代码示例来源：origin: NLPchina/elasticsearch-sql

private static Tuple<String, String> mathDoubleValueTemplate(String methodName, String fieldName, String val1, String val2, String valueName) {
  String name = fieldName + "_" + random();
  if (valueName == null) {
    return new Tuple(name, "def "+name+" = "+methodName+"(doc['"+val1+"'].value, "+val2+")");
  } else {
    return new Tuple(name, val1 + ";def "+name+" = "+methodName+"("+valueName+", "+val2+")");
  }
}

代码示例来源：origin: NLPchina/elasticsearch-sql

private static Tuple<String, String> mathRoundTemplate(String methodName, String fieldName, String strColumn, String valueName, int decimalPrecision) {
  StringBuilder sb = new StringBuilder("1");
  for (int i = 0; i < decimalPrecision; i++) {
    sb.append("0");
  }
  double num = Double.parseDouble(sb.toString());
  String name = fieldName + "_" + random();
  if (valueName == null) {
    return new Tuple<>(name, "def " + name + " = " + methodName + "((doc['" + strColumn + "'].value) * " + num + ")/" + num);
  } else {
    return new Tuple<>(name, strColumn + ";def " + name + " = " + methodName + "((" + valueName + ") * " + num + ")/" + num);
  }
}

代码示例来源：origin: NLPchina/elasticsearch-sql

public static Tuple<String, String> split(String strColumn, String pattern, int index, String valueName) {
  String name = "split_" + random();
  String script = "";
  if (valueName == null) {
    script = "def " + name + " = doc['" + strColumn + "'].value.split('" + pattern + "')[" + index + "]";
  } else {
    script = "; def " + name + " = " + valueName + ".split('" + pattern + "')[" + index + "]";
  }
  return new Tuple<>(name, script);
}

代码示例来源：origin: NLPchina/elasticsearch-sql

public static Tuple<String, String> field(String a) {
  String name = "field_" + random();
  return new Tuple<>(name, "def " + name + " = " + "doc['" + a + "'].value");
}

代码示例来源：origin: NLPchina/elasticsearch-sql

private static Tuple<String, String> concat_ws(String split, List<SQLExpr> columns, String valueName) {
  String name = "concat_ws_" + random();
  List<String> result = Lists.newArrayList();
  for (SQLExpr column : columns) {
    String strColumn = Util.expr2Object(column).toString();
    if (strColumn.startsWith("def ")) {
      result.add(strColumn);
    } else if (isProperty(column)) {
      result.add("doc['" + strColumn + "'].value");
    } else {
      result.add("'" + strColumn + "'");
    }
  }
  return new Tuple<>(name, "def " + name + " =" + Joiner.on("+ " + split + " +").join(result));
}

代码示例来源：origin: NLPchina/elasticsearch-sql

public static Tuple<String, String> log(SQLExpr base, SQLExpr strColumn, String valueName) {
  String name = "log_" + random();
  String result;
  if (valueName == null) {
    if (isProperty(strColumn)) {
      result = "def " + name + " = Math.log(doc['" + Util.expr2Object(strColumn).toString() + "'].value)/Math.log("+Util.expr2Object(base).toString()+")";
    } else {
      result = "def " + name + " = Math.log(" + Util.expr2Object(strColumn).toString() + ")/Math.log("+Util.expr2Object(base).toString()+")";
    }
  } else {
    result = Util.expr2Object(strColumn).toString()+";def "+name+" = Math.log("+valueName+")/Math.log("+Util.expr2Object(base).toString()+")";
  }
  return new Tuple(name, result);
}

代码示例来源：origin: floragunncom/search-guard

return new Tuple<Map<String,Set<String>>, Map<String,Set<String>>>(dlsQueries, flsFields);

代码示例来源：origin: floragunncom/search-guard

return new Tuple<Boolean, String[]>(modified, localIndices);

代码示例来源：origin: NLPchina/elasticsearch-sql

functionStr = new Tuple<>(nameIF,"if(("+caseString+")){"+paramers.get(1).value+"} else {"+paramers.get(2).value+"}");
  break;
case "split":
String returnCommand = ";return " + generatedFieldName +";" ;
String newScript = functionStr.v2() + returnCommand;
functionStr = new Tuple<>(generatedFieldName, newScript);

代码示例来源：origin: NLPchina/elasticsearch-sql

private static Tuple<String, String> binaryOpertator(String methodName, String operator, SQLExpr a, SQLExpr b) {
  String name = methodName + "_" + random();
  return new Tuple<>(name,
      scriptDeclare(a) + scriptDeclare(b) +
          convertType(a) + convertType(b) +
          " def " + name + " = " + extractName(a) + " " + operator + " " + extractName(b) ) ;
}

代码示例来源：origin: floragunncom/search-guard

return new Tuple<Long, Settings>(version, Settings.builder().loadFromStream("dummy.json", new ByteArrayInputStream(parser.binaryValue()), true).build());
} catch (final IOException e) {
  throw ExceptionsHelper.convertToElastic(e);

代码示例来源：origin: floragunncom/search-guard

return new Tuple<Long, Settings>(version, Settings.builder().loadFromStream("dummy.json", new ByteArrayInputStream(parser.binaryValue()), true).build());
} catch (final IOException e) {
  throw ExceptionsHelper.convertToElastic(e);

代码示例来源：origin: org.elasticsearch/elasticsearch

CompoundProcessor(boolean ignoreFailure, List<Processor> processors, List<Processor> onFailureProcessors,
         LongSupplier relativeTimeProvider) {
  super();
  this.ignoreFailure = ignoreFailure;
  this.processors = processors;
  this.onFailureProcessors = onFailureProcessors;
  this.relativeTimeProvider = relativeTimeProvider;
  this.processorsWithMetrics = new ArrayList<>(processors.size());
  processors.forEach(p -> processorsWithMetrics.add(new Tuple<>(p, new IngestMetric())));
}

代码示例来源：origin: org.elasticsearch/elasticsearch

void updateRemoteCluster(
    final String clusterAlias,
    final List<String> addresses,
    final String proxyAddress,
    final ActionListener<Void> connectionListener) {
  final List<Tuple<String, Supplier<DiscoveryNode>>> nodes =
      addresses.stream().<Tuple<String, Supplier<DiscoveryNode>>>map(address -> Tuple.tuple(address, () ->
          buildSeedNode(clusterAlias, address, Strings.hasLength(proxyAddress)))
      ).collect(Collectors.toList());
  updateRemoteClusters(Collections.singletonMap(clusterAlias, new Tuple<>(proxyAddress, nodes)), connectionListener);
}

代码示例来源：origin: org.elasticsearch/elasticsearch

@Override
public void readFrom(StreamInput in) throws IOException {
  super.readFrom(in);
  int size = in.readVInt();
  versions = new HashMap<>();
  for (int i=0; i<size; i++) {
    String index = in.readString();
    Version upgradeVersion = Version.readVersion(in);
    String oldestLuceneSegment = in.readString();
    versions.put(index, new Tuple<>(upgradeVersion, oldestLuceneSegment));
  }
}

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

Tuple

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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