Package com.hw.langchain.tools.flink.sql.tool

Class InfoFlinkSqlTool

java.lang.Object

com.hw.langchain.tools.base.BaseTool

com.hw.langchain.tools.flink.sql.tool.BaseFlinkSqlTool

com.hw.langchain.tools.flink.sql.tool.InfoFlinkSqlTool

public class InfoFlinkSqlTool
extends BaseFlinkSqlTool

Tool for getting metadata about a Flink SQL.

Author:

HamaWhite

Field Summary

Fields inherited from class com.hw.langchain.tools.flink.sql.tool.BaseFlinkSqlTool

db

Fields inherited from class com.hw.langchain.tools.base.BaseTool

description, name, returnDirect

Constructor Summary

Constructors

Constructor	Description
InfoFlinkSqlTool(FlinkSql db)

Method Summary

Modifier and Type	Method	Description
Object	innerRun(String query, Map<String,Object> kwargs)	Get the schema for tables in a comma-separated list.

Methods inherited from class com.hw.langchain.tools.base.BaseTool

args, canEqual, equals, getDescription, getName, hashCode, isReturnDirect, isSingleInput, run, toArgsAndKwargs, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

InfoFlinkSqlTool

public InfoFlinkSqlTool(FlinkSql db)

Method Details

innerRun

public Object innerRun(String query,
 Map<String,Object> kwargs)

Get the schema for tables in a comma-separated list.

Specified by:

innerRun in class BaseTool