A C D E G H I M N O P R S T V
All Classes All Packages

A

AbstractTestSource<T> - Class in org.apache.flink.test.util.source

Abstract base class for test sources that provides default implementations for all Source V2 methods.

AbstractTestSource() - Constructor for class org.apache.flink.test.util.source.AbstractTestSource

AbstractTestSourceBase<T,EnumChkptState> - Class in org.apache.flink.test.util.source

Base class for test sources that allows customization of the enumerator checkpoint type.

AbstractTestSourceBase() - Constructor for class org.apache.flink.test.util.source.AbstractTestSourceBase

addReader(int) - Method in class org.apache.flink.test.util.source.SingleSplitEnumerator

addReader(int) - Method in class org.apache.flink.test.util.source.TestSplitEnumerator

addSplits(List<TestSplit>) - Method in class org.apache.flink.test.util.source.TestSourceReader

addSplitsBack(List<TestSplit>, int) - Method in class org.apache.flink.test.util.source.TestSplitEnumerator

C

checkpointState - Variable in class org.apache.flink.test.util.source.TestSplitEnumerator

clear() - Method in class org.apache.flink.test.util.source.TestReaderOutput

Clears all collected records.

close() - Method in class org.apache.flink.test.util.source.TestSourceReader

close() - Method in class org.apache.flink.test.util.source.TestSplitEnumerator

collect(T) - Method in class org.apache.flink.test.util.source.TestReaderOutput

collect(T, long) - Method in class org.apache.flink.test.util.source.TestReaderOutput

context - Variable in class org.apache.flink.test.util.source.TestSourceReader

context - Variable in class org.apache.flink.test.util.source.TestSplitEnumerator

createEnumerator(SplitEnumeratorContext<TestSplit>) - Method in class org.apache.flink.test.util.source.AbstractTestSourceBase

Creates a new split enumerator for fresh starts.

createOutputForSplit(String) - Method in class org.apache.flink.test.util.source.TestReaderOutput

createReader(SourceReaderContext) - Method in class org.apache.flink.test.util.source.AbstractTestSourceBase

Creates a source reader.

D

deserialize(int, byte[]) - Method in enum org.apache.flink.test.util.source.VoidSerializer

E

emitWatermark(Watermark) - Method in class org.apache.flink.test.util.source.TestReaderOutput

G

getBoundedness() - Method in class org.apache.flink.test.util.source.AbstractTestSourceBase

getCollected() - Method in class org.apache.flink.test.util.source.TestReaderOutput

Returns all records collected by this output.

getCollectedCount() - Method in class org.apache.flink.test.util.source.TestReaderOutput

Returns the number of records collected.

getEnumeratorCheckpointSerializer() - Method in class org.apache.flink.test.util.source.AbstractTestSource

getEnumeratorCheckpointSerializer() - Method in class org.apache.flink.test.util.source.AbstractTestSourceBase

Returns the serializer for enumerator checkpoints.

getLastEmitted() - Method in class org.apache.flink.test.util.source.TestReaderOutput

Returns the last emitted record, or null if no records have been emitted.

getSplitSerializer() - Method in class org.apache.flink.test.util.source.AbstractTestSourceBase

getVersion() - Method in enum org.apache.flink.test.util.source.VoidSerializer

H

handleSplitRequest(int, String) - Method in class org.apache.flink.test.util.source.TestSplitEnumerator

I

INSTANCE - org.apache.flink.test.util.source.VoidSerializer

INSTANCE - Static variable in class org.apache.flink.test.util.source.TestSplit

Singleton instance for reuse across all test sources.

isAvailable() - Method in class org.apache.flink.test.util.source.TestSourceReader

M

markActive() - Method in class org.apache.flink.test.util.source.TestReaderOutput

markIdle() - Method in class org.apache.flink.test.util.source.TestReaderOutput

N

notifyNoMoreSplits() - Method in class org.apache.flink.test.util.source.TestSourceReader

O

org.apache.flink.test.util.source - package org.apache.flink.test.util.source

P

pollNext(ReaderOutput<T>) - Method in class org.apache.flink.test.util.source.TestSourceReader

R

releaseOutputForSplit(String) - Method in class org.apache.flink.test.util.source.TestReaderOutput

restoreEnumerator(SplitEnumeratorContext<TestSplit>, EnumChkptState) - Method in class org.apache.flink.test.util.source.AbstractTestSourceBase

Restores a split enumerator from a checkpoint.

S

serialize(Void) - Method in enum org.apache.flink.test.util.source.VoidSerializer

SERIALIZER - Static variable in class org.apache.flink.test.util.source.TestSplit

Serializer for TestSplit instances.

SingleSplitEnumerator - Class in org.apache.flink.test.util.source

A split enumerator where the first reader gets one split, others get nothing.

SingleSplitEnumerator(SplitEnumeratorContext<TestSplit>) - Constructor for class org.apache.flink.test.util.source.SingleSplitEnumerator

snapshotState(long) - Method in class org.apache.flink.test.util.source.TestSourceReader

snapshotState(long) - Method in class org.apache.flink.test.util.source.TestSplitEnumerator

Subclasses should override this method to provide their checkpoint state.

splitId() - Method in class org.apache.flink.test.util.source.TestSplit

start() - Method in class org.apache.flink.test.util.source.TestSourceReader

start() - Method in class org.apache.flink.test.util.source.TestSplitEnumerator

T

TestReaderOutput<T> - Class in org.apache.flink.test.util.source

Test utility for capturing output from SourceReader implementations.

TestReaderOutput() - Constructor for class org.apache.flink.test.util.source.TestReaderOutput

TestSourceReader<T> - Class in org.apache.flink.test.util.source

Base class for test source readers that provides default implementations for all SourceReader methods.

TestSourceReader(SourceReaderContext) - Constructor for class org.apache.flink.test.util.source.TestSourceReader

TestSplit - Class in org.apache.flink.test.util.source

A simple test split implementation that can be reused across test sources.

TestSplitEnumerator<EnumChkptState> - Class in org.apache.flink.test.util.source

Base split enumerator for test sources that provides sensible defaults for most methods.

TestSplitEnumerator(SplitEnumeratorContext<TestSplit>, EnumChkptState) - Constructor for class org.apache.flink.test.util.source.TestSplitEnumerator

toString() - Method in class org.apache.flink.test.util.source.TestSplit

V

valueOf(String) - Static method in enum org.apache.flink.test.util.source.VoidSerializer

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.apache.flink.test.util.source.VoidSerializer

Returns an array containing the constants of this enum type, in the order they are declared.

VoidSerializer - Enum in org.apache.flink.test.util.source

A serializer for Void checkpoint states.

A C D E G H I M N O P R S T V
All Classes All Packages