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

QueryResult.setSuccess介绍

暂无

代码示例

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

result.setSuccess(true);
result.setSize(entities.size());
return result;

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

result.setSuccess(true);
result.setSize(entities.size());
return result;

代码示例来源：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

queryResult.setSuccess(true);
queryResult.setSize(result.size());

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

result.setEntityType((Class<E>) Map.class);
  result.setSuccess(true);
} catch (Exception e) {
  LOG.error(e.getMessage(), e);

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

result.setSize(entities.size());
  if(!query.isHasAgg()) result.setEntityType((Class<E>) entityDefinition.getEntityClass());
  result.setSuccess(true);
} catch (Exception e) {
  LOG.error(e.getMessage(),e);