org.apache.gora.util.AvroUtils类的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(9.3k)|赞(0)|评价(0)|浏览(114)

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

AvroUtils介绍

[英]An utility class for Avro related tasks.
[中]用于Avro相关任务的实用程序类。

代码示例

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

private Object fromCouchDBEnum(final Schema fieldSchema, final String docf, final Object value) {
 final Object result;
 if (value instanceof Map) {
  result = AvroUtils.getEnumValue(fieldSchema, (String) ((Map) value).get(docf));
 } else {
  result = AvroUtils.getEnumValue(fieldSchema, (String) value);
 }
 return result;
}

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

/**
 * Return the field names from a persistent object.
 * 
 * @param persistent the persistent object to get the fields names from.
 * @return the field names String array.
 */
public static String[] getPersistentFieldNames(PersistentBase persistent) {
 return getSchemaFieldNames(persistent.getSchema());
}

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

/**
 * Returns a clone with exactly the requested fields shallowly copied
 */
private static<T extends PersistentBase> T getPersistent(T obj, String[] fields) {
 List<Field> otherFields = obj.getSchema().getFields();
 String[] otherFieldStrings = new String[otherFields.size()];
 for(int i = 0; i<otherFields.size(); i++ ){
  otherFieldStrings[i] = otherFields.get(i).name();
 }
 if(Arrays.equals(fields, otherFieldStrings)) { 
  return obj;
 }
 T newObj = AvroUtils.deepClonePersistent(obj);
 newObj.clear();
 for (String field : fields) {
  Field otherField = obj.getSchema().getField(field);
  int index = otherField.pos();
  newObj.put(index, obj.get(index));
 }
 return newObj;
}

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

@Override
public void initialize(Class<K> keyClass, Class<T> persistentClass,
    Properties properties) throws GoraException {
 setKeyClass(keyClass);
 setPersistentClass(persistentClass);
 if (this.beanFactory == null) {
  this.beanFactory = new BeanFactoryImpl<>(keyClass, persistentClass);
 }
 schema = this.beanFactory.getCachedPersistent().getSchema();
 fieldMap = AvroUtils.getFieldMap(schema);
 autoCreateSchema = DataStoreFactory.getAutoCreateSchema(properties, this);
 this.properties = properties;
 datumReader = new SpecificDatumReader<>(schema);
 datumWriter = new SpecificDatumWriter<>(schema);
}

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

/**
 * Returns a clone with exactly the requested fields shallowly copied
 */
private static<T extends PersistentBase> T getPersistent(T obj, String[] fields) {
 List<Field> otherFields = obj.getSchema().getFields();
 String[] otherFieldStrings = new String[otherFields.size()];
 for(int i = 0; i<otherFields.size(); i++ ){
  otherFieldStrings[i] = otherFields.get(i).name();
 }
 if(Arrays.equals(fields, otherFieldStrings)) { 
  return obj;
 }
 T newObj = AvroUtils.deepClonePersistent(obj);
 newObj.clear();
 for (String field : fields) {
  Field otherField = obj.getSchema().getField(field);
  int index = otherField.pos();
  newObj.put(index, obj.get(index));
 }
 return newObj;
}

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

@Override
public void initialize(Class<K> keyClass, Class<T> persistentClass,
    Properties properties) {
 setKeyClass(keyClass);
 setPersistentClass(persistentClass);
 if (this.beanFactory == null) {
  this.beanFactory = new BeanFactoryImpl<>(keyClass, persistentClass);
 }
 schema = this.beanFactory.getCachedPersistent().getSchema();
 fieldMap = AvroUtils.getFieldMap(schema);
 autoCreateSchema = DataStoreFactory.getAutoCreateSchema(properties, this);
 this.properties = properties;
 datumReader = new SpecificDatumReader<>(schema);
 datumWriter = new SpecificDatumWriter<>(schema);
}

代码示例来源：origin: org.apache.gora/gora-couchdb

private Object fromCouchDBEnum(final Schema fieldSchema, final String docf, final Object value) {
 final Object result;
 if (value instanceof Map) {
  result = AvroUtils.getEnumValue(fieldSchema, (String) ((Map) value).get(docf));
 } else {
  result = AvroUtils.getEnumValue(fieldSchema, (String) value);
 }
 return result;
}

代码示例来源：origin: org.apache.gora/gora-jcache

private static <T extends PersistentBase> T getPersistent(T persitent, String[] fields) {
 List<Schema.Field> otherFields = persitent.getSchema().getFields();
 String[] otherFieldStrings = new String[otherFields.size()];
 for (int i = 0; i < otherFields.size(); i++) {
  otherFieldStrings[i] = otherFields.get(i).name();
 }
 if (Arrays.equals(fields, otherFieldStrings)) {
  return persitent;
 }
 T clonedPersistent = AvroUtils.deepClonePersistent(persitent);
 clonedPersistent.clear();
 if (fields != null && fields.length > 0) {
  for (String field : fields) {
   Schema.Field otherField = persitent.getSchema().getField(field);
   int index = otherField.pos();
   clonedPersistent.put(index, persitent.get(index));
  }
 } else {
  for (String field : otherFieldStrings) {
   Schema.Field otherField = persitent.getSchema().getField(field);
   int index = otherField.pos();
   clonedPersistent.put(index, persitent.get(index));
  }
 }
 return clonedPersistent;
}

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

/**
 * Return the field names from a persistent object.
 * 
 * @param persistent the persistent object to get the fields names from.
 * @return the field names String array.
 */
public static String[] getPersistentFieldNames(PersistentBase persistent) {
 return getSchemaFieldNames(persistent.getSchema());
}

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

public static Object getEnumValue(Schema schema, int enumOrdinal) {
 String symbol = schema.getEnumSymbols().get(enumOrdinal);
 return getEnumValue(schema, symbol);
}

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

private static <T extends PersistentBase> T getPersistent(T persitent, String[] fields) {
 List<Schema.Field> otherFields = persitent.getSchema().getFields();
 String[] otherFieldStrings = new String[otherFields.size()];
 for (int i = 0; i < otherFields.size(); i++) {
  otherFieldStrings[i] = otherFields.get(i).name();
 }
 if (Arrays.equals(fields, otherFieldStrings)) {
  return persitent;
 }
 T clonedPersistent = AvroUtils.deepClonePersistent(persitent);
 clonedPersistent.clear();
 if (fields != null && fields.length > 0) {
  for (String field : fields) {
   Schema.Field otherField = persitent.getSchema().getField(field);
   int index = otherField.pos();
   clonedPersistent.put(index, persitent.get(index));
  }
 } else {
  for (String field : otherFieldStrings) {
   Schema.Field otherField = persitent.getSchema().getField(field);
   int index = otherField.pos();
   clonedPersistent.put(index, persitent.get(index));
  }
 }
 return clonedPersistent;
}

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

public static void testGetEmployee(DataStore<String, Employee> dataStore)
 throws Exception {
 dataStore.createSchema();
 Employee employee = DataStoreTestUtil.createEmployee();
 String ssn = employee.getSsn().toString();
 dataStore.put(ssn, employee);
 dataStore.flush();
 Employee after = dataStore.get(ssn, AvroUtils.getSchemaFieldNames(Employee.SCHEMA$));
 assertEqualEmployeeObjects(employee, after);
}

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

public static Object getEnumValue(Schema schema, int enumOrdinal) {
 String symbol = schema.getEnumSymbols().get(enumOrdinal);
 return getEnumValue(schema, symbol);
}

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

@Test
public void testDeepClonePersistent() throws Exception {
  CharSequence url = new Utf8("http://gora.apache.org/");
  WebPage.Builder builder = WebPage.newBuilder()
    .setUrl(url)
    .setContent(ByteBuffer.wrap("Gora".getBytes("UTF-8")));
  WebPage webPage = builder.build();
  WebPage clonedWebPage = AvroUtils.deepClonePersistent(webPage);
  assertThat(clonedWebPage, is(notNullValue()));
  assertThat(clonedWebPage.getUrl(), is(equalTo(url)));
  assertThat(clonedWebPage.getContent(), is(notNullValue()));
  String clonedWebPageContent = new String(clonedWebPage.getContent().array(), "UTF-8");
  assertThat(clonedWebPageContent, is(equalTo("Gora")));
}

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

public static void testGetEmployee3UnionField(DataStore<String, Employee> dataStore)
 throws Exception {
 Employee employee = DataStoreTestUtil.createEmployee();
 employee.setBoss(new Utf8("Real boss")) ;
 String ssn = employee.getSsn().toString();
 dataStore.put(ssn, employee);
 dataStore.flush();
 Employee after = dataStore.get(ssn, AvroUtils.getSchemaFieldNames(Employee.SCHEMA$));
 assertEqualEmployeeObjects(employee, after);
 assertEquals("Real boss", after.getBoss().toString()) ;
}

代码示例来源：origin: org.apache.gora/gora-aerospike

result = AvroUtils.getEnumValue(schema, (String) binValue);
break;

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

public static void testGetEmployeeRecursive(DataStore<String, Employee> dataStore)
 throws Exception {
 Employee employee = DataStoreTestUtil.createEmployee();
 Employee boss = DataStoreTestUtil.createBoss();
 employee.setBoss(boss);
 
 String ssn = employee.getSsn().toString();
 dataStore.put(ssn, employee);
 dataStore.flush();
 Employee after = dataStore.get(ssn, AvroUtils.getSchemaFieldNames(Employee.SCHEMA$));
 assertEqualEmployeeObjects(employee, after);
}

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

result = org.apache.gora.util.AvroUtils.getEnumValue(schema, (String) value);
break;

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

public static void testGetEmployeeNested(DataStore<String, Employee> dataStore)
 throws Exception {
 Employee employee = DataStoreTestUtil.createEmployee();
 WebPage webpage = new BeanFactoryImpl<>(String.class,WebPage.class).newPersistent() ;
 
 webpage.setUrl(new Utf8("url..")) ;
 webpage.setContent(ByteBuffer.wrap("test content".getBytes(Charset.defaultCharset()))) ;
 webpage.setParsedContent(new ArrayList<CharSequence>());
 Metadata metadata = new BeanFactoryImpl<>(String.class,Metadata.class).newPersistent();
 webpage.setMetadata(metadata) ;
 employee.setWebpage(webpage) ;
 
 String ssn = employee.getSsn().toString();
  dataStore.put(ssn, employee);
 dataStore.flush();
 Employee after = dataStore.get(ssn, AvroUtils.getSchemaFieldNames(Employee.SCHEMA$));
 assertEqualEmployeeObjects(employee, after);
 assertEqualWebPageObjects(webpage, after.getWebpage());
}

代码示例来源：origin: org.apache.gora/gora-cassandra

result = org.apache.gora.util.AvroUtils.getEnumValue(schema, (String) value);
break;

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

AvroUtils

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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