This operator is a Access operator with predefined parameters for:
- Transport handler:File transport handler
- Wrapper: Generic Pull
- Data handler: Tuple data handler
The following parameters (are options in the coressponding handlers) are supported
- From File transport handler:
- filename or directory
- From CSV protocol handler/ SimpleCSV protocol handler
- delimiter
- nullValueText
- textDelimiter
- trim
- readFirstLine
Remark: If a textDelimiter is defined, CSV protocol handler is used, else SimpleCSV protocol handler
in = CSVFILESOURCE({
delimiter = '\t',
schema = [
['ts', 'STARTTIMESTAMP'],
['value', 'Integer']
],
source = 'cars',
filename = '${WORKSPACEPROJECT}/example.csv',
options = [['baseTimeUnit','MILLISECONDS']]
}
)