public static Schema getBeamSchemaFromProto(String fileDescriptorPath, String messageName) {
    ProtoSchemaInfo dpd = getProtoDomain(fileDescriptorPath, messageName);
    ProtoDomain protoDomain = dpd.getProtoDomain();
    return ProtoDynamicMessageSchema.forDescriptor(protoDomain, messageName).getSchema();
  }
@Test
  public void testProtoSchemaToBeamSchema() {
    Schema schema = ProtoByteUtils.getBeamSchemaFromProto(DESCRIPTOR_PATH, MESSAGE_NAME);
    Assert.assertEquals(schema.getFieldNames(), SCHEMA.getFieldNames());
  }