Package | Description |
---|---|
org.apache.flink.connector.testframe.source | |
org.apache.flink.connector.testframe.source.enumerator |
Modifier and Type | Method and Description |
---|---|
SplitEnumerator<FromElementsSplit,NoOpEnumState> |
FromElementsSource.createEnumerator(SplitEnumeratorContext<FromElementsSplit> enumContext) |
SimpleVersionedSerializer<NoOpEnumState> |
FromElementsSource.getEnumeratorCheckpointSerializer() |
SplitEnumerator<FromElementsSplit,NoOpEnumState> |
FromElementsSource.restoreEnumerator(SplitEnumeratorContext<FromElementsSplit> enumContext,
NoOpEnumState checkpoint) |
Modifier and Type | Method and Description |
---|---|
SplitEnumerator<FromElementsSplit,NoOpEnumState> |
FromElementsSource.restoreEnumerator(SplitEnumeratorContext<FromElementsSplit> enumContext,
NoOpEnumState checkpoint) |
Modifier and Type | Method and Description |
---|---|
NoOpEnumState |
NoOpEnumStateSerializer.deserialize(int version,
byte[] serialized) |
NoOpEnumState |
NoOpEnumerator.snapshotState(long checkpointId) |
Modifier and Type | Method and Description |
---|---|
byte[] |
NoOpEnumStateSerializer.serialize(NoOpEnumState obj) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.