Toggle navigation
Home
org.apache.ignite.cache.query.FieldsQueryCursor to java.util.List
No. of Instances - 7
No. of Commits - 2
No. of Projects - {'ignite'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Jdk
Mapping:
Cascading Type Change (Similar)
FieldsQueryCursor<List<?>>
to
List<FieldsQueryCursor<List<?>>>
IgniteOutClosureX<FieldsQueryCursor<List<?>>>
to
IgniteOutClosureX<List<FieldsQueryCursor<List<?>>>>
FieldsQueryCursor<List<?>>
to
List<FieldsQueryCursor<List<?>>>
Rename Variable
cur
to
cursors
qryCursor
to
qryCursors
qryCursor
to
qryCursors
qryCursor
to
qryCursors
Update Anonymous class
{ @Override public FieldsQueryCursor<List<?>> applyx() throws IgniteCheckedException { GridQueryCancel cancel=new GridQueryCancel(); FieldsQueryCursor<List<?>> cur; if (cctx.config().getQueryParallelism() > 1) { qry.setDistributedJoins(true); cur=idx.queryDistributedSqlFields(schemaName,qry,keepBinary,cancel,mainCacheId,true).get(0); } else { IndexingQueryFilter filter=idx.backupFilter(requestTopVer.get(),qry.getPartitions()); cur=idx.queryLocalSqlFields(schemaName,qry,keepBinary,filter,cancel); } sendQueryExecutedEvent(qry.getSql(),qry.getArgs(),cctx.name()); return cur; } }
to
{ @Override public List<FieldsQueryCursor<List<?>>> applyx() throws IgniteCheckedException { GridQueryCancel cancel=new GridQueryCancel(); List<FieldsQueryCursor<List<?>>> cursors; if (cctx.config().getQueryParallelism() > 1) { qry.setDistributedJoins(true); cursors=idx.queryDistributedSqlFields(schemaName,qry,keepBinary,cancel,mainCacheId,true); } else { IndexingQueryFilter filter=idx.backupFilter(requestTopVer.get(),qry.getPartitions()); cursors=new ArrayList<>(1); cursors.add(idx.queryLocalSqlFields(schemaName,qry,keepBinary,filter,cancel)); } sendQueryExecutedEvent(qry.getSql(),qry.getArgs(),cctx.name()); return cursors; } }
Add or Remove Method invocation
ignite.context().query().querySqlFieldsNoCache(qry,true)
to
ignite.context().query().querySqlFieldsNoCache(qry,true,false)
c.withKeepBinary().query(qry)
to
((IgniteCacheProxy)c.withKeepBinary()).queryMultipleStatements(qry)