Package com.hw.langchain.utilities.flink.sql

Class FlinkSql

java.lang.Object

com.hw.langchain.utilities.flink.sql.FlinkSql

public class FlinkSql
extends Object

Author:

HamaWhite

Constructor Summary

Constructors

Constructor	Description
FlinkSql()

Method Summary

Modifier and Type	Method	Description
String	getSampleFlinkRows(String table)
String	getTableInfo(Set<String> tableNames)
Set<String>	getUsableTableNames()	Get names of tables available.
FlinkSql	init()
String	run(String command)

Methods inherited from class java.lang.Object

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

Constructor Details

FlinkSql

public FlinkSql()

Method Details

init

public FlinkSql init()

getUsableTableNames

public Set<String> getUsableTableNames()

Get names of tables available.

getTableInfo

public String getTableInfo(Set<String> tableNames)

getSampleFlinkRows

public String getSampleFlinkRows(String table)

run

public String run(String command)