public class SqlClient extends Object
- In embedded mode, the SQL CLI is tightly coupled with the executor in a common process. This allows for submitting jobs without having to start an additional component.
- In future versions: In gateway mode, the SQL CLI client connects to the REST API of the gateway and allows for managing queries via console.
For debugging in an IDE you can execute the main method of this class using: "--defaults /path/to/sql-client-defaults.yaml --jar /path/to/target/flink-sql-client-*.jar"
Make sure that the FLINK_CONF_DIR environment variable is set.
Modifier and Type | Field and Description |
---|---|
static String |
MODE_EMBEDDED |
static String |
MODE_GATEWAY |
Constructor and Description |
---|
SqlClient(boolean isEmbedded,
CliOptions options,
java.util.function.Supplier<org.jline.terminal.Terminal> terminalFactory) |
Modifier and Type | Method and Description |
---|---|
static void |
main(String[] args) |
protected static void |
startClient(String[] args,
java.util.function.Supplier<org.jline.terminal.Terminal> terminalFactory) |
public static final String MODE_EMBEDDED
public static final String MODE_GATEWAY
public SqlClient(boolean isEmbedded, CliOptions options, java.util.function.Supplier<org.jline.terminal.Terminal> terminalFactory)
public static void main(String[] args)
@VisibleForTesting protected static void startClient(String[] args, java.util.function.Supplier<org.jline.terminal.Terminal> terminalFactory)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.