Class HybridSourceEnumeratorState
- java.lang.Object
-
- org.apache.flink.connector.base.source.hybrid.HybridSourceEnumeratorState
-
public class HybridSourceEnumeratorState extends Object
The state of hybrid source enumerator.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description int
getCurrentSourceIndex()
byte[]
getWrappedState()
int
getWrappedStateSerializerVersion()
-