Ignite SQL线程池查询示例

// 导入相关类
import org.apache.ignite.Ignite;
import org.apache.ignite.IgniteCache;
import org.apache.ignite.Ignition;
import org.apache.ignite.cache.query.SqlFieldsQuery;

// 启动Ignite节点
Ignite ignite = Ignition.start();

// 获取一个Ignite缓存实例
IgniteCache<Integer, String> cache = ignite.getOrCreateCache("myCache");

// 执行SQL查询
SqlFieldsQuery query = new SqlFieldsQuery("SELECT * FROM myCache WHERE age > ?");
query.setArgs(30);

// 获取查询结果
List<List<?>> result = cache.query(query).getAll();

// 处理查询结果
for (List<?> row : result) {
    Integer id = (Integer) row.get(0);
    String name = (String) row.get(1);
    // 处理查询结果...
}

// 关闭Ignite节点
ignite.close();