Package org.apache.ignite.internal.sql.command

Class SqlKillQueryCommand

java.lang.Object

org.apache.ignite.internal.sql.command.SqlKillQueryCommand

All Implemented Interfaces:

SqlCommand

public class SqlKillQueryCommand
extends Object
implements SqlCommand

KILL QUERY command.

See Also:

QueryMXBean.cancelSQL(String), SqlQueryView.queryId()

Constructor Summary

Constructors

Constructor	Description
SqlKillQueryCommand()
SqlKillQueryCommand(UUID nodeId, long nodeQryId, boolean async)

Method Summary

Modifier and Type	Method	Description
boolean	async()
UUID	nodeId()
long	nodeQueryId()
SqlCommand	parse(SqlLexer lex)	Parse command.
static T2<UUID,Long>	parseGlobalQueryId(String globalQryId)	Parse global SQL query id.
String	schemaName()
void	schemaName(String schemaName)

Methods inherited from class java.lang.Object

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

Constructor Detail

SqlKillQueryCommand

public SqlKillQueryCommand()

SqlKillQueryCommand

public SqlKillQueryCommand(UUID nodeId,
                           long nodeQryId,
                           boolean async)

Parameters:

nodeId - Node id.

nodeQryId - Local query id.

async - Async flag.

Method Detail

parse

public SqlCommand parse(SqlLexer lex)

Parse command.

Specified by:

parse in interface SqlCommand

Parameters:

lex - Lexer.

Returns:

This instance.

schemaName

public String schemaName()

Specified by:

schemaName in interface SqlCommand

Returns:

Schema name.

schemaName

public void schemaName(String schemaName)

Specified by:

schemaName in interface SqlCommand

Parameters:

schemaName - Schema name.

parseGlobalQueryId

public static T2<UUID,Long> parseGlobalQueryId(String globalQryId)

Parse global SQL query id. Format is {origin_node_id}_{query_id}.

Parameters:

globalQryId - Global query id.

Returns:

Results of parsing of null if parse failed.

nodeQueryId

public long nodeQueryId()

Returns:

Node query id.

nodeId

public UUID nodeId()

Returns:

Node order id.

async

public boolean async()

Returns:

Async flag.