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

Yaml介绍

[英]Public YAML interface. Each Thread must have its own instance.
[中]公共YAML接口。每个线程都必须有自己的实例。

代码示例

代码示例来源：origin: apache/incubator-shardingsphere

private static YamlOrchestrationMasterSlaveRuleConfiguration unmarshal(final File yamlFile) throws IOException {
  try (
      FileInputStream fileInputStream = new FileInputStream(yamlFile);
      InputStreamReader inputStreamReader = new InputStreamReader(fileInputStream, "UTF-8")
  ) {
    return new Yaml(new Constructor(YamlOrchestrationMasterSlaveRuleConfiguration.class)).loadAs(inputStreamReader, YamlOrchestrationMasterSlaveRuleConfiguration.class);
  }
}

代码示例来源：origin: alibaba/jstorm

public static void LoadYaml(String confPath) {
  
  Yaml yaml = new Yaml();
  
  try {
    InputStream stream = new FileInputStream(confPath);
    
    conf = (Map) yaml.load(stream);
    if (conf == null || conf.isEmpty() == true) {
      throw new RuntimeException("Failed to read config file");
    }
    
  } catch (FileNotFoundException e) {
    System.out.println("No such file " + confPath);
    throw new RuntimeException("No config file");
  } catch (Exception e1) {
    e1.printStackTrace();
    throw new RuntimeException("Failed to read config file");
  }
  
  return;
}

代码示例来源：origin: Netflix/Priam

public void updateAutoBootstrap(String yamlFile, boolean autobootstrap) throws IOException {
  DumperOptions options = new DumperOptions();
  options.setDefaultFlowStyle(DumperOptions.FlowStyle.BLOCK);
  Yaml yaml = new Yaml(options);
  @SuppressWarnings("rawtypes")
  Map map = yaml.load(new FileInputStream(yamlFile));
  // Dont bootstrap in restore mode
  map.put("auto_bootstrap", autobootstrap);
  if (logger.isInfoEnabled()) {
    logger.info("Updating yaml: " + yaml.dump(map));
  }
  yaml.dump(map, new FileWriter(yamlFile));
}

代码示例来源：origin: apache/incubator-shardingsphere

@SuppressWarnings("unchecked")
  @Override
  public Map<String, Object> load(final String data) {
    return Strings.isNullOrEmpty(data) ? new LinkedHashMap<String, Object>() : (Map) new Yaml().load(data);
  }
}

代码示例来源：origin: apache/incubator-shardingsphere

@Override
  public Properties load(final String data) {
    return Strings.isNullOrEmpty(data) ? new Properties() : new Yaml().loadAs(data, Properties.class);
  }
}

代码示例来源：origin: geotools/geotools

@Test
public void testFTSVendorOption() throws Exception {
  PointSymbolizer p = CommonFactoryFinder.getStyleFactory().createPointSymbolizer();
  FeatureTypeStyle fts = fts(p);
  fts.getOptions().put("foo", "bar");
  StringWriter out = new StringWriter();
  Ysld.encode(sld(fts), out);
  System.out.append(out.toString());
  YamlMap obj = new YamlMap(YamlUtil.getSafeYaml().load(out.toString()));
  YamlMap result = obj.seq("feature-styles").map(0);
  assertThat(result.str("x-foo"), equalTo("bar"));
}

代码示例来源：origin: geotools/geotools

YamlMap encode(String dirname, String filename) throws Exception {
    SLDParser sldParser = new SLDParser(CommonFactoryFinder.getStyleFactory());
    sldParser.setInput(YsldTests.sld(dirname, filename));

    StyledLayerDescriptor sld = sldParser.parseSLD();

    StringWriter w = new StringWriter();
    YsldEncoder ysldEncoder = new YsldEncoder(w, new UomMapper());
    ysldEncoder.encode(sld);

    // System.out.println(w.toString());
    return new YamlMap(YamlUtil.getSafeYaml().load(new StringReader(w.toString())));
  }
}

代码示例来源：origin: palantir/atlasdb

private void assertSyncStateStructureCorrect(File syncStateFile) throws FileNotFoundException {
  Iterable<Object> syncState = new Yaml().loadAll(new FileInputStream(syncStateFile));
  for (Object ymlMap : syncState) {
    assertTrue("Sync state contains unrecognizable object", ymlMap instanceof Map);
    Map map = (Map) ymlMap;
    if (map.containsKey(LockServiceStateLogger.SYNC_STATE_TITLE)) {
      Object mapObj = map.get(LockServiceStateLogger.SYNC_STATE_TITLE);
      assertTrue("Sync state is not a map", mapObj instanceof Map);
      assertEquals(getSyncStateDescriptors().size(), ((Map) mapObj).size());
    } else {
      throw new IllegalStateException("Map found in YAML document without an expected key");
    }
  }
}

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

public static <T> T getYamlDataObject(String path, Class<T> clazz) {
  Yaml ymal = new Yaml();
  FileInputStream fis = null;
  try {
    fis = new FileInputStream(new File(path));
    return ymal.loadAs(fis, clazz);
  } catch (Exception e) {
    throw new AclException(String.format("The  file for Plain mode was not found , paths %s", path), e);
  } finally {
    if (fis != null) {
      try {
        fis.close();
      } catch (IOException e) {
        throw new AclException("close transport fileInputStream Exception", e);
      }
    }
  }
}

代码示例来源：origin: geotools/geotools

@Test
public void testFilter() throws Exception {
  FilterFactory2 filterFactory = CommonFactoryFinder.getFilterFactory2();
  StyleFactory styleFactory = CommonFactoryFinder.getStyleFactory();
  StyledLayerDescriptor sld = styleFactory.createStyledLayerDescriptor();
  UserLayer layer = styleFactory.createUserLayer();
  sld.layers().add(layer);
  Style style = styleFactory.createStyle();
  layer.userStyles().add(style);
  Rule rule = styleFactory.createRule();
  rule.setFilter(filterFactory.less(filterFactory.property("foo"), filterFactory.literal(2)));
  style.featureTypeStyles().add(styleFactory.createFeatureTypeStyle());
  style.featureTypeStyles().get(0).rules().add(rule);
  PointSymbolizer p = styleFactory.createPointSymbolizer();
  rule.symbolizers().add((Symbolizer) p);
  StringWriter out = new StringWriter();
  Ysld.encode(sld, out);
  YamlMap obj = new YamlMap(YamlUtil.getSafeYaml().load(out.toString()));
  YamlMap result = obj.seq("feature-styles").map(0).seq("rules").map(0);
  assertThat(result, yHasEntry("filter", equalTo("${foo < 2}")));
}

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

/**
 * Convert this into a YAML String.
 * @return this as a YAML String.
 */
public String toYamlString() {
  Yaml yaml = new Yaml(new SafeConstructor());
  StringWriter writer = new StringWriter();
  yaml.dump(toConf(), writer);
  return writer.toString();
}

代码示例来源：origin: alibaba/jstorm

static Map loadYamlConf(String f) throws IOException {
  InputStreamReader reader = null;
  try {
    FileInputStream fis = new FileInputStream(f);
    reader = new InputStreamReader(fis, UTF8);
    return (Map) yaml.load(reader);
  } finally {
    if (reader != null)
      reader.close();
  }
}

代码示例来源：origin: azkaban/azkaban

public NodeBean load(final File flowFile) throws Exception {
 checkArgument(flowFile != null && flowFile.exists());
 checkArgument(flowFile.getName().endsWith(Constants.FLOW_FILE_SUFFIX));
 final NodeBean nodeBean = new Yaml().loadAs(new FileInputStream(flowFile), NodeBean.class);
 if (nodeBean == null) {
  throw new ProjectManagerException(
    "Failed to load flow file " + flowFile.getName() + ". Node bean is null .");
 }
 nodeBean.setName(getFlowName(flowFile));
 nodeBean.setType(Constants.FLOW_NODE_TYPE);
 return nodeBean;
}

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

superConf.put(Config.STORM_WORKERS_ARTIFACTS_DIR, stormLocal);
final StringWriter yamlDump = new StringWriter();
String yamlResult = yamlDump.toString();
Yaml yaml = new Yaml();
Map<String, Object> result = (Map<String, Object>) yaml.load(yamlResult);
assertEquals(workerId, result.get("worker-id"));
assertEquals(user, result.get(Config.TOPOLOGY_SUBMITTER_USER));

代码示例来源：origin: geotools/geotools

@Test
public void testTextSymbolizerPriority() throws Exception {
  StyleFactory styleFactory = CommonFactoryFinder.getStyleFactory();
  FilterFactory filterFactory = CommonFactoryFinder.getFilterFactory();
  TextSymbolizer symb = styleFactory.createTextSymbolizer();
  symb.setPriority(filterFactory.property("foo"));
  StringWriter out = new StringWriter();
  Ysld.encode(sld(symb), out);
  YamlMap obj = new YamlMap(YamlUtil.getSafeYaml().load(out.toString()));
  YamlMap text =
      obj.seq("feature-styles")
          .map(0)
          .seq("rules")
          .map(0)
          .seq("symbolizers")
          .map(0)
          .map("text");
  assertEquals("${foo}", text.str("priority"));
}

代码示例来源：origin: geotools/geotools

YamlMap yaml(SldTransformer transformer) throws Exception {
  String yaml = ((StringWriter) transformer.context().output()).toString();
  return new YamlMap(YamlUtil.getSafeYaml().load(yaml));
}

代码示例来源：origin: SonarSource/sonarqube

public void writeToYmlSettingsFile(File file) {
  DumperOptions dumperOptions = new DumperOptions();
  dumperOptions.setPrettyFlow(true);
  dumperOptions.setDefaultFlowStyle(BLOCK);
  Yaml yaml = new Yaml(dumperOptions);
  String output = ELASTICSEARCH_YML_OPTIONS_HEADER + yaml.dump(elasticsearchSettings);
  try {
   Files.write(file.toPath(), output.getBytes(StandardCharsets.UTF_8));
  } catch (IOException e) {
   throw new IllegalStateException("Cannot write Elasticsearch yml settings file", e);
  }
 }
}

代码示例来源：origin: apache/incubator-dubbo

private static <T> T parseObject(String rawConfig) {
  Constructor constructor = new Constructor(ConfiguratorConfig.class);
  TypeDescription itemDescription = new TypeDescription(ConfiguratorConfig.class);
  itemDescription.addPropertyParameters("items", ConfigItem.class);
  constructor.addTypeDescription(itemDescription);
  Yaml yaml = new Yaml(constructor);
  return yaml.load(rawConfig);
}

代码示例来源：origin: alibaba/jstorm

/**
 * dumps a conf map into a file, note that the output yaml file uses a compact format
 * e.g., for a list, it uses key: [xx, xx] instead of multiple lines.
 */
public static void dumpYaml(Map conf, String file) {
  Yaml yaml = new Yaml();
  try {
    Writer writer = new OutputStreamWriter(new FileOutputStream(file), "UTF-8");
    yaml.dump(conf, writer);
  } catch (Exception ex) {
    LOG.error("Error:", ex);
  }
}

代码示例来源：origin: apache/incubator-shardingsphere

private static YamlOrchestrationShardingRuleConfiguration unmarshal(final byte[] yamlByteArray) {
    return new Yaml(new Constructor(YamlOrchestrationShardingRuleConfiguration.class)).loadAs(new ByteArrayInputStream(yamlByteArray), YamlOrchestrationShardingRuleConfiguration.class);
  }
}