org.apache.flink.table.sinks

Class TableSinkBase<T>

java.lang.Object

org.apache.flink.table.sinks.TableSinkBase<T>

Type Parameters:

T - The return type of the TableSinkBase.

All Implemented Interfaces:

TableSink<T>

@Internal
public abstract class TableSinkBase<T>
extends Object
implements TableSink<T>

Base class for TableSink.

Constructor Summary

Constructors

Constructor and Description
TableSinkBase()

Method Summary

Modifier and Type	Method and Description
TableSink<T>	configure(String[] fieldNames, TypeInformation<?>[] fieldTypes) Returns a copy of this TableSink configured with the field names and types of the table to emit.
protected abstract TableSinkBase<T>	copy() Returns a deep copy of the TableSink.
String[]	getFieldNames() Returns the field names of the table to emit.
TypeInformation<?>[]	getFieldTypes() Returns the field types of the table to emit.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.table.sinks.TableSink

getConsumedDataType, getOutputType, getTableSchema

Constructor Detail

TableSinkBase

public TableSinkBase()

Method Detail

copy

protected abstract TableSinkBase<T> copy()

Returns a deep copy of the TableSink.

getFieldNames

public String[] getFieldNames()

Returns the field names of the table to emit.

Specified by:

getFieldNames in interface TableSink<T>

getFieldTypes

public TypeInformation<?>[] getFieldTypes()

Returns the field types of the table to emit.

Specified by:

getFieldTypes in interface TableSink<T>

configure

public final TableSink<T> configure(String[] fieldNames,
                                    TypeInformation<?>[] fieldTypes)

Returns a copy of this TableSink configured with the field names and types of the table to emit.

Specified by:

configure in interface TableSink<T>

Parameters:

fieldNames - The field names of the table to emit.

fieldTypes - The field types of the table to emit.

Returns:

A copy of this TableSink configured with the field names and types of the table to emit.