Modifier and Type | Method and Description |
---|---|
boolean |
FileSystemTableSink.TableRollingPolicy.shouldRollOnCheckpoint(PartFileInfo<String> partFileState) |
boolean |
FileSystemTableSink.TableRollingPolicy.shouldRollOnEvent(PartFileInfo<String> partFileState,
RowData element) |
boolean |
FileSystemTableSink.TableRollingPolicy.shouldRollOnProcessingTime(PartFileInfo<String> partFileState,
long currentTime) |
Modifier and Type | Class and Description |
---|---|
class |
HadoopPathBasedPartFileWriter<IN,BucketID>
The part-file writer that writes to the specified hadoop path.
|
Modifier and Type | Interface and Description |
---|---|
interface |
InProgressFileWriter<IN,BucketID>
The
Bucket uses the InProgressFileWriter to write element to a part file. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractPartFileWriter<IN,BucketID>
An abstract writer for the currently open part file in a specific
Bucket . |
class |
OutputStreamBasedPartFileWriter<IN,BucketID>
The base class for all the part file writer that use
RecoverableFsDataOutputStream . |
class |
RowWisePartWriter<IN,BucketID>
A
InProgressFileWriter for row-wise formats that use an Encoder . |
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 |
CheckpointRollingPolicy.shouldRollOnCheckpoint(PartFileInfo<BucketID> partFileState) |
boolean |
OnCheckpointRollingPolicy.shouldRollOnEvent(PartFileInfo<BucketID> partFileState,
IN element) |
boolean |
DefaultRollingPolicy.shouldRollOnEvent(PartFileInfo<BucketID> partFileState,
IN element) |
abstract boolean |
CheckpointRollingPolicy.shouldRollOnEvent(PartFileInfo<BucketID> partFileState,
IN element) |
boolean |
OnCheckpointRollingPolicy.shouldRollOnProcessingTime(PartFileInfo<BucketID> partFileState,
long currentTime) |
boolean |
DefaultRollingPolicy.shouldRollOnProcessingTime(PartFileInfo<BucketID> partFileState,
long currentTime) |
abstract boolean |
CheckpointRollingPolicy.shouldRollOnProcessingTime(PartFileInfo<BucketID> partFileState,
long currentTime) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.