org.apache.eagle.storage.result.QueryResult.setData()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(5.0k)|赞(0)|评价(0)|浏览(66)

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

QueryResult.setData介绍

暂无

代码示例

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

result.setData((List<E>) entities);
result.setSuccess(true);
result.setSize(entities.size());

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

result.setData((List<E>) entities);
result.setSuccess(true);
result.setSize(entities.size());

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

QueryResult<TestTimeSeriesAPIEntity> queryResult = new QueryResult<>();
queryResult.setData(result);
queryResult.setSuccess(true);
queryResult.setSize(result.size());

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

.build();
List<E> entities = reader.result();
result.setData(entities);
result.setFirstTimestamp(reader.getFirstTimeStamp());
result.setLastTimestamp(reader.getLastTimestamp());

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

.build();
List<E> entities =  reader.result();
result.setData(entities);
result.setFirstTimestamp(reader.getFirstTimeStamp());
result.setLastTimestamp(reader.getLastTimestamp());

相关文章