Java 类org.codehaus.jackson.map.ObjectReader 实例源码

项目：dcs-sdk-java 文件：Directive.java

@Override
public Directive deserialize(JsonParser jp, DeserializationContext ctx)
        throws IOException {
    ObjectReader reader = ObjectMapperUtil.instance().getObjectReader();
    ObjectNode obj = (ObjectNode) reader.readTree(jp);
    Iterator<Map.Entry<String, JsonNode>> elementsIterator = obj.getFields();

    String rawMessage = obj.toString();
    DialogRequestIdHeader header = null;
    JsonNode payloadNode = null;
    ObjectReader headerReader =
            ObjectMapperUtil.instance().getObjectReader(DialogRequestIdHeader.class);
    while (elementsIterator.hasNext()) {
        Map.Entry<String, JsonNode> element = elementsIterator.next();
        if (element.getKey().equals("header")) {
            header = headerReader.readValue(element.getValue());
        }
        if (element.getKey().equals("payload")) {
            payloadNode = element.getValue();
        }
    }
    if (header == null) {
        throw ctx.mappingException("Missing header");
    }
    if (payloadNode == null) {
        throw ctx.mappingException("Missing payload");
    }

    return createDirective(header, payloadNode, rawMessage);
}

项目：hadoop 文件：JsonUtil.java

public static List<String> toXAttrNames(final Map<?, ?> json)
    throws IOException {
  if (json == null) {
    return null;
  }

  final String namesInJson = (String) json.get("XAttrNames");
  ObjectReader reader = new ObjectMapper().reader(List.class);
  final List<Object> xattrs = reader.readValue(namesInJson);
  final List<String> names =
    Lists.newArrayListWithCapacity(json.keySet().size());

  for (Object xattr : xattrs) {
    names.add((String) xattr);
  }
  return names;
}

项目：hadoop 文件：TestJsonUtil.java

@Test
public void testHdfsFileStatus() throws IOException {
  final long now = Time.now();
  final String parent = "/dir";
  final HdfsFileStatus status = new HdfsFileStatus(1001L, false, 3, 1L << 26,
      now, now + 10, new FsPermission((short) 0644), "user", "group",
      DFSUtil.string2Bytes("bar"), DFSUtil.string2Bytes("foo"),
      INodeId.GRANDFATHER_INODE_ID, 0, null, (byte) 0);
  final FileStatus fstatus = toFileStatus(status, parent);
  System.out.println("status  = " + status);
  System.out.println("fstatus = " + fstatus);
  final String json = JsonUtil.toJsonString(status, true);
  System.out.println("json    = " + json.replace(",", ",\n  "));
  ObjectReader reader = new ObjectMapper().reader(Map.class);
  final HdfsFileStatus s2 =
      JsonUtil.toFileStatus((Map<?, ?>) reader.readValue(json), true);
  final FileStatus fs2 = toFileStatus(s2, parent);
  System.out.println("s2      = " + s2);
  System.out.println("fs2     = " + fs2);
  Assert.assertEquals(fstatus, fs2);
}

项目：hadoop 文件：TestJsonUtil.java

@Test
public void testToAclStatus() throws IOException {
  String jsonString =
      "{\"AclStatus\":{\"entries\":[\"user::rwx\",\"user:user1:rw-\",\"group::rw-\",\"other::r-x\"],\"group\":\"supergroup\",\"owner\":\"testuser\",\"stickyBit\":false}}";
  ObjectReader reader = new ObjectMapper().reader(Map.class);
  Map<?, ?> json = reader.readValue(jsonString);

  List<AclEntry> aclSpec =
      Lists.newArrayList(aclEntry(ACCESS, USER, ALL),
          aclEntry(ACCESS, USER, "user1", READ_WRITE),
          aclEntry(ACCESS, GROUP, READ_WRITE),
          aclEntry(ACCESS, OTHER, READ_EXECUTE));

  AclStatus.Builder aclStatusBuilder = new AclStatus.Builder();
  aclStatusBuilder.owner("testuser");
  aclStatusBuilder.group("supergroup");
  aclStatusBuilder.addEntries(aclSpec);
  aclStatusBuilder.stickyBit(false);

  Assert.assertEquals("Should be equal", aclStatusBuilder.build(),
      JsonUtil.toAclStatus(json));
}

项目：hadoop 文件：TestJsonUtil.java

@Test
public void testToXAttrMap() throws IOException {
  String jsonString = 
      "{\"XAttrs\":[{\"name\":\"user.a1\",\"value\":\"0x313233\"}," +
      "{\"name\":\"user.a2\",\"value\":\"0x313131\"}]}";
  ObjectReader reader = new ObjectMapper().reader(Map.class);
  Map<?, ?> json = reader.readValue(jsonString);
  XAttr xAttr1 = (new XAttr.Builder()).setNameSpace(XAttr.NameSpace.USER).
      setName("a1").setValue(XAttrCodec.decodeValue("0x313233")).build();
  XAttr xAttr2 = (new XAttr.Builder()).setNameSpace(XAttr.NameSpace.USER).
      setName("a2").setValue(XAttrCodec.decodeValue("0x313131")).build();
  List<XAttr> xAttrs = Lists.newArrayList();
  xAttrs.add(xAttr1);
  xAttrs.add(xAttr2);
  Map<String, byte[]> xAttrMap = XAttrHelper.buildXAttrMap(xAttrs);
  Map<String, byte[]> parsedXAttrMap = JsonUtil.toXAttrs(json);

  Assert.assertEquals(xAttrMap.size(), parsedXAttrMap.size());
  Iterator<Entry<String, byte[]>> iter = xAttrMap.entrySet().iterator();
  while(iter.hasNext()) {
    Entry<String, byte[]> entry = iter.next();
    Assert.assertArrayEquals(entry.getValue(), 
        parsedXAttrMap.get(entry.getKey()));
  }
}

项目：aliyun-oss-hadoop-fs 文件：JsonUtilClient.java

static List<String> toXAttrNames(final Map<?, ?> json)
    throws IOException {
  if (json == null) {
    return null;
  }

  final String namesInJson = (String) json.get("XAttrNames");
  ObjectReader reader = new ObjectMapper().reader(List.class);
  final List<Object> xattrs = reader.readValue(namesInJson);
  final List<String> names =
      Lists.newArrayListWithCapacity(json.keySet().size());

  for (Object xattr : xattrs) {
    names.add((String) xattr);
  }
  return names;
}

项目：aliyun-oss-hadoop-fs 文件：TestJsonUtil.java

@Test
public void testHdfsFileStatus() throws IOException {
  final long now = Time.now();
  final String parent = "/dir";
  final HdfsFileStatus status = new HdfsFileStatus(1001L, false, 3, 1L << 26,
      now, now + 10, new FsPermission((short) 0644), "user", "group",
      DFSUtil.string2Bytes("bar"), DFSUtil.string2Bytes("foo"),
      HdfsConstants.GRANDFATHER_INODE_ID, 0, null, (byte) 0, null);
  final FileStatus fstatus = toFileStatus(status, parent);
  System.out.println("status  = " + status);
  System.out.println("fstatus = " + fstatus);
  final String json = JsonUtil.toJsonString(status, true);
  System.out.println("json    = " + json.replace(",", ",\n  "));
  ObjectReader reader = new ObjectMapper().reader(Map.class);
  final HdfsFileStatus s2 =
      JsonUtilClient.toFileStatus((Map<?, ?>) reader.readValue(json), true);
  final FileStatus fs2 = toFileStatus(s2, parent);
  System.out.println("s2      = " + s2);
  System.out.println("fs2     = " + fs2);
  Assert.assertEquals(fstatus, fs2);
}

项目：aliyun-oss-hadoop-fs 文件：TestJsonUtil.java

@Test
public void testToAclStatus() throws IOException {
  String jsonString =
      "{\"AclStatus\":{\"entries\":[\"user::rwx\",\"user:user1:rw-\",\"group::rw-\",\"other::r-x\"],\"group\":\"supergroup\",\"owner\":\"testuser\",\"stickyBit\":false}}";
  ObjectReader reader = new ObjectMapper().reader(Map.class);
  Map<?, ?> json = reader.readValue(jsonString);

  List<AclEntry> aclSpec =
      Lists.newArrayList(aclEntry(ACCESS, USER, ALL),
          aclEntry(ACCESS, USER, "user1", READ_WRITE),
          aclEntry(ACCESS, GROUP, READ_WRITE),
          aclEntry(ACCESS, OTHER, READ_EXECUTE));

  AclStatus.Builder aclStatusBuilder = new AclStatus.Builder();
  aclStatusBuilder.owner("testuser");
  aclStatusBuilder.group("supergroup");
  aclStatusBuilder.addEntries(aclSpec);
  aclStatusBuilder.stickyBit(false);

  Assert.assertEquals("Should be equal", aclStatusBuilder.build(),
      JsonUtilClient.toAclStatus(json));
}

项目：aliyun-oss-hadoop-fs 文件：TestJsonUtil.java

@Test
public void testToXAttrMap() throws IOException {
  String jsonString = 
      "{\"XAttrs\":[{\"name\":\"user.a1\",\"value\":\"0x313233\"}," +
      "{\"name\":\"user.a2\",\"value\":\"0x313131\"}]}";
  ObjectReader reader = new ObjectMapper().reader(Map.class);
  Map<?, ?> json = reader.readValue(jsonString);
  XAttr xAttr1 = (new XAttr.Builder()).setNameSpace(XAttr.NameSpace.USER).
      setName("a1").setValue(XAttrCodec.decodeValue("0x313233")).build();
  XAttr xAttr2 = (new XAttr.Builder()).setNameSpace(XAttr.NameSpace.USER).
      setName("a2").setValue(XAttrCodec.decodeValue("0x313131")).build();
  List<XAttr> xAttrs = Lists.newArrayList();
  xAttrs.add(xAttr1);
  xAttrs.add(xAttr2);
  Map<String, byte[]> xAttrMap = XAttrHelper.buildXAttrMap(xAttrs);
  Map<String, byte[]> parsedXAttrMap = JsonUtilClient.toXAttrs(json);

  Assert.assertEquals(xAttrMap.size(), parsedXAttrMap.size());
  Iterator<Entry<String, byte[]>> iter = xAttrMap.entrySet().iterator();
  while(iter.hasNext()) {
    Entry<String, byte[]> entry = iter.next();
    Assert.assertArrayEquals(entry.getValue(), 
        parsedXAttrMap.get(entry.getKey()));
  }
}

项目：big-c 文件：JsonUtil.java

public static List<String> toXAttrNames(final Map<?, ?> json)
    throws IOException {
  if (json == null) {
    return null;
  }

  final String namesInJson = (String) json.get("XAttrNames");
  ObjectReader reader = new ObjectMapper().reader(List.class);
  final List<Object> xattrs = reader.readValue(namesInJson);
  final List<String> names =
    Lists.newArrayListWithCapacity(json.keySet().size());

  for (Object xattr : xattrs) {
    names.add((String) xattr);
  }
  return names;
}

项目：big-c 文件：TestJsonUtil.java

@Test
public void testHdfsFileStatus() throws IOException {
  final long now = Time.now();
  final String parent = "/dir";
  final HdfsFileStatus status = new HdfsFileStatus(1001L, false, 3, 1L << 26,
      now, now + 10, new FsPermission((short) 0644), "user", "group",
      DFSUtil.string2Bytes("bar"), DFSUtil.string2Bytes("foo"),
      INodeId.GRANDFATHER_INODE_ID, 0, null, (byte) 0);
  final FileStatus fstatus = toFileStatus(status, parent);
  System.out.println("status  = " + status);
  System.out.println("fstatus = " + fstatus);
  final String json = JsonUtil.toJsonString(status, true);
  System.out.println("json    = " + json.replace(",", ",\n  "));
  ObjectReader reader = new ObjectMapper().reader(Map.class);
  final HdfsFileStatus s2 =
      JsonUtil.toFileStatus((Map<?, ?>) reader.readValue(json), true);
  final FileStatus fs2 = toFileStatus(s2, parent);
  System.out.println("s2      = " + s2);
  System.out.println("fs2     = " + fs2);
  Assert.assertEquals(fstatus, fs2);
}

项目：big-c 文件：TestJsonUtil.java

@Test
public void testToAclStatus() throws IOException {
  String jsonString =
      "{\"AclStatus\":{\"entries\":[\"user::rwx\",\"user:user1:rw-\",\"group::rw-\",\"other::r-x\"],\"group\":\"supergroup\",\"owner\":\"testuser\",\"stickyBit\":false}}";
  ObjectReader reader = new ObjectMapper().reader(Map.class);
  Map<?, ?> json = reader.readValue(jsonString);

  List<AclEntry> aclSpec =
      Lists.newArrayList(aclEntry(ACCESS, USER, ALL),
          aclEntry(ACCESS, USER, "user1", READ_WRITE),
          aclEntry(ACCESS, GROUP, READ_WRITE),
          aclEntry(ACCESS, OTHER, READ_EXECUTE));

  AclStatus.Builder aclStatusBuilder = new AclStatus.Builder();
  aclStatusBuilder.owner("testuser");
  aclStatusBuilder.group("supergroup");
  aclStatusBuilder.addEntries(aclSpec);
  aclStatusBuilder.stickyBit(false);

  Assert.assertEquals("Should be equal", aclStatusBuilder.build(),
      JsonUtil.toAclStatus(json));
}

项目：big-c 文件：TestJsonUtil.java

@Test
public void testToXAttrMap() throws IOException {
  String jsonString = 
      "{\"XAttrs\":[{\"name\":\"user.a1\",\"value\":\"0x313233\"}," +
      "{\"name\":\"user.a2\",\"value\":\"0x313131\"}]}";
  ObjectReader reader = new ObjectMapper().reader(Map.class);
  Map<?, ?> json = reader.readValue(jsonString);
  XAttr xAttr1 = (new XAttr.Builder()).setNameSpace(XAttr.NameSpace.USER).
      setName("a1").setValue(XAttrCodec.decodeValue("0x313233")).build();
  XAttr xAttr2 = (new XAttr.Builder()).setNameSpace(XAttr.NameSpace.USER).
      setName("a2").setValue(XAttrCodec.decodeValue("0x313131")).build();
  List<XAttr> xAttrs = Lists.newArrayList();
  xAttrs.add(xAttr1);
  xAttrs.add(xAttr2);
  Map<String, byte[]> xAttrMap = XAttrHelper.buildXAttrMap(xAttrs);
  Map<String, byte[]> parsedXAttrMap = JsonUtil.toXAttrs(json);

  Assert.assertEquals(xAttrMap.size(), parsedXAttrMap.size());
  Iterator<Entry<String, byte[]>> iter = xAttrMap.entrySet().iterator();
  while(iter.hasNext()) {
    Entry<String, byte[]> entry = iter.next();
    Assert.assertArrayEquals(entry.getValue(), 
        parsedXAttrMap.get(entry.getKey()));
  }
}

项目：community-edition-old 文件：JacksonHelper.java

/**
 * Constructs the object based on the content as a List, the JSON can be an array or just a single value without the [] symbols
 * @param content Reader
 * @return A collection of the specified type
 * @throws IOException
 */
public <T> List<T> constructList(Reader content, Class<T> requiredType) throws IOException, JsonMappingException, JsonParseException
{
    ObjectReader reader = objectMapper.reader(TypeFactory.defaultInstance().constructParametricType(List.class, requiredType));
    try
    {
        List<T> toReturn = reader.readValue(content);
        if (toReturn == null || toReturn.isEmpty())
        {
          throw new InvalidArgumentException("Could not read content from HTTP request body, the list is empty");
        }
        return toReturn;
    }
    catch (IOException error)
    {
        throw new InvalidArgumentException("Could not read content from HTTP request body: "+error.getMessage());
    }
}

项目：helix 文件：TestTopStateHandoffMetrics.java

private Object[][] loadInputData(String inputEntry) {
  Object[][] inputData = null;
  InputStream inputStream = getClass().getClassLoader().getResourceAsStream(TEST_INPUT_FILE);

  try {
    ObjectReader mapReader = new ObjectMapper().reader(Map.class);
    Map<String, Object> inputMaps = mapReader.readValue(inputStream);

    List<Map<String, Object>> inputs = (List<Map<String, Object>>) inputMaps.get(inputEntry);
    inputData = new Object[inputs.size()][];
    for (int i = 0; i < inputs.size(); i++) {
      Map<String, Map<String, String>> intialCurrentStates =
          (Map<String, Map<String, String>>) inputs.get(i).get(INITIAL_CURRENT_STATES);
      Map<String, Map<String, String>> handoffCurrentStates =
          (Map<String, Map<String, String>>) inputs.get(i).get(HANDOFF_CURRENT_STATES);
      Long expectedDuration = Long.parseLong((String) inputs.get(i).get(EXPECTED_DURATION));

      inputData[i] = new Object[] { intialCurrentStates, handoffCurrentStates, expectedDuration };
    }
  } catch (IOException e) {
    e.printStackTrace();
  }

  return inputData;
}

项目：helix 文件：TestInputLoader.java

public static Object[][] loadTestInputs(String inputFile, String[] params) {
  List<Object[]> data = new ArrayList<Object[]>();
  InputStream inputStream = TestInputLoader.class.getClassLoader().getResourceAsStream(inputFile);
  try {
    ObjectReader mapReader = new ObjectMapper().reader(Map[].class);
    Map[] inputs = mapReader.readValue(inputStream);

    for (Map input : inputs) {
      Object[] objects = new Object[params.length];
      for (int i = 0; i < params.length; i++) {
        objects[i] = input.get(params[i]);
      }
      data.add(objects);
    }
  } catch (IOException e) {
    e.printStackTrace();
  }

  Object[][] ret = new Object[data.size()][];
  for(int i = 0; i < data.size(); i++) {
    ret[i] = data.get(i);
  }
  return ret;
}

项目：testForceDotComCanvas 文件：SignedRequest.java

public static CanvasRequest verifyAndDecode(String input, String secret) throws SecurityException {

        String[] split = getParts(input);

        String encodedSig = split[0];
        String encodedEnvelope = split[1];

        // Deserialize the json body
        String json_envelope = new String(new Base64(true).decode(encodedEnvelope));
        ObjectMapper mapper = new ObjectMapper();
        ObjectReader reader = mapper.reader(CanvasRequest.class);
        CanvasRequest canvasRequest;
        String algorithm;
        try {
            canvasRequest = reader.readValue(json_envelope);
            algorithm = canvasRequest.getAlgorithm() == null ? "HMACSHA256" : canvasRequest.getAlgorithm();
        } catch (IOException e) {
            throw new SecurityException(String.format("Error [%s] deserializing JSON to Object [%s]", e.getMessage(), CanvasRequest.class.getName()), e);
        }

        verify(secret, algorithm, encodedEnvelope, encodedSig);

        // If we got this far, then the request was not tampered with.
        // return the request as a Java object
        return canvasRequest;
    }

项目：hadoop 文件：TestJsonUtil.java

@Test
public void testGetXAttrFromJson() throws IOException {
  String jsonString = 
      "{\"XAttrs\":[{\"name\":\"user.a1\",\"value\":\"0x313233\"}," +
      "{\"name\":\"user.a2\",\"value\":\"0x313131\"}]}";
  ObjectReader reader = new ObjectMapper().reader(Map.class);
  Map<?, ?> json = reader.readValue(jsonString);

  // Get xattr: user.a2
  byte[] value = JsonUtil.getXAttr(json, "user.a2");
  Assert.assertArrayEquals(XAttrCodec.decodeValue("0x313131"), value);
}

项目：aliyun-oss-hadoop-fs 文件：TestJsonUtil.java

@Test
public void testGetXAttrFromJson() throws IOException {
  String jsonString = 
      "{\"XAttrs\":[{\"name\":\"user.a1\",\"value\":\"0x313233\"}," +
      "{\"name\":\"user.a2\",\"value\":\"0x313131\"}]}";
  ObjectReader reader = new ObjectMapper().reader(Map.class);
  Map<?, ?> json = reader.readValue(jsonString);

  // Get xattr: user.a2
  byte[] value = JsonUtilClient.getXAttr(json, "user.a2");
  Assert.assertArrayEquals(XAttrCodec.decodeValue("0x313131"), value);
}

项目：big-c 文件：TestJsonUtil.java

@Test
public void testGetXAttrFromJson() throws IOException {
  String jsonString = 
      "{\"XAttrs\":[{\"name\":\"user.a1\",\"value\":\"0x313233\"}," +
      "{\"name\":\"user.a2\",\"value\":\"0x313131\"}]}";
  ObjectReader reader = new ObjectMapper().reader(Map.class);
  Map<?, ?> json = reader.readValue(jsonString);

  // Get xattr: user.a2
  byte[] value = JsonUtil.getXAttr(json, "user.a2");
  Assert.assertArrayEquals(XAttrCodec.decodeValue("0x313131"), value);
}

项目：apex-core 文件：StringCodec.java

@Override
public T fromString(String string)
{
  try {
    ObjectMapper mapper = new ObjectMapper();
    mapper.configure(DeserializationConfig.Feature.FAIL_ON_UNKNOWN_PROPERTIES, false);
    ObjectReader reader = mapper.reader(clazz);
    return reader.readValue(string);
  } catch (IOException e) {
    throw Throwables.propagate(e);
  }
}

项目：apex-malhar 文件：ZKAssistedDiscovery.java

JacksonInstanceSerializer(ObjectReader objectReader, ObjectWriter objectWriter,
    TypeReference<ServiceInstance<T>> typeRef)
{
  this.objectReader = objectReader;
  this.objectWriter = objectWriter;
  this.typeRef = typeRef;
}

项目：Megh 文件：ZKAssistedDiscovery.java

JacksonInstanceSerializer(ObjectReader objectReader, ObjectWriter objectWriter,
    TypeReference<ServiceInstance<T>> typeRef)
{
  this.objectReader = objectReader;
  this.objectWriter = objectWriter;
  this.typeRef = typeRef;
}

项目：community-edition-old 文件：JacksonHelper.java

/**
 * Constructs the object based on the content.
 * @param content Reader
 * @return T
 * @throws IOException
 */
public <T> T construct(Reader content, Class<T> requiredType) throws IOException, JsonMappingException, JsonParseException
{
        ObjectReader reader = objectMapper.reader(requiredType);
        try
        {
            return reader.readValue(content);
        }
        catch (IOException error)
        {
            throw new InvalidArgumentException("Could not read content from HTTP request body: "+error.getMessage());
        }
}

项目：helix 文件：StateTransitionThrottleConfig.java

/**
 * Instantiate a throttle config from a config JSON string.
 *
 * @param configJsonStr
 * @return StateTransitionThrottleConfig or null if the given configs map is not a valid StateTransitionThrottleConfig.
 */
public static StateTransitionThrottleConfig fromJSON(String configJsonStr) {
  StateTransitionThrottleConfig throttleConfig = null;
  try {
    ObjectReader objectReader = OBJECT_MAPPER.reader(Map.class);
    Map<String, String> configsMap = objectReader.readValue(configJsonStr);
    throttleConfig = fromConfigMap(configsMap);
  } catch (IOException e) {
    logger.error("Failed to convert JSON string to config map! " + configJsonStr);
  }

  return throttleConfig;
}

项目：helix 文件：TestZeroReplicaAvoidance.java

public List<Object[]> loadTestInputs(String fileName) {
  List<Object[]> ret = null;
  InputStream inputStream = getClass().getClassLoader().getResourceAsStream(fileName);
  try {
    ObjectReader mapReader = new ObjectMapper().reader(Map.class);
    Map<String, Object> inputMaps = mapReader.readValue(inputStream);
    String stateModelName = (String) inputMaps.get(STATE_MODEL);

    StateModelDefinition stateModelDef =
        BuiltInStateModelDefinitions.valueOf(stateModelName).getStateModelDefinition();

    List<Map<String, Object>> inputs = (List<Map<String, Object>>) inputMaps.get(INPUT);
    ret = new ArrayList<Object[]>();
    for (Map<String, Object> inMap : inputs) {
      Map<String, String> currentStates = (Map<String, String>) inMap.get(CURRENT_STATE);
      Map<String, String> bestPossibleStates =
          (Map<String, String>) inMap.get(BEST_POSSIBLE_STATE);
      List<String> preferenceList = (List<String>) inMap.get(PREFERENCE_LIST);

      ret.add(new Object[] { stateModelDef, preferenceList, currentStates, bestPossibleStates });
    }
  } catch (IOException e) {
    e.printStackTrace();
  }

  return ret;
}

项目：inflection 文件：InflectionTest.java

@Test
public void testProxies() throws Throwable
{
    Person person = createTestPerson();

    FullTaxonomy_Person fullTaxonomyPerson = Inflection.cast( FullTaxonomy_Person.class, person );
    UseCase1_Person useCase1Person = Inflection.cast( UseCase1_Person.class, person );
    UseCase2_Person useCase2Person = Inflection.cast( UseCase2_Person.class, person );
    UseCase3_Person useCase3Person = Inflection.cast( UseCase3_Person.class, person );
    UseCase4_Address useCase4Address = Inflection.cast( UseCase4_Address.class, person.getAddresses().get( 0 ) );
    UseCase5_Person useCase5Person = Inflection.cast( UseCase5_Person.class, person );

    ObjectMapper mapper = new ObjectMapper();
    ObjectWriter writer = mapper.writerWithDefaultPrettyPrinter();
    ObjectReader reader = mapper.reader().withType( FullTaxonomy_Person.class );

    reader.readValue( writer.writeValueAsString( fullTaxonomyPerson ) );

    printStream.println( "FullTaxonomy_Person:" );
    printStream.println( writer.writeValueAsString( fullTaxonomyPerson ) );
    printStream.println();
    printStream.println( "UseCase1_Person:" );
    printStream.println( writer.writeValueAsString( useCase1Person ) );
    printStream.println();
    printStream.println( "UseCase2_Person:" );
    printStream.println( writer.writeValueAsString( useCase2Person ) );
    printStream.println();
    printStream.println( "UseCase3_Person:" );
    printStream.println( writer.writeValueAsString( useCase3Person ) );
    printStream.println();
    printStream.println( "UseCase4_Address:" );
    printStream.println( writer.writeValueAsString( useCase4Address ) );
    printStream.println();
    printStream.println( "UseCase5_Person:" );
    printStream.println( writer.writeValueAsString( useCase5Person ) );
    printStream.println();
}

项目：dcs-sdk-java 文件：ObjectMapperUtil.java

public ObjectReader getObjectReader() {
    return objectMapper.reader();
}

项目：dcs-sdk-java 文件：ObjectMapperUtil.java

public ObjectReader getObjectReader(Class<?> clazz) {
    return objectMapper.reader().withType(clazz);
}

项目：apex-malhar 文件：ZKAssistedDiscovery.java

InstanceSerializerFactory(ObjectReader objectReader, ObjectWriter objectWriter)
{
  this.objectReader = objectReader;
  this.objectWriter = objectWriter;
}

项目：Megh 文件：ZKAssistedDiscovery.java

InstanceSerializerFactory(ObjectReader objectReader, ObjectWriter objectWriter)
{
  this.objectReader = objectReader;
  this.objectWriter = objectWriter;
}