Hi Folks, I'm trying to find a way to create custom source functions in pyflink, but I only found this API, that seemingly just wraps a java source function. QQ: is this the only way as of now?

class SourceFunction(JavaFunctionWrapper):
    """
    Base class for all stream data source in Flink.
    """

    def __init__(self, source_func: Union[str, JavaObject]):
        """
        Constructor of SinkFunction.

        :param source_func: The java SourceFunction object.
        """
        super(SourceFunction, self).__init__(source_func)

Yes. Python connectors are always basically wrappers around the Java equivalent

Ok, thanks!