org.apache.flink.connector.pulsar.source.enumerator.assigner

Class SplitAssignerFactory

java.lang.Object

org.apache.flink.connector.pulsar.source.enumerator.assigner.SplitAssignerFactory

@Internal
public final class SplitAssignerFactory
extends Object

The factory for creating split assigner.

Method Summary

Modifier and Type	Method and Description
static SplitAssigner	createAssigner(StopCursor stopCursor, SourceConfiguration sourceConfiguration, SplitEnumeratorContext<PulsarPartitionSplit> context, PulsarSourceEnumState enumState)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

createAssigner

public static SplitAssigner createAssigner(StopCursor stopCursor,
                                           SourceConfiguration sourceConfiguration,
                                           SplitEnumeratorContext<PulsarPartitionSplit> context,
                                           PulsarSourceEnumState enumState)