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