org.apache.tinkerpop.shaded.jackson.databind.ObjectMapper类的使用及代码示例

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

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

ObjectMapper介绍

暂无

代码示例

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

  1. @Test
  2. @LoadGraphWith(LoadGraphWith.GraphData.MODERN)
  3. public void shouldSerializeVertex() throws Exception {
  4.   final ObjectMapper mapper = graph.io(GraphSONIo.build(GraphSONVersion.V1_0)).mapper().version(GraphSONVersion.V1_0).create().createMapper();
  5.   final Vertex v = graph.vertices(convertToVertexId("marko")).next();
  6.   final String json = mapper.writeValueAsString(v);
  7.   final Map<String, Object> m = mapper.readValue(json, mapTypeReference);
  8.   assertEquals(GraphSONTokens.VERTEX, m.get(GraphSONTokens.TYPE));
  9.   assertEquals(v.label(), m.get(GraphSONTokens.LABEL));
  10.   assertNotNull(m.get(GraphSONTokens.ID));
  11.   final Map<String,List<Map<String,Object>>> properties = (Map<String,List<Map<String,Object>>>) m.get(GraphSONTokens.PROPERTIES);
  12.   assertEquals(v.value("name").toString(), properties.get("name").get(0).get(GraphSONTokens.VALUE).toString());
  13.   assertEquals((Integer) v.value("age"), properties.get("age").get(0).get(GraphSONTokens.VALUE));
  14.   assertEquals(1, properties.get("name").size());
  15.   assertEquals(1, properties.get("age").size());
  16.   assertEquals(2, properties.size());
  17. }

代码示例来源：origin: JanusGraph/janusgraph

  1. private T parse(String json){
  2.   try {
  3.     return jsonType.cast(OBJECT_MAPPER.readTree(json));
  4.   } catch (IOException e) {
  5.     throw new JsonNodeParseException(e);
  6.   }
  7. }

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

  1. @Override
  2. public ByteBuf serializeResponseAsBinary(final ResponseMessage responseMessage, final ByteBufAllocator allocator) throws SerializationException {
  3.   ByteBuf encodedMessage = null;
  4.   try {
  5.     final byte[] payload = mapper.writeValueAsBytes(responseMessage);
  6.     encodedMessage = allocator.buffer(payload.length);
  7.     encodedMessage.writeBytes(payload);
  8.     return encodedMessage;
  9.   } catch (Exception ex) {
  10.     if (encodedMessage != null) ReferenceCountUtil.release(encodedMessage);
  11.     logger.warn(String.format("Response [%s] could not be serialized by %s.", responseMessage, AbstractGraphSONMessageSerializerV2d0.class.getName()), ex);
  12.     throw new SerializationException(ex);
  13.   }
  14. }

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

  1. /**
  2.  * {@inheritDoc}
  3.  */
  4. @Override
  5. public <C> C readObject(final InputStream inputStream, final Class<? extends C> clazz) throws IOException {
  6.   return mapper.readValue(inputStream, clazz);
  7. }

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

  1. @Override
  2. public String serializeResponseAsString(final ResponseMessage responseMessage) throws SerializationException {
  3.   try {
  4.     return mapper.writeValueAsString(responseMessage);
  5.   } catch (Exception ex) {
  6.     logger.warn(String.format("Response [%s] could not be serialized by %s.", responseMessage.toString(), GraphSONMessageSerializerV3d0.class.getName()), ex);
  7.     throw new SerializationException(ex);
  8.   }
  9. }

代码示例来源：origin: unipop-graph/unipop

  1. private void reloadContexts() throws IOException {
  2.   SQLDialect dialect = SQLDialect.valueOf(this.conf.getString("sqlDialect"));
  3.   BasicDataSource ds = new BasicDataSource();
  4.   ds.setUrl(new ObjectMapper()
  5.       .readValue(conf.getJSONArray("address").toString(), List.class).get(0).toString());
  6.   ds.setDriverClassName(conf.getString("driver"));
  7.   String user = conf.optString("user");
  8.   String password = conf.optString("password");
  9.   if (!user.isEmpty()) ds.setUsername(user);
  10.   if (!password.isEmpty()) ds.setPassword(password);
  11.   Settings settings = new Settings();
  12.   settings.setRenderNameStyle(RenderNameStyle.AS_IS);
  13.   Configuration conf = new DefaultConfiguration().set(ds).set(dialect)
  14.       .set(settings)
  15.       .set(new DefaultExecuteListenerProvider(new TimingExecuterListener()));
  16.   this.context = DSL.using(conf);
  17. }

代码示例来源：origin: unipop-graph/unipop

  1. @Override
  2. public List<E> parseResults(List<String> resultList, PredicateQuery query) {
  3.   List<E> results = new ArrayList<>();
  4.   for( String result : resultList)
  5.     try {
  6.       JsonNode hits = mapper.readTree(result).get("hits").get("hits");
  7.       for (JsonNode hit : hits) {
  8.         Map<String, Object> source = hit.has("_source") ? mapper.readValue(hit.get("_source").toString(), Map.class) : new HashMap<>();
  9.         Document document = new Document(hit.get("_index").asText(), hit.get("_type").asText(), hit.get("_id").asText(), source);
  10.         Collection<E> elements = fromDocument(document);
  11.         if(elements != null) {
  12.           elements.forEach(element -> {
  13.             if(element != null && query.test(element, query.getPredicates()))
  14.               results.add(element);
  15.           });
  16.         }
  17.       }
  18.     }
  19.     catch (IOException e) {
  20.       e.printStackTrace();
  21.     }
  22.   return results;
  23. }
  24. public List<E> parseResultsOptimized(List<JsonElement> hits, PredicateQuery query) {

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

  1. @Override
  2. public ObjectMapper createMapper() {
  3.   final ObjectMapper om = new ObjectMapper();
  4.   om.disable(SerializationFeature.FAIL_ON_EMPTY_BEANS);
  5.   om.registerModule(graphSONModule);
  6.   customModules.forEach(om::registerModule);
  7.     om.findAndRegisterModules();
  8.     om.setDefaultTyping(typer);
  9.   } else if (version == GraphSONVersion.V1_0 || version == GraphSONVersion.V2_0) {
  10.     if (typeInfo == TypeInfo.PARTIAL_TYPES) {
  11.           .inclusion(JsonTypeInfo.As.PROPERTY)
  12.           .typeProperty(GraphSONTokens.CLASS);
  13.       om.setDefaultTyping(typer);
  14.   om.setSerializerProvider(provider);
  15.     om.enable(SerializationFeature.ORDER_MAP_ENTRIES_BY_KEYS);
  16.   om.getFactory().disable(JsonGenerator.Feature.AUTO_CLOSE_TARGET);
  17.   return om;

代码示例来源：origin: org.janusgraph/janusgraph-es

  1. @Override
  2. public RestSearchResponse search(String indexName, String type, Map<String,Object> request, boolean useScroll) throws IOException {
  3.   final StringBuilder path = new StringBuilder(REQUEST_SEPARATOR).append(indexName);
  4.   if (!Strings.isNullOrEmpty(type)) {
  5.     path.append(REQUEST_SEPARATOR).append(type);
  6.   }
  7.   path.append(REQUEST_SEPARATOR).append("_search");
  8.   if (useScroll) path.append(REQUEST_PARAM_BEGINNING).append("scroll=").append(scrollKeepAlive);
  9.   final byte[] requestData = mapper.writeValueAsBytes(request);
  10.   if (log.isDebugEnabled()) {
  11.     log.debug("Elasticsearch request: " + mapper.writerWithDefaultPrettyPrinter().writeValueAsString(request));
  12.   }
  13.   final Response response = performRequest(REQUEST_TYPE_POST, path.toString(), requestData);
  14.   try (final InputStream inputStream = response.getEntity().getContent()) {
  15.     return mapper.readValue(inputStream, RestSearchResponse.class);
  16.   }
  17. }

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

  1. writer.writeGraph(baos, graph);
  2. final JsonNode jsonGraph = new ObjectMapper().readTree(baos.toByteArray());
  3. final JsonNode idValue = jsonGraph.get(GraphSONTokens.ID);
  4. assertTrue(idValue.has("cluster"));

代码示例来源：origin: synchrony/smsn

  1. public static ObjectMapper createObjectMapper() {
  2.   // add any configuration here
  3.   return new ObjectMapper();
  4. }

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

  1. final Graph.Features.VertexFeatures vertexFeatures = graphToWriteTo.features().vertex();
  2. final JsonFactory factory = mapper.getFactory();
  3. final LegacyGraphSONUtility graphson = new LegacyGraphSONUtility(graphToWriteTo, vertexFeatures, edgeFeatures, cache);

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

  1. @Override
  2. public ResponseMessage deserializeResponse(final String msg) throws SerializationException {
  3.   try {
  4.     return mapper.readValue(msg, ResponseMessage.class);
  5.   } catch (Exception ex) {
  6.     logger.warn("Response [{}] could not be deserialized by {}.", msg, AbstractGraphSONMessageSerializerV2d0.class.getName());
  7.     throw new SerializationException(ex);
  8.   }
  9. }

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

  1. @Override
  2.   public String serializeRequestAsString(final RequestMessage requestMessage) throws SerializationException {
  3.     try {
  4.       return mapper.writeValueAsString(requestMessage);
  5.     } catch (Exception ex) {
  6.       logger.warn(String.format("Request [%s] could not be serialized by %s.", requestMessage.toString(), GraphSONMessageSerializerV3d0.class.getName()), ex);
  7.       throw new SerializationException(ex);
  8.     }
  9.   }
  10. }

代码示例来源：origin: HuygensING/timbuctoo

  1. ObjectMapper mapper = new ObjectMapper();
  2. GraphTraversalSource traversalSource = graphManager.getGraph().traversal();
  3. traversalSource
  4.  .forEachRemaining(vertex -> {
  5.   try {
  6.    String[] types = mapper.readValue(vertex.<String>value("types"), String[].class);
  7.    for (String type : types) {
  8.     if (TYPES_TO_IGNORE.contains(type)) {

代码示例来源：origin: org.apache.tinkerpop/gremlin-core

  1. @Override
  2. public ObjectMapper createMapper() {
  3.   final ObjectMapper om = new ObjectMapper();
  4.   om.disable(SerializationFeature.FAIL_ON_EMPTY_BEANS);
  5.   om.registerModule(graphSONModule);
  6.   customModules.forEach(om::registerModule);
  7.     om.findAndRegisterModules();
  8.     om.setDefaultTyping(typer);
  9.   } else if (version == GraphSONVersion.V1_0 || version == GraphSONVersion.V2_0) {
  10.     if (typeInfo == TypeInfo.PARTIAL_TYPES) {
  11.           .inclusion(JsonTypeInfo.As.PROPERTY)
  12.           .typeProperty(GraphSONTokens.CLASS);
  13.       om.setDefaultTyping(typer);
  14.   om.setSerializerProvider(provider);
  15.     om.enable(SerializationFeature.ORDER_MAP_ENTRIES_BY_KEYS);
  16.   om.getFactory().disable(JsonGenerator.Feature.AUTO_CLOSE_TARGET);
  17.   return om;

代码示例来源：origin: org.janusgraph/janusgraph-es

  1. @Override
  2. public RestSearchResponse search(String scrollId) throws IOException {
  3.   final String path;
  4.   final byte[] requestData;
  5.   if (ElasticMajorVersion.ONE == majorVersion) {
  6.      path = REQUEST_SEPARATOR + "_search" + REQUEST_SEPARATOR + "scroll" + REQUEST_PARAM_BEGINNING + "scroll=" + scrollKeepAlive;
  7.      requestData = scrollId.getBytes(UTF8_CHARSET);
  8.   } else {
  9.     path = REQUEST_SEPARATOR + "_search" + REQUEST_SEPARATOR + "scroll";
  10.     final Map<String, Object> request = new HashMap<>();
  11.     request.put("scroll", scrollKeepAlive);
  12.     request.put("scroll_id", scrollId);
  13.     requestData = mapper.writeValueAsBytes(request);
  14.     if (log.isDebugEnabled()) {
  15.       log.debug("Elasticsearch request: " + mapper.writerWithDefaultPrettyPrinter().writeValueAsString(request));
  16.     }
  17.   }
  18.   final Response response = performRequest(REQUEST_TYPE_POST, path, requestData);
  19.   try (final InputStream inputStream = response.getEntity().getContent()) {
  20.     return mapper.readValue(inputStream, RestSearchResponse.class);
  21.   }
  22. }

代码示例来源：origin: org.apache.tinkerpop/gremlin-test

  1. writer.writeGraph(baos, graph);
  2. final JsonNode jsonGraph = new ObjectMapper().readTree(baos.toByteArray());
  3. final JsonNode idValue = jsonGraph.get(GraphSONTokens.ID);
  4. assertTrue(idValue.has("cluster"));

代码示例来源：origin: HuygensING/timbuctoo

  1. public ChangeRangeFacetDescription(String facetName, String propertyName) {
  2.  super(facetName, propertyName, new ChangeRangeFacetGetter(), new LocalPropertyValueGetter());
  3.  objectMapper = new ObjectMapper();
  4. }

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

  1. final JsonFactory factory    = mapper.getFactory();

内容来源于网络，如有侵权，请联系作者删除！

ObjectMapper

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com