This operator is a Access operator with predefined parameters for:

The following parameters (are options in the coressponding handlers) are supported

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']]
  }
)
  • No labels