Uses of Class
org.apache.flink.annotation.VisibleForTesting

Packages that use VisibleForTesting

Package	Description
org.apache.flink.api.common.functions.util
org.apache.flink.api.java.typeutils.runtime
org.apache.flink.api.java.typeutils.runtime.kryo
org.apache.flink.cep.nfa
org.apache.flink.cep.nfa.sharedbuffer
org.apache.flink.changelog.fs
org.apache.flink.client.program.rest
org.apache.flink.configuration
org.apache.flink.connector.base.source.reader.fetcher
org.apache.flink.connector.base.source.reader.synchronization
org.apache.flink.connector.datagen.table
org.apache.flink.connector.file.sink.compactor.operator
org.apache.flink.connectors.hive
org.apache.flink.connectors.hive.read
org.apache.flink.contrib.streaming.state
org.apache.flink.core.fs
org.apache.flink.core.fs.local
org.apache.flink.core.memory
org.apache.flink.core.plugin
org.apache.flink.docs.util
org.apache.flink.formats.csv
org.apache.flink.formats.parquet
org.apache.flink.kubernetes.kubeclient
org.apache.flink.kubernetes.kubeclient.decorators
org.apache.flink.kubernetes.kubeclient.resources
org.apache.flink.orc
org.apache.flink.orc.shim
org.apache.flink.orc.writer
org.apache.flink.python.env
org.apache.flink.python.util
org.apache.flink.queryablestate.network
org.apache.flink.runtime.blob
org.apache.flink.runtime.checkpoint
org.apache.flink.runtime.checkpoint.channel
org.apache.flink.runtime.checkpoint.filemerging
org.apache.flink.runtime.checkpoint.metadata
org.apache.flink.runtime.clusterframework	This package contains the cluster resource management functionality.
org.apache.flink.runtime.clusterframework.types
org.apache.flink.runtime.deployment
org.apache.flink.runtime.dispatcher
org.apache.flink.runtime.dispatcher.cleanup
org.apache.flink.runtime.entrypoint
org.apache.flink.runtime.executiongraph
org.apache.flink.runtime.executiongraph.failover.flip1
org.apache.flink.runtime.executiongraph.failover.flip1.partitionrelease
org.apache.flink.runtime.highavailability
org.apache.flink.runtime.highavailability.nonha.embedded
org.apache.flink.runtime.io.disk
org.apache.flink.runtime.io.network
org.apache.flink.runtime.io.network.api.writer
org.apache.flink.runtime.io.network.buffer
org.apache.flink.runtime.io.network.metrics
org.apache.flink.runtime.io.network.netty
org.apache.flink.runtime.io.network.partition
org.apache.flink.runtime.io.network.partition.consumer
org.apache.flink.runtime.jobgraph
org.apache.flink.runtime.jobgraph.tasks
org.apache.flink.runtime.jobmanager
org.apache.flink.runtime.jobmaster
org.apache.flink.runtime.jobmaster.slotpool
org.apache.flink.runtime.leaderelection
org.apache.flink.runtime.leaderretrieval
org.apache.flink.runtime.memory
org.apache.flink.runtime.messages.checkpoint	This package contains the messages that are sent between JobMaster and TaskExecutor to coordinate the checkpoint snapshots of the distributed dataflow.
org.apache.flink.runtime.messages.webmonitor	This package contains the actor messages that are sent between the JobManager and components that are interested in the status of the JobManager.
org.apache.flink.runtime.metrics
org.apache.flink.runtime.metrics.groups
org.apache.flink.runtime.minicluster
org.apache.flink.runtime.net
org.apache.flink.runtime.operators.coordination
org.apache.flink.runtime.persistence
org.apache.flink.runtime.query
org.apache.flink.runtime.resourcemanager
org.apache.flink.runtime.resourcemanager.active
org.apache.flink.runtime.resourcemanager.slotmanager
org.apache.flink.runtime.rest.handler
org.apache.flink.runtime.rest.handler.legacy.metrics
org.apache.flink.runtime.rest.messages
org.apache.flink.runtime.rest.messages.taskmanager
org.apache.flink.runtime.rpc
org.apache.flink.runtime.rpc.pekko
org.apache.flink.runtime.scheduler
org.apache.flink.runtime.scheduler.adaptivebatch
org.apache.flink.runtime.scheduler.exceptionhistory
org.apache.flink.runtime.scheduler.metrics
org.apache.flink.runtime.security.modules
org.apache.flink.runtime.shuffle
org.apache.flink.runtime.state
org.apache.flink.runtime.state.heap	This package contains the classes for key/value state backends that store the state on the JVM heap as objects.
org.apache.flink.runtime.taskexecutor
org.apache.flink.runtime.taskexecutor.slot
org.apache.flink.runtime.taskmanager
org.apache.flink.runtime.util
org.apache.flink.runtime.util.bash
org.apache.flink.runtime.util.config.memory.jobmanager
org.apache.flink.runtime.webmonitor.handlers
org.apache.flink.runtime.webmonitor.stats
org.apache.flink.runtime.zookeeper
org.apache.flink.state.changelog
org.apache.flink.state.common
org.apache.flink.streaming.api.datastream
org.apache.flink.streaming.api.functions.sink
org.apache.flink.streaming.api.functions.sink.filesystem
org.apache.flink.streaming.api.functions.source
org.apache.flink.streaming.api.graph
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.api.operators.co
org.apache.flink.streaming.api.operators.collect
org.apache.flink.streaming.api.operators.source
org.apache.flink.streaming.api.runners.python.beam
org.apache.flink.streaming.api.transformations
org.apache.flink.streaming.api.windowing.evictors
org.apache.flink.streaming.api.windowing.triggers
org.apache.flink.streaming.runtime.io.checkpointing
org.apache.flink.streaming.runtime.operators.sink
org.apache.flink.streaming.runtime.operators.sink.committables
org.apache.flink.streaming.runtime.operators.windowing	This package contains the operators that implement the various window operations on data streams.
org.apache.flink.streaming.runtime.tasks	This package contains classes that realize streaming tasks.
org.apache.flink.streaming.runtime.tasks.mailbox
org.apache.flink.streaming.runtime.watermarkstatus
org.apache.flink.table.api.internal
org.apache.flink.table.catalog
org.apache.flink.table.catalog.hive
org.apache.flink.table.client
org.apache.flink.table.client.cli
org.apache.flink.table.client.gateway
org.apache.flink.table.client.gateway.result
org.apache.flink.table.connector.source
org.apache.flink.table.endpoint.hive
org.apache.flink.table.endpoint.hive.util
org.apache.flink.table.functions.hive
org.apache.flink.table.gateway.rest.handler.util
org.apache.flink.table.gateway.service
org.apache.flink.table.gateway.service.operation
org.apache.flink.table.gateway.service.result
org.apache.flink.table.gateway.service.session
org.apache.flink.table.jdbc
org.apache.flink.table.module.hive
org.apache.flink.table.operations
org.apache.flink.table.planner.plan.nodes.exec
org.apache.flink.table.planner.plan.nodes.exec.batch
org.apache.flink.table.planner.plan.nodes.exec.common
org.apache.flink.table.planner.utils
org.apache.flink.table.resource
org.apache.flink.table.runtime.functions.table.lookup
org.apache.flink.table.runtime.generated
org.apache.flink.table.runtime.operators.join.lookup
org.apache.flink.table.runtime.operators.multipleinput
org.apache.flink.table.runtime.operators.over
org.apache.flink.table.runtime.operators.python.aggregate
org.apache.flink.table.runtime.operators.sort
org.apache.flink.table.runtime.operators.window.slicing
org.apache.flink.table.runtime.typeutils
org.apache.flink.util
org.apache.flink.yarn.configuration

Uses of VisibleForTesting in org.apache.flink.api.common.functions.util

Methods in org.apache.flink.api.common.functions.util with annotations of type VisibleForTesting

Modifier and Type	Method and Description
String	AbstractRuntimeUDFContext.getAllocationIDAsString()

Constructors in org.apache.flink.api.common.functions.util with annotations of type VisibleForTesting

Constructor and Description
RuntimeUDFContext(TaskInfo taskInfo, ClassLoader userCodeClassLoader, ExecutionConfig executionConfig, Map<String,Future<Path>> cpTasks, Map<String,Accumulator<?,?>> accumulators, OperatorMetricGroup metrics)

Uses of VisibleForTesting in org.apache.flink.api.java.typeutils.runtime

Methods in org.apache.flink.api.java.typeutils.runtime with annotations of type VisibleForTesting

Modifier and Type	Method and Description
TypeSerializer<Object>[]	TupleSerializerBase.getFieldSerializers()

Uses of VisibleForTesting in org.apache.flink.api.java.typeutils.runtime.kryo

Methods in org.apache.flink.api.java.typeutils.runtime.kryo with annotations of type VisibleForTesting

Modifier and Type	Method and Description
com.esotericsoftware.kryo.Kryo	KryoSerializer.getKryo()

Uses of VisibleForTesting in org.apache.flink.cep.nfa

Methods in org.apache.flink.cep.nfa with annotations of type VisibleForTesting

Modifier and Type	Method and Description
Collection<State<T>>	NFA.getStates()

Uses of VisibleForTesting in org.apache.flink.cep.nfa.sharedbuffer

Methods in org.apache.flink.cep.nfa.sharedbuffer with annotations of type VisibleForTesting

Modifier and Type	Method and Description
int	SharedBuffer.getEventsBufferCacheSize()
int	SharedBuffer.getEventsBufferSize()
int	SharedBuffer.getSharedBufferNodeCacheSize()
int	SharedBuffer.getSharedBufferNodeSize()

Constructors in org.apache.flink.cep.nfa.sharedbuffer with annotations of type VisibleForTesting

Constructor and Description
SharedBuffer(KeyedStateStore stateStore, TypeSerializer<V> valueSerializer)

Uses of VisibleForTesting in org.apache.flink.changelog.fs

Fields in org.apache.flink.changelog.fs with annotations of type VisibleForTesting

Modifier and Type	Field and Description
static String	StateChangeFsUploader.PATH_SUB_DIR

Methods in org.apache.flink.changelog.fs with annotations of type VisibleForTesting

Modifier and Type	Method and Description
static TaskChangelogRegistry	TaskChangelogRegistry.defaultChangelogRegistry(Executor executor)
Path	StateChangeFsUploader.getBasePath()
StreamStateHandle	StateChangeUploader.UploadTasksResult.getStreamStateHandle()

Constructors in org.apache.flink.changelog.fs with annotations of type VisibleForTesting

Constructor and Description
FsStateChangelogStorage(JobID jobID, Path basePath, boolean compression, int bufferSize, ChangelogStorageMetricGroup metricGroup, TaskChangelogRegistry changelogRegistry, LocalRecoveryConfig localRecoveryConfig)
FsStateChangelogStorage(StateChangeUploadScheduler uploader, long preEmptivePersistThresholdInBytes, TaskChangelogRegistry changelogRegistry, LocalRecoveryConfig localRecoveryConfig)
StateChangeFsUploader(JobID jobID, Path basePath, FileSystem fileSystem, boolean compression, int bufferSize, ChangelogStorageMetricGroup metrics, TaskChangelogRegistry changelogRegistry)

Uses of VisibleForTesting in org.apache.flink.client.program.rest

Methods in org.apache.flink.client.program.rest with annotations of type VisibleForTesting

Modifier and Type	Method and Description
<M extends MessageHeaders<R,P,U>,U extends MessageParameters,R extends RequestBody,P extends ResponseBody> CompletableFuture<P>	RestClusterClient.sendRequest(M messageHeaders, U messageParameters, R request)

Uses of VisibleForTesting in org.apache.flink.configuration

Methods in org.apache.flink.configuration with annotations of type VisibleForTesting

Modifier and Type	Method and Description
static Map<String,String>	ConfigurationUtils.parseJvmArgString(String jvmParamsStr)
static Map<String,String>	ConfigurationUtils.parseTmResourceDynamicConfigs(String dynamicConfigsStr)

Uses of VisibleForTesting in org.apache.flink.connector.base.source.reader.fetcher

Methods in org.apache.flink.connector.base.source.reader.fetcher with annotations of type VisibleForTesting

Modifier and Type	Method and Description
int	SplitFetcherManager.getNumAliveFetchers()

Constructors in org.apache.flink.connector.base.source.reader.fetcher with annotations of type VisibleForTesting

Constructor and Description
SingleThreadFetcherManager(FutureCompletingBlockingQueue<RecordsWithSplitIds<E>> elementsQueue, Supplier<SplitReader<E,SplitT>> splitReaderSupplier, Configuration configuration, Consumer<Collection<String>> splitFinishedHook) Creates a new SplitFetcherManager with a single I/O threads.
SplitFetcherManager(FutureCompletingBlockingQueue<RecordsWithSplitIds<E>> elementsQueue, Supplier<SplitReader<E,SplitT>> splitReaderFactory, Configuration configuration, Consumer<Collection<String>> splitFinishedHook) Create a split fetcher manager.

Uses of VisibleForTesting in org.apache.flink.connector.base.source.reader.synchronization

Methods in org.apache.flink.connector.base.source.reader.synchronization with annotations of type VisibleForTesting

Modifier and Type	Method and Description
T	FutureCompletingBlockingQueue.take() Warning: This is a dangerous method and should only be used for testing convenience.

Uses of VisibleForTesting in org.apache.flink.connector.datagen.table

Methods in org.apache.flink.connector.datagen.table with annotations of type VisibleForTesting

Modifier and Type	Method and Description
DataGeneratorSource<RowData>	DataGenTableSource.createSource()

Uses of VisibleForTesting in org.apache.flink.connector.file.sink.compactor.operator

Methods in org.apache.flink.connector.file.sink.compactor.operator with annotations of type VisibleForTesting

Modifier and Type	Method and Description
CompletableFuture<?>	CompactorOperator.getAllTasksFuture()

Uses of VisibleForTesting in org.apache.flink.connectors.hive

Methods in org.apache.flink.connectors.hive with annotations of type VisibleForTesting

Modifier and Type	Method and Description
protected DataStream<RowData>	HiveTableSource.getDataStream(ProviderContext providerContext, StreamExecutionEnvironment execEnv)
PartitionFetcher.Context<P>	FileSystemLookupFunction.getFetcherContext()
org.apache.hadoop.mapred.JobConf	HiveTableSource.getJobConf()
org.apache.hadoop.mapred.JobConf	HiveTableSink.getJobConf()
PartitionFetcher<P>	FileSystemLookupFunction.getPartitionFetcher()
PartitionReader<P,RowData>	FileSystemLookupFunction.getPartitionReader()
Duration	FileSystemLookupFunction.getReloadInterval()

Uses of VisibleForTesting in org.apache.flink.connectors.hive.read

Fields in org.apache.flink.connectors.hive.read with annotations of type VisibleForTesting

Modifier and Type	Field and Description
protected SplitReader	HiveTableInputFormat.reader

Uses of VisibleForTesting in org.apache.flink.contrib.streaming.state

Methods in org.apache.flink.contrib.streaming.state with annotations of type VisibleForTesting

Modifier and Type	Method and Description
static long	RocksDBMemoryControllerUtils.calculateActualCacheCapacity(long totalMemorySize, double writeBufferRatio) Calculate the actual memory capacity of cache, which would be shared among rocksDB instance(s).
void	RocksDBKeyedStateBackend.compactState(StateDescriptor<?,?> stateDesc)
void	RocksDBNativeMetricOptions.enableNativeStatistics(ConfigOption<Boolean> nativeStatisticsOption)
PredefinedOptions	EmbeddedRocksDBStateBackend.getPredefinedOptions() Gets the currently set predefined options for RocksDB.
PredefinedOptions	RocksDBStateBackend.getPredefinedOptions() Deprecated. Gets the currently set predefined options for RocksDB.
int	RocksDBKeyedStateBackend.numKeyValueStateEntries()

Constructors in org.apache.flink.contrib.streaming.state with annotations of type VisibleForTesting

Constructor and Description
RocksDBResourceContainer()
RocksDBResourceContainer(PredefinedOptions predefinedOptions, RocksDBOptionsFactory optionsFactory)
RocksDBResourceContainer(PredefinedOptions predefinedOptions, RocksDBOptionsFactory optionsFactory, OpaqueMemoryResource<org.apache.flink.contrib.streaming.state.RocksDBSharedResources> sharedResources)

Uses of VisibleForTesting in org.apache.flink.core.fs

Methods in org.apache.flink.core.fs with annotations of type VisibleForTesting

Modifier and Type	Method and Description
int	RefCountedBufferingFileStream.getReferenceCounter()

Constructors in org.apache.flink.core.fs with annotations of type VisibleForTesting

Constructor and Description
RefCountedBufferingFileStream(RefCountedFileWithStream file, int bufferSize)

Uses of VisibleForTesting in org.apache.flink.core.fs.local

Methods in org.apache.flink.core.fs.local with annotations of type VisibleForTesting

Modifier and Type	Method and Description
static File	LocalRecoverableWriter.generateStagingTempFilePath(File targetFile)

Uses of VisibleForTesting in org.apache.flink.core.memory

Methods in org.apache.flink.core.memory with annotations of type VisibleForTesting

Modifier and Type	Method and Description
static MemorySegment	MemorySegmentFactory.allocateOffHeapUnsafeMemory(int size)
boolean	MemorySegment.isFreed() Checks whether the memory segment was freed.

Uses of VisibleForTesting in org.apache.flink.core.plugin

Methods in org.apache.flink.core.plugin with annotations of type VisibleForTesting

Modifier and Type	Method and Description
static URLClassLoader	PluginLoader.createPluginClassLoader(PluginDescriptor pluginDescriptor, ClassLoader parentClassLoader, String[] alwaysParentFirstPatterns)

Constructors in org.apache.flink.core.plugin with annotations of type VisibleForTesting

Constructor and Description
PluginLoader(String pluginId, URLClassLoader pluginClassLoader)

Uses of VisibleForTesting in org.apache.flink.docs.util

Methods in org.apache.flink.docs.util with annotations of type VisibleForTesting

Modifier and Type	Method and Description
static List<OptionWithMetaInfo>	ConfigurationOptionLocator.extractConfigOptions(Class<?> clazz)

Uses of VisibleForTesting in org.apache.flink.formats.csv

Classes in org.apache.flink.formats.csv with annotations of type VisibleForTesting

Modifier and Type	Class and Description
static class	CsvFileFormatFactory.CsvBulkDecodingFormat CsvBulkDecodingFormat which implements FileBasedStatisticsReportableInputFormat.

Uses of VisibleForTesting in org.apache.flink.formats.parquet

Classes in org.apache.flink.formats.parquet with annotations of type VisibleForTesting

Modifier and Type	Class and Description
static class	ParquetFileFormatFactory.ParquetBulkDecodingFormat ParquetBulkDecodingFormat which implements FileBasedStatisticsReportableInputFormat.

Uses of VisibleForTesting in org.apache.flink.kubernetes.kubeclient

Methods in org.apache.flink.kubernetes.kubeclient with annotations of type VisibleForTesting

Modifier and Type	Method and Description
io.fabric8.kubernetes.client.NamespacedKubernetesClient	FlinkKubeClientFactory.createFabric8ioKubernetesClient(Configuration flinkConfig)

Uses of VisibleForTesting in org.apache.flink.kubernetes.kubeclient.decorators

Methods in org.apache.flink.kubernetes.kubeclient.decorators with annotations of type VisibleForTesting

Modifier and Type	Method and Description
static String	FlinkConfMountDecorator.getFlinkConfConfigMapName(String clusterId)

Uses of VisibleForTesting in org.apache.flink.kubernetes.kubeclient.resources

Fields in org.apache.flink.kubernetes.kubeclient.resources with annotations of type VisibleForTesting

Modifier and Type	Field and Description
static String	KubernetesLeaderElector.LEADER_ANNOTATION_KEY

Constructors in org.apache.flink.kubernetes.kubeclient.resources with annotations of type VisibleForTesting

Constructor and Description
KubernetesLeaderElector(io.fabric8.kubernetes.client.NamespacedKubernetesClient kubernetesClient, KubernetesLeaderElectionConfiguration leaderConfig, KubernetesLeaderElector.LeaderCallbackHandler leaderCallbackHandler, ExecutorService executorService)

Uses of VisibleForTesting in org.apache.flink.orc

Classes in org.apache.flink.orc with annotations of type VisibleForTesting

Modifier and Type	Class and Description
static class	OrcFileFormatFactory.OrcBulkDecodingFormat OrcBulkDecodingFormat which implements FileBasedStatisticsReportableInputFormat.

Methods in org.apache.flink.orc with annotations of type VisibleForTesting

Modifier and Type	Method and Description
org.apache.orc.RecordReader	OrcSplitReader.getRecordReader()

Uses of VisibleForTesting in org.apache.flink.orc.shim

Methods in org.apache.flink.orc.shim with annotations of type VisibleForTesting

Modifier and Type	Method and Description
static Tuple2<Long,Long>	OrcShimV200.getOffsetAndLengthForSplit(long splitStart, long splitLength, List<org.apache.orc.StripeInformation> stripes)

Uses of VisibleForTesting in org.apache.flink.orc.writer

Methods in org.apache.flink.orc.writer with annotations of type VisibleForTesting

Modifier and Type	Method and Description
protected org.apache.orc.OrcFile.WriterOptions	OrcBulkWriterFactory.getWriterOptions()

Uses of VisibleForTesting in org.apache.flink.python.env

Fields in org.apache.flink.python.env with annotations of type VisibleForTesting

Modifier and Type	Field and Description
static String	AbstractPythonEnvironmentManager.PYFLINK_GATEWAY_DISABLED
static String	AbstractPythonEnvironmentManager.PYTHON_ARCHIVES_DIR
static String	AbstractPythonEnvironmentManager.PYTHON_FILES_DIR
static String	AbstractPythonEnvironmentManager.PYTHON_REQUIREMENTS_CACHE
static String	AbstractPythonEnvironmentManager.PYTHON_REQUIREMENTS_DIR
static String	AbstractPythonEnvironmentManager.PYTHON_REQUIREMENTS_FILE
static String	AbstractPythonEnvironmentManager.PYTHON_REQUIREMENTS_INSTALL_DIR
static String	AbstractPythonEnvironmentManager.PYTHON_WORKING_DIR

Methods in org.apache.flink.python.env with annotations of type VisibleForTesting

Modifier and Type	Method and Description
Map<String,String>	AbstractPythonEnvironmentManager.constructEnvironmentVariables(String baseDirectory) Constructs the environment variables which is used to launch the python UDF worker.
String	AbstractPythonEnvironmentManager.getBaseDirectory()
Map<String,String>	AbstractPythonEnvironmentManager.getPythonEnv()

Uses of VisibleForTesting in org.apache.flink.python.util

Fields in org.apache.flink.python.util with annotations of type VisibleForTesting

Modifier and Type	Field and Description
static String	PythonEnvironmentManagerUtils.PYFLINK_UDF_RUNNER_DIR

Uses of VisibleForTesting in org.apache.flink.queryablestate.network

Methods in org.apache.flink.queryablestate.network with annotations of type VisibleForTesting

Modifier and Type	Method and Description
boolean	AbstractServerBase.isEventGroupShutdown()
boolean	Client.isEventGroupShutdown()

Uses of VisibleForTesting in org.apache.flink.runtime.blob

Classes in org.apache.flink.runtime.blob with annotations of type VisibleForTesting

Modifier and Type	Class and Description
class	VoidBlobWriter BlobWriter which does not support writing BLOBs to a store.

Methods in org.apache.flink.runtime.blob with annotations of type VisibleForTesting

Modifier and Type	Method and Description
byte[]	BlobKey.getHash() Returns the hash component of this key.
File	TransientBlobCache.getStorageLocation(JobID jobId, BlobKey key) Returns a file handle to the file associated with the given blob key on the blob server.
File	PermanentBlobCache.getStorageLocation(JobID jobId, BlobKey key) Returns a file handle to the file associated with the given blob key on the blob server.
File	BlobServer.getStorageLocation(JobID jobId, BlobKey key) Returns a file handle to the file associated with the given blob key on the blob server.

Constructors in org.apache.flink.runtime.blob with annotations of type VisibleForTesting

Constructor and Description
BlobServer(Configuration config, File storageDir, BlobStore blobStore)
PermanentBlobCache(Configuration blobClientConfig, File storageDir, BlobView blobView, InetSocketAddress serverAddress)
PermanentBlobCache(Configuration blobClientConfig, File storageDir, BlobView blobView, InetSocketAddress serverAddress, BlobCacheSizeTracker blobCacheSizeTracker)
PermanentBlobCache(Configuration blobClientConfig, Reference<File> storageDir, BlobView blobView, InetSocketAddress serverAddress, BlobCacheSizeTracker blobCacheSizeTracker)
PermanentBlobKey() Constructs a new BLOB key.
TransientBlobCache(Configuration blobClientConfig, File storageDir, InetSocketAddress serverAddress)
TransientBlobKey() Constructs a new BLOB key.

Uses of VisibleForTesting in org.apache.flink.runtime.checkpoint

Methods in org.apache.flink.runtime.checkpoint with annotations of type VisibleForTesting

Modifier and Type	Method and Description
static void	StateAssignmentOperation.extractIntersectingState(Collection<? extends KeyedStateHandle> originalSubtaskStateHandles, KeyGroupRange rangeToExtract, List<KeyedStateHandle> extractedStateCollector) Extracts certain key group ranges from the given state handles and adds them to the collector.
static CheckpointOptions	CheckpointOptions.forCheckpointWithDefaultLocation()
Collection<ExecutionJobVertex>	CheckpointPlan.getFullyFinishedJobVertex() Returns the job vertices whose tasks are all finished when taking the checkpoint.
static <T extends CompletedCheckpointStore> CheckpointRecoveryFactory	PerJobCheckpointRecoveryFactory.withoutCheckpointStoreRecovery(IntFunction<T> storeFn)

Constructors in org.apache.flink.runtime.checkpoint with annotations of type VisibleForTesting

Constructor and Description
CheckpointCoordinator(JobID job, CheckpointCoordinatorConfiguration chkConfig, Collection<OperatorCoordinatorCheckpointContext> coordinatorsToCheckpoint, CheckpointIDCounter checkpointIDCounter, CompletedCheckpointStore completedCheckpointStore, CheckpointStorage checkpointStorage, Executor executor, CheckpointsCleaner checkpointsCleaner, ScheduledExecutor timer, CheckpointFailureManager failureManager, CheckpointPlanCalculator checkpointPlanCalculator, Clock clock, CheckpointStatsTracker statsTracker, BiFunction<Set<ExecutionJobVertex>,Map<OperatorID,OperatorState>,VertexFinishedStateChecker> vertexFinishedStateCheckerFactory)
CheckpointMetrics()
CheckpointOptions(SnapshotType checkpointType, CheckpointStorageLocationReference targetLocation)
EmbeddedCompletedCheckpointStore()
EmbeddedCompletedCheckpointStore(int maxRetainedCheckpoints)
StandaloneCompletedCheckpointStore(int maxNumberOfCheckpointsToRetain)

Uses of VisibleForTesting in org.apache.flink.runtime.checkpoint.channel

Methods in org.apache.flink.runtime.checkpoint.channel with annotations of type VisibleForTesting

Modifier and Type	Method and Description
ChannelStateWriter.ChannelStateWriteResult	ChannelStateWriterImpl.getWriteResult(long checkpointId)
void	ChannelStateWriter.ChannelStateWriteResult.waitForDone()

Uses of VisibleForTesting in org.apache.flink.runtime.checkpoint.filemerging

Methods in org.apache.flink.runtime.checkpoint.filemerging with annotations of type VisibleForTesting

Modifier and Type	Method and Description
boolean	LogicalFile.isDiscarded()

Uses of VisibleForTesting in org.apache.flink.runtime.checkpoint.metadata

Methods in org.apache.flink.runtime.checkpoint.metadata with annotations of type VisibleForTesting

Modifier and Type	Method and Description
static StateObjectCollection<InputChannelStateHandle>	MetadataV3Serializer.deserializeInputChannelStateHandle(DataInputStream dis)
StateObjectCollection<InputChannelStateHandle>	MetadataV3Serializer.deserializeInputChannelStateHandle(DataInputStream dis, MetadataV2V3SerializerBase.DeserializationContext context)
static KeyedStateHandle	MetadataV3Serializer.deserializeKeyedStateHandleUtil(DataInputStream dis)
static OperatorStateHandle	MetadataV3Serializer.deserializeOperatorStateHandleUtil(DataInputStream dis)
StateObjectCollection<ResultSubpartitionStateHandle>	MetadataV3Serializer.deserializeResultSubpartitionStateHandle(DataInputStream dis)
StateObjectCollection<ResultSubpartitionStateHandle>	MetadataV3Serializer.deserializeResultSubpartitionStateHandle(DataInputStream dis, MetadataV2V3SerializerBase.DeserializationContext context)
static StreamStateHandle	MetadataV3Serializer.deserializeStreamStateHandle(DataInputStream dis)
void	MetadataV3Serializer.serializeInputChannelStateHandle(InputChannelStateHandle handle, DataOutputStream dos)
static void	MetadataV3Serializer.serializeKeyedStateHandleUtil(KeyedStateHandle stateHandle, DataOutputStream dos)
static void	MetadataV3Serializer.serializeOperatorStateHandleUtil(OperatorStateHandle stateHandle, DataOutputStream dos)
void	MetadataV3Serializer.serializeResultSubpartitionStateHandle(ResultSubpartitionStateHandle handle, DataOutputStream dos)
static void	MetadataV3Serializer.serializeStreamStateHandle(StreamStateHandle stateHandle, DataOutputStream dos)

Uses of VisibleForTesting in org.apache.flink.runtime.clusterframework

Constructors in org.apache.flink.runtime.clusterframework with annotations of type VisibleForTesting

Constructor and Description
TaskExecutorProcessSpec(CPUResource cpuCores, MemorySize frameworkHeapSize, MemorySize frameworkOffHeapSize, MemorySize taskHeapSize, MemorySize taskOffHeapSize, MemorySize networkMemSize, MemorySize managedMemorySize, MemorySize jvmMetaspaceSize, MemorySize jvmOverheadSize, Collection<ExternalResource> extendedResources)

Uses of VisibleForTesting in org.apache.flink.runtime.clusterframework.types

Fields in org.apache.flink.runtime.clusterframework.types with annotations of type VisibleForTesting

Modifier and Type	Field and Description
static ResourceProfile	ResourceProfile.ANY A ResourceProfile that indicates infinite resource that matches any resource requirement.

Methods in org.apache.flink.runtime.clusterframework.types with annotations of type VisibleForTesting

Modifier and Type	Method and Description
static ResourceProfile	ResourceProfile.fromResources(double cpuCores, int taskHeapMemoryMB)

Uses of VisibleForTesting in org.apache.flink.runtime.deployment

Constructors in org.apache.flink.runtime.deployment with annotations of type VisibleForTesting

Constructor and Description
InputGateDeploymentDescriptor(IntermediateDataSetID consumedResultId, ResultPartitionType consumedPartitionType, int consumedSubpartitionIndex, TaskDeploymentDescriptorFactory.ShuffleDescriptorAndIndex[] inputChannels)

Uses of VisibleForTesting in org.apache.flink.runtime.dispatcher

Fields in org.apache.flink.runtime.dispatcher with annotations of type VisibleForTesting

Modifier and Type	Field and Description
static ConfigOption<Duration>	Dispatcher.CLIENT_ALIVENESS_CHECK_DURATION

Methods in org.apache.flink.runtime.dispatcher with annotations of type VisibleForTesting

Modifier and Type	Method and Description
protected CompletableFuture<org.apache.flink.runtime.dispatcher.Dispatcher.CleanupJobState>	Dispatcher.jobReachedTerminalState(ExecutionGraphInfo executionGraphInfo)

Constructors in org.apache.flink.runtime.dispatcher with annotations of type VisibleForTesting

Constructor and Description
Dispatcher(RpcService rpcService, DispatcherId fencingToken, Collection<JobGraph> recoveredJobs, Collection<JobResult> recoveredDirtyJobs, DispatcherBootstrapFactory dispatcherBootstrapFactory, DispatcherServices dispatcherServices, JobManagerRunnerRegistry jobManagerRunnerRegistry, ResourceCleanerFactory resourceCleanerFactory)
DispatcherOperationCaches()
DispatcherOperationCaches(Duration cacheDuration)
MiniDispatcher(RpcService rpcService, DispatcherId fencingToken, DispatcherServices dispatcherServices, JobGraph jobGraph, JobResult recoveredDirtyJob, DispatcherBootstrapFactory dispatcherBootstrapFactory, JobManagerRunnerRegistry jobManagerRunnerRegistry, ResourceCleanerFactory resourceCleanerFactory, ClusterEntrypoint.ExecutionMode executionMode)

Uses of VisibleForTesting in org.apache.flink.runtime.dispatcher.cleanup

Constructors in org.apache.flink.runtime.dispatcher.cleanup with annotations of type VisibleForTesting

Constructor and Description
DispatcherResourceCleanerFactory(Executor cleanupExecutor, RetryStrategy retryStrategy, JobManagerRunnerRegistry jobManagerRunnerRegistry, JobGraphWriter jobGraphWriter, BlobServer blobServer, HighAvailabilityServices highAvailabilityServices, JobManagerMetricGroup jobManagerMetricGroup)

Uses of VisibleForTesting in org.apache.flink.runtime.entrypoint

Methods in org.apache.flink.runtime.entrypoint with annotations of type VisibleForTesting

Modifier and Type	Method and Description
static File	ClusterEntrypointUtils.generateJobManagerWorkingDirectoryFile(Configuration configuration, ResourceID resourceId) Generates the working directory File for the JobManager process.
static File	ClusterEntrypointUtils.generateTaskManagerWorkingDirectoryFile(Configuration configuration, ResourceID resourceId) Generates the working directory File for the TaskManager process.

Uses of VisibleForTesting in org.apache.flink.runtime.executiongraph

Methods in org.apache.flink.runtime.executiongraph with annotations of type VisibleForTesting

Modifier and Type	Method and Description
void	ExecutionVertex.deployToSlot(LogicalSlot slot)
List<IntermediateResultPartition>	ExecutionVertex.finishPartitionsIfNeeded() Mark partition finished if needed.
void	Execution.markFinished()
JobStatus	DefaultExecutionGraph.waitUntilTerminal()
JobStatus	ExecutionGraph.waitUntilTerminal()

Constructors in org.apache.flink.runtime.executiongraph with annotations of type VisibleForTesting

Constructor and Description
ArchivedExecutionVertex(int subTaskIndex, String taskNameWithSubtask, ArchivedExecution currentExecution, ExecutionHistory executionHistory)
ExecutionJobVertex(InternalExecutionGraphAccessor graph, JobVertex jobVertex, VertexParallelismInformation parallelismInfo)
ExecutionVertex(ExecutionJobVertex jobVertex, int subTaskIndex, IntermediateResult[] producedDataSets, Time timeout, long createTimestamp, int executionHistorySizeLimit, int initialAttemptCount) Creates an ExecutionVertex.
IOMetrics(long numBytesIn, long numBytesOut, long numRecordsIn, long numRecordsOut, long accumulateIdleTime, double accumulateBusyTime, long accumulateBackPressuredTime, Map<IntermediateResultPartitionID,ResultPartitionBytes> resultPartitionBytes)

Uses of VisibleForTesting in org.apache.flink.runtime.executiongraph.failover.flip1

Methods in org.apache.flink.runtime.executiongraph.failover.flip1 with annotations of type VisibleForTesting

Modifier and Type	Method and Description
SchedulingPipelinedRegion	RestartPipelinedRegionFailoverStrategy.getFailoverRegion(ExecutionVertexID vertexID) Returns the failover region that contains the given execution vertex.

Constructors in org.apache.flink.runtime.executiongraph.failover.flip1 with annotations of type VisibleForTesting

Constructor and Description
RestartPipelinedRegionFailoverStrategy(SchedulingTopology topology) Creates a new failover strategy to restart pipelined regions that works on the given topology.

Uses of VisibleForTesting in org.apache.flink.runtime.executiongraph.failover.flip1.partitionrelease

Methods in org.apache.flink.runtime.executiongraph.failover.flip1.partitionrelease with annotations of type VisibleForTesting

Modifier and Type	Method and Description
boolean	RegionPartitionGroupReleaseStrategy.isRegionOfVertexFinished(ExecutionVertexID executionVertexId)

Uses of VisibleForTesting in org.apache.flink.runtime.highavailability

Methods in org.apache.flink.runtime.highavailability with annotations of type VisibleForTesting

Modifier and Type	Method and Description
static boolean	FileSystemJobResultStore.hasValidDirtyJobResultStoreEntryExtension(String filename)
static boolean	FileSystemJobResultStore.hasValidJobResultStoreEntryExtension(String filename)

Uses of VisibleForTesting in org.apache.flink.runtime.highavailability.nonha.embedded

Methods in org.apache.flink.runtime.highavailability.nonha.embedded with annotations of type VisibleForTesting

Modifier and Type	Method and Description
boolean	EmbeddedLeaderService.isShutdown()

Uses of VisibleForTesting in org.apache.flink.runtime.io.disk

Methods in org.apache.flink.runtime.io.disk with annotations of type VisibleForTesting

Modifier and Type	Method and Description
int	BatchShuffleReadBufferPool.getAvailableBuffers()
int	BatchShuffleReadBufferPool.getNumTotalBuffers()

Uses of VisibleForTesting in org.apache.flink.runtime.io.network

Methods in org.apache.flink.runtime.io.network with annotations of type VisibleForTesting

Modifier and Type	Method and Description
static NettyShuffleEnvironment	NettyShuffleServiceFactory.createNettyShuffleEnvironment(NettyShuffleEnvironmentConfiguration config, ResourceID taskExecutorResourceId, TaskEventPublisher taskEventPublisher, ResultPartitionManager resultPartitionManager, ConnectionManager connectionManager, MetricGroup metricGroup, Executor ioExecutor, int numberOfSlots, String[] tmpDirPaths)
BatchShuffleReadBufferPool	NettyShuffleEnvironment.getBatchShuffleReadBufferPool()
ScheduledExecutorService	NettyShuffleEnvironment.getBatchShuffleReadIOExecutor()
NettyShuffleEnvironmentConfiguration	NettyShuffleEnvironment.getConfiguration()
ConnectionManager	NettyShuffleEnvironment.getConnectionManager()
Optional<Collection<SingleInputGate>>	NettyShuffleEnvironment.getInputGate(InputGateID id)
NetworkBufferPool	NettyShuffleEnvironment.getNetworkBufferPool()
ResultPartitionManager	NettyShuffleEnvironment.getResultPartitionManager()

Uses of VisibleForTesting in org.apache.flink.runtime.io.network.api.writer

Fields in org.apache.flink.runtime.io.network.api.writer with annotations of type VisibleForTesting

Modifier and Type	Field and Description
static String	RecordWriter.DEFAULT_OUTPUT_FLUSH_THREAD_NAME Default name for the output flush thread, if no name with a task reference is given.

Methods in org.apache.flink.runtime.io.network.api.writer with annotations of type VisibleForTesting

Modifier and Type	Method and Description
ChannelSelector<T>	ChannelSelectorRecordWriter.getChannelSelector()
static ByteBuffer	RecordWriter.serializeRecord(DataOutputSerializer serializer, IOReadableWritable record)

Uses of VisibleForTesting in org.apache.flink.runtime.io.network.buffer

Methods in org.apache.flink.runtime.io.network.buffer with annotations of type VisibleForTesting

Modifier and Type	Method and Description
Buffer	BufferDecompressor.decompressToOriginalBuffer(Buffer buffer) The difference between this method and BufferDecompressor.decompressToIntermediateBuffer(Buffer) is that this method copies the decompressed data to the input Buffer starting from offset 0.
int	LocalBufferPool.getNumberOfRequestedMemorySegments()

Constructors in org.apache.flink.runtime.io.network.buffer with annotations of type VisibleForTesting

Constructor and Description
NetworkBufferPool(int numberOfSegmentsToAllocate, int segmentSize)

Uses of VisibleForTesting in org.apache.flink.runtime.io.network.metrics

Methods in org.apache.flink.runtime.io.network.metrics with annotations of type VisibleForTesting

Modifier and Type	Method and Description
abstract int	AbstractBuffersUsageGauge.calculateTotalBuffers(SingleInputGate inputGate)
abstract int	AbstractBuffersUsageGauge.calculateUsedBuffers(SingleInputGate inputGate)

Uses of VisibleForTesting in org.apache.flink.runtime.io.network.netty

Constructors in org.apache.flink.runtime.io.network.netty with annotations of type VisibleForTesting

Constructor and Description
NettyConnectionManager(NettyBufferPool bufferPool, ResultPartitionProvider partitionProvider, TaskEventPublisher taskEventPublisher, NettyConfig nettyConfig, int maxNumberOfConnections, boolean connectionReuseEnabled)

Uses of VisibleForTesting in org.apache.flink.runtime.io.network.partition

Methods in org.apache.flink.runtime.io.network.partition with annotations of type VisibleForTesting

Modifier and Type	Method and Description
int	ResultSubpartition.add(BufferConsumer bufferConsumer)
ResultPartition	ResultPartitionFactory.create(String taskNameWithSubtaskAndId, int partitionIndex, ResultPartitionID id, ResultPartitionType type, int numberOfSubpartitions, int maxParallelism, boolean isBroadcast, SupplierWithException<BufferPool,IOException> bufferPoolFactory)
ResultSubpartition[]	BufferWritingResultPartition.getAllPartitions()
long	PipelinedSubpartition.getChannelStateCheckpointId()
TimerGauge	BufferWritingResultPartition.getHardBackPressuredTimeMsPerSecond()
ResultPartitionManager	ResultPartition.getPartitionManager()
static DataSetMetaInfo	DataSetMetaInfo.withNumRegisteredPartitions(int numRegisteredPartitions, int numTotalPartitions)

Constructors in org.apache.flink.runtime.io.network.partition with annotations of type VisibleForTesting

Constructor and Description
ResultPartitionID()

Uses of VisibleForTesting in org.apache.flink.runtime.io.network.partition.consumer

Methods in org.apache.flink.runtime.io.network.partition.consumer with annotations of type VisibleForTesting

Modifier and Type	Method and Description
void	SingleInputGate.announceBufferSize(int newBufferSize)
void	SingleInputGate.convertRecoveredInputChannels()
protected InputChannel	SingleInputGateFactory.createKnownInputChannel(SingleInputGate inputGate, int index, int buffersPerChannel, NettyShuffleDescriptor inputChannelDescriptor, int consumedSubpartitionIndex, SingleInputGateFactory.ChannelStatistics channelStatistics, InputChannelMetrics metrics)
Buffer	RemoteInputChannel.getNextReceivedBuffer()
int	RemoteInputChannel.getNumberOfAvailableBuffers()
protected int	RecoveredInputChannel.getNumberOfQueuedBuffers()
int	RemoteInputChannel.getNumberOfRequiredBuffers()
int	RemoteInputChannel.getSenderBacklog()
void	RemoteInputChannel.requestSubpartition() Requests a remote subpartition.
void	SingleInputGate.setupChannels() Assign the exclusive buffers to all remote input channels directly for credit-based mode.

Constructors in org.apache.flink.runtime.io.network.partition.consumer with annotations of type VisibleForTesting

Constructor and Description
BufferOrEvent(AbstractEvent event, InputChannelInfo channelInfo)
BufferOrEvent(Buffer buffer, InputChannelInfo channelInfo)

Uses of VisibleForTesting in org.apache.flink.runtime.jobgraph

Constructors in org.apache.flink.runtime.jobgraph with annotations of type VisibleForTesting

Constructor and Description
IntermediateResultPartitionID() Creates an new random intermediate result partition ID for testing.

Uses of VisibleForTesting in org.apache.flink.runtime.jobgraph.tasks

Constructors in org.apache.flink.runtime.jobgraph.tasks with annotations of type VisibleForTesting

Constructor and Description
CheckpointCoordinatorConfiguration(long checkpointInterval, long checkpointTimeout, long minPauseBetweenCheckpoints, int maxConcurrentCheckpoints, CheckpointRetentionPolicy checkpointRetentionPolicy, boolean isExactlyOnce, boolean isUnalignedCheckpoint, int tolerableCpFailureNumber, long checkpointIdOfIgnoredInFlightData) Deprecated. use CheckpointCoordinatorConfiguration.builder().

Uses of VisibleForTesting in org.apache.flink.runtime.jobmanager

Methods in org.apache.flink.runtime.jobmanager with annotations of type VisibleForTesting

Modifier and Type	Method and Description
static JobManagerProcessSpec	JobManagerProcessUtils.createDefaultJobManagerProcessSpec(int totalProcessMemoryMb)

Constructors in org.apache.flink.runtime.jobmanager with annotations of type VisibleForTesting

Constructor and Description
JobManagerProcessSpec(MemorySize jvmHeapSize, MemorySize offHeapSize, MemorySize jvmMetaspaceSize, MemorySize jvmOverheadSize)

Uses of VisibleForTesting in org.apache.flink.runtime.jobmaster

Methods in org.apache.flink.runtime.jobmaster with annotations of type VisibleForTesting

Modifier and Type	Method and Description
LeaderElection	JobMasterServiceLeadershipRunner.getLeaderElection()

Uses of VisibleForTesting in org.apache.flink.runtime.jobmaster.slotpool

Methods in org.apache.flink.runtime.jobmaster.slotpool with annotations of type VisibleForTesting

Modifier and Type	Method and Description
int	DeclarativeSlotPoolBridge.getNumPendingRequests()

Constructors in org.apache.flink.runtime.jobmaster.slotpool with annotations of type VisibleForTesting

Constructor and Description
SingleLogicalSlot(SlotRequestId slotRequestId, SlotContext slotContext, Locality locality, SlotOwner slotOwner)

Uses of VisibleForTesting in org.apache.flink.runtime.leaderelection

Methods in org.apache.flink.runtime.leaderelection with annotations of type VisibleForTesting

Modifier and Type	Method and Description
UUID	DefaultLeaderElectionService.getLeaderSessionID(String componentId) Returns the current leader session ID for the given componentId or null, if the session wasn't confirmed.

Constructors in org.apache.flink.runtime.leaderelection with annotations of type VisibleForTesting

Constructor and Description
DefaultLeaderElectionService(LeaderElectionDriverFactory leaderElectionDriverFactory, FatalErrorHandler fallbackErrorHandler)

Uses of VisibleForTesting in org.apache.flink.runtime.leaderretrieval

Methods in org.apache.flink.runtime.leaderretrieval with annotations of type VisibleForTesting

Modifier and Type	Method and Description
String	ZooKeeperLeaderRetrievalDriver.getConnectionInformationPath()

Uses of VisibleForTesting in org.apache.flink.runtime.memory

Methods in org.apache.flink.runtime.memory with annotations of type VisibleForTesting

Modifier and Type	Method and Description
boolean	MemoryManager.isShutdown() Checks whether the MemoryManager has been shut down.

Uses of VisibleForTesting in org.apache.flink.runtime.messages.checkpoint

Constructors in org.apache.flink.runtime.messages.checkpoint with annotations of type VisibleForTesting

Constructor and Description
AcknowledgeCheckpoint(JobID jobId, ExecutionAttemptID taskExecutionId, long checkpointId)

Uses of VisibleForTesting in org.apache.flink.runtime.messages.webmonitor

Constructors in org.apache.flink.runtime.messages.webmonitor with annotations of type VisibleForTesting

Constructor and Description
JobDetails(JobID jobId, String jobName, long startTime, long endTime, long duration, JobStatus status, long lastUpdateTime, int[] tasksPerState, int numTasks)

Uses of VisibleForTesting in org.apache.flink.runtime.metrics

Methods in org.apache.flink.runtime.metrics with annotations of type VisibleForTesting

Modifier and Type	Method and Description
static ReporterSetup	ReporterSetup.forReporter(String reporterName, MetricConfig metricConfig, MetricReporter reporter)
static ReporterSetup	ReporterSetup.forReporter(String reporterName, MetricFilter metricFilter, MetricReporter reporter)
static ReporterSetup	ReporterSetup.forReporter(String reporterName, MetricReporter reporter)
long	TimerGauge.getCount()
List<MetricReporter>	MetricRegistryImpl.getReporters()
boolean	TimerGauge.isMeasuring()

Constructors in org.apache.flink.runtime.metrics with annotations of type VisibleForTesting

Constructor and Description
ThresholdMeter(double maxEventsPerInterval, Duration interval, Clock clock)

Uses of VisibleForTesting in org.apache.flink.runtime.metrics.groups

Methods in org.apache.flink.runtime.metrics.groups with annotations of type VisibleForTesting

Modifier and Type	Method and Description
TaskManagerJobMetricGroup	TaskManagerMetricGroup.getJobMetricsGroup(JobID jobId)
long	TaskIOMetricGroup.getTaskInitializationDuration() Returns the duration of time required for a task's restoring/initialization, which reaches its maximum when the task begins running and remains constant throughout the task's running.
static InternalSinkWriterMetricGroup	InternalSinkWriterMetricGroup.mock(MetricGroup metricGroup)
static InternalSourceReaderMetricGroup	InternalSourceReaderMetricGroup.mock(MetricGroup metricGroup)
static InternalSinkWriterMetricGroup	InternalSinkWriterMetricGroup.mock(MetricGroup metricGroup, OperatorIOMetricGroup operatorIOMetricGroup)

Uses of VisibleForTesting in org.apache.flink.runtime.minicluster

Methods in org.apache.flink.runtime.minicluster with annotations of type VisibleForTesting

Modifier and Type	Method and Description
protected Collection<? extends DispatcherResourceManagerComponent>	MiniCluster.createDispatcherResourceManagerComponents(Configuration configuration, MiniCluster.RpcServiceFactory rpcServiceFactory, BlobServer blobServer, HeartbeatServices heartbeatServices, DelegationTokenManager delegationTokenManager, MetricRegistry metricRegistry, MetricQueryServiceRetriever metricQueryServiceRetriever, FatalErrorHandler fatalErrorHandler)
protected HighAvailabilityServices	MiniCluster.createHighAvailabilityServices(Configuration configuration, Executor executor)
Configuration	MiniCluster.getConfiguration()
protected CompletableFuture<DispatcherGateway>	MiniCluster.getDispatcherGatewayFuture()
protected boolean	MiniCluster.useLocalCommunication()

Uses of VisibleForTesting in org.apache.flink.runtime.net

Methods in org.apache.flink.runtime.net with annotations of type VisibleForTesting

Modifier and Type	Method and Description
static SSLContext	SSLUtils.createRestSSLContext(Configuration config, boolean clientMode) Creates an SSL context for clients against the external REST endpoint.

Uses of VisibleForTesting in org.apache.flink.runtime.operators.coordination

Methods in org.apache.flink.runtime.operators.coordination with annotations of type VisibleForTesting

Modifier and Type	Method and Description
protected OperatorCoordinator	RecreateOnResetOperatorCoordinator.Provider.create(OperatorCoordinator.Context context, long closingTimeoutMs)
OperatorCoordinator	RecreateOnResetOperatorCoordinator.getInternalCoordinator()

Uses of VisibleForTesting in org.apache.flink.runtime.persistence

Constructors in org.apache.flink.runtime.persistence with annotations of type VisibleForTesting

Constructor and Description
PossibleInconsistentStateException()

Uses of VisibleForTesting in org.apache.flink.runtime.query

Methods in org.apache.flink.runtime.query with annotations of type VisibleForTesting

Modifier and Type	Method and Description
int	KvStateEntry.getCacheSize()

Uses of VisibleForTesting in org.apache.flink.runtime.resourcemanager

Methods in org.apache.flink.runtime.resourcemanager with annotations of type VisibleForTesting

Modifier and Type	Method and Description
static Configuration	StandaloneResourceManagerFactory.getConfigurationWithoutMaxResourceIfSet(Configuration configuration) Get the configuration for standalone ResourceManager, overwrite invalid configs.
Optional<InstanceID>	ResourceManager.getInstanceIdByResourceId(ResourceID resourceID)
ResourceManager<?>	ResourceManagerServiceImpl.getLeaderResourceManager()

Uses of VisibleForTesting in org.apache.flink.runtime.resourcemanager.active

Methods in org.apache.flink.runtime.resourcemanager.active with annotations of type VisibleForTesting

Modifier and Type	Method and Description
void	ActiveResourceManager.declareResourceNeeded(Collection<ResourceDeclaration> resourceDeclarations)
void	ActiveResourceManager.requestNewWorker(WorkerResourceSpec workerResourceSpec) Allocates a resource using the worker resource specification.

Uses of VisibleForTesting in org.apache.flink.runtime.resourcemanager.slotmanager

Methods in org.apache.flink.runtime.resourcemanager.slotmanager with annotations of type VisibleForTesting

Modifier and Type	Method and Description
long	FineGrainedSlotManager.getTaskManagerIdleSince(InstanceID instanceId)

Uses of VisibleForTesting in org.apache.flink.runtime.rest.handler

Methods in org.apache.flink.runtime.rest.handler with annotations of type VisibleForTesting

Modifier and Type	Method and Description
static <R extends RequestBody,M extends MessageParameters> HandlerRequest<R>	HandlerRequest.create(R requestBody, M messageParameters) Short-cut for HandlerRequest.create(RequestBody, MessageParameters, Collection) without any uploaded files.
static <R extends RequestBody,M extends MessageParameters> HandlerRequest<R>	HandlerRequest.create(R requestBody, M messageParameters, Collection<File> uploadedFiles) Creates a new HandlerRequest.

Uses of VisibleForTesting in org.apache.flink.runtime.rest.handler.legacy.metrics

Methods in org.apache.flink.runtime.rest.handler.legacy.metrics with annotations of type VisibleForTesting

Modifier and Type	Method and Description
void	MetricStore.add(MetricDump metric)

Uses of VisibleForTesting in org.apache.flink.runtime.rest.messages

Methods in org.apache.flink.runtime.rest.messages with annotations of type VisibleForTesting

Modifier and Type	Method and Description
protected static String	ThreadDumpInfo.stringifyThreadInfo(ThreadInfo threadInfo, int maxDepth) Custom stringify format of JVM thread info to bypass the MAX_FRAMES = 8 limitation.

Uses of VisibleForTesting in org.apache.flink.runtime.rest.messages.taskmanager

Methods in org.apache.flink.runtime.rest.messages.taskmanager with annotations of type VisibleForTesting

Modifier and Type	Method and Description
TaskManagerMetricsInfo	TaskManagerDetailsInfo.getTaskManagerMetricsInfo()

Uses of VisibleForTesting in org.apache.flink.runtime.rpc

Methods in org.apache.flink.runtime.rpc with annotations of type VisibleForTesting

Modifier and Type	Method and Description
static void	RpcUtils.terminateRpcEndpoint(RpcEndpoint... rpcEndpoints) Shuts the given RpcEndpoints down and awaits their termination.
static void	RpcUtils.terminateRpcService(RpcService... rpcServices) Shuts the given rpc services down and waits for their termination.

Uses of VisibleForTesting in org.apache.flink.runtime.rpc.pekko

Methods in org.apache.flink.runtime.rpc.pekko with annotations of type VisibleForTesting

Modifier and Type	Method and Description
static org.apache.pekko.actor.ActorSystem	ActorSystemBootstrapTools.startRemoteActorSystem(Configuration configuration, String externalAddress, String externalPortRange, org.slf4j.Logger logger) Starts a remote ActorSystem at given address and specific port range.

Constructors in org.apache.flink.runtime.rpc.pekko with annotations of type VisibleForTesting

Constructor and Description
PekkoRpcService(org.apache.pekko.actor.ActorSystem actorSystem, PekkoRpcServiceConfiguration configuration)

Uses of VisibleForTesting in org.apache.flink.runtime.scheduler

Methods in org.apache.flink.runtime.scheduler with annotations of type VisibleForTesting

Modifier and Type	Method and Description
Iterable<RootExceptionHistoryEntry>	SchedulerBase.getExceptionHistory()
ExecutionGraph	SchedulerBase.getExecutionGraph() ExecutionGraph is exposed to make it easier to rework tests to be based on the new scheduler.

Uses of VisibleForTesting in org.apache.flink.runtime.scheduler.adaptivebatch

Methods in org.apache.flink.runtime.scheduler.adaptivebatch with annotations of type VisibleForTesting

Modifier and Type	Method and Description
static VertexParallelismStore	AdaptiveBatchScheduler.computeVertexParallelismStoreForDynamicGraph(Iterable<JobVertex> vertices, int defaultMaxParallelism) Compute the VertexParallelismStore for all given vertices in a dynamic graph, which will set defaults and ensure that the returned store contains valid parallelisms, with the configured default max parallelism.
void	AdaptiveBatchScheduler.initializeVerticesIfPossible()

Uses of VisibleForTesting in org.apache.flink.runtime.scheduler.exceptionhistory

Constructors in org.apache.flink.runtime.scheduler.exceptionhistory with annotations of type VisibleForTesting

Constructor and Description
RootExceptionHistoryEntry(Throwable cause, long timestamp, CompletableFuture<Map<String,String>> failureLabels, String failingTaskName, TaskManagerLocation taskManagerLocation, Iterable<ExceptionHistoryEntry> concurrentExceptions) Instantiates a RootExceptionHistoryEntry.

Uses of VisibleForTesting in org.apache.flink.runtime.scheduler.metrics

Methods in org.apache.flink.runtime.scheduler.metrics with annotations of type VisibleForTesting

Modifier and Type	Method and Description
static String	StateTimeMetric.getCurrentTimeMetricName(String baseName)
static String	StateTimeMetric.getStateMetricName(String baseName)
static String	StateTimeMetric.getTotalTimeMetricName(String baseName)

Uses of VisibleForTesting in org.apache.flink.runtime.security.modules

Methods in org.apache.flink.runtime.security.modules with annotations of type VisibleForTesting

Modifier and Type	Method and Description
SecurityConfiguration	HadoopModule.getSecurityConfig()

Uses of VisibleForTesting in org.apache.flink.runtime.shuffle

Constructors in org.apache.flink.runtime.shuffle with annotations of type VisibleForTesting

Constructor and Description
NetworkPartitionConnectionInfo(InetSocketAddress address, int connectionIndex)
PartitionDescriptor(IntermediateDataSetID resultId, int totalNumberOfPartitions, IntermediateResultPartitionID partitionId, ResultPartitionType partitionType, int numberOfSubpartitions, int connectionIndex, boolean isBroadcast, boolean isAllToAllDistribution)
ProducerDescriptor(ResourceID producerLocation, ExecutionAttemptID producerExecutionId, InetAddress address, int dataPort)

Uses of VisibleForTesting in org.apache.flink.runtime.state

Classes in org.apache.flink.runtime.state with annotations of type VisibleForTesting

Modifier and Type	Class and Description
class	JavaSerializer<T extends Serializable> A TypeSerializer that uses Java serialization.
interface	TestableKeyedStateBackend<K> A keyed state backend interface for internal testing purpose.

Fields in org.apache.flink.runtime.state with annotations of type VisibleForTesting

Modifier and Type	Field and Description
protected boolean	DefaultOperatorStateBackendBuilder.asynchronousSnapshots Flag to de/activate asynchronous snapshots.
protected CloseableRegistry	DefaultOperatorStateBackendBuilder.cancelStreamRegistry
protected ExecutionConfig	DefaultOperatorStateBackendBuilder.executionConfig The execution configuration.
protected Collection<OperatorStateHandle>	DefaultOperatorStateBackendBuilder.restoreStateHandles State handles for restore.
protected ClassLoader	DefaultOperatorStateBackendBuilder.userClassloader The user code classloader.

Methods in org.apache.flink.runtime.state with annotations of type VisibleForTesting

Modifier and Type	Method and Description
protected void	AsyncSnapshotCallable.cancel()
SharedStateRegistryKey	IncrementalRemoteKeyedStateHandle.createSharedStateRegistryKey(StreamStateHandle handle) Create a unique key based on physical id to register one of our shared state handles.
boolean	IncrementalRemoteKeyedStateHandle.equals(Object o) This method is should only be called in tests!
Optional<StateChangelogStorage<?>>	TaskExecutorStateChangelogStoragesManager.getChangelogStoragesByJobId(JobID jobId)
ChannelStateWriteRequestExecutorFactory	TaskExecutorChannelStateExecutorFactoryManager.getFactoryByJobId(JobID jobId)
ArrayListSerializer<S>	PartitionableListState.getInternalListCopySerializer()
MapSerializer<K,V>	HeapBroadcastState.getInternalMapCopySerializer()
StreamCompressionDecorator	AbstractKeyedStateBackend.getKeyGroupCompressionDecorator()
int	IncrementalRemoteKeyedStateHandle.hashCode() This method should only be called in tests!
int	AbstractKeyedStateBackend.numKeyValueStatesByName()

Constructors in org.apache.flink.runtime.state with annotations of type VisibleForTesting

Constructor and Description
IncrementalRemoteKeyedStateHandle(UUID backendIdentifier, KeyGroupRange keyGroupRange, long checkpointId, List<IncrementalKeyedStateHandle.HandleAndLocalPath> sharedState, List<IncrementalKeyedStateHandle.HandleAndLocalPath> privateState, StreamStateHandle metaStateHandle)
InputChannelStateHandle(InputChannelInfo info, StreamStateHandle delegate, List<Long> offset)
ResultSubpartitionStateHandle(ResultSubpartitionInfo info, StreamStateHandle delegate, List<Long> offset)
SharedStateRegistryKey(String keyString)
StateSnapshotContextSynchronousImpl(long checkpointId, long checkpointTimestamp)

Uses of VisibleForTesting in org.apache.flink.runtime.state.heap

Classes in org.apache.flink.runtime.state.heap with annotations of type VisibleForTesting

Modifier and Type	Class and Description
protected static class	CopyOnWriteStateMap.StateMapEntry<K,N,S> One entry in the CopyOnWriteStateMap.

Methods in org.apache.flink.runtime.state.heap with annotations of type VisibleForTesting

Modifier and Type	Method and Description
LocalRecoveryConfig	HeapKeyedStateBackend.getLocalRecoveryConfig()
StateMap<K,N,S>	StateTable.getMapForKeyGroup(int keyGroupIndex)
StateMap<K,N,S>[]	StateTable.getState() Returns the internal data structure.
StateTable<K,N,SV>	AbstractHeapState.getStateTable() This should only be used for testing.
int	HeapKeyedStateBackend.numKeyValueStateEntries() Returns the total number of state entries across all keys/namespaces.
int	HeapKeyedStateBackend.numKeyValueStateEntries(Object namespace) Returns the total number of state entries across all keys for the given namespace.
int	StateTable.sizeOfNamespace(Object namespace)
abstract int	StateMap.sizeOfNamespace(Object namespace)

Uses of VisibleForTesting in org.apache.flink.runtime.taskexecutor

Fields in org.apache.flink.runtime.taskexecutor with annotations of type VisibleForTesting

Modifier and Type	Field and Description
static int	TaskManagerRunner.FAILURE_EXIT_CODE

Methods in org.apache.flink.runtime.taskexecutor with annotations of type VisibleForTesting

Modifier and Type	Method and Description
boolean	DefaultJobLeaderService.containsJob(JobID jobId) Check whether the service monitors the given job.
static ResourceProfile	TaskExecutorResourceUtils.generateDefaultSlotResourceProfile(TaskExecutorResourceSpec taskExecutorResourceSpec, int numberOfSlots) This must be consist with SlotManagerUtils.generateDefaultSlotResourceProfile(org.apache.flink.runtime.resourcemanager.WorkerResourceSpec, int).
static ResourceProfile	TaskExecutorResourceUtils.generateTotalAvailableResourceProfile(TaskExecutorResourceSpec taskExecutorResourceSpec)
static TaskExecutorResourceSpec	TaskExecutorResourceUtils.resourceSpecFromConfigForLocalExecution(Configuration config)

Constructors in org.apache.flink.runtime.taskexecutor with annotations of type VisibleForTesting

Constructor and Description
Factory(Duration cacheExpireTimeout, int cacheSizeLimit, org.apache.flink.shaded.guava31.com.google.common.base.Ticker ticker)

Uses of VisibleForTesting in org.apache.flink.runtime.taskexecutor.slot

Methods in org.apache.flink.runtime.taskexecutor.slot with annotations of type VisibleForTesting

Modifier and Type	Method and Description
boolean	TaskSlotTable.allocateSlot(int index, JobID jobId, AllocationID allocationId, Time slotTimeout) Allocate the slot with the given index for the given job and allocation id.
boolean	TaskSlotTableImpl.allocateSlot(int index, JobID jobId, AllocationID allocationId, Time slotTimeout)
boolean	TaskSlotTableImpl.isClosed()

Uses of VisibleForTesting in org.apache.flink.runtime.taskmanager

Classes in org.apache.flink.runtime.taskmanager with annotations of type VisibleForTesting

Modifier and Type	Class and Description
static class	TaskManagerLocation.DefaultHostNameSupplier This Supplier class could retrieve the FQDN host name of the given InetAddress on demand, extract the pure host name and cache the results for later use.
static class	TaskManagerLocation.IpOnlyHostNameSupplier This Supplier class returns the IP address of the given InetAddress directly, therefore no reverse DNS lookup is required.

Methods in org.apache.flink.runtime.taskmanager with annotations of type VisibleForTesting

Modifier and Type	Method and Description
static void	Task.setupPartitionsAndGates(ResultPartitionWriter[] producedPartitions, InputGate[] inputGates)

Constructors in org.apache.flink.runtime.taskmanager with annotations of type VisibleForTesting

Constructor and Description
TaskManagerLocation(ResourceID resourceID, InetAddress inetAddress, int dataPort) Constructs a new instance connection info object.
TaskManagerLocation(ResourceID resourceID, InetAddress inetAddress, int dataPort, TaskManagerLocation.HostNameSupplier hostNameSupplier, String nodeId) Constructs a new instance connection info object.

Uses of VisibleForTesting in org.apache.flink.runtime.util

Fields in org.apache.flink.runtime.util with annotations of type VisibleForTesting

Modifier and Type	Field and Description
static String	EnvironmentInformation.UNKNOWN_COMMIT_ID
static String	EnvironmentInformation.UNKNOWN_COMMIT_ID_ABBREV

Methods in org.apache.flink.runtime.util with annotations of type VisibleForTesting

Modifier and Type	Method and Description
static CuratorFrameworkWithUnhandledErrorListener	ZooKeeperUtils.startCuratorFramework(org.apache.flink.shaded.curator5.org.apache.curator.framework.CuratorFrameworkFactory.Builder builder, FatalErrorHandler fatalErrorHandler) Starts a CuratorFramework instance and connects it to the given ZooKeeper quorum from a builder.

Uses of VisibleForTesting in org.apache.flink.runtime.util.bash

Fields in org.apache.flink.runtime.util.bash with annotations of type VisibleForTesting

Modifier and Type	Field and Description
static String	BashJavaUtils.EXECUTION_PREFIX

Uses of VisibleForTesting in org.apache.flink.runtime.util.config.memory.jobmanager

Constructors in org.apache.flink.runtime.util.config.memory.jobmanager with annotations of type VisibleForTesting

Constructor and Description
JobManagerFlinkMemory(MemorySize jvmHeap, MemorySize offHeapMemory)

Uses of VisibleForTesting in org.apache.flink.runtime.webmonitor.handlers

Methods in org.apache.flink.runtime.webmonitor.handlers with annotations of type VisibleForTesting

Modifier and Type	Method and Description
CompletableFuture<JarUploadResponseBody>	JarUploadHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)
CompletableFuture<JarRunResponseBody>	JarRunHandler.handleRequest(HandlerRequest<JarRunRequestBody> request, DispatcherGateway gateway)

Constructors in org.apache.flink.runtime.webmonitor.handlers with annotations of type VisibleForTesting

Constructor and Description
JarPlanRequestBody()

Uses of VisibleForTesting in org.apache.flink.runtime.webmonitor.stats

Methods in org.apache.flink.runtime.webmonitor.stats with annotations of type VisibleForTesting

Modifier and Type	Method and Description
int	TaskStatsRequestCoordinator.getNumberOfPendingRequests()

Uses of VisibleForTesting in org.apache.flink.runtime.zookeeper

Methods in org.apache.flink.runtime.zookeeper with annotations of type VisibleForTesting

Modifier and Type	Method and Description
protected void	ZooKeeperStateHandleStore.setStateHandle(String path, byte[] serializedStateHandle, int expectedVersion)

Uses of VisibleForTesting in org.apache.flink.state.changelog

Methods in org.apache.flink.state.changelog with annotations of type VisibleForTesting

Modifier and Type	Method and Description
int	ChangelogKeyedStateBackend.numKeyValueStateEntries()

Uses of VisibleForTesting in org.apache.flink.state.common

Fields in org.apache.flink.state.common with annotations of type VisibleForTesting

Modifier and Type	Field and Description
static String	ChangelogMaterializationMetricGroup.COMPLETED_MATERIALIZATION
static String	ChangelogMaterializationMetricGroup.FAILED_MATERIALIZATION
static String	ChangelogMaterializationMetricGroup.LAST_DURATION_OF_MATERIALIZATION
static String	ChangelogMaterializationMetricGroup.STARTED_MATERIALIZATION

Methods in org.apache.flink.state.common with annotations of type VisibleForTesting

Modifier and Type	Method and Description
void	PeriodicMaterializationManager.triggerMaterialization()

Uses of VisibleForTesting in org.apache.flink.streaming.api.datastream

Classes in org.apache.flink.streaming.api.datastream with annotations of type VisibleForTesting

Modifier and Type	Class and Description
static class	CoGroupedStreams.UnionSerializer<T1,T2> TypeSerializer for CoGroupedStreams.TaggedUnion.

Uses of VisibleForTesting in org.apache.flink.streaming.api.functions.sink

Classes in org.apache.flink.streaming.api.functions.sink with annotations of type VisibleForTesting

Modifier and Type	Class and Description
static class	TwoPhaseCommitSinkFunction.State<TXN,CONTEXT> State POJO class coupling pendingTransaction, context and pendingCommitTransactions.
static class	TwoPhaseCommitSinkFunction.StateSerializer<TXN,CONTEXT> Custom TypeSerializer for the sink state.
static class	TwoPhaseCommitSinkFunction.TransactionHolder<TXN> Adds metadata (currently only the start time of the transaction) to the transaction object.

Constructors in org.apache.flink.streaming.api.functions.sink with annotations of type VisibleForTesting

Constructor and Description
TransactionHolder(TXN handle, long transactionStartTime)

Uses of VisibleForTesting in org.apache.flink.streaming.api.functions.sink.filesystem

Methods in org.apache.flink.streaming.api.functions.sink.filesystem with annotations of type VisibleForTesting

Modifier and Type	Method and Description
long	Buckets.getMaxPartCounter()
Bucket<IN,BucketID>	Buckets.onElement(IN value, SinkFunction.Context context)

Uses of VisibleForTesting in org.apache.flink.streaming.api.functions.source

Methods in org.apache.flink.streaming.api.functions.source with annotations of type VisibleForTesting

Modifier and Type	Method and Description
long	ContinuousFileMonitoringFunction.getGlobalModificationTime() Deprecated.
TypeSerializer<T>	FromElementsFunction.getSerializer() Deprecated.

Uses of VisibleForTesting in org.apache.flink.streaming.api.graph

Methods in org.apache.flink.streaming.api.graph with annotations of type VisibleForTesting

Modifier and Type	Method and Description
static JobGraph	StreamingJobGraphGenerator.createJobGraph(StreamGraph streamGraph)
JobGraph	StreamGraph.getJobGraph() Gets the assembled JobGraph with a random JobID.
StreamOperator<?>	StreamNode.getOperator()
List<StreamEdge>	StreamGraph.getStreamEdges(int sourceId)
List<StreamEdge>	StreamGraph.getStreamEdges(int sourceId, int targetId)
List<StreamEdge>	StreamGraph.getStreamEdgesOrThrow(int sourceId, int targetId) Deprecated.
<T extends StreamOperator<?>> T	StreamConfig.getStreamOperator(ClassLoader cl)
void	StreamConfig.setAndSerializeTransitiveChainedTaskConfigs(Map<Integer,StreamConfig> chainedTaskConfigs)
void	StreamConfig.setStateBackendUsesManagedMemory(boolean usesManagedMemory)
void	StreamConfig.setStreamOperator(StreamOperator<?> operator)

Constructors in org.apache.flink.streaming.api.graph with annotations of type VisibleForTesting

Constructor and Description
StreamNode(Integer id, String slotSharingGroup, String coLocationGroup, StreamOperator<?> operator, String operatorName, Class<? extends TaskInvokable> jobVertexClass)

Uses of VisibleForTesting in org.apache.flink.streaming.api.operators

Methods in org.apache.flink.streaming.api.operators with annotations of type VisibleForTesting

Modifier and Type	Method and Description
boolean	StreamSource.emitsProgressiveWatermarks() Deprecated.
<K,N> InternalTimerService<N>	AbstractStreamOperatorV2.getInternalTimerService(String name, TypeSerializer<N> namespaceSerializer, Triggerable<K,N> triggerable) Returns a InternalTimerService that can be used to query current processing time and event time and to set timers.
OperatorStateBackend	AbstractStreamOperatorV2.getOperatorStateBackend()
OperatorStateBackend	AbstractStreamOperator.getOperatorStateBackend()
ProcessingTimeService	AbstractStreamOperatorV2.getProcessingTimeService() Returns the ProcessingTimeService responsible for getting the current processing time and registering timers.
ProcessingTimeService	AbstractStreamOperator.getProcessingTimeService() Returns the ProcessingTimeService responsible for getting the current processing time and registering timers.
StreamingRuntimeContext	AbstractStreamOperator.getRuntimeContext() Returns a context that allows the operator to query information about the execution and also to interact with systems such as broadcast variables and managed state.
SourceReader<OUT,SplitT>	SourceOperator.getSourceReader()
protected void	SourceOperator.initSourceMetricGroup()
int	InternalTimerServiceImpl.numEventTimeTimers()
int	InternalTimeServiceManagerImpl.numEventTimeTimers()
int	InternalTimerServiceImpl.numEventTimeTimers(N namespace)
int	InternalTimerServiceImpl.numProcessingTimeTimers()
int	InternalTimeServiceManagerImpl.numProcessingTimeTimers()
int	InternalTimerServiceImpl.numProcessingTimeTimers(N namespace)

Constructors in org.apache.flink.streaming.api.operators with annotations of type VisibleForTesting

Constructor and Description
StreamingRuntimeContext(AbstractStreamOperator<?> operator, Environment env, Map<String,Accumulator<?,?>> accumulators)
StreamTaskStateInitializerImpl(Environment environment, StateBackend stateBackend, TtlTimeProvider ttlTimeProvider, InternalTimeServiceManager.Provider timeServiceManagerProvider, StreamTaskCancellationContext cancellationContext)

Uses of VisibleForTesting in org.apache.flink.streaming.api.operators.co

Classes in org.apache.flink.streaming.api.operators.co with annotations of type VisibleForTesting

Modifier and Type	Class and Description
static class	IntervalJoinOperator.BufferEntry<T> A container for elements put in the left/write buffer.
static class	IntervalJoinOperator.BufferEntrySerializer<T> A serializer for the IntervalJoinOperator.BufferEntry.

Methods in org.apache.flink.streaming.api.operators.co with annotations of type VisibleForTesting

Modifier and Type	Method and Description
T	IntervalJoinOperator.BufferEntry.getElement()
boolean	IntervalJoinOperator.BufferEntry.hasBeenJoined()

Uses of VisibleForTesting in org.apache.flink.streaming.api.operators.collect

Methods in org.apache.flink.streaming.api.operators.collect with annotations of type VisibleForTesting

Modifier and Type	Method and Description
static byte[]	CollectSinkFunction.serializeAccumulatorResult(long offset, String version, long lastCheckpointedOffset, List<byte[]> buffer)

Constructors in org.apache.flink.streaming.api.operators.collect with annotations of type VisibleForTesting

Constructor and Description
CollectResultIterator(AbstractCollectResultBuffer<T> buffer, CompletableFuture<OperatorID> operatorIdFuture, String accumulatorName, int retryMillis)

Uses of VisibleForTesting in org.apache.flink.streaming.api.operators.source

Constructors in org.apache.flink.streaming.api.operators.source with annotations of type VisibleForTesting

Constructor and Description
WatermarkToDataOutput(PushingAsyncDataInput.DataOutput<?> output)

Uses of VisibleForTesting in org.apache.flink.streaming.api.runners.python.beam

Fields in org.apache.flink.streaming.api.runners.python.beam with annotations of type VisibleForTesting

Modifier and Type	Field and Description
protected org.apache.beam.sdk.fn.data.FnDataReceiver<org.apache.beam.sdk.util.WindowedValue<byte[]>>	BeamPythonFunctionRunner.mainInputReceiver The receiver which forwards the input elements to a remote environment for processing.
protected LinkedBlockingQueue<Tuple2<String,byte[]>>	BeamPythonFunctionRunner.resultBuffer Buffers the Python function execution result which has still not been processed.

Methods in org.apache.flink.streaming.api.runners.python.beam with annotations of type VisibleForTesting

Modifier and Type	Method and Description
org.apache.beam.runners.fnexecution.control.JobBundleFactory	BeamPythonFunctionRunner.createJobBundleFactory(org.apache.beam.vendor.grpc.v1p48p1.com.google.protobuf.Struct pipelineOptions)
protected void	BeamPythonFunctionRunner.startBundle()

Uses of VisibleForTesting in org.apache.flink.streaming.api.transformations

Methods in org.apache.flink.streaming.api.transformations with annotations of type VisibleForTesting

Modifier and Type	Method and Description
TwoInputStreamOperator<IN1,IN2,OUT>	TwoInputTransformation.getOperator()
StreamSink<T>	LegacySinkTransformation.getOperator()
StreamSource<T,?>	LegacySourceTransformation.getOperator()
OneInputStreamOperator<IN,OUT>	OneInputTransformation.getOperator()

Uses of VisibleForTesting in org.apache.flink.streaming.api.windowing.evictors

Methods in org.apache.flink.streaming.api.windowing.evictors with annotations of type VisibleForTesting

Modifier and Type	Method and Description
long	TimeEvictor.getWindowSize()

Uses of VisibleForTesting in org.apache.flink.streaming.api.windowing.triggers

Methods in org.apache.flink.streaming.api.windowing.triggers with annotations of type VisibleForTesting

Modifier and Type	Method and Description
long	ContinuousProcessingTimeTrigger.getInterval()
long	ContinuousEventTimeTrigger.getInterval()
Trigger<T,W>	PurgingTrigger.getNestedTrigger()

Uses of VisibleForTesting in org.apache.flink.streaming.runtime.io.checkpointing

Classes in org.apache.flink.streaming.runtime.io.checkpointing with annotations of type VisibleForTesting

Modifier and Type	Interface and Description
interface	UpstreamRecoveryTracker Tracks status of upstream channels while they recover.

Methods in org.apache.flink.streaming.runtime.io.checkpointing with annotations of type VisibleForTesting

Modifier and Type	Method and Description
static SingleCheckpointBarrierHandler	SingleCheckpointBarrierHandler.createUnalignedCheckpointBarrierHandler(SubtaskCheckpointCoordinator checkpointCoordinator, String taskName, CheckpointableTask toNotifyOnCheckpoint, Clock clock, boolean enableCheckpointsAfterTasksFinish, CheckpointableInput... inputs)

Uses of VisibleForTesting in org.apache.flink.streaming.runtime.operators.sink

Methods in org.apache.flink.streaming.runtime.operators.sink with annotations of type VisibleForTesting

Modifier and Type	Method and Description
Sink<InputT>	SinkWriterOperatorFactory.getSink()

Uses of VisibleForTesting in org.apache.flink.streaming.runtime.operators.sink.committables

Fields in org.apache.flink.streaming.runtime.operators.sink.committables with annotations of type VisibleForTesting

Modifier and Type	Field and Description
static int	SinkV1CommittableDeserializer.MAGIC_NUMBER It is important to keep this number consistent with the number used by the StreamingCommitterStateSerializer in Flink 1.13 and 1.14.

Uses of VisibleForTesting in org.apache.flink.streaming.runtime.operators.windowing

Methods in org.apache.flink.streaming.runtime.operators.windowing with annotations of type VisibleForTesting

Modifier and Type	Method and Description
long	WindowOperatorBuilder.getAllowedLateness()
Evictor<? super IN,? super W>	EvictingWindowOperator.getEvictor()
KeySelector<IN,K>	WindowOperator.getKeySelector()
StateDescriptor<? extends AppendingState<IN,Iterable<IN>>,?>	EvictingWindowOperator.getStateDescriptor()
StateDescriptor<? extends AppendingState<IN,ACC>,?>	WindowOperator.getStateDescriptor()
Trigger<? super IN,? super W>	WindowOperator.getTrigger()
WindowAssigner<? super IN,W>	WindowOperator.getWindowAssigner()

Uses of VisibleForTesting in org.apache.flink.streaming.runtime.tasks

Methods in org.apache.flink.streaming.runtime.tasks with annotations of type VisibleForTesting

Modifier and Type	Method and Description
static <OUT> RecordWriterDelegate<SerializationDelegate<StreamRecord<OUT>>>	StreamTask.createRecordWriterDelegate(StreamConfig configuration, Environment environment)
Iterable<StreamOperatorWrapper<?,?>>	OperatorChain.getAllOperators() Returns an Iterable which traverses all operators in forward topological order.
boolean	StreamTask.isMailboxLoopRunning()
boolean	StreamTask.runMailboxStep()

Constructors in org.apache.flink.streaming.runtime.tasks with annotations of type VisibleForTesting

Constructor and Description
OneInputStreamTask(Environment env, TimerService timeProvider) Constructor for initialization, possibly with initial state (recovery / savepoint / etc).

Uses of VisibleForTesting in org.apache.flink.streaming.runtime.tasks.mailbox

Methods in org.apache.flink.streaming.runtime.tasks.mailbox with annotations of type VisibleForTesting

Modifier and Type	Method and Description
MailboxMetricsController	MailboxProcessor.getMailboxMetricsControl() Gets MailboxMetricsController for control and access to mailbox metrics.
boolean	MailboxProcessor.isDefaultActionAvailable()
boolean	MailboxProcessor.isMailboxLoopRunning()
void	MailboxMetricsController.measureMailboxLatency()
boolean	MailboxProcessor.runMailboxStep() Execute a single (as small as possible) step of the mailbox.
void	MailboxMetricsController.setLatencyMeasurementInterval(int measurementInterval)

Constructors in org.apache.flink.streaming.runtime.tasks.mailbox with annotations of type VisibleForTesting

Constructor and Description
MailboxProcessor()
TaskMailboxImpl()

Uses of VisibleForTesting in org.apache.flink.streaming.runtime.watermarkstatus

Classes in org.apache.flink.streaming.runtime.watermarkstatus with annotations of type VisibleForTesting

Modifier and Type	Class and Description
protected static class	StatusWatermarkValve.InputChannelStatus An InputChannelStatus keeps track of an input channel's last watermark, stream status, and whether or not the channel's current watermark is aligned with the overall watermark output from the valve.

Methods in org.apache.flink.streaming.runtime.watermarkstatus with annotations of type VisibleForTesting

Modifier and Type	Method and Description
protected StatusWatermarkValve.InputChannelStatus	StatusWatermarkValve.getInputChannelStatus(int channelIndex)

Uses of VisibleForTesting in org.apache.flink.table.api.internal

Methods in org.apache.flink.table.api.internal with annotations of type VisibleForTesting

Modifier and Type	Method and Description
TableImpl	TableEnvironmentImpl.createTable(QueryOperation tableOperation)
List<ModifyOperation>	StatementSetImpl.getOperations()
Planner	TableEnvironmentImpl.getPlanner()

Uses of VisibleForTesting in org.apache.flink.table.catalog

Methods in org.apache.flink.table.catalog with annotations of type VisibleForTesting

Modifier and Type	Method and Description
List<CatalogModificationListener>	CatalogManager.getCatalogModificationListeners()

Constructors in org.apache.flink.table.catalog with annotations of type VisibleForTesting

Constructor and Description
ConnectorCatalogTable(TableSource<T1> tableSource, TableSink<T2> tableSink, TableSchema tableSchema, boolean isBatch)

Uses of VisibleForTesting in org.apache.flink.table.catalog.hive

Methods in org.apache.flink.table.catalog.hive with annotations of type VisibleForTesting

Modifier and Type	Method and Description
org.apache.hadoop.hive.metastore.api.Database	HiveCatalog.getHiveDatabase(String databaseName)
org.apache.hadoop.hive.metastore.api.Partition	HiveCatalog.getHivePartition(org.apache.hadoop.hive.metastore.api.Table hiveTable, CatalogPartitionSpec partitionSpec)

Uses of VisibleForTesting in org.apache.flink.table.client

Methods in org.apache.flink.table.client with annotations of type VisibleForTesting

Modifier and Type	Method and Description
protected static void	SqlClient.startClient(String[] args, Supplier<org.jline.terminal.Terminal> terminalFactory)

Uses of VisibleForTesting in org.apache.flink.table.client.cli

Constructors in org.apache.flink.table.client.cli with annotations of type VisibleForTesting

Constructor and Description
CliChangelogResultView(org.jline.terminal.Terminal terminal, ResultDescriptor resultDescriptor, ChangelogResult collectResult)
CliClient(Supplier<org.jline.terminal.Terminal> terminalFactory, Executor executor, Path historyFilePath, org.jline.reader.MaskingCallback inputTransformer) Creates a CLI instance with a custom terminal.
CliTableauResultView(org.jline.terminal.Terminal terminal, ResultDescriptor resultDescriptor, ChangelogResult collectResult)
CliTableResultView(org.jline.terminal.Terminal terminal, ResultDescriptor resultDescriptor, MaterializedResult materializedResult)

Uses of VisibleForTesting in org.apache.flink.table.client.gateway

Methods in org.apache.flink.table.client.gateway with annotations of type VisibleForTesting

Modifier and Type	Method and Description
SessionHandle	ExecutorImpl.getSessionHandle()

Constructors in org.apache.flink.table.client.gateway with annotations of type VisibleForTesting

Constructor and Description
StatementResult(ResolvedSchema resultSchema, CloseableIterator<RowData> resultProvider, boolean isQueryResult, ResultKind resultKind, JobID jobID, RowDataToStringConverter toStringConverter)

Uses of VisibleForTesting in org.apache.flink.table.client.gateway.result

Fields in org.apache.flink.table.client.gateway.result with annotations of type VisibleForTesting

Modifier and Type	Field and Description
protected static int	ChangelogCollectResult.CHANGE_RECORD_BUFFER_SIZE

Methods in org.apache.flink.table.client.gateway.result with annotations of type VisibleForTesting

Modifier and Type	Method and Description
protected List<RowData>	MaterializedCollectResultBase.getMaterializedTable()

Constructors in org.apache.flink.table.client.gateway.result with annotations of type VisibleForTesting

Constructor and Description
MaterializedCollectBatchResult(StatementResult tableResult, int maxRowCount, int overcommitThreshold)
MaterializedCollectStreamResult(StatementResult tableResult, int maxRowCount, int overcommitThreshold)

Uses of VisibleForTesting in org.apache.flink.table.connector.source

Methods in org.apache.flink.table.connector.source with annotations of type VisibleForTesting

Modifier and Type	Method and Description
Collection<RowData>	DynamicFilteringData.getData()

Uses of VisibleForTesting in org.apache.flink.table.endpoint.hive

Constructors in org.apache.flink.table.endpoint.hive with annotations of type VisibleForTesting

Constructor and Description
HiveServer2Endpoint(SqlGatewayService service, InetSocketAddress socketAddress, long maxMessageSize, int requestTimeoutMs, int backOffSlotLengthMs, int minWorkerThreads, int maxWorkerThreads, Duration workerKeepAliveTime, String catalogName, HiveConf hiveConf, String defaultDatabase, String moduleName, boolean allowEmbedded, boolean isVerbose)

Uses of VisibleForTesting in org.apache.flink.table.endpoint.hive.util

Methods in org.apache.flink.table.endpoint.hive.util with annotations of type VisibleForTesting

Modifier and Type	Method and Description
static org.apache.hive.service.rpc.thrift.TRowSet	ThriftObjectConversions.toColumnBasedSet(List<LogicalType> fieldTypes, List<RowData.FieldGetter> fieldGetters, List<RowData> rows)
static org.apache.hive.service.rpc.thrift.TRowSet	ThriftObjectConversions.toRowBasedSet(List<LogicalType> fieldTypes, List<RowData.FieldGetter> fieldGetters, List<RowData> rows)

Uses of VisibleForTesting in org.apache.flink.table.functions.hive

Methods in org.apache.flink.table.functions.hive with annotations of type VisibleForTesting

Modifier and Type	Method and Description
protected void	HiveGenericUDTF.setCollector(org.apache.hadoop.hive.ql.udf.generic.Collector collector)

Uses of VisibleForTesting in org.apache.flink.table.gateway.rest.handler.util

Constructors in org.apache.flink.table.gateway.rest.handler.util with annotations of type VisibleForTesting

Constructor and Description
GetApiVersionHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,GetApiVersionResponseBody,EmptyMessageParameters> messageHeaders, List<SqlGatewayRestAPIVersion> stableVersions)

Uses of VisibleForTesting in org.apache.flink.table.gateway.service

Methods in org.apache.flink.table.gateway.service with annotations of type VisibleForTesting

Modifier and Type	Method and Description
Session	SqlGatewayServiceImpl.getSession(SessionHandle sessionHandle)

Uses of VisibleForTesting in org.apache.flink.table.gateway.service.operation

Classes in org.apache.flink.table.gateway.service.operation with annotations of type VisibleForTesting

Modifier and Type	Class and Description
class	OperationManager.Operation Operation to manage the execution, results and so on.

Methods in org.apache.flink.table.gateway.service.operation with annotations of type VisibleForTesting

Modifier and Type	Method and Description
OperationManager.Operation	OperationManager.getOperation(OperationHandle operationHandle)
int	OperationManager.getOperationCount()

Constructors in org.apache.flink.table.gateway.service.operation with annotations of type VisibleForTesting

Constructor and Description
OperationExecutor(SessionContext context, Configuration executionConfig)

Uses of VisibleForTesting in org.apache.flink.table.gateway.service.result

Methods in org.apache.flink.table.gateway.service.result with annotations of type VisibleForTesting

Modifier and Type	Method and Description
ResultStore	ResultFetcher.getResultStore()

Uses of VisibleForTesting in org.apache.flink.table.gateway.service.session

Methods in org.apache.flink.table.gateway.service.session with annotations of type VisibleForTesting

Modifier and Type	Method and Description
int	SessionManagerImpl.currentSessionCount()
int	SessionManagerImpl.getOperationCount(SessionHandle sessionHandle)
boolean	SessionManagerImpl.isSessionAlive(SessionHandle sessionId)

Uses of VisibleForTesting in org.apache.flink.table.jdbc

Constructors in org.apache.flink.table.jdbc with annotations of type VisibleForTesting

Constructor and Description
FlinkDatabaseMetaData(String url, FlinkConnection connection, Statement statement)

Uses of VisibleForTesting in org.apache.flink.table.module.hive

Constructors in org.apache.flink.table.module.hive with annotations of type VisibleForTesting

Constructor and Description
HiveModule()
HiveModule(String hiveVersion)

Uses of VisibleForTesting in org.apache.flink.table.operations

Methods in org.apache.flink.table.operations with annotations of type VisibleForTesting

Modifier and Type	Method and Description
ObjectIdentifier	TruncateTableOperation.getTableIdentifier()

Uses of VisibleForTesting in org.apache.flink.table.planner.plan.nodes.exec

Methods in org.apache.flink.table.planner.plan.nodes.exec with annotations of type VisibleForTesting

Modifier and Type	Method and Description
Transformation<T>	ExecNodeBase.getTransformation()
static ExecNodeConfig	ExecNodeConfig.ofTableConfig(TableConfig tableConfig, boolean isCompiled)
static void	ExecNodeContext.resetIdCounter() Reset the id counter to 0.

Uses of VisibleForTesting in org.apache.flink.table.planner.plan.nodes.exec.batch

Methods in org.apache.flink.table.planner.plan.nodes.exec.batch with annotations of type VisibleForTesting

Modifier and Type	Method and Description
Optional<StreamExchangeMode>	BatchExecExchange.getRequiredExchangeMode()
ExecNode<?>	BatchExecMultipleInput.getRootNode()

Uses of VisibleForTesting in org.apache.flink.table.planner.plan.nodes.exec.common

Methods in org.apache.flink.table.planner.plan.nodes.exec.common with annotations of type VisibleForTesting

Modifier and Type	Method and Description
static Tuple2<Pattern<RowData,RowData>,List<String>>	CommonExecMatch.translatePattern(MatchSpec matchSpec, ReadableConfig config, ClassLoader classLoader, RelBuilder relBuilder, RowType inputRowType)

Uses of VisibleForTesting in org.apache.flink.table.planner.utils

Methods in org.apache.flink.table.planner.utils with annotations of type VisibleForTesting

Modifier and Type	Method and Description
static Map<String,ColumnStats>	CatalogTableStatisticsConverter.convertToColumnStatsMap(Map<String,CatalogColumnStatisticsDataBase> columnStatisticsData)

Uses of VisibleForTesting in org.apache.flink.table.resource

Methods in org.apache.flink.table.resource with annotations of type VisibleForTesting

Modifier and Type	Method and Description
protected URL	ResourceManager.getURLFromPath(Path path)

Uses of VisibleForTesting in org.apache.flink.table.runtime.functions.table.lookup

Classes in org.apache.flink.table.runtime.functions.table.lookup with annotations of type VisibleForTesting

Modifier and Type	Class and Description
static class	LookupCacheManager.RefCountedCache A wrapper class of LookupCache which also tracks the reference count of it.

Methods in org.apache.flink.table.runtime.functions.table.lookup with annotations of type VisibleForTesting

Modifier and Type	Method and Description
LookupCache	CachingLookupFunction.getCache()
LookupCache	CachingAsyncLookupFunction.getCache()

Uses of VisibleForTesting in org.apache.flink.table.runtime.generated

Constructors in org.apache.flink.table.runtime.generated with annotations of type VisibleForTesting

Constructor and Description
GeneratedAggsHandleFunction(String className, String code, Object[] references)
GeneratedCollector(String className, String code, Object[] references)
GeneratedFunction(String className, String code, Object[] references)
GeneratedJoinCondition(String className, String code, Object[] references)
GeneratedNamespaceAggsHandleFunction(String className, String code, Object[] references)
GeneratedNamespaceTableAggsHandleFunction(String className, String code, Object[] references)
GeneratedNormalizedKeyComputer(String className, String code)
GeneratedProjection(String className, String code, Object[] references)
GeneratedRecordComparator(String className, String code, Object[] references)
GeneratedRecordEqualiser(String className, String code, Object[] references)
GeneratedResultFuture(String className, String code, Object[] references)

Uses of VisibleForTesting in org.apache.flink.table.runtime.operators.join.lookup

Methods in org.apache.flink.table.runtime.operators.join.lookup with annotations of type VisibleForTesting

Modifier and Type	Method and Description
List<org.apache.flink.table.runtime.operators.join.lookup.AsyncLookupJoinRunner.JoinedRowResultFuture>	AsyncLookupJoinRunner.getAllResultFutures()

Constructors in org.apache.flink.table.runtime.operators.join.lookup with annotations of type VisibleForTesting

Constructor and Description
ResultRetryStrategy(AsyncRetryStrategy retryStrategy)

Uses of VisibleForTesting in org.apache.flink.table.runtime.operators.multipleinput

Methods in org.apache.flink.table.runtime.operators.multipleinput with annotations of type VisibleForTesting

Modifier and Type	Method and Description
int	TableOperatorWrapper.getEndedInputCount()

Uses of VisibleForTesting in org.apache.flink.table.runtime.operators.over

Methods in org.apache.flink.table.runtime.operators.over with annotations of type VisibleForTesting

Modifier and Type	Method and Description
protected Counter	RowTimeRowsBoundedPrecedingFunction.getCounter()
protected Counter	AbstractRowTimeUnboundedPrecedingOver.getCounter()
protected Counter	RowTimeRangeBoundedPrecedingFunction.getCounter()

Uses of VisibleForTesting in org.apache.flink.table.runtime.operators.python.aggregate

Fields in org.apache.flink.table.runtime.operators.python.aggregate with annotations of type VisibleForTesting

Modifier and Type	Field and Description
protected static String	PythonStreamGroupAggregateOperator.STREAM_GROUP_AGGREGATE_URN
protected static String	PythonStreamGroupTableAggregateOperator.STREAM_GROUP_TABLE_AGGREGATE_URN

Uses of VisibleForTesting in org.apache.flink.table.runtime.operators.sort

Methods in org.apache.flink.table.runtime.operators.sort with annotations of type VisibleForTesting

Modifier and Type	Method and Description
void	BinaryExternalSorter.write(MutableObjectIterator<BinaryRowData> iterator)

Uses of VisibleForTesting in org.apache.flink.table.runtime.operators.window.slicing

Methods in org.apache.flink.table.runtime.operators.window.slicing with annotations of type VisibleForTesting

Modifier and Type	Method and Description
Counter	SlicingWindowOperator.getNumLateRecordsDropped()
Gauge<Long>	SlicingWindowOperator.getWatermarkLatency()

Uses of VisibleForTesting in org.apache.flink.table.runtime.typeutils

Methods in org.apache.flink.table.runtime.typeutils with annotations of type VisibleForTesting

Modifier and Type	Method and Description
TypeSerializer	ArrayDataSerializer.getEleSer()
TypeSerializer	MapDataSerializer.getKeySerializer()
TypeSerializer	MapDataSerializer.getValueSerializer()

Uses of VisibleForTesting in org.apache.flink.util

Methods in org.apache.flink.util with annotations of type VisibleForTesting

Modifier and Type	Method and Description
int	AbstractAutoCloseableRegistry.getNumberOfRegisteredCloseables()
boolean	AbstractAutoCloseableRegistry.isCloseableRegistered(R c)

Uses of VisibleForTesting in org.apache.flink.yarn.configuration

Methods in org.apache.flink.yarn.configuration with annotations of type VisibleForTesting

Modifier and Type	Method and Description
static Configuration	YarnLogConfigUtil.setLogConfigFileInConfig(Configuration configuration, String configurationDirectory)