public static final class FlinkStreaming.MRDataFileSourceFunction extends Object implements org.apache.flink.streaming.api.function.source.SourceFunction<FData>
Constructor and Description |
---|
FlinkStreaming.MRDataFileSourceFunction(String directory,
long time_window,
org.apache.flink.api.common.io.FileInputFormat<FData> input_format) |
public void invoke(org.apache.flink.util.Collector<FData> collector) throws IOException
invoke
in interface org.apache.flink.streaming.api.function.source.SourceFunction<FData>
IOException
Copyright © 2013-2015 The Apache Software Foundation. All Rights Reserved.