org.apache.flink.table.api

Class TableUtils

java.lang.Object

org.apache.flink.table.api.TableUtils

@Experimental
public class TableUtils
extends Object

A collection of utilities for fetching table results.

NOTE: Methods in this utility class are experimental and can only be used for demonstration or testing small table results. Please DO NOT use them in production or on large tables.

We ought to put this class in the api module, but as converting high precision timestamp data type to type information is not possible in flink planner, we have to put this class in blink planner.

Constructor Summary

Constructors

Constructor and Description
TableUtils()

Method Summary

Modifier and Type	Method and Description
static List<Row>	collectToList(Table table) Convert Flink table to Java list.

Methods inherited from class java.lang.Object

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

Constructor Detail

TableUtils

public TableUtils()

Method Detail

collectToList

public static List<Row> collectToList(Table table)
                               throws Exception

Convert Flink table to Java list. This method is only applicable for small batch jobs and small finite append only stream jobs.

Parameters:

table - Flink table to convert

Returns:

Converted Java list

Throws:

Exception