public class RowDataRollingFileWriter extends RollingFileWriter<org.apache.flink.table.data.RowData,DataFileMeta>
RollingFileWriter
for data files containing RowData
.Constructor and Description |
---|
RowDataRollingFileWriter(long schemaId,
FileFormat fileFormat,
long targetFileSize,
org.apache.flink.table.types.logical.RowType writeSchema,
DataFilePathFactory pathFactory,
org.apache.flink.api.common.accumulators.LongCounter seqNumCounter) |
abort, close, length, recordCount, result, targetFileSize, write
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
write, write, write
public RowDataRollingFileWriter(long schemaId, FileFormat fileFormat, long targetFileSize, org.apache.flink.table.types.logical.RowType writeSchema, DataFilePathFactory pathFactory, org.apache.flink.api.common.accumulators.LongCounter seqNumCounter)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.