io.krakens.grok.api.Grok.getPatterns()方法的使用及代码示例

x33g5p2x  于2022-01-20 转载在 其他  
字(2.5k)|赞(0)|评价(0)|浏览(131)

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

Grok.getPatterns介绍

[英]Get the current map of Grok pattern.
[中]获取Grok模式的当前地图。

代码示例

代码示例来源:origin: apache/nifi

private static void populateSchemaFieldNames(final Grok grok, String grokExpression, final List<RecordField> fields) {
  final Set<String> namedGroups = GrokUtils.getNameGroups(GrokUtils.GROK_PATTERN.pattern());
  while (grokExpression.length() > 0) {
    final Matcher matcher = GrokUtils.GROK_PATTERN.matcher(grokExpression);
    if (matcher.find()) {
      final Map<String, String> extractedGroups = GrokUtils.namedGroups(matcher, namedGroups);
      final String subName = extractedGroups.get("subname");
      if (subName == null) {
        final String subPatternName = extractedGroups.get("pattern");
        if (subPatternName == null) {
          continue;
        }
        final String subExpression = grok.getPatterns().get(subPatternName);
        populateSchemaFieldNames(grok, subExpression, fields);
      } else {
        DataType dataType = RecordFieldType.STRING.getDataType();
        final RecordField recordField = new RecordField(subName, dataType);
        fields.add(recordField);
      }
      if (grokExpression.length() > matcher.end() + 1) {
        grokExpression = grokExpression.substring(matcher.end());
      } else {
        break;
      }
    } else {
      break;
    }
  }
}

代码示例来源:origin: vmware/hillview

int index = 0;
boolean continueIteration = true;
Map<String, String> patternDefinitions = grok.getPatterns();

代码示例来源:origin: thekrakken/java-grok

Map<String, String> grokPatterns = grok.getPatterns();

代码示例来源:origin: io.krakens/java-grok

Map<String, String> grokPatterns = grok.getPatterns();

代码示例来源:origin: thekrakken/java-grok

@Test
public void test020_postfix_patterns() throws Throwable {
 GrokCompiler compiler = GrokCompiler.newInstance();
 compiler.register(Resources.getResource("patterns/postfix").openStream());
 compiler.register(Resources.getResource("patterns/patterns").openStream());
 Grok grok = compiler.compile("%{POSTFIX_SMTPD}", false);
 assertTrue(grok.getPatterns().containsKey("POSTFIX_SMTPD"));
}

代码示例来源:origin: thekrakken/java-grok

@Test
public void test021_postfix_patterns_with_named_captures_only() throws Throwable {
 GrokCompiler compiler = GrokCompiler.newInstance();
 compiler.register(Resources.getResource("patterns/postfix").openStream());
 compiler.register(Resources.getResource("patterns/patterns").openStream());
 Grok grok = compiler.compile("%{POSTFIX_SMTPD}", true);
 assertTrue(grok.getPatterns().containsKey("POSTFIX_SMTPD"));
}

相关文章