blob: 87057beec194a5c5880a9f6fcf965ea502e93864 [file] [log] [blame]
source {
fields = ["ID"]
scheme = file
path = "target/test-classes"
readerPath = "asf.txt"
}
destination {
fields = ["DOC"]
scheme = file
path = "target/test-classes"
writerPath = "FlinkTwitterFollowingPipelineFollowersIT"
}
twitter.endpoint = friends
providerWaitMs = 1000
local = true
test = true