public class FlinkAppenderFactory extends java.lang.Object implements FileAppenderFactory<org.apache.flink.table.data.RowData>, java.io.Serializable
Constructor and Description |
---|
FlinkAppenderFactory(Table table,
Schema schema,
org.apache.flink.table.types.logical.RowType flinkSchema,
java.util.Map<java.lang.String,java.lang.String> props,
PartitionSpec spec,
int[] equalityFieldIds,
Schema eqDeleteRowSchema,
Schema posDeleteRowSchema) |
Modifier and Type | Method and Description |
---|---|
FileAppender<org.apache.flink.table.data.RowData> |
newAppender(OutputFile outputFile,
FileFormat format)
Create a new
FileAppender . |
DataWriter<org.apache.flink.table.data.RowData> |
newDataWriter(EncryptedOutputFile file,
FileFormat format,
StructLike partition)
Create a new
DataWriter . |
EqualityDeleteWriter<org.apache.flink.table.data.RowData> |
newEqDeleteWriter(EncryptedOutputFile outputFile,
FileFormat format,
StructLike partition)
Create a new
EqualityDeleteWriter . |
PositionDeleteWriter<org.apache.flink.table.data.RowData> |
newPosDeleteWriter(EncryptedOutputFile outputFile,
FileFormat format,
StructLike partition)
Create a new
PositionDeleteWriter . |
public FlinkAppenderFactory(Table table, Schema schema, org.apache.flink.table.types.logical.RowType flinkSchema, java.util.Map<java.lang.String,java.lang.String> props, PartitionSpec spec, int[] equalityFieldIds, Schema eqDeleteRowSchema, Schema posDeleteRowSchema)
public FileAppender<org.apache.flink.table.data.RowData> newAppender(OutputFile outputFile, FileFormat format)
FileAppenderFactory
FileAppender
.newAppender
in interface FileAppenderFactory<org.apache.flink.table.data.RowData>
outputFile
- an OutputFile used to create an output stream.format
- File format.FileAppender
public DataWriter<org.apache.flink.table.data.RowData> newDataWriter(EncryptedOutputFile file, FileFormat format, StructLike partition)
FileAppenderFactory
DataWriter
.newDataWriter
in interface FileAppenderFactory<org.apache.flink.table.data.RowData>
file
- an OutputFile used to create an output stream.format
- a file formatpartition
- a tuple of partition valuesDataWriter
for rowspublic EqualityDeleteWriter<org.apache.flink.table.data.RowData> newEqDeleteWriter(EncryptedOutputFile outputFile, FileFormat format, StructLike partition)
FileAppenderFactory
EqualityDeleteWriter
.newEqDeleteWriter
in interface FileAppenderFactory<org.apache.flink.table.data.RowData>
outputFile
- an OutputFile used to create an output stream.format
- a file formatpartition
- a tuple of partition valuesEqualityDeleteWriter
for equality deletespublic PositionDeleteWriter<org.apache.flink.table.data.RowData> newPosDeleteWriter(EncryptedOutputFile outputFile, FileFormat format, StructLike partition)
FileAppenderFactory
PositionDeleteWriter
.newPosDeleteWriter
in interface FileAppenderFactory<org.apache.flink.table.data.RowData>
outputFile
- an OutputFile used to create an output stream.format
- a file formatpartition
- a tuple of partition valuesPositionDeleteWriter
for position deletes