Package io.openlineage.client.circuitBreaker
package io.openlineage.client.circuitBreaker
-
ClassDescriptionNon-closing circuit breaker which always runs callable.Static circuit breaker used mainly for the integration tests.Queues every openlineage task for execution by a bounded threadpool to prevent creation of too many threads (unlike cachedthreadpool) and resulting impact on the spark job.