Toggle navigation
Home
boolean to java.lang.Boolean
No. of Instances - 9
No. of Commits - 4
No. of Projects - {'pulsar'}
Hierarchy/Composition: -
Primitive Info: Boxing
NameSpace: Jdk -> Jdk
Mapping:
Rename Variable
flag
to
expected
flag
to
expected
postCheckAndPut
to
preCheckAndPut
splitOrMergeEnabledSwitch
to
rpcCall
isValid
to
valid
isValid
to
valid
Introduce Literal
true
to
Boolean.TRUE
false
to
endpointDiscoveryEnabled
false
to
endpointDiscoveryEnabled
singleThreadModel
to
null
Add or Remove Method invocation
new Builder().setTimeout(timeout).setParallelism(parallelism).setMigrate(migrate).setToken(token)
to
new Builder().setTimeout(timeout).setParallelism(parallelism).setMigrate(migrate).setOverlap(overlap).setToken(token)
setResult(oserver.postCheckAndPut(ctx,row,family,qualifier,compareOp,comparator,put,getResult()))
to
setResult(oserver.preCheckAndPut(ctx,row,family,qualifier,op,comparator,put,getResult()))
executeCallable
to
get
Boolean.parseBoolean(getProperty(className + ".rotatable","true"))
to
Boolean.valueOf(getProperty(className + ".rotatable","true"))
RowEqualOperator.equals(rowType,leftRow,rightRow)
to
result
afp.process(exchange,new AsyncCallback(){ public void done( boolean sync){ log.trace("Failure processor done: {} processing Exchange: {}",processor,exchange); try { prepareExchangeAfterFailure(processor,exchange,data,isDeadLetterChannel,shouldHandle,shouldContinue); boolean deadLetterChannel=processor == data.deadLetterProcessor; EventHelper.notifyExchangeFailureHandled(exchange.getContext(),exchange,processor,deadLetterChannel); } finally { data.sync&=sync; callback.done(data.sync); } } } )
to
afp.process(exchange,new AsyncCallback(){ public void done( boolean sync){ log.trace("Failure processor done: {} processing Exchange: {}",processor,exchange); try { prepareExchangeAfterFailure(exchange,data,isDeadLetterChannel,shouldHandle,shouldContinue); boolean deadLetterChannel=processor == data.deadLetterProcessor; EventHelper.notifyExchangeFailureHandled(exchange.getContext(),exchange,processor,deadLetterChannel); } finally { data.sync&=sync; callback.done(data.sync); } } } )
Other
endpointDiscoveryEnabled
to
endpointDiscoveryEnabled
endpointDiscoveryEnabled
to
endpointDiscoveryEnabled
singleThreadModel
to
singleThreadModel
Update Anonymous class
{ @Override public void call( RegionObserver oserver, ObserverContext<RegionCoprocessorEnvironment> ctx) throws IOException { setResult(oserver.postCheckAndPut(ctx,row,family,qualifier,compareOp,comparator,put,getResult())); } }
to
{ @Override public void call( RegionObserver oserver, ObserverContext<RegionCoprocessorEnvironment> ctx) throws IOException { setResult(oserver.preCheckAndPut(ctx,row,family,qualifier,op,comparator,put,getResult())); } }
Cascading Type Change (Different)
PipelineRuleParser
to
ConfigurationStateUpdater