WriteSinkFunctionByMillis (Flink : Streaming Java 1.19.3-cp1 API)

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, org.apache.flink.api.common.functions.Function, SinkFunction<IN>
```
@PublicEvolving
@Deprecated
public class WriteSinkFunctionByMillis<IN>
extends WriteSinkFunction<IN>
```
Deprecated.
Please use the StreamingFileSink for writing to files from a streaming program.

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

Field Summary
- Fields inherited from class org.apache.flink.streaming.api.functions.sink.WriteSinkFunction
  format, path, tupleList

Constructor Summary

Constructors
Constructor Description

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

Method Summary

All Methods Instance Methods Concrete Methods Deprecated Methods
Modifier and Type	Method	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
finish, invoke, writeWatermark

- 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>