本文整理了Java中org.apache.avro.Protocol.writeProps()
方法的一些代码示例,展示了Protocol.writeProps()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Protocol.writeProps()
方法的具体详情如下:
包路径:org.apache.avro.Protocol
类名称:Protocol
方法名:writeProps
暂无
代码示例来源:origin: apache/avro
void toJson(JsonGenerator gen) throws IOException {
types.space(namespace);
gen.writeStartObject();
gen.writeStringField("protocol", name);
gen.writeStringField("namespace", namespace);
if (doc != null) gen.writeStringField("doc", doc);
writeProps(gen);
gen.writeArrayFieldStart("types");
Schema.Names resolved = new Schema.Names(namespace);
for (Schema type : types.values())
if (!resolved.contains(type))
type.toJson(resolved, gen);
gen.writeEndArray();
gen.writeObjectFieldStart("messages");
for (Map.Entry<String,Message> e : messages.entrySet()) {
gen.writeFieldName(e.getKey());
e.getValue().toJson(gen);
}
gen.writeEndObject();
gen.writeEndObject();
}
代码示例来源:origin: org.apache.avro/avro
void toJson(JsonGenerator gen) throws IOException {
types.space(namespace);
gen.writeStartObject();
gen.writeStringField("protocol", name);
gen.writeStringField("namespace", namespace);
if (doc != null) gen.writeStringField("doc", doc);
writeProps(gen);
gen.writeArrayFieldStart("types");
Schema.Names resolved = new Schema.Names(namespace);
for (Schema type : types.values())
if (!resolved.contains(type))
type.toJson(resolved, gen);
gen.writeEndArray();
gen.writeObjectFieldStart("messages");
for (Map.Entry<String,Message> e : messages.entrySet()) {
gen.writeFieldName(e.getKey());
e.getValue().toJson(gen);
}
gen.writeEndObject();
gen.writeEndObject();
}
代码示例来源:origin: com.facebook.presto.hive/hive-apache
void toJson(JsonGenerator gen) throws IOException {
types.space(namespace);
gen.writeStartObject();
gen.writeStringField("protocol", name);
gen.writeStringField("namespace", namespace);
if (doc != null) gen.writeStringField("doc", doc);
writeProps(gen);
gen.writeArrayFieldStart("types");
Schema.Names resolved = new Schema.Names(namespace);
for (Schema type : types.values())
if (!resolved.contains(type))
type.toJson(resolved, gen);
gen.writeEndArray();
gen.writeObjectFieldStart("messages");
for (Map.Entry<String,Message> e : messages.entrySet()) {
gen.writeFieldName(e.getKey());
e.getValue().toJson(gen);
}
gen.writeEndObject();
gen.writeEndObject();
}
代码示例来源:origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.avro
void toJson(JsonGenerator gen) throws IOException {
types.space(namespace);
gen.writeStartObject();
gen.writeStringField("protocol", name);
gen.writeStringField("namespace", namespace);
if (doc != null) gen.writeStringField("doc", doc);
writeProps(gen);
gen.writeArrayFieldStart("types");
Schema.Names resolved = new Schema.Names(namespace);
for (Schema type : types.values())
if (!resolved.contains(type))
type.toJson(resolved, gen);
gen.writeEndArray();
gen.writeObjectFieldStart("messages");
for (Map.Entry<String,Message> e : messages.entrySet()) {
gen.writeFieldName(e.getKey());
e.getValue().toJson(gen);
}
gen.writeEndObject();
gen.writeEndObject();
}
内容来源于网络,如有侵权,请联系作者删除!