@Test public void testCreate(){ }
@Override public <E extends TaggedLogAPIEntity> ModifyResult<String> create(List<E> entities, EntityDefinition entityDefinition) throws IOException { ModifyResult<String> result = new ModifyResult<>(); try { GenericEntityWriter entityWriter = new GenericEntityWriter(entityDefinition); result.setIdentifiers(entityWriter.write(entities)); result.setSuccess(true); } catch (Exception e) { LOG.error(e.getMessage(),e); throw new IOException(e); } return result; }
HBaseStorage extends DataStorageBase { @Override public <E extends TaggedLogAPIEntity> ModifyResult<String> create(List<E> entities, EntityDefinition entityDefinition) throws IOException { ModifyResult<String> result = new ModifyResult<>(); try { GenericEntityWriter entityWriter = new GenericEntityWriter(entityDefinition); result.setIdentifiers(entityWriter.write(entities)); result.setSuccess(true); } catch (Exception e) { LOG.error(e.getMessage(),e); throw new IOException(e); } return result; } }
HBaseStorage extends DataStorageBase { @Override public <E extends TaggedLogAPIEntity> ModifyResult<String> create(List<E> entities, EntityDefinition entityDefinition) throws IOException { ModifyResult<String> result = new ModifyResult<>(); try { GenericEntityWriter entityWriter = new GenericEntityWriter(entityDefinition); result.setIdentifiers(entityWriter.write(entities)); result.setSuccess(true); } catch (Exception e) { LOG.error(e.getMessage(),e); throw new IOException(e); } return result; }  }
HBaseStorage extends DataStorageBase { @Override public <E extends TaggedLogAPIEntity> ModifyResult<String> create(List<E> entities, EntityDefinition entityDefinition) throws IOException { ModifyResult<String> result = new ModifyResult<>(); try { GenericEntityWriter entityWriter = new GenericEntityWriter(entityDefinition); result.setIdentifiers(entityWriter.write(entities)); result.setSuccess(true); } catch (Exception e) { LOG.error(e.getMessage(),e); throw new IOException(e); } return result; }  @Override void init(); @Override ModifyResult<String> update(List<E> entities, EntityDefinition entityDefinition); @Override ModifyResult<String> create(List<E> entities, EntityDefinition entityDefinition); @Override ModifyResult<String> delete(List<E> entities, EntityDefinition entityDefinition); @Override ModifyResult<String> deleteByID(List<String> ids, EntityDefinition entityDefinition); @Override ModifyResult<String> delete(CompiledQuery query, EntityDefinition entityDefinition); @Override @SuppressWarnings("unchecked") QueryResult<E> query(CompiledQuery query, EntityDefinition entityDefinition); @Override QueryResult<E> queryById(List<String> ids, EntityDefinition entityDefinition); @Override void close(); }
HBaseStorage extends DataStorageBase { @Override public <E extends TaggedLogAPIEntity> ModifyResult<String> create(List<E> entities, EntityDefinition entityDefinition) throws IOException { ModifyResult<String> result = new ModifyResult<>(); try { GenericEntityWriter entityWriter = new GenericEntityWriter(entityDefinition); result.setIdentifiers(entityWriter.write(entities)); result.setSuccess(true); } catch (Exception e) { LOG.error(e.getMessage(),e); throw new IOException(e); } return result; }  @Override void init(); @Override ModifyResult<String> update(List<E> entities, EntityDefinition entityDefinition); @Override ModifyResult<String> create(List<E> entities, EntityDefinition entityDefinition); @Override ModifyResult<String> delete(List<E> entities, EntityDefinition entityDefinition); @Override ModifyResult<String> deleteByID(List<String> ids, EntityDefinition entityDefinition); @Override ModifyResult<String> delete(CompiledQuery query, EntityDefinition entityDefinition); @Override @SuppressWarnings("unchecked") QueryResult<E> query(CompiledQuery query, EntityDefinition entityDefinition); @Override QueryResult<E> queryById(List<String> ids, EntityDefinition entityDefinition); @Override void close();  }