import org.apache.gora.util.TestIOUtils; //导入依赖的package包/类
/**
 * Creates an WebPage object in-memory setting several fields to dirty. 
 * Run a query over the persistent data.
 * Asserts that the results can be serialized and 
 * deserialzed without loosing data. We do this by asserting
 * what we get 'before' and 'after' (de)serialization processes.
 * Also simple assertion for equal number of URL's in WebPage 
 * and results.
 * @throws Exception
 */
@SuppressWarnings("unchecked")
@Test
public void testSerdeWebPage() throws Exception {

  MemStore<String, WebPage> store = DataStoreFactory.getDataStore(
      MemStore.class, String.class, WebPage.class, new Configuration());
  WebPageDataCreator.createWebPageData(store);

  Result<String, WebPage> result = store.newQuery().execute();

  int i = 0;
  while (result.next()) {
    WebPage page = result.get();
    TestIOUtils.testSerializeDeserialize(page);
    i++;
  }
  assertEquals(WebPageDataCreator.URLS.length, i);
}
 

import org.apache.gora.util.TestIOUtils; //导入依赖的package包/类
/**
 * Creates multiple WebPage objects setting several fields to dirty. 
 * Asserts that the data can be serialized and 
 * deserialzed without loosing data. We do this by asserting
 * what we get 'before' and 'after' (de)serialization processes.
 * @throws Exception
 */
@Test
public void testSerdeMultipleWebPages() throws Exception {
  WebPage page1 = WebPage.newBuilder().build();
  WebPage page2 = WebPage.newBuilder().build();
  WebPage page3 = WebPage.newBuilder().build();

  page1.setUrl(new Utf8("foo"));
  page2.setUrl(new Utf8("baz"));
  page3.setUrl(new Utf8("bar"));
  page1.setParsedContent(new ArrayList<CharSequence>());
  page1.getParsedContent().add(new Utf8("coo"));
  page2.setOutlinks(new HashMap<CharSequence, CharSequence>());
  page2.getOutlinks().put(new Utf8("a"), new Utf8("b"));

  TestIOUtils.testSerializeDeserialize(page1, page2, page3);
}
 

import org.apache.gora.util.TestIOUtils; //导入依赖的package包/类
/**
 * Creates an WebPage object in-memory setting several fields to dirty.
 * Run a query over the persistent data.
 * Asserts that the results can be serialized and
 * deserialzed without loosing data. We do this by asserting
 * what we get 'before' and 'after' (de)serialization processes.
 * Also simple assertion for equal number of URL's in WebPage
 * and results.
 * @throws Exception
 */
@SuppressWarnings("unchecked")
@Test
public void testSerdeWebPage() throws Exception {

  MemStore<String, WebPage> store = DataStoreFactory.getDataStore(
          MemStore.class, String.class, WebPage.class, new Configuration());
  WebPageDataCreator.createWebPageData(store);

  Result<String, WebPage> result = store.newQuery().execute();

  int i = 0;
  while (result.next()) {
    WebPage page = result.get();
    TestIOUtils.testSerializeDeserialize(page);
    i++;
  }
  assertEquals(WebPageDataCreator.URLS.length, i);
}
 

import org.apache.gora.util.TestIOUtils; //导入依赖的package包/类
/**
 * Creates multiple WebPage objects setting several fields to dirty.
 * Asserts that the data can be serialized and
 * deserialzed without loosing data. We do this by asserting
 * what we get 'before' and 'after' (de)serialization processes.
 * @throws Exception
 */
@Test
public void testSerdeMultipleWebPages() throws Exception {
  WebPage page1 = WebPage.newBuilder().build();
  WebPage page2 = WebPage.newBuilder().build();
  WebPage page3 = WebPage.newBuilder().build();

  page1.setUrl(new Utf8("foo"));
  page2.setUrl(new Utf8("baz"));
  page3.setUrl(new Utf8("bar"));
  page1.setParsedContent(new ArrayList<CharSequence>());
  page1.getParsedContent().add(new Utf8("coo"));
  page2.setOutlinks(new HashMap<CharSequence, CharSequence>());
  page2.getOutlinks().put(new Utf8("a"), new Utf8("b"));

  TestIOUtils.testSerializeDeserialize(page1, page2, page3);
}
 

import org.apache.gora.util.TestIOUtils; //导入依赖的package包/类
@SuppressWarnings("unchecked")
@Test
public void testSerdeWebPage() throws Exception {

  MemStore<String, WebPage> store = DataStoreFactory.getDataStore(
      MemStore.class, String.class, WebPage.class, new Configuration());
  WebPageDataCreator.createWebPageData(store);

  Result<String, WebPage> result = store.newQuery().execute();

  int i=0;
  while(result.next()) {
    WebPage page = result.get();
    TestIOUtils.testSerializeDeserialize(page);
    i++;
  }
  Assert.assertEquals(WebPageDataCreator.URLS.length, i);
}
 

import org.apache.gora.util.TestIOUtils; //导入依赖的package包/类
@Test
public void testSerdeMultipleWebPages() throws Exception {
  WebPage page1 = new WebPage();
  WebPage page2 = new WebPage();
  WebPage page3 = new WebPage();

  page1.setUrl(new Utf8("foo"));
  page2.setUrl(new Utf8("baz"));
  page3.setUrl(new Utf8("bar"));

  page1.addToParsedContent(new Utf8("coo"));

  page2.putToOutlinks(new Utf8("a"), new Utf8("b"));

  TestIOUtils.testSerializeDeserialize(page1, page2, page3);
}
 

import org.apache.gora.util.TestIOUtils; //导入依赖的package包/类
@SuppressWarnings("unchecked")
@Test
public void testSerdeWebPage() throws Exception {

  MemStore<String, WebPage> store = DataStoreFactory.getDataStore(
      MemStore.class, String.class, WebPage.class, new Configuration());
  WebPageDataCreator.createWebPageData(store);

  Result<String, WebPage> result = store.newQuery().execute();

  int i=0;
  while(result.next()) {
    WebPage page = result.get();
    TestIOUtils.testSerializeDeserialize(page);
    i++;
  }
  assertEquals(WebPageDataCreator.URLS.length, i);
}
 

import org.apache.gora.util.TestIOUtils; //导入依赖的package包/类
@Test
public void testReadWrite() throws Exception {
  query.setFields(FIELDS);
  query.setKeyRange(START_KEY, END_KEY);
  TestIOUtils.testSerializeDeserialize(query);
  
  assertNotNull(query.getDataStore());
}
 

import org.apache.gora.util.TestIOUtils; //导入依赖的package包/类
/**
 * Creates an Employee object in-memory setting several fields to dirty. 
 * Asserts that it can be serialized and 
 * deserialzed without loosing data. We do this by asserting
 * what we get 'before' and 'after' (de)serialization processes.
 * @throws Exception
 */
@SuppressWarnings("unchecked")
@Test
public void testSerdeEmployee() throws Exception {

  MemStore<String, Employee> store = DataStoreFactory.getDataStore(
      MemStore.class, String.class, Employee.class, new Configuration());

  Employee employee = DataStoreTestUtil.createEmployee(store);

  TestIOUtils.testSerializeDeserialize(employee);
}
 

import org.apache.gora.util.TestIOUtils; //导入依赖的package包/类
/**
 * Creates an Employee object but only sets one field as dirty.
 * We then do (de)serialization and check 'before' and 'after'
 * states. 
 * @throws Exception
 */
@Test
public void testSerdeEmployeeOneField() throws Exception {
  Employee employee = Employee.newBuilder().build();
  employee.setSsn(new Utf8("11111"));

  TestIOUtils.testSerializeDeserialize(employee);
}
 

import org.apache.gora.util.TestIOUtils; //导入依赖的package包/类
/**
 * Creates an Employee object setting only two fields as dirty.
 * We then do (de)serialization and check 'before' and 'after'
 * states. 
 * @throws Exception
 */
@Test
public void testSerdeEmployeeTwoFields() throws Exception {
  Employee employee = Employee.newBuilder().build();
  employee.setSsn(new Utf8("11111"));
  employee.setSalary(100);

  TestIOUtils.testSerializeDeserialize(employee);
}
 

import org.apache.gora.util.TestIOUtils; //导入依赖的package包/类
@Test
public void testQueryMarshability() throws Exception {
   Utils.populateEmployeeStore(employeeStore, 100);
   InfinispanQuery<String,Employee> query = new InfinispanQuery<>(employeeDataStore);
   query.setFields("field");
   query.setLimit(1);
   query.setOffset(1);
   query.build();
   TestIOUtils.testSerializeDeserialize(query);
}
 

import org.apache.gora.util.TestIOUtils; //导入依赖的package包/类
@Test
public void testQueryMarshability() throws Exception {
  Utils.populateEmployeeStore(employeeStore, 100);
  InfinispanQuery<String,Employee> query = new InfinispanQuery<>(employeeDataStore);
  query.setFields("field");
  query.setLimit(1);
  query.setOffset(1);
  query.build();
  TestIOUtils.testSerializeDeserialize(query);
}
 

import org.apache.gora.util.TestIOUtils; //导入依赖的package包/类
/**
 * Creates an Employee object in-memory setting several fields to dirty. 
 * Asserts that it can be serialized and 
 * deserialzed without loosing data. We do this by asserting
 * what we get 'before' and 'after' (de)serialization processes.
 * @throws Exception
 */
@SuppressWarnings("unchecked")
@Test
public void testSerdeEmployee() throws Exception {

  MemStore<String, Employee> store = DataStoreFactory.getDataStore(
          MemStore.class, String.class, Employee.class, new Configuration());

  Employee employee = DataStoreTestUtil.createEmployee();

  TestIOUtils.testSerializeDeserialize(employee);
}
 

import org.apache.gora.util.TestIOUtils; //导入依赖的package包/类
/**
 * Creates an Employee object but only sets one field as dirty.
 * We then do (de)serialization and check 'before' and 'after'
 * states.
 * @throws Exception
 */
@Test
public void testSerdeEmployeeOneField() throws Exception {
  Employee employee = Employee.newBuilder().build();
  employee.setSsn(new Utf8("11111"));

  TestIOUtils.testSerializeDeserialize(employee);
}
 

import org.apache.gora.util.TestIOUtils; //导入依赖的package包/类
/**
 * Creates an Employee object setting only two fields as dirty.
 * We then do (de)serialization and check 'before' and 'after'
 * states.
 * @throws Exception
 */
@Test
public void testSerdeEmployeeTwoFields() throws Exception {
  Employee employee = Employee.newBuilder().build();
  employee.setSsn(new Utf8("11111"));
  employee.setSalary(100);

  TestIOUtils.testSerializeDeserialize(employee);
}
 

import org.apache.gora.util.TestIOUtils; //导入依赖的package包/类
@Test
public void testReadWrite() throws Exception {
  query.setFields(FIELDS);
  query.setKeyRange(START_KEY, END_KEY);
  TestIOUtils.testSerializeDeserialize(query);
  
  Assert.assertNotNull(query.getDataStore());
}
 

import org.apache.gora.util.TestIOUtils; //导入依赖的package包/类
@SuppressWarnings("unchecked")
@Test
public void testSerdeEmployee() throws Exception {

  MemStore<String, Employee> store = DataStoreFactory.getDataStore(
      MemStore.class, String.class, Employee.class, new Configuration());

  Employee employee = DataStoreTestUtil.createEmployee(store);

  TestIOUtils.testSerializeDeserialize(employee);
}
 

import org.apache.gora.util.TestIOUtils; //导入依赖的package包/类
@Test
public void testSerdeEmployeeOneField() throws Exception {
  Employee employee = new Employee();
  employee.setSsn(new Utf8("11111"));

  TestIOUtils.testSerializeDeserialize(employee);
}
 

import org.apache.gora.util.TestIOUtils; //导入依赖的package包/类
@Test
public void testSerdeEmployeeTwoFields() throws Exception {
  Employee employee = new Employee();
  employee.setSsn(new Utf8("11111"));
  employee.setSalary(100);

  TestIOUtils.testSerializeDeserialize(employee);
}