@Internal public class StreamingFileSinkHelper<IN> extends Object implements ProcessingTimeCallback
Constructor and Description |
---|
StreamingFileSinkHelper(Buckets<IN,?> buckets,
boolean isRestored,
OperatorStateStore stateStore,
ProcessingTimeService procTimeService,
long bucketCheckInterval) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
commitUpToCheckpoint(long checkpointId) |
void |
onElement(IN value,
long currentProcessingTime,
Long elementTimestamp,
long currentWatermark) |
void |
onProcessingTime(long timestamp)
This method is invoked with the timestamp for which the trigger was scheduled.
|
void |
snapshotState(long checkpointId) |
public StreamingFileSinkHelper(Buckets<IN,?> buckets, boolean isRestored, OperatorStateStore stateStore, ProcessingTimeService procTimeService, long bucketCheckInterval) throws Exception
Exception
public void commitUpToCheckpoint(long checkpointId) throws Exception
Exception
public void onProcessingTime(long timestamp) throws Exception
ProcessingTimeCallback
If the triggering is delayed for whatever reason (trigger timer was blocked, JVM stalled due to a garbage collection), the timestamp supplied to this function will still be the original timestamp for which the trigger was scheduled.
onProcessingTime
in interface ProcessingTimeCallback
timestamp
- The timestamp for which the trigger event was scheduled.Exception
public void onElement(IN value, long currentProcessingTime, @Nullable Long elementTimestamp, long currentWatermark) throws Exception
Exception
public void close()
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.