IN
- Input tuple type@PublicEvolving public class WriteSinkFunctionByMillis<IN> extends WriteSinkFunction<IN>
format, path, tupleList
Constructor and Description |
---|
WriteSinkFunctionByMillis(String path,
WriteFormat<IN> format,
long millis) |
Modifier and Type | Method and Description |
---|---|
protected void |
resetParameters()
Statements to be executed after writing a batch goes here.
|
protected boolean |
updateCondition()
Condition for writing the contents of tupleList and clearing it.
|
cleanFile, invoke
public WriteSinkFunctionByMillis(String path, WriteFormat<IN> format, long millis)
protected boolean updateCondition()
WriteSinkFunction
updateCondition
in class WriteSinkFunction<IN>
protected void resetParameters()
WriteSinkFunction
resetParameters
in class WriteSinkFunction<IN>
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.