blob: d3663fedd68ad916f1436e33c3b8a85f8e14d5fe [file] [log] [blame]
source {
fields = ["ID"]
scheme = file
path = "target/test-classes"
readerPath = "1000twitterids.txt"
}
destination {
fields = ["DOC"]
scheme = file
path = "target/test-classes"
writerPath = "FlinkTwitterUserInformationPipelineIT"
}
providerWaitMs = 1000
local = true
test = true