Package | Description |
---|---|
org.apache.flink.streaming.api.functions.sink.filesystem | |
org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies |
Modifier and Type | Method and Description |
---|---|
boolean |
RollingPolicy.shouldRollOnCheckpoint(PartFileInfo<BucketID> partFileState)
Determines if the in-progress part file for a bucket should roll on every checkpoint.
|
boolean |
RollingPolicy.shouldRollOnEvent(PartFileInfo<BucketID> partFileState,
IN element)
Determines if the in-progress part file for a bucket should roll based on its current state, e.g.
|
boolean |
RollingPolicy.shouldRollOnProcessingTime(PartFileInfo<BucketID> partFileState,
long currentTime)
Determines if the in-progress part file for a bucket should roll based on a time condition.
|
Modifier and Type | Method and Description |
---|---|
boolean |
DefaultRollingPolicy.shouldRollOnCheckpoint(PartFileInfo<BucketID> partFileState) |
boolean |
OnCheckpointRollingPolicy.shouldRollOnCheckpoint(PartFileInfo<BucketID> partFileState) |
boolean |
DefaultRollingPolicy.shouldRollOnEvent(PartFileInfo<BucketID> partFileState,
IN element) |
boolean |
OnCheckpointRollingPolicy.shouldRollOnEvent(PartFileInfo<BucketID> partFileState,
IN element) |
boolean |
DefaultRollingPolicy.shouldRollOnProcessingTime(PartFileInfo<BucketID> partFileState,
long currentTime) |
boolean |
OnCheckpointRollingPolicy.shouldRollOnProcessingTime(PartFileInfo<BucketID> partFileState,
long currentTime) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.