org.apache.flink.streaming.api.functions.source

Class FileReadFunction

java.lang.Object

org.apache.flink.streaming.api.functions.source.FileReadFunction

All Implemented Interfaces:

Serializable, FlatMapFunction<Tuple3<String,Long,Long>,String>, Function

Deprecated.

Internal class deprecated in favour of ContinuousFileMonitoringFunction.

@Internal
 @Deprecated
public class FileReadFunction
extends Object
implements FlatMapFunction<Tuple3<String,Long,Long>,String>

This is used together with FileMonitoringFunction to read from files that the monitoring functions discovers.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
FileReadFunction() Deprecated.

Method Summary

Modifier and Type	Method and Description
void	flatMap(Tuple3<String,Long,Long> value, Collector<String> out) Deprecated. The core method of the FlatMapFunction.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FileReadFunction

public FileReadFunction()

Deprecated.

Method Detail

flatMap

public void flatMap(Tuple3<String,Long,Long> value,
                    Collector<String> out)
             throws Exception

Deprecated.

Description copied from interface: FlatMapFunction

The core method of the FlatMapFunction. Takes an element from the input data set and transforms it into zero, one, or more elements.

Specified by:

flatMap in interface FlatMapFunction<Tuple3<String,Long,Long>,String>

Parameters:

value - The input value.

out - The collector for returning result values.

Throws:

Exception - This method may throw exceptions. Throwing an exception will cause the operation to fail and may trigger recovery.