def create_source_table()

in pyflink-examples/StreamingFileSink/streaming-file-sink.py [0:0]

• 2 lines of code
• 1 McCabe index (conditional complexity)

def create_source_table(table_name, stream_name, region, stream_initpos):
    return """ CREATE TABLE {0} (