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 |