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.operator
org.apache.flink.contrib.streaming.state
org.apache.flink.orc
org.apache.flink.queryablestate.network
org.apache.flink.runtime.blob
org.apache.flink.runtime.checkpoint
org.apache.flink.runtime.checkpoint.savepoint
org.apache.flink.runtime.executiongraph
org.apache.flink.runtime.executiongraph.failover
org.apache.flink.runtime.io.network
org.apache.flink.runtime.io.network.partition
org.apache.flink.runtime.io.network.partition.consumer
org.apache.flink.runtime.jobmanager.scheduler
org.apache.flink.runtime.jobmaster.slotpool
org.apache.flink.runtime.messages.checkpoint	This package contains the messages that are sent between JobManager and TaskManager to coordinate the checkpoint snapshots of the distributed dataflow.
org.apache.flink.runtime.metrics
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.security.modules
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.streaming.api.functions.sink
org.apache.flink.streaming.api.functions.source
org.apache.flink.streaming.api.operators
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.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.util

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

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

Modifier and Type	Method and Description
PatternFlatSelectFunction<IN,OUT1>	FlatSelectTimeoutCepOperator.FlatSelectWrapper.getFlatSelectFunction()
PatternFlatTimeoutFunction<IN,OUT2>	FlatSelectTimeoutCepOperator.FlatSelectWrapper.getFlatTimeoutFunction()
int	AbstractKeyedCEPPatternOperator.getPQSize(KEY key)
boolean	AbstractKeyedCEPPatternOperator.hasNonEmptyNFA(KEY key)
boolean	AbstractKeyedCEPPatternOperator.hasNonEmptyPQ(KEY key)

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
int	RocksDBKeyedStateBackend.numStateEntries()

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

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

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
CheckpointTriggerResult	CheckpointCoordinator.triggerCheckpoint(long timestamp, CheckpointProperties props, String externalSavepointLocation, boolean isPeriodic)

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

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

Modifier and Type	Method and Description
static KeyedStateHandle	SavepointV1Serializer.deserializeKeyedStateHandle(DataInputStream dis)
static OperatorStateHandle	SavepointV1Serializer.deserializeOperatorStateHandle(DataInputStream dis)
static StreamStateHandle	SavepointV1Serializer.deserializeStreamStateHandle(DataInputStream dis)
static void	SavepointV1Serializer.serializeKeyedStateHandle(KeyedStateHandle stateHandle, DataOutputStream dos)
static void	SavepointV1Serializer.serializeOperatorStateHandle(OperatorStateHandle stateHandle, DataOutputStream dos)
static void	SavepointV1Serializer.serializeStreamStateHandle(StreamStateHandle stateHandle, DataOutputStream dos)
static void	SavepointSerializers.setFailWhenLegacyStateDetected(boolean fail) This is only visible as a temporary solution to keep the stateful job migration it cases working from binary savepoints that still contain legacy state (<= Flink 1.1).

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(SimpleSlot slot)
JobStatus	ExecutionGraph.waitUntilTerminal()

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

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

Modifier and Type	Method and Description
FailoverRegion	RestartPipelinedRegionStrategy.getFailoverRegion(ExecutionVertex ev) Finds the failover region that contains the given execution vertex.

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
void	NetworkEnvironment.setupInputGate(SingleInputGate gate)
void	NetworkEnvironment.setupPartition(ResultPartition partition)

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.getBuffersInBacklog() Gets the number of non-event buffers in this subpartition.

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	RemoteInputChannel.requestSubpartition(int subpartitionIndex) Requests a remote subpartition.

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

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

Modifier and Type	Method and Description
Instance	Scheduler.getInstance(ResourceID resourceId)

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
protected org.apache.flink.runtime.jobmaster.slotpool.SlotPool.AllocatedSlots	SlotPool.getAllocatedSlots()
protected SlotPool.AvailableSlots	SlotPool.getAvailableSlots()
Collection<SlotSharingManager.MultiTaskSlot>	SlotSharingManager.getResolvedRootSlots() Returns a collection of all resolved root slots.
int	SlotPool.AvailableSlots.size()
protected void	SlotPool.timeoutPendingSlotRequest(SlotRequestId slotRequestId)

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

Constructor and Description
SlotPool(RpcService rpcService, JobID jobId, SchedulingStrategy schedulingStrategy)

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
akka.actor.ActorRef	MetricRegistryImpl.getQueryService()
List<MetricReporter>	MetricRegistryImpl.getReporters()

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 void	ResourceManager.startNewWorker(ResourceProfile resourceProfile) Allocates a resource using the resource profile.

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
void	SlotManager.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.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.state

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

Modifier and Type	Method and Description
SharedStateRegistryKey	IncrementalKeyedStateHandle.createSharedStateRegistryKeyFromFileName(StateHandleID shId) Create a unique key to register one of our shared state handles.
boolean	IncrementalKeyedStateHandle.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	IncrementalKeyedStateHandle.hashCode() This method should only be called in tests! This should never serve as key in a hash map.
abstract int	AbstractKeyedStateBackend.numStateEntries() Returns the total number of state entries across all keys/namespaces.
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

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

Modifier and Type	Method and Description
LocalRecoveryConfig	HeapKeyedStateBackend.getLocalRecoveryConfig()
Map<N,Map<K,S>>[]	NestedMapsStateTable.getState() Returns the internal data structure.
StateTable<K,N,SV>	AbstractHeapState.getStateTable() This should only be used for testing.
int	HeapKeyedStateBackend.numStateEntries() Returns the total number of state entries across all keys/namespaces.
int	HeapKeyedStateBackend.numStateEntries(Object namespace) Returns the total number of state entries across all keys for the given namespace.
abstract 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	JobLeaderService.containsJob(JobID jobId) Check whether the service monitors the given job.

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

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

Modifier and Type	Method and Description
Set<InternalTimer<K,N>>[]	HeapInternalTimerService.getEventTimeTimersPerKeyGroup()
int	HeapInternalTimerService.getLocalKeyGroupRangeStartIdx()
Set<InternalTimer<K,N>>[]	HeapInternalTimerService.getProcessingTimeTimersPerKeyGroup()
int	InternalTimeServiceManager.numEventTimeTimers()
int	AbstractStreamOperator.numEventTimeTimers()
int	InternalTimeServiceManager.numProcessingTimeTimers()
int	AbstractStreamOperator.numProcessingTimeTimers()

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

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	FlinkKafkaProducer011.ContextStateSerializer TypeSerializer for FlinkKafkaProducer011.KafkaTransactionContext.
static class	FlinkKafkaProducer011.KafkaTransactionContext Context associated to this instance of the FlinkKafkaProducer011.
static class	FlinkKafkaProducer011.TransactionStateSerializer TypeSerializer for KafkaTransactionState.

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

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

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

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

Modifier and Type	Method and Description
int	FlinkKafkaProducer.getTransactionCoordinatorId()

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,ACC>,?>	WindowOperator.getStateDescriptor()
StateDescriptor<? extends AppendingState<IN,Iterable<IN>>,?>	EvictingWindowOperator.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

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

Modifier and Type	Class and Description
protected static class	StreamTask.AsyncCheckpointRunnable This runnable executes the asynchronous parts of all involved backend snapshots for the subtask.

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

Modifier and Type	Method and Description
static <OUT> List<StreamRecordWriter<SerializationDelegate<StreamRecord<OUT>>>>	StreamTask.createStreamRecordWriters(StreamConfig configuration, Environment environment)

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

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

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)