PrintTableSinkFactory (Flink : Table : API Java bridge 1.19.3-cp3 API)

java.lang.Object
- org.apache.flink.connector.print.table.PrintTableSinkFactory

All Implemented Interfaces:

org.apache.flink.table.factories.DynamicTableFactory, org.apache.flink.table.factories.DynamicTableSinkFactory, org.apache.flink.table.factories.Factory
```
@Internal
public class PrintTableSinkFactory
extends Object
implements org.apache.flink.table.factories.DynamicTableSinkFactory
```
Print table sink factory writing every row to the standard output or standard error stream. It is designed for: - easy test for streaming job. - very useful in production debugging.
Four possible format options: PRINT_IDENTIFIER:taskId> output <- PRINT_IDENTIFIER provided, parallelism > 1 PRINT_IDENTIFIER> output <- PRINT_IDENTIFIER provided, parallelism == 1 taskId> output <- no PRINT_IDENTIFIER provided, parallelism > 1 output <- no PRINT_IDENTIFIER provided, parallelism == 1
output string format is "$RowKind[f0, f1, f2, ...]", example is: "+I[1, 1]".

Nested Class Summary
- Nested classes/interfaces inherited from interface org.apache.flink.table.factories.DynamicTableFactory
  org.apache.flink.table.factories.DynamicTableFactory.Context

Field Summary

Fields
Modifier and Type Field Description

static String IDENTIFIER

Constructor Summary

Constructors
Constructor Description

PrintTableSinkFactory()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`org.apache.flink.table.connector.sink.DynamicTableSink`	`createDynamicTableSink(org.apache.flink.table.factories.DynamicTableFactory.Context context)`
`String`	`factoryIdentifier()`
`Set<org.apache.flink.configuration.ConfigOption<?>>`	`optionalOptions()`
`Set<org.apache.flink.configuration.ConfigOption<?>>`	`requiredOptions()`

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.factories.DynamicTableFactory
forwardOptions

- Field Detail
  - IDENTIFIER
```
public static final String IDENTIFIER
```
    See Also:
    
    Constant Field Values
- Constructor Detail
  - PrintTableSinkFactory
```
public PrintTableSinkFactory()
```
- Method Detail
  - factoryIdentifier
```
public String factoryIdentifier()
```
    Specified by:
    
    factoryIdentifier in interface org.apache.flink.table.factories.Factory
  - requiredOptions
```
public Set<org.apache.flink.configuration.ConfigOption<?>> requiredOptions()
```
    Specified by:
    
    requiredOptions in interface org.apache.flink.table.factories.Factory
  - optionalOptions
```
public Set<org.apache.flink.configuration.ConfigOption<?>> optionalOptions()
```
    Specified by:
    
    optionalOptions in interface org.apache.flink.table.factories.Factory
  - createDynamicTableSink
```
public org.apache.flink.table.connector.sink.DynamicTableSink createDynamicTableSink(org.apache.flink.table.factories.DynamicTableFactory.Context context)
```
    Specified by:
    
    createDynamicTableSink in interface org.apache.flink.table.factories.DynamicTableSinkFactory