in zookeeper-jute/src/main/java/org/apache/jute/compiler/JRecord.java [421:603]
public void genJavaCode(File outputDirectory) throws IOException {
String pkg = getJavaPackage();
String pkgpath = pkg.replaceAll("\\.", "/");
File pkgdir = new File(outputDirectory, pkgpath);
if (!pkgdir.exists()) {
// create the pkg directory
if (!pkgdir.mkdirs()) {
throw new IOException("Cannot create directory: " + pkgpath);
}
} else if (!pkgdir.isDirectory()) {
throw new IOException(pkgpath + " is not a directory.");
}
try (FileWriter jj = new FileWriter(new File(pkgdir, getName() + ".java"))) {
jj.write("// File generated by hadoop record compiler. Do not edit.\n");
jj.write("/**\n");
jj.write("* Licensed to the Apache Software Foundation (ASF) under one\n");
jj.write("* or more contributor license agreements. See the NOTICE file\n");
jj.write("* distributed with this work for additional information\n");
jj.write("* regarding copyright ownership. The ASF licenses this file\n");
jj.write("* to you under the Apache License, Version 2.0 (the\n");
jj.write("* \"License\"); you may not use this file except in compliance\n");
jj.write("* with the License. You may obtain a copy of the License at\n");
jj.write("*\n");
jj.write("* http://www.apache.org/licenses/LICENSE-2.0\n");
jj.write("*\n");
jj.write("* Unless required by applicable law or agreed to in writing, software\n");
jj.write("* distributed under the License is distributed on an \"AS IS\" BASIS,\n");
jj.write("* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n");
jj.write("* See the License for the specific language governing permissions and\n");
jj.write("* limitations under the License.\n");
jj.write("*/\n");
jj.write("\n");
jj.write("package " + getJavaPackage() + ";\n\n");
jj.write("import org.apache.jute.*;\n");
jj.write("import org.apache.jute.Record; // JDK14 needs explicit import due to clash with java.lang.Record\n");
jj.write("import org.apache.yetus.audience.InterfaceAudience;\n");
String recordComments = getRecordComments();
if (recordComments != null && !recordComments.isEmpty()) {
jj.write(recordComments);
}
jj.write("@InterfaceAudience.Public\n");
jj.write("public class " + getName() + " implements Record {\n");
for (Iterator<JField> i = mFields.iterator(); i.hasNext(); ) {
JField jf = i.next();
String fieldComments = getJavaFieldComments(jf);
if (fieldComments != null && !fieldComments.isEmpty()) {
jj.write(fieldComments);
}
jj.write(jf.genJavaDecl());
}
jj.write(" public " + getName() + "() {\n");
jj.write(" }\n");
jj.write(" public " + getName() + "(\n");
int fIdx = 0;
int fLen = mFields.size();
for (Iterator<JField> i = mFields.iterator(); i.hasNext(); fIdx++) {
JField jf = i.next();
jj.write(jf.genJavaConstructorParam(jf.getName()));
jj.write((fLen - 1 == fIdx) ? "" : ",\n");
}
jj.write(") {\n");
fIdx = 0;
for (Iterator<JField> i = mFields.iterator(); i.hasNext(); fIdx++) {
JField jf = i.next();
jj.write(jf.genJavaConstructorSet(jf.getName()));
}
jj.write(" }\n");
fIdx = 0;
for (Iterator<JField> i = mFields.iterator(); i.hasNext(); fIdx++) {
JField jf = i.next();
jj.write(jf.genJavaGetSet(fIdx));
}
jj.write(" public void serialize(OutputArchive a_, String tag) throws java.io.IOException {\n");
jj.write(" a_.startRecord(this,tag);\n");
fIdx = 0;
for (Iterator<JField> i = mFields.iterator(); i.hasNext(); fIdx++) {
JField jf = i.next();
jj.write(jf.genJavaWriteMethodName());
}
jj.write(" a_.endRecord(this,tag);\n");
jj.write(" }\n");
jj.write(" public void deserialize(InputArchive a_, String tag) throws java.io.IOException {\n");
jj.write(" a_.startRecord(tag);\n");
fIdx = 0;
for (Iterator<JField> i = mFields.iterator(); i.hasNext(); fIdx++) {
JField jf = i.next();
jj.write(jf.genJavaReadMethodName());
}
jj.write(" a_.endRecord(tag);\n");
jj.write("}\n");
jj.write(" public String toString() {\n");
jj.write(" try {\n");
jj.write(" java.io.ByteArrayOutputStream s =\n");
jj.write(" new java.io.ByteArrayOutputStream();\n");
jj.write(" ToStringOutputArchive a_ = \n");
jj.write(" new ToStringOutputArchive(s);\n");
jj.write(" a_.startRecord(this,\"\");\n");
fIdx = 0;
for (Iterator<JField> i = mFields.iterator(); i.hasNext(); fIdx++) {
JField jf = i.next();
jj.write(jf.genJavaWriteMethodName());
}
jj.write(" a_.endRecord(this,\"\");\n");
jj.write(" return new String(s.toByteArray(), java.nio.charset.StandardCharsets.UTF_8);\n");
jj.write(" } catch (Throwable ex) {\n");
jj.write(" ex.printStackTrace();\n");
jj.write(" }\n");
jj.write(" return \"ERROR\";\n");
jj.write(" }\n");
jj.write(" public void write(java.io.DataOutput out) throws java.io.IOException {\n");
jj.write(" BinaryOutputArchive archive = new BinaryOutputArchive(out);\n");
jj.write(" serialize(archive, \"\");\n");
jj.write(" }\n");
jj.write(" public void readFields(java.io.DataInput in) throws java.io.IOException {\n");
jj.write(" BinaryInputArchive archive = new BinaryInputArchive(in);\n");
jj.write(" deserialize(archive, \"\");\n");
jj.write(" }\n");
jj.write(" public int compareTo (Object peer_) throws ClassCastException {\n");
boolean unimplemented = false;
for (JField f : mFields) {
if ((f.getType() instanceof JMap)
|| (f.getType() instanceof JVector)) {
unimplemented = true;
}
}
if (unimplemented) {
jj.write(" throw new UnsupportedOperationException(\"comparing "
+ getName() + " is unimplemented\");\n");
} else {
jj.write(" if (!(peer_ instanceof " + getName() + ")) {\n");
jj.write(" throw new ClassCastException(\"Comparing different types of records.\");\n");
jj.write(" }\n");
jj.write(" " + getName() + " peer = (" + getName() + ") peer_;\n");
jj.write(" int ret = 0;\n");
for (Iterator<JField> i = mFields.iterator(); i.hasNext(); fIdx++) {
JField jf = i.next();
jj.write(jf.genJavaCompareTo());
jj.write(" if (ret != 0) return ret;\n");
}
jj.write(" return ret;\n");
}
jj.write(" }\n");
jj.write(" public boolean equals(Object peer_) {\n");
jj.write(" if (!(peer_ instanceof " + getName() + ")) {\n");
jj.write(" return false;\n");
jj.write(" }\n");
jj.write(" if (peer_ == this) {\n");
jj.write(" return true;\n");
jj.write(" }\n");
jj.write(" " + getName() + " peer = (" + getName() + ") peer_;\n");
jj.write(" boolean ret = false;\n");
for (Iterator<JField> i = mFields.iterator(); i.hasNext(); fIdx++) {
JField jf = i.next();
jj.write(jf.genJavaEquals());
jj.write(" if (!ret) return ret;\n");
}
jj.write(" return ret;\n");
jj.write(" }\n");
jj.write(" public int hashCode() {\n");
jj.write(" int result = 17;\n");
jj.write(" int ret;\n");
for (Iterator<JField> i = mFields.iterator(); i.hasNext(); fIdx++) {
JField jf = i.next();
jj.write(jf.genJavaHashCode());
jj.write(" result = 37*result + ret;\n");
}
jj.write(" return result;\n");
jj.write(" }\n");
jj.write(" public static String signature() {\n");
jj.write(" return \"" + getSignature() + "\";\n");
jj.write(" }\n");
jj.write("}\n");
}
}