include/lightspeed@pipeline@connector_FileSource.hrl
-record(file_source, {
name :: binary(),
path :: binary(),
format :: binary(),
batch_size :: integer()
}).
-record(file_source, {
name :: binary(),
path :: binary(),
format :: binary(),
batch_size :: integer()
}).