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

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

QueryResult.setFirstTimestamp介绍

暂无

代码示例

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

@Override
public QueryResult queryById(List ids, EntityDefinition entityDefinition) throws IOException {
QueryResult result = new QueryResult();
try {
JdbcEntityDefinition jdbcEntityDefinition = JdbcEntityDefinitionManager.getJdbcEntityDefinition(entityDefinition);
JdbcEntityReader reader = new JdbcEntityReaderImpl(jdbcEntityDefinition);
List entities = reader.query(ids);
result.setData(entities);
if(entities!=null) {
result.setSize(entities.size());
}else{
result.setSize(0);
}
result.setEntityType((Class) 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 QueryResult queryById(List ids, EntityDefinition entityDefinition) throws IOException {
QueryResult result = new QueryResult();
try {
JdbcEntityDefinition jdbcEntityDefinition = JdbcEntityDefinitionManager.getJdbcEntityDefinition(entityDefinition);
JdbcEntityReader reader = new JdbcEntityReaderImpl(jdbcEntityDefinition);
List entities = reader.query(ids);
result.setData(entities);
if(entities!=null) {
result.setSize(entities.size());
}else{
result.setSize(0);
}
result.setEntityType((Class) 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 QueryResult query(CompiledQuery query, EntityDefinition entityDefinition) throws IOException {
QueryResult result = new QueryResult();
try {
JdbcEntityDefinition jdbcEntityDefinition = JdbcEntityDefinitionManager.getJdbcEntityDefinition(entityDefinition);
JdbcEntityReader reader = new JdbcEntityReaderImpl(jdbcEntityDefinition);
List entities = reader.query(query);
result.setData(entities);
if(entities!=null) {
result.setSize(entities.size());
}else{
result.setSize(0);
}
if(query.isHasAgg()){
result.setEntityType((Class) Map.class);
}else {
result.setEntityType((Class) 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 QueryResult query(CompiledQuery query, EntityDefinition entityDefinition) throws IOException {
QueryResult result = new QueryResult();
try {
JdbcEntityDefinition jdbcEntityDefinition = JdbcEntityDefinitionManager.getJdbcEntityDefinition(entityDefinition);
JdbcEntityReader reader = new JdbcEntityReaderImpl(jdbcEntityDefinition);
List entities = reader.query(query);
result.setData(entities);
if(entities!=null) {
result.setSize(entities.size());
}else{
result.setSize(0);
}
if(query.isHasAgg()){
result.setEntityType((Class) Map.class);
}else {
result.setEntityType((Class) 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

List entities = reader.result();
result.setData(entities);
result.setFirstTimestamp(reader.getFirstTimeStamp());
result.setLastTimestamp(reader.getLastTimestamp());
result.setSize(entities.size());

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

List entities = reader.result();
result.setData(entities);
result.setFirstTimestamp(reader.getFirstTimeStamp());
result.setLastTimestamp(reader.getLastTimestamp());
result.setSize(entities.size());