batch sink

stream sink

schema = 'sepal_length double, sepal_width double, petal_length double, petal_width double, category string'
csvSource = CsvSourceStreamOp()\
    .setFilePath(filePath)\
csvSink = CsvSinkStreamOp()\
    .setFilePath('~/csv_test_s.txt')
csvSource.link(csvSink)
StreamOperator.execute()