本文整理了Java中org.apache.eagle.storage.result.QueryResult.setData
方法的一些代码示例,展示了QueryResult.setData
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。QueryResult.setData
方法的具体详情如下:
包路径:org.apache.eagle.storage.result.QueryResult
类名称: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());
内容来源于网络,如有侵权,请联系作者删除!