Skip to content

Commit

Permalink
Remove CompatExecutionMonitor
Browse files Browse the repository at this point in the history
  • Loading branch information
s1ck committed Feb 15, 2024
1 parent f100de4 commit 874731d
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 103 deletions.

This file was deleted.

Original file line number Diff line number Diff line change
Expand Up @@ -45,7 +45,6 @@
import org.neo4j.internal.batchimport.input.InputEntityVisitor;
import org.neo4j.internal.batchimport.input.ReadableGroups;
import org.neo4j.internal.batchimport.staging.ExecutionMonitor;
import org.neo4j.internal.batchimport.staging.StageExecution;
import org.neo4j.internal.helpers.HostnamePort;
import org.neo4j.internal.id.IdGenerator;
import org.neo4j.internal.id.IdGeneratorFactory;
Expand Down Expand Up @@ -113,7 +112,6 @@
import java.util.Locale;
import java.util.Optional;
import java.util.Set;
import java.util.concurrent.TimeUnit;
import java.util.function.Function;
import java.util.stream.Stream;

Expand Down Expand Up @@ -652,39 +650,6 @@ public static RecordFormats recordFormatSelector(
);
}

public static ExecutionMonitor executionMonitor(CompatExecutionMonitor compatExecutionMonitor) {
return new ExecutionMonitor.Adapter(
compatExecutionMonitor.checkIntervalMillis(),
TimeUnit.MILLISECONDS
) {

@Override
public void initialize(DependencyResolver dependencyResolver) {
compatExecutionMonitor.initialize(dependencyResolver);
}

@Override
public void start(StageExecution execution) {
compatExecutionMonitor.start(execution);
}

@Override
public void end(StageExecution execution, long totalTimeMillis) {
compatExecutionMonitor.end(execution, totalTimeMillis);
}

@Override
public void done(boolean successful, long totalTimeMillis, String additionalInformation) {
compatExecutionMonitor.done(successful, totalTimeMillis, additionalInformation);
}

@Override
public void check(StageExecution execution) {
compatExecutionMonitor.check(execution);
}
};
}

public static UserFunctionSignature userFunctionSignature(
QualifiedName name,
List<FieldSignature> inputSignature,
Expand Down

0 comments on commit 874731d

Please sign in to comment.