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

QueryResult.<init>介绍

暂无

代码示例

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

public <E> QueryResult<E> queryById(List<String> ids, EntityDefinition entityDefinition) throws IOException {
  List<byte[]> rowkeys = new ArrayList<>(ids.size());
  QueryResult<E> result = new QueryResult<E>();
  for (String id : ids) {
    rowkeys.add(EagleBase64Wrapper.decode(id));

代码示例来源：origin: org.apache.eagle/eagle-storage-hbase

public <E> QueryResult<E> queryById(List<String> ids, EntityDefinition entityDefinition) throws IOException {
  List<byte[]> rowkeys = new ArrayList<>(ids.size());
  QueryResult<E> result = new QueryResult<E>();
  for(String id:ids) rowkeys.add(EagleBase64Wrapper.decode(id));
  RowKeyLogReader reader = null;

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

@Override
public <E> QueryResult<E> queryById(List<String> ids, EntityDefinition entityDefinition) throws IOException {
  QueryResult<E> result = new QueryResult<E>();
  try {
    JdbcEntityDefinition jdbcEntityDefinition =  JdbcEntityDefinitionManager.getJdbcEntityDefinition(entityDefinition);
    JdbcEntityReader reader = new JdbcEntityReaderImpl(jdbcEntityDefinition);
    List<E> entities = reader.query(ids);
    result.setData(entities);
    if(entities!=null) {
      result.setSize(entities.size());
    }else{
      result.setSize(0);
    }
    result.setEntityType((Class<E>) entityDefinition.getEntityClass());
    result.setFirstTimestamp(reader.getResultFirstTimestamp());
    result.setLastTimestamp(reader.getResultLastTimestamp());
    result.setSuccess(true);
  } catch (Exception e) {
    LOG.error(e.getMessage(), e);
    result.setSuccess(false);
    throw new IOException(e.getCause());
  }
  return result;
}

代码示例来源：origin: org.apache.eagle/eagle-storage-jdbc

@Override
public <E> QueryResult<E> queryById(List<String> ids, EntityDefinition entityDefinition) throws IOException {
  QueryResult<E> result = new QueryResult<E>();
  try {
    JdbcEntityDefinition jdbcEntityDefinition =  JdbcEntityDefinitionManager.getJdbcEntityDefinition(entityDefinition);
    JdbcEntityReader reader = new JdbcEntityReaderImpl(jdbcEntityDefinition);
    List<E> entities = reader.query(ids);
    result.setData(entities);
    if(entities!=null) {
      result.setSize(entities.size());
    }else{
      result.setSize(0);
    }
    result.setEntityType((Class<E>) entityDefinition.getEntityClass());
    result.setFirstTimestamp(reader.getResultFirstTimestamp());
    result.setLastTimestamp(reader.getResultLastTimestamp());
    result.setSuccess(true);
  } catch (Exception e) {
    LOG.error(e.getMessage(), e);
    result.setSuccess(false);
    throw new IOException(e.getCause());
  }
  return result;
}

代码示例来源：origin: org.apache.eagle/eagle-storage-jdbc

@Override
@SuppressWarnings("unchecked")
public <E extends Object> QueryResult<E> query(CompiledQuery query, EntityDefinition entityDefinition) throws IOException {
  QueryResult<E> result = new QueryResult<E>();
  try {
    JdbcEntityDefinition jdbcEntityDefinition =  JdbcEntityDefinitionManager.getJdbcEntityDefinition(entityDefinition);
    JdbcEntityReader reader = new JdbcEntityReaderImpl(jdbcEntityDefinition);
    List<E> entities = reader.query(query);
    result.setData(entities);
    if(entities!=null) {
      result.setSize(entities.size());
    }else{
      result.setSize(0);
    }
    if(query.isHasAgg()){
      result.setEntityType((Class<E>) Map.class);
    }else {
      result.setEntityType((Class<E>) entityDefinition.getEntityClass());
    }
    result.setFirstTimestamp(reader.getResultFirstTimestamp());
    result.setLastTimestamp(reader.getResultLastTimestamp());
    result.setSuccess(true);
  } catch (Exception e) {
    LOG.error(e.getMessage(), e);
    result.setSuccess(false);
    throw new IOException(e.getCause());
  }
  return result;
}

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

@Override
@SuppressWarnings("unchecked")
public <E extends Object> QueryResult<E> query(CompiledQuery query, EntityDefinition entityDefinition) throws IOException {
  QueryResult<E> result = new QueryResult<E>();
  try {
    JdbcEntityDefinition jdbcEntityDefinition =  JdbcEntityDefinitionManager.getJdbcEntityDefinition(entityDefinition);
    JdbcEntityReader reader = new JdbcEntityReaderImpl(jdbcEntityDefinition);
    List<E> entities = reader.query(query);
    result.setData(entities);
    if(entities!=null) {
      result.setSize(entities.size());
    }else{
      result.setSize(0);
    }
    if(query.isHasAgg()){
      result.setEntityType((Class<E>) Map.class);
    }else {
      result.setEntityType((Class<E>) entityDefinition.getEntityClass());
    }
    result.setFirstTimestamp(reader.getResultFirstTimestamp());
    result.setLastTimestamp(reader.getResultLastTimestamp());
    result.setSuccess(true);
  } catch (Exception e) {
    LOG.error(e.getMessage(), e);
    result.setSuccess(false);
    throw new IOException(e.getCause());
  }
  return result;
}

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

@Test
public void testGenericEntityServiceResourceSearchFalse() throws IllegalAccessException, InstantiationException, IOException {
  QueryResult<TestTimeSeriesAPIEntity> queryResult = new QueryResult<>();
  queryResult.setSuccess(false);
  List<String> rowkeys = new ArrayList<>();
  rowkeys.add("test");
  EntityDefinition ed = EntityDefinitionManager.getEntityByServiceName("TestTimeSeriesAPIEntity");
  when(dataStorage.queryById(rowkeys, ed)).thenReturn(queryResult);
  GenericServiceAPIResponseEntity responseEntity = resources.client().resource("/entities/rowkey").queryParam("value", "test").queryParam("serviceName", "TestTimeSeriesAPIEntity").get(GenericServiceAPIResponseEntity.class);
  Assert.assertFalse(responseEntity.isSuccess());
  Assert.assertEquals(null, responseEntity.getMeta());
  Assert.assertEquals(null, responseEntity.getType());
  Assert.assertEquals(null, responseEntity.getObj());
  Assert.assertEquals(null, responseEntity.getException());
  verify(dataStorage).queryById(rowkeys, ed);
}

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

e.getTags().put("jobId", "job_2");
result.add(e);
QueryResult<TestTimeSeriesAPIEntity> queryResult = new QueryResult<>();

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

@Override
@SuppressWarnings("unchecked")
public <E extends Object> QueryResult<E> query(CompiledQuery query, EntityDefinition entityDefinition) throws IOException {
  QueryResult<E> result = new QueryResult<E>();
  try {
    GenericQuery reader = GenericQueryBuilder

代码示例来源：origin: org.apache.eagle/eagle-storage-hbase

@SuppressWarnings("unchecked")
public <E extends Object> QueryResult<E> query(CompiledQuery query, EntityDefinition entityDefinition) throws IOException {
  QueryResult<E> result = new QueryResult<E>();
  try {
    GenericQuery reader = GenericQueryBuilder