No. of Instances - 665
No. of Commits - 111
No. of Projects - {'pheonix', 'byte-buddy', 'guacamole-client', 'keycloak', 'Lealone', 'cryptomator', 'hadoop', 'Chronicle-Queue', 'aws-sdk-java', 'wildfly', 'pulsar', 'speedment', 'optaplanner', 'jacoco', 'camel', 'tomcat', 'gwt', 'geoserver', 'framework', 'pentaho-kettle', 'che', 'helios', 'sonarqube', 'drill', 'alluxio', 'hbase', 'brave', 'ignite', 'graylog2-server', 'presto', 'uaa', 'james-project', 'jOOQ', 'vert.x', 'orientdb', 'nutz', 'java-driver', 'HikariCP', 'neo4j', 'flink', 'hibernate-orm', 'rapidoid', 'languagetool', 'killbill', 'giraph'}
Hierarchy/Composition: -
Primitive Info: Boxing
NameSpace: Jdk -> Jdk
Mapping:
- 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);
}
}
}
)
- {
@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()));
}
}