blob: b5212ed78efadc43d6909d0587f3217bf03b7b02 [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 = "FlinkTwitterFollowingPipelineFriendsIT"
}
twitter.endpoint = friends
providerWaitMs = 1000
local = true
test = true