pyflink package

Subpackages

• pyflink.common package
• pyflink.table package
• pyflink.dataset package
• pyflink.datastream package

pyflink.add_version_doc(f, version)

Annotates a function to append the version the function was added.

pyflink.keyword(func)

A decorator that forces keyword arguments usage and store actual input keyword arguments in _input_kwargs.