cacheRebuildRunner.getOrDefault(cctx.name(),() -> {}).run(); | cacheRebuildRunner.getOrDefault(nodeName(cctx),emptyMap()).getOrDefault(cctx.name(),() -> {}).run(); | cacheRebuildRunner | cacheRebuildRunner.getOrDefault(nodeName(cctx),emptyMap()) | ignite | 43a7a1a14cec08ec1bbe706a57753b7498cc04d2 | org.apache.ignite.internal.processors.cache.index.StopRebuildIndexTest.IndexesRebuildTaskEx | | _1 | cacheRebuildRunner |
---|
_2 | cacheRebuildRunner |
---|
| | | | Uses | False |
super.startRebuild(cctx,rebuildIdxFut,new SchemaIndexCacheVisitorClosure(){ /** * {@inheritDoc} */ @Override public void apply( CacheDataRow row) throws IgniteCheckedException { cacheRowConsumer.getOrDefault(cctx.name(),r -> { }).accept(row); clo.apply(row); }},cancel); | super.startRebuild(cctx,rebuildIdxFut,new SchemaIndexCacheVisitorClosure(){ /** * {@inheritDoc} */ @Override public void apply( CacheDataRow row) throws IgniteCheckedException { cacheRowConsumer.getOrDefault(nodeName(cctx),emptyMap()).getOrDefault(cctx.name(),r -> { }).accept(row); clo.apply(row); }},cancel); | cacheRowConsumer | cacheRowConsumer.getOrDefault(nodeName(cctx),emptyMap()) | ignite | 43a7a1a14cec08ec1bbe706a57753b7498cc04d2 | org.apache.ignite.internal.processors.cache.index.StopRebuildIndexTest.IndexesRebuildTaskEx | | _1 | cacheRowConsumer |
---|
_2 | cacheRowConsumer |
---|
| | | | Uses | False |
cacheRowConsumer.getOrDefault(cctx.name(),r -> {}).accept(row); | cacheRowConsumer.getOrDefault(nodeName(cctx),emptyMap()).getOrDefault(cctx.name(),r -> {}).accept(row); | cacheRowConsumer | cacheRowConsumer.getOrDefault(nodeName(cctx),emptyMap()) | ignite | 43a7a1a14cec08ec1bbe706a57753b7498cc04d2 | org.apache.ignite.internal.processors.cache.index.StopRebuildIndexTest.IndexesRebuildTaskEx | | _1 | cacheRowConsumer |
---|
_2 | cacheRowConsumer |
---|
| | | | Uses | False |