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.io.jdbc
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.client.program.rest
org.apache.flink.configuration
org.apache.flink.connector.base.source.reader.synchronization
org.apache.flink.connector.hbase.sink
org.apache.flink.connector.hbase.source
org.apache.flink.connector.jdbc
org.apache.flink.connector.jdbc.catalog
org.apache.flink.connector.jdbc.internal
org.apache.flink.connector.jdbc.table
org.apache.flink.connectors.hive.read
org.apache.flink.contrib.streaming.state
org.apache.flink.core.fs
org.apache.flink.core.memory
org.apache.flink.core.plugin
org.apache.flink.formats.parquet
org.apache.flink.fs.s3.common.utils
org.apache.flink.kubernetes.kubeclient.decorators
org.apache.flink.orc
org.apache.flink.orc.shim
org.apache.flink.orc.writer
org.apache.flink.python
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.metadata
org.apache.flink.runtime.clusterframework	This package contains the cluster resource management functionality.
org.apache.flink.runtime.clusterframework.types
org.apache.flink.runtime.executiongraph
org.apache.flink.runtime.executiongraph.failover.flip1
org.apache.flink.runtime.highavailability.nonha.embedded
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.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.jobmanager.scheduler
org.apache.flink.runtime.jobmaster.slotpool
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.metrics
org.apache.flink.runtime.minicluster
org.apache.flink.runtime.net
org.apache.flink.runtime.operators.coordination
org.apache.flink.runtime.query
org.apache.flink.runtime.resourcemanager
org.apache.flink.runtime.resourcemanager.slotmanager
org.apache.flink.runtime.rest.handler.legacy.metrics
org.apache.flink.runtime.rpc.akka
org.apache.flink.runtime.scheduler
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.bash
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.transformations
org.apache.flink.streaming.api.windowing.evictors
org.apache.flink.streaming.api.windowing.triggers
org.apache.flink.streaming.connectors.elasticsearch
org.apache.flink.streaming.connectors.fs.bucketing
org.apache.flink.streaming.connectors.kafka
org.apache.flink.streaming.connectors.kafka.internal
org.apache.flink.streaming.connectors.kinesis
org.apache.flink.streaming.connectors.kinesis.internals
org.apache.flink.streaming.runtime.io
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.streamstatus
org.apache.flink.streaming.runtime.tasks	This package contains classes that realize streaming tasks.
org.apache.flink.streaming.runtime.tasks.mailbox
org.apache.flink.table.api.internal
org.apache.flink.table.catalog
org.apache.flink.table.catalog.hive
org.apache.flink.table.client.cli
org.apache.flink.table.client.gateway.local
org.apache.flink.table.client.gateway.local.result
org.apache.flink.table.executor
org.apache.flink.table.filesystem
org.apache.flink.table.functions.hive
org.apache.flink.table.planner.delegation
org.apache.flink.table.planner.functions.aggfunctions
org.apache.flink.table.planner.utils
org.apache.flink.table.runtime.operators.sort
org.apache.flink.table.runtime.runners.python
org.apache.flink.table.runtime.runners.python.scalar
org.apache.flink.table.runtime.runners.python.table
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()

Uses of VisibleForTesting in org.apache.flink.api.java.io.jdbc

Methods in org.apache.flink.api.java.io.jdbc with annotations of type VisibleForTesting

Modifier and Type	Method and Description
protected Connection	JDBCInputFormat.getDbConn() Deprecated.
protected PreparedStatement	JDBCInputFormat.getStatement() Deprecated.

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()

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.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.hbase.sink

Methods in org.apache.flink.connector.hbase.sink with annotations of type VisibleForTesting

Modifier and Type	Method and Description
HBaseOptions	HBaseUpsertTableSink.getHBaseOptions()
HBaseOptions	HBaseDynamicTableSink.getHBaseOptions()
HBaseTableSchema	HBaseUpsertTableSink.getHBaseTableSchema()
HBaseTableSchema	HBaseDynamicTableSink.getHBaseTableSchema()
HBaseWriteOptions	HBaseUpsertTableSink.getWriteOptions()
HBaseWriteOptions	HBaseDynamicTableSink.getWriteOptions()

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

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

Modifier and Type	Method and Description
HBaseTableSchema	HBaseDynamicTableSource.getHBaseTableSchema()
HBaseTableSchema	HBaseTableSource.getHBaseTableSchema()
String	HBaseRowDataLookupFunction.getHTableName()
String	HBaseLookupFunction.getHTableName()

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

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

Modifier and Type	Method and Description
protected Connection	JdbcInputFormat.getDbConn()
protected PreparedStatement	JdbcInputFormat.getStatement()

Uses of VisibleForTesting in org.apache.flink.connector.jdbc.catalog

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

Modifier and Type	Method and Description
AbstractJdbcCatalog	JdbcCatalog.getInternal()

Uses of VisibleForTesting in org.apache.flink.connector.jdbc.internal

Methods in org.apache.flink.connector.jdbc.internal with annotations of type VisibleForTesting

Modifier and Type	Method and Description
Connection	AbstractJdbcOutputFormat.getConnection()

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

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

Modifier and Type	Method and Description
Connection	JdbcRowDataLookupFunction.getDbConnection()
Connection	JdbcLookupFunction.getDbConnection()

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
void	RocksDBKeyedStateBackend.compactState(StateDescriptor<?,?> stateDesc)
PredefinedOptions	RocksDBStateBackend.getPredefinedOptions() Gets the currently set predefined options for RocksDB.
int	RocksDBKeyedStateBackend.numKeyValueStateEntries()

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	RefCountedFile.getReferenceCounter()

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)

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 ClassLoader	PluginLoader.createPluginClassLoader(PluginDescriptor pluginDescriptor, ClassLoader parentClassLoader, String[] alwaysParentFirstPatterns)

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

Constructor and Description
PluginLoader(ClassLoader pluginClassLoader)

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

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

Modifier and Type	Method and Description
protected org.apache.parquet.filter2.predicate.FilterPredicate	ParquetInputFormat.getPredicate()

Uses of VisibleForTesting in org.apache.flink.fs.s3.common.utils

Methods in org.apache.flink.fs.s3.common.utils with annotations of type VisibleForTesting

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

Constructors in org.apache.flink.fs.s3.common.utils with annotations of type VisibleForTesting

Constructor and Description
RefCountedBufferingFileStream(RefCountedFileWithStream file, int bufferSize)

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.orc

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

Modifier and Type	Method and Description
protected OrcRowInputFormat	OrcTableSource.buildOrcInputFormat()
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

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

Modifier and Type	Method and Description
org.apache.beam.runners.fnexecution.control.JobBundleFactory	AbstractPythonFunctionRunner.createJobBundleFactory(org.apache.beam.vendor.grpc.v1p21p0.com.google.protobuf.Struct pipelineOptions)

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	ProcessPythonEnvironmentManager.PYTHON_REQUIREMENTS_CACHE
static String	ProcessPythonEnvironmentManager.PYTHON_REQUIREMENTS_FILE
static String	ProcessPythonEnvironmentManager.PYTHON_REQUIREMENTS_INSTALL_DIR
static String	ProcessPythonEnvironmentManager.PYTHON_WORKING_DIR

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	Client.isEventGroupShutdown()
boolean	AbstractServerBase.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	BlobServer.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	TransientBlobCache.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
PermanentBlobKey() Constructs a new BLOB key.
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()
CompletableFuture<CompletedCheckpoint>	CheckpointCoordinator.triggerCheckpoint(CheckpointProperties props, String externalSavepointLocation, boolean isPeriodic)

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

Constructor and Description
CheckpointCoordinator(JobID job, CheckpointCoordinatorConfiguration chkConfig, ExecutionVertex[] tasksToTrigger, ExecutionVertex[] tasksToWaitFor, ExecutionVertex[] tasksToCommitTo, Collection<OperatorCoordinatorCheckpointContext> coordinatorsToCheckpoint, CheckpointIDCounter checkpointIDCounter, CompletedCheckpointStore completedCheckpointStore, StateBackend checkpointStateBackend, Executor executor, ScheduledExecutor timer, SharedStateRegistryFactory sharedStateRegistryFactory, CheckpointFailureManager failureManager, Clock clock)
CheckpointOptions(CheckpointType checkpointType, CheckpointStorageLocationReference targetLocation)

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

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

Modifier and Type	Method and Description
static akka.actor.ActorSystem	BootstrapTools.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.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)

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, for testability purpose only.

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)
static SlotProfile	SlotProfile.noLocality(ResourceProfile resourceProfile) Returns a slot profile for the given resource profile, without any locality requirements.
static SlotProfile	SlotProfile.noRequirements() Returns a slot profile that has no requirements.
static SlotProfile	SlotProfile.preferredLocality(ResourceProfile resourceProfile, Collection<TaskManagerLocation> preferredLocations) Returns a slot profile for the given resource profile and the preferred locations.

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
CompletableFuture<Collection<TaskManagerLocation>>	Execution.calculatePreferredLocations(LocationPreferenceConstraint locationPreferenceConstraint) Calculates the preferred locations based on the location preference constraint.
void	ExecutionVertex.deployToSlot(LogicalSlot slot)
JobStatus	ExecutionGraph.waitUntilTerminal()

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.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.network

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

Modifier and Type	Method and Description
NettyShuffleEnvironmentConfiguration	NettyShuffleEnvironment.getConfiguration()
ConnectionManager	NettyShuffleEnvironment.getConnectionManager()
Optional<InputGate>	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
Meter	RecordWriter.getIdleTimeMsPerSecond()

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.
MemorySegment	BufferBuilder.getMemorySegment()
BufferRecycler	BufferBuilder.getRecycler()

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

Constructor and Description
NetworkBufferPool(int numberOfSegmentsToAllocate, int segmentSize, int numberOfSegmentsToRequest)

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.partition

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

Modifier and Type	Method and Description
ResultPartition	ResultPartitionFactory.create(String taskNameWithSubtaskAndId, int partitionIndex, ResultPartitionID id, ResultPartitionType type, int numberOfSubpartitions, int maxParallelism, FunctionWithException<BufferPoolOwner,BufferPool,IOException> bufferPoolFactory)
int	PipelinedSubpartition.getBuffersInBacklog() Gets the number of non-event buffers in this subpartition.
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.assignExclusiveSegments() Assign the exclusive buffers to all remote input channels directly for credit-based mode.
protected InputChannel	SingleInputGateFactory.createKnownInputChannel(SingleInputGate inputGate, int index, NettyShuffleDescriptor inputChannelDescriptor, SingleInputGateFactory.ChannelStatistics channelStatistics, InputChannelMetrics metrics)
Buffer	RemoteInputChannel.getNextReceivedBuffer()
int	RemoteInputChannel.getNumberOfAvailableBuffers()
protected int	RecoveredInputChannel.getNumberOfQueuedBuffers()
int	RemoteInputChannel.getNumberOfRequiredBuffers()
int	RemoteInputChannel.getSenderBacklog()
void	RemoteInputChannel.requestSubpartition(int subpartitionIndex) Requests a remote subpartition.

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, boolean isPreferCheckpointForRecovery, int tolerableCpFailureNumber) 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)

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

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

Constructor and Description
ScheduledUnit(Execution task)
ScheduledUnit(JobVertexID jobVertexId, SlotSharingGroupId slotSharingGroupId, CoLocationConstraint coLocationConstraint)

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
Collection<SlotSharingManager.MultiTaskSlot>	SlotSharingManager.getResolvedRootSlots() Returns a collection of all resolved root slots.
int	SlotPoolImpl.AvailableSlots.size()
protected void	SlotPoolImpl.timeoutPendingSlotRequest(SlotRequestId slotRequestId)

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

Constructor and Description
SchedulerImpl(SlotSelectionStrategy slotSelectionStrategy, SlotPool slotPool, Map<SlotSharingGroupId,SlotSharingManager> slotSharingManagers)

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
org.apache.flink.runtime.memory.UnsafeMemoryBudget	MemoryManager.getMemoryBudget() Gets memory budget.
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.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, MetricReporter reporter)
List<MetricReporter>	MetricRegistryImpl.getReporters()

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, HighAvailabilityServices haServices, BlobServer blobServer, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, MetricQueryServiceRetriever metricQueryServiceRetriever, FatalErrorHandler fatalErrorHandler)
protected HighAvailabilityServices	MiniCluster.createHighAvailabilityServices(Configuration configuration, Executor executor)
protected CompletableFuture<DispatcherGateway>	MiniCluster.getDispatcherGatewayFuture()
protected CompletableFuture<Void>	MiniCluster.terminateTaskExecutor(int index)
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.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
abstract boolean	ResourceManager.startNewWorker(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
static ResourceProfile	SlotManagerImpl.generateDefaultSlotResourceProfile(WorkerResourceSpec workerResourceSpec, int numSlotsPerWorker)
int	SlotManagerImpl.getNumberAssignedPendingTaskManagerSlots()
int	SlotManagerImpl.getNumberPendingTaskManagerSlots()
void	SlotManager.unregisterTaskManagersAndReleaseResources()
void	SlotManagerImpl.unregisterTaskManagersAndReleaseResources()

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.rpc.akka

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

Modifier and Type	Method and Description
static AkkaRpcServiceUtils.AkkaRpcServiceBuilder	AkkaRpcServiceUtils.remoteServiceBuilder(Configuration configuration, String externalAddress, int externalPort)

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

Constructor and Description
AkkaRpcService(akka.actor.ActorSystem actorSystem, AkkaRpcServiceConfiguration 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
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.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(ConnectionID connectionID)
PartitionDescriptor(IntermediateDataSetID resultId, int totalNumberOfPartitions, IntermediateResultPartitionID partitionId, ResultPartitionType partitionType, int numberOfSubpartitions, int connectionIndex)
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.

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.createSharedStateRegistryKeyFromFileName(StateHandleID shId) Create a unique key to register one of our shared state handles.
boolean	IncrementalRemoteKeyedStateHandle.equals(Object o) This method is should only be called in tests! This should never serve as key in a hash map.
StreamCompressionDecorator	AbstractKeyedStateBackend.getKeyGroupCompressionDecorator()
int	IncrementalRemoteKeyedStateHandle.hashCode() This method should only be called in tests! This should never serve as key in a hash map.
abstract int	AbstractKeyedStateBackend.numKeyValueStateEntries() Returns the total number of state entries across all keys/namespaces.
int	AbstractKeyedStateBackend.numKeyValueStatesByName()
boolean	AbstractKeyedStateBackend.supportsAsynchronousSnapshots()

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

Constructor and Description
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.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.
abstract int	StateMap.sizeOfNamespace(Object namespace)
int	StateTable.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 String	TaskManagerServices.LOCAL_STATE_SUB_DIRECTORY_ROOT

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 TaskExecutorResourceSpec	TaskExecutorResourceUtils.resourceSpecFromConfigForLocalExecution(Configuration config)

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	TaskSlotTableImpl.allocateSlot(int index, JobID jobId, AllocationID allocationId, Time slotTimeout)
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.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) Constructs a new instance connection info object.

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.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()

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

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

Modifier and Type	Field and Description
static String	StreamConfig.SERIALIZEDUDF

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

Modifier and Type	Method and Description
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)

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, List<OutputSelector<?>> outputSelector, Class<? extends AbstractInvokable> 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
<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.
<K> KeyedStateBackend<K>	AbstractStreamOperator.getKeyedStateBackend()
<K> KeyedStateBackend<K>	AbstractStreamOperatorV2.getKeyedStateBackend()
OperatorStateBackend	AbstractStreamOperator.getOperatorStateBackend()
OperatorStateBackend	AbstractStreamOperatorV2.getOperatorStateBackend()
ProcessingTimeService	AbstractStreamOperator.getProcessingTimeService() Returns the ProcessingTimeService responsible for getting the current processing time and registering timers.
ProcessingTimeService	AbstractStreamOperatorV2.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()
int	InternalTimerServiceImpl.numEventTimeTimers()
int	InternalTimeServiceManager.numEventTimeTimers()
int	AbstractStreamOperator.numEventTimeTimers()
int	AbstractStreamOperatorV2.numEventTimeTimers()
int	InternalTimerServiceImpl.numEventTimeTimers(N namespace)
int	InternalTimerServiceImpl.numProcessingTimeTimers()
int	InternalTimeServiceManager.numProcessingTimeTimers()
int	AbstractStreamOperator.numProcessingTimeTimers()
int	AbstractStreamOperatorV2.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)

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 <T> byte[]	CollectSinkFunction.serializeAccumulatorResult(long offset, String version, long lastCheckpointedOffset, List<T> bufferedResults, TypeSerializer<T> serializer)

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

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

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
StreamSource<T,?>	LegacySourceTransformation.getOperator()
TwoInputStreamOperator<IN1,IN2,OUT>	TwoInputTransformation.getOperator()
StreamSink<T>	SinkTransformation.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	ContinuousEventTimeTrigger.getInterval()
long	ContinuousProcessingTimeTrigger.getInterval()
Trigger<T,W>	PurgingTrigger.getNestedTrigger()

Uses of VisibleForTesting in org.apache.flink.streaming.connectors.elasticsearch

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

Modifier and Type	Method and Description
protected org.elasticsearch.action.bulk.BulkProcessor	ElasticsearchSinkBase.buildBulkProcessor(org.elasticsearch.action.bulk.BulkProcessor.Listener listener) Build the BulkProcessor.

Uses of VisibleForTesting in org.apache.flink.streaming.connectors.fs.bucketing

Methods in org.apache.flink.streaming.connectors.fs.bucketing with annotations of type VisibleForTesting

Modifier and Type	Method and Description
org.apache.flink.streaming.connectors.fs.bucketing.BucketingSink.State<T>	BucketingSink.getState() Deprecated.

Uses of VisibleForTesting in org.apache.flink.streaming.connectors.kafka

Classes in org.apache.flink.streaming.connectors.kafka with annotations of type VisibleForTesting

Modifier and Type	Class and Description
static class	FlinkKafkaProducer.ContextStateSerializer TypeSerializer for FlinkKafkaProducer.KafkaTransactionContext.
static class	FlinkKafkaProducer.KafkaTransactionContext Context associated to this instance of the FlinkKafkaProducer.
static class	FlinkKafkaProducer.KafkaTransactionState State for handling transactions.
static class	FlinkKafkaProducer.NextTransactionalIdHintSerializer TypeSerializer for FlinkKafkaProducer.NextTransactionalIdHint.
static class	FlinkKafkaProducer.TransactionStateSerializer TypeSerializer for FlinkKafkaProducer.KafkaTransactionState.
static class	FlinkKafkaProducer011.ContextStateSerializer TypeSerializer for FlinkKafkaProducer011.KafkaTransactionContext.
static class	FlinkKafkaProducer011.KafkaTransactionContext Context associated to this instance of the FlinkKafkaProducer011.
static class	FlinkKafkaProducer011.KafkaTransactionState State for handling transactions.
static class	FlinkKafkaProducer011.NextTransactionalIdHintSerializer TypeSerializer for FlinkKafkaProducer011.NextTransactionalIdHint.
static class	FlinkKafkaProducer011.TransactionStateSerializer TypeSerializer for FlinkKafkaProducer011.KafkaTransactionState.

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

Modifier and Type	Method and Description
boolean	FlinkKafkaConsumerBase.getEnableCommitOnCheckpoints()
protected <K,V> org.apache.kafka.clients.producer.KafkaProducer<K,V>	FlinkKafkaProducerBase.getKafkaProducer(Properties props) Used for testing only.
protected long	FlinkKafkaProducerBase.numPendingRecords()

Constructors in org.apache.flink.streaming.connectors.kafka with annotations of type VisibleForTesting

Constructor and Description
KafkaTransactionContext(Set<String> transactionalIds)
KafkaTransactionContext(Set<String> transactionalIds)
KafkaTransactionState(FlinkKafkaInternalProducer<byte[],byte[]> producer)
KafkaTransactionState(FlinkKafkaProducer<byte[],byte[]> producer)
KafkaTransactionState(String transactionalId, FlinkKafkaInternalProducer<byte[],byte[]> producer)
KafkaTransactionState(String transactionalId, FlinkKafkaProducer<byte[],byte[]> producer)
KafkaTransactionState(String transactionalId, long producerId, short epoch, FlinkKafkaInternalProducer<byte[],byte[]> producer)
KafkaTransactionState(String transactionalId, long producerId, short epoch, FlinkKafkaProducer<byte[],byte[]> producer)

Uses of VisibleForTesting in org.apache.flink.streaming.connectors.kafka.internal

Classes in org.apache.flink.streaming.connectors.kafka.internal with annotations of type VisibleForTesting

Modifier and Type	Class and Description
static class	KafkaShuffleFetcher.KafkaShuffleElement An element in a KafkaShuffle.
static class	KafkaShuffleFetcher.KafkaShuffleElementDeserializer<T> Deserializer for KafkaShuffleElement.
static class	KafkaShuffleFetcher.KafkaShuffleRecord<T> One value with Type T in a KafkaShuffle.
static class	KafkaShuffleFetcher.KafkaShuffleWatermark A watermark element in a KafkaShuffle.

Methods in org.apache.flink.streaming.connectors.kafka.internal with annotations of type VisibleForTesting

Modifier and Type	Method and Description
KafkaShuffleFetcher.KafkaShuffleElement	KafkaShuffleFetcher.KafkaShuffleElementDeserializer.deserialize(org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> record)
protected org.apache.kafka.clients.consumer.ConsumerRecords<byte[],byte[]>	KafkaConsumerThread.getRecordsFromKafka() Get records from Kafka.
int	FlinkKafkaInternalProducer.getTransactionCoordinatorId()
int	FlinkKafkaProducer.getTransactionCoordinatorId()

Constructors in org.apache.flink.streaming.connectors.kafka.internal with annotations of type VisibleForTesting

Constructor and Description
KafkaShuffleElementDeserializer(TypeSerializer<T> typeSerializer)

Uses of VisibleForTesting in org.apache.flink.streaming.connectors.kinesis

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

Modifier and Type	Method and Description
protected com.amazonaws.services.kinesis.producer.KinesisProducer	FlinkKinesisProducer.getKinesisProducer(com.amazonaws.services.kinesis.producer.KinesisProducerConfiguration producerConfig) Creates a KinesisProducer.

Uses of VisibleForTesting in org.apache.flink.streaming.connectors.kinesis.internals

Methods in org.apache.flink.streaming.connectors.kinesis.internals with annotations of type VisibleForTesting

Modifier and Type	Method and Description
protected ExecutorService	KinesisDataFetcher.createShardConsumersThreadPool(String subtaskName)
protected void	KinesisDataFetcher.emitWatermark() Called periodically to emit a watermark.
protected long	KinesisDataFetcher.getCurrentTimeMillis() Return the current system time.
List<KinesisStreamShardState>	KinesisDataFetcher.getSubscribedShardsState()

Constructors in org.apache.flink.streaming.connectors.kinesis.internals with annotations of type VisibleForTesting

Constructor and Description

KinesisDataFetcher(List<String> streams, SourceFunction.SourceContext<T> sourceContext, Object checkpointLock, RuntimeContext runtimeContext, Properties configProps, KinesisDeserializationSchema<T> deserializationSchema, KinesisShardAssigner shardAssigner, AssignerWithPeriodicWatermarks<T> periodicWatermarkAssigner, WatermarkTracker watermarkTracker, AtomicReference<Throwable> error, List<KinesisStreamShardState> subscribedShardsState, HashMap<String,String> subscribedStreamsToLastDiscoveredShardIds, KinesisDataFetcher.FlinkKinesisProxyFactory kinesisProxyFactory)

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

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

Modifier and Type	Method and Description
int	CheckpointBarrierAligner.getNumClosedChannels()

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
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.streamstatus

Classes in org.apache.flink.streaming.runtime.streamstatus 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.streamstatus 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.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)
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
Meter	MailboxProcessor.getIdleTime()
boolean	MailboxProcessor.hasMail()
boolean	MailboxProcessor.isDefaultActionUnavailable()
boolean	MailboxProcessor.isMailboxLoopRunning()
boolean	MailboxProcessor.runMailboxStep() Execute a single (as small as possible) step of the mailbox.

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

Constructor and Description
TaskMailboxImpl()

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
protected ExplainDetail[]	TableEnvironmentImpl.getExplainDetails(boolean extended)
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
static CatalogManager.TableLookupResult	CatalogManager.TableLookupResult.permanent(CatalogBaseTable table, TableSchema resolvedSchema)
static CatalogManager.TableLookupResult	CatalogManager.TableLookupResult.temporary(CatalogBaseTable table, TableSchema resolvedSchema)

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.conf.HiveConf	HiveCatalog.getHiveConf()
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)
org.apache.hadoop.hive.metastore.api.Table	HiveCatalog.getHiveTable(ObjectPath tablePath)
String	HiveCatalog.getHiveVersion()
static boolean	HiveCatalog.isEmbeddedMetastore(org.apache.hadoop.hive.conf.HiveConf hiveConf)

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

Constructor and Description
HiveCatalog(String catalogName, String defaultDatabase, org.apache.hadoop.hive.conf.HiveConf hiveConf, String hiveVersion, boolean allowEmbedded)

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
CliClient(org.jline.terminal.Terminal terminal, String sessionId, Executor executor, Path historyFilePath) Creates a CLI instance with a custom terminal.

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

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

Modifier and Type	Method and Description
protected ExecutionContext<?>	LocalExecutor.getExecutionContext(String sessionId) Get the existed ExecutionContext from contextMap, or thrown exception if does not exist.

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

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

Modifier and Type	Method and Description
protected List<Row>	MaterializedCollectStreamResult.getMaterializedTable()

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

Constructor and Description
MaterializedCollectStreamResult(TableSchema tableSchema, ExecutionConfig config, InetAddress gatewayAddress, int gatewayPort, int maxRowCount, int overcommitThreshold, ClassLoader classLoader)

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

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

Constructor and Description
StreamExecutor(StreamExecutionEnvironment executionEnvironment)

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

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

Modifier and Type	Method and Description
java.time.Duration	FileSystemLookupFunction.getCacheTTL()

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.planner.delegation

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

Constructor and Description
BatchExecutor(StreamExecutionEnvironment executionEnvironment)
StreamExecutor(StreamExecutionEnvironment executionEnvironment)

Uses of VisibleForTesting in org.apache.flink.table.planner.functions.aggfunctions

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

Modifier and Type	Method and Description
boolean	ListAggWithRetractAggFunction.ListAggWithRetractAccumulator.equals(Object o)
boolean	ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator.equals(Object o)

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.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.runners.python

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

Modifier and Type	Method and Description
abstract FlinkFnApi.UserDefinedFunctions	AbstractPythonStatelessFunctionRunner.getUserDefinedFunctionsProto() Gets the proto representation of the Python user-defined functions to be executed.

Uses of VisibleForTesting in org.apache.flink.table.runtime.runners.python.scalar

Methods in org.apache.flink.table.runtime.runners.python.scalar with annotations of type VisibleForTesting

Modifier and Type	Method and Description
FlinkFnApi.UserDefinedFunctions	AbstractPythonScalarFunctionRunner.getUserDefinedFunctionsProto() Gets the proto representation of the Python user-defined functions to be executed.

Uses of VisibleForTesting in org.apache.flink.table.runtime.runners.python.table

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

Modifier and Type	Method and Description
FlinkFnApi.UserDefinedFunctions	AbstractPythonTableFunctionRunner.getUserDefinedFunctionsProto() Gets the proto representation of the Python user-defined functions to be executed.

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	AbstractCloseableRegistry.getNumberOfRegisteredCloseables()
boolean	AbstractCloseableRegistry.isCloseableRegistered(Closeable 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)