No. of Instances - 258
No. of Commits - 144
No. of Projects - {'JGroups', 'pheonix', 'jetty.project', 'byte-buddy', 'keycloak', 'Lealone', 'CoreNLP', 'error-prone', 'cryptomator', 'hadoop', 'wildfly', 'pulsar', 'spark', 'redisson', 'camel', 'AxonFramework', 'tomcat', 'gwt', 'j2objc', 'GCViewer', 'framework', 'graphhopper', 'Singularity', 'sonarqube', 'nd4j', 'drill', 'alluxio', 'datumbox-framework', 'hbase', 'OpenTripPlanner', 'ignite', 'presto', 'junit5', 'pinpoint', 'uaa', 'infinispan', 'vert.x', 'orientdb', 'javaparser', 'nutz', 'fastjson', 'neo4j', 'flink', 'guava', 'rapidoid', 'usergrid', 'languagetool', 'giraph'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Jdk -> Jdk
Mapping:
- {
@Override public void call( List<Edge> edges){
final MutationBatch batch=keyspace.prepareMutationBatch();
for ( Edge edge : edges) {
logger.info("Migrating meta for edge {}",edge);
final MutationBatch edgeBatch=edgeMigrationStrategy.getMigration().to().writeEdge(applicationScope,edge);
batch.mergeShallow(edgeBatch);
}
try {
batch.execute();
}
catch ( ConnectionException e) {
throw new RuntimeException("Unable to perform migration",e);
}
final long newCount=counter.addAndGet(edges.size());
observer.update(getVersion(),String.format("Currently running. Rewritten %d edge types",newCount));
}
}
to {
@Override public void call( List<Edge> edges){
final MutationBatch batch=keyspace.prepareMutationBatch();
for ( Edge edge : edges) {
logger.info("Migrating meta for edge {}",edge);
final MutationBatch edgeBatch=migration.to.writeEdge(applicationScope,edge);
batch.mergeShallow(edgeBatch);
}
try {
batch.execute();
}
catch ( ConnectionException e) {
throw new RuntimeException("Unable to perform migration",e);
}
final long newCount=counter.addAndGet(edges.size());
observer.update(migration.to.getImplementationVersion(),String.format("Currently running. Rewritten %d edge types",newCount));
}
}
- {
@Override public Observable call( final Observable<List<Edge>> listObservable){
return listObservable.doOnNext(new Action1<List<Edge>>(){
@Override public void call( List<Edge> edges){
final MutationBatch batch=keyspace.prepareMutationBatch();
for ( Edge edge : edges) {
logger.info("Migrating meta for edge {}",edge);
final MutationBatch edgeBatch=edgeMigrationStrategy.getMigration().to().writeEdge(applicationScope,edge);
batch.mergeShallow(edgeBatch);
}
try {
batch.execute();
}
catch ( ConnectionException e) {
throw new RuntimeException("Unable to perform migration",e);
}
final long newCount=counter.addAndGet(edges.size());
observer.update(getVersion(),String.format("Currently running. Rewritten %d edge types",newCount));
}
}
);
}
}
to {
@Override public Observable call( final Observable<List<Edge>> listObservable){
return listObservable.doOnNext(new Action1<List<Edge>>(){
@Override public void call( List<Edge> edges){
final MutationBatch batch=keyspace.prepareMutationBatch();
for ( Edge edge : edges) {
logger.info("Migrating meta for edge {}",edge);
final MutationBatch edgeBatch=migration.to.writeEdge(applicationScope,edge);
batch.mergeShallow(edgeBatch);
}
try {
batch.execute();
}
catch ( ConnectionException e) {
throw new RuntimeException("Unable to perform migration",e);
}
final long newCount=counter.addAndGet(edges.size());
observer.update(migration.to.getImplementationVersion(),String.format("Currently running. Rewritten %d edge types",newCount));
}
}
);
}
}