import org.codehaus.plexus.util.xml.XMLWriter; //导入依赖的package包/类
/**
 * org.apache.maven.plugins.help.EffectivePomMojo#writeEffectivePom
 */
private static void writeEffectivePom(MavenProject project, XMLWriter writer)
  throws MojoExecutionException {
  Model pom = project.getModel();
  cleanModel(pom);

  String effectivePom;

  StringWriter sWriter = new StringWriter();
  MavenXpp3Writer pomWriter = new MavenXpp3Writer();
  try {
    pomWriter.write(sWriter, pom);
  }
  catch (IOException e) {
    throw new MojoExecutionException("Cannot serialize POM to XML.", e);
  }

  effectivePom = addMavenNamespace(sWriter.toString(), true);

  writeComment(writer, "Effective POM for project \'" + project.getId() + "\'");

  writer.writeMarkup(effectivePom);
}
 

import org.codehaus.plexus.util.xml.XMLWriter; //导入依赖的package包/类
public static void writeJobConfiguration(XMLWriter writer, Schedule schedule, Configuration conf) {

    property(writer, WORKFLOW_NOMINAL_TIME, "${" + COORD_NOMINAL_TIME + "}");

    // Write the Hive metastore URI, if available. It may be null
    // in local or testing environments.
    if (conf.get(HIVE_METASTORE_URIS) != null) {
      property(writer, HIVE_METASTORE_URIS, conf.get(HIVE_METASTORE_URIS));
    }

    // Include the dataset inputs to make them visible to the workflow.
    for (String name: schedule.getViewTemplates().keySet()) {

      property(writer, "wf_" + toIdentifier(name), "${coord_" + toIdentifier(name) + "}");
    }
  }
 

import org.codehaus.plexus.util.xml.XMLWriter; //导入依赖的package包/类
/**
 * Patches the IDE GWT module by replacing inheritance of Full.gwt.xml by
 * Full-with-excludes.gwt.xml.
 */
private void patchGwtModule() throws XmlPullParserException, IOException {
  String gwtModuleFileRelPath = getGwtModule().replace('.', '/') + ".gwt.xml";
  Path gwtModuleFilePath = Paths.get(outputDirectory.getPath(), gwtModuleFileRelPath);

  Xpp3Dom module = Xpp3DomBuilder.build(Files.newInputStream(gwtModuleFilePath), UTF_8.name());

  for (int i = module.getChildCount() - 1; i >= 0; i--) {
    Xpp3Dom child = module.getChild(i);

    if ("inherits".equals(child.getName())) {
      String moduleName = child.getAttribute("name");

      if (moduleName.equals(fullIdeGwtModule)) {
        child.setAttribute("name", fullIdeGwtModule + FULL_IDE_GWT_MODULE_SUFFIX);
        break;
      }
    }
  }

  try (Writer writer = new StringWriter()) {
    XMLWriter xmlWriter = new PrettyPrintXMLWriter(writer);
    Xpp3DomWriter.write(xmlWriter, module);
    Files.write(gwtModuleFilePath, writer.toString().getBytes());
  }
}
 

import org.codehaus.plexus.util.xml.XMLWriter; //导入依赖的package包/类
/**
 * method from org.apache.maven.plugins.help.EffectivePomMojo Method for writing the effective pom
 * informations of the current build.
 *
 * @param project the project of the current build, not null.
 * @param writer the XML writer , not null, not null.
 * @throws MojoExecutionException if any
 */
private static void writeEffectivePom(MavenProject project, XMLWriter writer)
    throws MojoExecutionException {
  Model pom = project.getModel();
  cleanModel(pom);

  String effectivePom;

  StringWriter sWriter = new StringWriter();
  MavenXpp3Writer pomWriter = new MavenXpp3Writer();
  try {
    pomWriter.write(sWriter, pom);
  } catch (IOException e) {
    throw new MojoExecutionException("Cannot serialize POM to XML.", e);
  }

  effectivePom = addMavenNamespace(sWriter.toString(), true);

  writeComment(writer, "Effective POM for project \'" + project.getId() + "\'");

  writer.writeMarkup(effectivePom);
}
 

import org.codehaus.plexus.util.xml.XMLWriter; //导入依赖的package包/类
/**
 * method from org.apache.maven.plugins.help.AbstractEffectiveMojo Write comments in the Effective
 * POM/settings header.
 *
 * @param writer not null
 */
protected static void writeHeader(XMLWriter writer) {
  XmlWriterUtil.writeCommentLineBreak(writer);
  XmlWriterUtil.writeComment(writer, "    ");
  // Use ISO8601-format for date and time
  DateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd'T'hh:mm:ss");
  XmlWriterUtil.writeComment(
      writer,
      "Generated by Maven Help Plugin on "
          + dateFormat.format(new Date(System.currentTimeMillis())));
  XmlWriterUtil.writeComment(writer, "See: http://maven.apache.org/plugins/maven-help-plugin/");
  XmlWriterUtil.writeComment(writer, "    ");
  XmlWriterUtil.writeCommentLineBreak(writer);

  XmlWriterUtil.writeLineBreak(writer);
}
 

import org.codehaus.plexus.util.xml.XMLWriter; //导入依赖的package包/类
private void write(PlexusConfiguration c, XMLWriter w, int depth) throws IOException {
  int count = c.getChildCount();

  if (count == 0) {
    writeTag(c, w, depth);
  } else {
    w.startElement(c.getName());
    writeAttributes(c, w);

    for (int i = 0; i < count; i++) {
      PlexusConfiguration child = c.getChild(i);

      write(child, w, depth + 1);
    }

    w.endElement();
  }
}
 

import org.codehaus.plexus.util.xml.XMLWriter; //导入依赖的package包/类
public void writeDescriptor(OutputStream outputStream, PluginDescriptor pluginDescriptor) throws IOException {
  OutputStreamWriter writer = new OutputStreamWriter(outputStream, encoding);

  XMLWriter w = new PrettyPrintXMLWriter(writer, encoding, null);

  w.writeMarkup("\n<!-- Generated by takari-plugin-tools -->\n\n");
  w.startElement("plugin");
  element(w, "name", pluginDescriptor.getName());
  element(w, "description", pluginDescriptor.getDescription());
  element(w, "groupId", pluginDescriptor.getGroupId());
  element(w, "artifactId", pluginDescriptor.getArtifactId());
  element(w, "version", pluginDescriptor.getVersion());
  element(w, "goalPrefix", pluginDescriptor.getGoalPrefix());
  element(w, "isolatedRealm", String.valueOf(pluginDescriptor.isIsolatedRealm()));
  element(w, "inheritedByDefault", String.valueOf(pluginDescriptor.isInheritedByDefault()));
  writeMojos(w, pluginDescriptor);
  writeDependencies(w, pluginDescriptor);
  w.endElement();

  writer.flush();
}
 

import org.codehaus.plexus.util.xml.XMLWriter; //导入依赖的package包/类
/**
 * Copy/pasted from org.apache.maven.plugins.help.AbstractEffectiveMojo#writeHeader
 */
protected static void writeHeader(XMLWriter writer) {
  XmlWriterUtil.writeCommentLineBreak(writer);
  XmlWriterUtil.writeComment(writer, " ");
  // Use ISO8601-format for date and time
  DateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd'T'hh:mm:ss");
  XmlWriterUtil.writeComment(writer, "Generated on " + dateFormat.format(new Date(System.currentTimeMillis())));
  XmlWriterUtil.writeComment(writer, " ");
  XmlWriterUtil.writeCommentLineBreak(writer);

  XmlWriterUtil.writeLineBreak(writer);
}
 

import org.codehaus.plexus.util.xml.XMLWriter; //导入依赖的package包/类
/**
 * Copy/pasted from org.apache.maven.plugins.help.AbstractEffectiveMojo
 */
protected static void writeComment(XMLWriter writer, String comment) {
  XmlWriterUtil.writeCommentLineBreak(writer);
  XmlWriterUtil.writeComment(writer, " ");
  XmlWriterUtil.writeComment(writer, comment);
  XmlWriterUtil.writeComment(writer, " ");
  XmlWriterUtil.writeCommentLineBreak(writer);

  XmlWriterUtil.writeLineBreak(writer);
}
 

import org.codehaus.plexus.util.xml.XMLWriter; //导入依赖的package包/类
@Override
public void writeOozieActionBlock(XMLWriter writer, Schedule schedule) {

  writer.startElement("spark");
  writer.addAttribute("xmlns", "uri:oozie:spark-action:0.1");
  element(writer, "job-tracker", "${jobTracker}");
  element(writer, "name-node", "${nameNode}");

  // TODO: the job-xml should probably be job-specific configuration.
  // element(writer, "job-xml", "${appConfigPath}");

  // Make the nominal time visible to the workflow action.
  writer.startElement("configuration");

  // Use the spark and hive sharelibs since many actions use both.
  property(writer, "oozie.action.sharelib.for.spark", "spark,hive2");
  property(writer, "kiteAppRoot", "${kiteAppRoot}");

  OozieScheduling.writeJobConfiguration(writer, schedule, context.getHadoopConf());

  writer.endElement(); // configuration

  element(writer, "master", "yarn-cluster");
  element(writer, "name", schedule.getName());
  element(writer, "class", SparkScheduledJobMain.class.getCanonicalName());

  JobConf jobConf = new JobConf();
  jobConf.setJarByClass(schedule.getJobClass());
  String containingJar = jobConf.getJar();

  String jarName = containingJar != null ?
      "${kiteAppRoot}/lib/" + new File(containingJar).getName() :
      "";

  element(writer, "jar",  jarName);
  element(writer, "spark-opts", getSparkConfString(schedule));
  element(writer, "arg", schedule.getName());

  writer.endElement(); // spark
}
 

import org.codehaus.plexus.util.xml.XMLWriter; //导入依赖的package包/类
public static void element(XMLWriter writer, String name, String attributeName,
                            String attributeValue) {

  writer.startElement(name);
  writer.addAttribute(attributeName, attributeValue);
  writer.endElement();
}
 

import org.codehaus.plexus.util.xml.XMLWriter; //导入依赖的package包/类
/**
 * Writes a Hadoop-style configuration property.
 */
public static void property(XMLWriter writer, String name, String value) {
  writer.startElement("property");

  element(writer, "name", name);
  element(writer, "value", value);

  writer.endElement();
}
 

import org.codehaus.plexus.util.xml.XMLWriter; //导入依赖的package包/类
/** Creates copy of the Full.gwt.xml with removed '<inherits>' for the excluded GWT modules. */
private void createFullIdeModuleWithExcludes(Set<String> modulesToExclude)
    throws XmlPullParserException, IOException {
  String fullIdeGwtModulePath = fullIdeGwtModule.replace('.', '/') + ".gwt.xml";
  String fullIdeGwtModuleContent =
      getFileContent(new ZipFile(fullIdeArtifact.getFile()), fullIdeGwtModulePath);

  InputStream in = new ByteArrayInputStream(fullIdeGwtModuleContent.getBytes(UTF_8.name()));
  Xpp3Dom module = Xpp3DomBuilder.build(in, UTF_8.name());

  for (int i = module.getChildCount() - 1; i >= 0; i--) {
    Xpp3Dom child = module.getChild(i);

    if ("inherits".equals(child.getName())) {
      String moduleName = child.getAttribute("name");

      if (modulesToExclude.contains(moduleName)) {
        module.removeChild(i);
      }
    }
  }

  String moduleRelPath =
      fullIdeGwtModulePath.replace(".gwt.xml", FULL_IDE_GWT_MODULE_SUFFIX + ".gwt.xml");

  Path modulePath = Paths.get(outputDirectory.getPath(), moduleRelPath);

  try (Writer writer = new StringWriter()) {
    XMLWriter xmlWriter = new PrettyPrintXMLWriter(writer);
    Xpp3DomWriter.write(xmlWriter, module);
    Files.write(modulePath, writer.toString().getBytes());
  }
}
 

import org.codehaus.plexus.util.xml.XMLWriter; //导入依赖的package包/类
/**
 * method from org.apache.maven.plugins.help.AbstractEffectiveMojo Write comments in a normalize
 * way.
 *
 * @param writer not null
 * @param comment not null
 */
protected static void writeComment(XMLWriter writer, String comment) {
  XmlWriterUtil.writeCommentLineBreak(writer);
  XmlWriterUtil.writeComment(writer, " ");
  XmlWriterUtil.writeComment(writer, comment);
  XmlWriterUtil.writeComment(writer, " ");
  XmlWriterUtil.writeCommentLineBreak(writer);

  XmlWriterUtil.writeLineBreak(writer);
}
 

import org.codehaus.plexus.util.xml.XMLWriter; //导入依赖的package包/类
private void writeTag(PlexusConfiguration c, XMLWriter w, int depth) throws IOException {
  w.startElement(c.getName());

  writeAttributes(c, w);

  String value = c.getValue(null);
  if (value != null) {
    w.writeText(value);
  }

  w.endElement();
}
 

import org.codehaus.plexus.util.xml.XMLWriter; //导入依赖的package包/类
private void writeAttributes(PlexusConfiguration c, XMLWriter w) throws IOException {
  String[] names = c.getAttributeNames();

  for (int i = 0; i < names.length; i++) {
    w.addAttribute(names[i], c.getAttribute(names[i], null));
  }
}
 

import org.codehaus.plexus.util.xml.XMLWriter; //导入依赖的package包/类
protected void addQNameAttribute(XMLWriter writer, String attributeName,
        QName attributeValue, Map namespaceMap) {
    if (attributeValue != null) {
        StringBuffer attributeStringValue = new StringBuffer();
        attributeStringValue.append(namespaceMap.get(attributeValue
                .getNamespaceURI()));
        attributeStringValue.append(":");
        attributeStringValue.append(attributeValue.getLocalPart());
        writer.addAttribute(attributeName, attributeStringValue.toString());
    }

}
 

import org.codehaus.plexus.util.xml.XMLWriter; //导入依赖的package包/类
private void writeConnection(Map namespaceMap, XMLWriter writer,
        Connection connection) {
    writer.startElement("connection");
    if (connection.getConsumes() != null) {
        writer.startElement("consumer");
        addQNameAttribute(writer, "interface-name", connection
                .getConsumes().getInterfaceName(), namespaceMap);
        addQNameAttribute(writer, "service-name", connection.getConsumes()
                .getServiceName(), namespaceMap);
        addStringAttribute(writer, "endpoint-name", connection
                .getConsumes().getEndpointName());
        writer.endElement();
    }
    if (connection.getProvides() != null) {
        writer.startElement("provider");
        addQNameAttribute(writer, "interface-name", connection
                .getProvides().getInterfaceName(), namespaceMap);
        addQNameAttribute(writer, "service-name", connection.getProvides()
                .getServiceName(), namespaceMap);
        addStringAttribute(writer, "endpoint-name", connection
                .getProvides().getEndpointName());
        writer.endElement();
    }

    writer.endElement();

}
 

import org.codehaus.plexus.util.xml.XMLWriter; //导入依赖的package包/类
private void writeServiceUnit(XMLWriter writer,
        DependencyInformation serviceUnitInfo) throws JbiPluginException {
    writer.startElement("service-unit");
    writer.startElement("identification");
    writer.startElement("name");
    writer.writeText(serviceUnitInfo.getName());
    writer.endElement();
    writer.startElement("description");
    if (serviceUnitInfo.getDescription() != null) {
        writer.writeText(serviceUnitInfo.getDescription());
    } else {
        writer.writeText(serviceUnitInfo.getName());
    }
    writer.endElement();
    writer.endElement();

    writer.startElement("target");
    writer.startElement("artifacts-zip");
    writer.writeText(serviceUnitInfo.getFilename());
    writer.endElement();

    writer.startElement("component-name");
    writer.writeText(serviceUnitInfo.getComponent());
    writer.endElement();

    writer.endElement();

    writer.endElement();
}
 

import org.codehaus.plexus.util.xml.XMLWriter; //导入依赖的package包/类
public static String evaluateEffectivePom(final Maven3ServerEmbedderImpl embedder,
                                          @NotNull final File file,
                                          @NotNull List<String> activeProfiles)
  throws RemoteException, MavenServerProcessCanceledException {

  final MavenExecutionRequest
    request = embedder.createRequest(file, activeProfiles, Collections.<String>emptyList(), Collections.<String>emptyList());

  final StringWriter w = new StringWriter();

  embedder.executeWithMavenSession(request, new Runnable() {
    @Override
    public void run() {
      try {
        // copied from DefaultMavenProjectBuilder.buildWithDependencies
        ProjectBuilder builder = embedder.getComponent(ProjectBuilder.class);
        ProjectBuildingResult buildingResult = builder.build(new File(file.getPath()), request.getProjectBuildingRequest());

        MavenProject project = buildingResult.getProject();

        XMLWriter writer = new PrettyPrintXMLWriter(w, StringUtils.repeat(" ", XmlWriterUtil.DEFAULT_INDENTATION_SIZE));

        writeHeader(writer);

        writeEffectivePom(project, writer);
      }
      catch (Exception e) {
        throw new RuntimeException(e);
      }
    }
  });

  return w.toString();
}