Toggle navigation
Home
? to java.lang.Boolean
No. of Instances - 13
No. of Commits - 5
No. of Projects - {'ignite', 'flink'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: TypeVariable -> Jdk
Mapping:
Cascading Type Change (Different)
IgniteInClosure<IgniteInternalFuture<?>>
to
IgniteInClosure<IgniteInternalFuture<Boolean>>
Update Anonymous class
{ @Override public void apply( IgniteInternalFuture<?> fut){ try { fut.get(); AffinityTopologyVersion topVer0=ctx.affinity().affinityTopologyVersion(); if (topVer0.equals(topVer)) opFut.onDone(); else removeAllAsync(opFut,topVer0); } catch ( ClusterGroupEmptyCheckedException ignore) { if (log.isDebugEnabled()) log.debug("All remote nodes left while cache remove [cacheName=" + name() + "]"); opFut.onDone(); } catch ( IgniteCheckedException e) { opFut.onDone(e); } catch ( Error e) { opFut.onDone(e); throw e; } } }
to
{ @Override public void apply( IgniteInternalFuture<Boolean> fut){ try { boolean retry=!fut.get(); AffinityTopologyVersion topVer0=ctx.affinity().affinityTopologyVersion(); if (topVer0.equals(topVer) && !retry) opFut.onDone(); else removeAllAsync(opFut,topVer0,skipStore); } catch ( ClusterGroupEmptyCheckedException ignore) { if (log.isDebugEnabled()) log.debug("All remote nodes left while cache remove [cacheName=" + name() + "]"); opFut.onDone(); } catch ( IgniteCheckedException e) { opFut.onDone(e); } catch ( Error e) { opFut.onDone(e); throw e; } } }
Rename Variable
rmvFut
to
rmvAll