org.apache.flink.connector.testframe.utils

Class ConnectorTestConstants

java.lang.Object

org.apache.flink.connector.testframe.utils.ConnectorTestConstants

public class ConnectorTestConstants
extends Object

The default configuration values used in connector tests.

Field Summary

Fields

Modifier and Type	Field and Description
static java.time.Duration	DEFAULT_COLLECT_DATA_TIMEOUT
static long	HEARTBEAT_INTERVAL_MS
static long	HEARTBEAT_TIMEOUT_MS
static long	METRIC_FETCHER_UPDATE_INTERVAL_MS
static long	SLOT_REQUEST_TIMEOUT_MS

Constructor Summary

Constructors

Constructor and Description
ConnectorTestConstants()

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

METRIC_FETCHER_UPDATE_INTERVAL_MS

public static final long METRIC_FETCHER_UPDATE_INTERVAL_MS

See Also:

Constant Field Values

SLOT_REQUEST_TIMEOUT_MS

public static final long SLOT_REQUEST_TIMEOUT_MS

See Also:

Constant Field Values

HEARTBEAT_TIMEOUT_MS

public static final long HEARTBEAT_TIMEOUT_MS

See Also:

Constant Field Values

HEARTBEAT_INTERVAL_MS

public static final long HEARTBEAT_INTERVAL_MS

See Also:

Constant Field Values

DEFAULT_COLLECT_DATA_TIMEOUT

public static final java.time.Duration DEFAULT_COLLECT_DATA_TIMEOUT

Constructor Detail

ConnectorTestConstants

public ConnectorTestConstants()