Uses of Class
org.apache.flink.connector.testframe.source.split.FromElementsSplit
-
Packages that use FromElementsSplit Package Description org.apache.flink.connector.testframe.source org.apache.flink.connector.testframe.source.enumerator org.apache.flink.connector.testframe.source.split -
-
Uses of FromElementsSplit in org.apache.flink.connector.testframe.source
Methods in org.apache.flink.connector.testframe.source that return types with arguments of type FromElementsSplit Modifier and Type Method Description org.apache.flink.api.connector.source.SplitEnumerator<FromElementsSplit,NoOpEnumState>FromElementsSource. createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FromElementsSplit> enumContext)org.apache.flink.api.connector.source.SourceReader<OUT,FromElementsSplit>FromElementsSource. createReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext)org.apache.flink.core.io.SimpleVersionedSerializer<FromElementsSplit>FromElementsSource. getSplitSerializer()org.apache.flink.api.connector.source.SplitEnumerator<FromElementsSplit,NoOpEnumState>FromElementsSource. restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FromElementsSplit> enumContext, NoOpEnumState checkpoint)List<FromElementsSplit>FromElementsSourceReader. snapshotState(long checkpointId)Method parameters in org.apache.flink.connector.testframe.source with type arguments of type FromElementsSplit Modifier and Type Method Description voidFromElementsSourceReader. addSplits(List<FromElementsSplit> splits)org.apache.flink.api.connector.source.SplitEnumerator<FromElementsSplit,NoOpEnumState>FromElementsSource. createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FromElementsSplit> enumContext)org.apache.flink.api.connector.source.SplitEnumerator<FromElementsSplit,NoOpEnumState>FromElementsSource. restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FromElementsSplit> enumContext, NoOpEnumState checkpoint) -
Uses of FromElementsSplit in org.apache.flink.connector.testframe.source.enumerator
Method parameters in org.apache.flink.connector.testframe.source.enumerator with type arguments of type FromElementsSplit Modifier and Type Method Description voidNoOpEnumerator. addSplitsBack(List<FromElementsSplit> splits, int subtaskId) -
Uses of FromElementsSplit in org.apache.flink.connector.testframe.source.split
Methods in org.apache.flink.connector.testframe.source.split that return FromElementsSplit Modifier and Type Method Description FromElementsSplitFromElementsSplitSerializer. deserialize(int version, byte[] serialized)Methods in org.apache.flink.connector.testframe.source.split with parameters of type FromElementsSplit Modifier and Type Method Description byte[]FromElementsSplitSerializer. serialize(FromElementsSplit split)
-