Package | Description |
---|---|
org.apache.flink.table.api.java |
Modifier and Type | Method and Description |
---|---|
void |
BatchTableEnvironment.insertInto(Table table,
BatchQueryConfig queryConfig,
String sinkPath,
String... sinkPathContinued)
Deprecated.
|
void |
BatchTableEnvironment.sqlUpdate(String stmt,
BatchQueryConfig config)
Evaluates a SQL statement such as INSERT, UPDATE or DELETE; or a DDL statement;
NOTE: Currently only SQL INSERT statements are supported.
|
<T> DataSet<T> |
BatchTableEnvironment.toDataSet(Table table,
Class<T> clazz,
BatchQueryConfig queryConfig)
|
<T> DataSet<T> |
BatchTableEnvironment.toDataSet(Table table,
TypeInformation<T> typeInfo,
BatchQueryConfig queryConfig)
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.