bryanyang0528/ksql-python

default value of condition should be string

Closed this issue · 0 comments

bryanyang0528 commented 
def build(self, table_name, select_columns, src_table, kafka_topic=None, 
			  value_format='DELIMITED', conditions=[], partition_by=None, **kwargs):