@Experimental public final class MiniClusterExtension extends Object implements org.junit.jupiter.api.extension.BeforeAllCallback, org.junit.jupiter.api.extension.BeforeEachCallback, org.junit.jupiter.api.extension.AfterEachCallback, org.junit.jupiter.api.extension.AfterAllCallback, org.junit.jupiter.api.extension.ParameterResolver
MiniCluster
and registers the respective ExecutionEnvironment
and
StreamExecutionEnvironment
in the correct thread local environment.
Example usage:
{@code
Constructor and Description |
---|
MiniClusterExtension() |
MiniClusterExtension(MiniClusterResourceConfiguration miniClusterResourceConfiguration) |
MiniClusterExtension(Supplier<MiniClusterResourceConfiguration> miniClusterResourceConfigurationSupplier) |
Modifier and Type | Method and Description |
---|---|
void |
afterAll(org.junit.jupiter.api.extension.ExtensionContext context) |
void |
afterEach(org.junit.jupiter.api.extension.ExtensionContext context) |
void |
beforeAll(org.junit.jupiter.api.extension.ExtensionContext context) |
void |
beforeEach(org.junit.jupiter.api.extension.ExtensionContext context) |
Configuration |
getClientConfiguration() |
Integer |
getNumberSlots() |
TestEnvironment |
getTestEnvironment() |
boolean |
isRunning() |
Object |
resolveParameter(org.junit.jupiter.api.extension.ParameterContext parameterContext,
org.junit.jupiter.api.extension.ExtensionContext extensionContext) |
boolean |
supportsParameter(org.junit.jupiter.api.extension.ParameterContext parameterContext,
org.junit.jupiter.api.extension.ExtensionContext extensionContext) |
public MiniClusterExtension()
public MiniClusterExtension(MiniClusterResourceConfiguration miniClusterResourceConfiguration)
@Experimental public MiniClusterExtension(Supplier<MiniClusterResourceConfiguration> miniClusterResourceConfigurationSupplier)
public boolean supportsParameter(org.junit.jupiter.api.extension.ParameterContext parameterContext, org.junit.jupiter.api.extension.ExtensionContext extensionContext) throws org.junit.jupiter.api.extension.ParameterResolutionException
supportsParameter
in interface org.junit.jupiter.api.extension.ParameterResolver
org.junit.jupiter.api.extension.ParameterResolutionException
public Object resolveParameter(org.junit.jupiter.api.extension.ParameterContext parameterContext, org.junit.jupiter.api.extension.ExtensionContext extensionContext) throws org.junit.jupiter.api.extension.ParameterResolutionException
resolveParameter
in interface org.junit.jupiter.api.extension.ParameterResolver
org.junit.jupiter.api.extension.ParameterResolutionException
public void beforeAll(org.junit.jupiter.api.extension.ExtensionContext context) throws Exception
beforeAll
in interface org.junit.jupiter.api.extension.BeforeAllCallback
Exception
public void beforeEach(org.junit.jupiter.api.extension.ExtensionContext context) throws Exception
beforeEach
in interface org.junit.jupiter.api.extension.BeforeEachCallback
Exception
public void afterEach(org.junit.jupiter.api.extension.ExtensionContext context) throws Exception
afterEach
in interface org.junit.jupiter.api.extension.AfterEachCallback
Exception
public void afterAll(org.junit.jupiter.api.extension.ExtensionContext context) throws Exception
afterAll
in interface org.junit.jupiter.api.extension.AfterAllCallback
Exception
public TestEnvironment getTestEnvironment()
public Configuration getClientConfiguration()
public Integer getNumberSlots()
public boolean isRunning()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.