org.apache.avro.Protocol.writeProps()方法的使用及代码示例

x33g5p2x  于2022-01-26 转载在 其他  
字(3.1k)|赞(0)|评价(0)|浏览(90)

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

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();
}

相关文章