public class TableStoreOutputFormat extends Object implements org.apache.hadoop.mapred.OutputFormat<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData>
OutputFormat
for table split. Currently useless.Constructor and Description |
---|
TableStoreOutputFormat() |
Modifier and Type | Method and Description |
---|---|
void |
checkOutputSpecs(org.apache.hadoop.fs.FileSystem fileSystem,
org.apache.hadoop.mapred.JobConf jobConf) |
org.apache.hadoop.mapred.RecordWriter<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData> |
getRecordWriter(org.apache.hadoop.fs.FileSystem fileSystem,
org.apache.hadoop.mapred.JobConf jobConf,
String s,
org.apache.hadoop.util.Progressable progressable) |
public org.apache.hadoop.mapred.RecordWriter<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData> getRecordWriter(org.apache.hadoop.fs.FileSystem fileSystem, org.apache.hadoop.mapred.JobConf jobConf, String s, org.apache.hadoop.util.Progressable progressable) throws IOException
getRecordWriter
in interface org.apache.hadoop.mapred.OutputFormat<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData>
IOException
public void checkOutputSpecs(org.apache.hadoop.fs.FileSystem fileSystem, org.apache.hadoop.mapred.JobConf jobConf) throws IOException
checkOutputSpecs
in interface org.apache.hadoop.mapred.OutputFormat<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData>
IOException
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.