Package | Description |
---|---|
org.apache.flink.table.client.gateway | |
org.apache.flink.table.client.gateway.local |
Modifier and Type | Method and Description |
---|---|
ProgramTargetDescriptor |
Executor.executeUpdate(SessionContext session,
String statement)
Submits a Flink SQL update statement such as INSERT INTO.
|
static <C> ProgramTargetDescriptor |
ProgramTargetDescriptor.of(C clusterId,
JobID jobId,
String webInterfaceUrl)
Creates a program target description from deployment classes.
|
Modifier and Type | Method and Description |
---|---|
ProgramTargetDescriptor |
LocalExecutor.executeUpdate(SessionContext session,
String statement) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.