org.apache.flink.streaming.api.functions.sink

Class WriteSinkFunctionByMillis<IN>

java.lang.Object

org.apache.flink.streaming.api.functions.sink.WriteSinkFunction<IN>

org.apache.flink.streaming.api.functions.sink.WriteSinkFunctionByMillis<IN>

Type Parameters:

IN - Input tuple type

All Implemented Interfaces:

Serializable, Function, SinkFunction<IN>

Deprecated.

Please use the StreamingFileSink for writing to files from a streaming program.

@PublicEvolving
 @Deprecated
public class WriteSinkFunctionByMillis<IN>
extends WriteSinkFunction<IN>

Implementation of WriteSinkFunction. Writes tuples to file in every millis milliseconds.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.streaming.api.functions.sink.SinkFunction

SinkFunction.Context<T>

Field Summary

Fields inherited from class org.apache.flink.streaming.api.functions.sink.WriteSinkFunction

format, path, tupleList

Constructor Summary

Constructors

Constructor and Description
WriteSinkFunctionByMillis(String path, WriteFormat<IN> format, long millis) Deprecated.

Method Summary

Modifier and Type	Method and Description
protected void	resetParameters() Deprecated. Statements to be executed after writing a batch goes here.
protected boolean	updateCondition() Deprecated. Condition for writing the contents of tupleList and clearing it.

Methods inherited from class org.apache.flink.streaming.api.functions.sink.WriteSinkFunction

cleanFile, invoke

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.streaming.api.functions.sink.SinkFunction

invoke

Constructor Detail

WriteSinkFunctionByMillis

public WriteSinkFunctionByMillis(String path,
                                 WriteFormat<IN> format,
                                 long millis)

Deprecated.

Method Detail

updateCondition

protected boolean updateCondition()

Deprecated.

Description copied from class: WriteSinkFunction

Condition for writing the contents of tupleList and clearing it.

Specified by:

updateCondition in class WriteSinkFunction<IN>

Returns:

value of the updating condition

resetParameters

protected void resetParameters()

Deprecated.

Description copied from class: WriteSinkFunction

Statements to be executed after writing a batch goes here.

Specified by:

resetParameters in class WriteSinkFunction<IN>