org.apache.arrow.flight.sql

Class FlightSqlUtils

java.lang.Object

org.apache.arrow.flight.sql.FlightSqlUtils

public final class FlightSqlUtils
extends Object

Utilities to work with Flight SQL semantics.

Field Summary

Fields

Modifier and Type	Field and Description
static List<ActionType>	FLIGHT_SQL_ACTIONS
static ActionType	FLIGHT_SQL_BEGIN_SAVEPOINT
static ActionType	FLIGHT_SQL_BEGIN_TRANSACTION
static ActionType	FLIGHT_SQL_CANCEL_QUERY
static ActionType	FLIGHT_SQL_CLOSE_PREPARED_STATEMENT
static ActionType	FLIGHT_SQL_CREATE_PREPARED_STATEMENT
static ActionType	FLIGHT_SQL_CREATE_PREPARED_SUBSTRAIT_PLAN
static ActionType	FLIGHT_SQL_END_SAVEPOINT
static ActionType	FLIGHT_SQL_END_TRANSACTION

Constructor Summary

Constructors

Constructor and Description
FlightSqlUtils()

Method Summary

Modifier and Type	Method and Description
static com.google.protobuf.Any	parseOrThrow(byte[] source) Helper to parse Any objects to the specific protobuf object.
static <T extends com.google.protobuf.Message> T	unpackAndParseOrThrow(byte[] source, Class<T> as) Helper to parse and unpack Any objects to the specific protobuf object.
static <T extends com.google.protobuf.Message> T	unpackOrThrow(com.google.protobuf.Any source, Class<T> as) Helper to unpack Any objects to the specific protobuf object.

Methods inherited from class java.lang.Object

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

Field Detail

FLIGHT_SQL_BEGIN_SAVEPOINT

public static final ActionType FLIGHT_SQL_BEGIN_SAVEPOINT

FLIGHT_SQL_BEGIN_TRANSACTION

public static final ActionType FLIGHT_SQL_BEGIN_TRANSACTION

FLIGHT_SQL_CREATE_PREPARED_STATEMENT

public static final ActionType FLIGHT_SQL_CREATE_PREPARED_STATEMENT

FLIGHT_SQL_CLOSE_PREPARED_STATEMENT

public static final ActionType FLIGHT_SQL_CLOSE_PREPARED_STATEMENT

FLIGHT_SQL_CREATE_PREPARED_SUBSTRAIT_PLAN

public static final ActionType FLIGHT_SQL_CREATE_PREPARED_SUBSTRAIT_PLAN

FLIGHT_SQL_CANCEL_QUERY

public static final ActionType FLIGHT_SQL_CANCEL_QUERY

FLIGHT_SQL_END_SAVEPOINT

public static final ActionType FLIGHT_SQL_END_SAVEPOINT

FLIGHT_SQL_END_TRANSACTION

public static final ActionType FLIGHT_SQL_END_TRANSACTION

FLIGHT_SQL_ACTIONS

public static final List<ActionType> FLIGHT_SQL_ACTIONS

Constructor Detail

FlightSqlUtils

public FlightSqlUtils()

Method Detail

parseOrThrow

public static com.google.protobuf.Any parseOrThrow(byte[] source)

Helper to parse Any objects to the specific protobuf object.

Parameters:

source - the raw bytes source value.

Returns:

the materialized protobuf object.

unpackOrThrow

public static <T extends com.google.protobuf.Message> T unpackOrThrow(com.google.protobuf.Any source,
                                                                      Class<T> as)

Helper to unpack Any objects to the specific protobuf object.

Type Parameters:

T - the class to unpack as.

Parameters:

source - the parsed Source value.

as - the class to unpack as.

Returns:

the materialized protobuf object.

unpackAndParseOrThrow

public static <T extends com.google.protobuf.Message> T unpackAndParseOrThrow(byte[] source,
                                                                              Class<T> as)

Helper to parse and unpack Any objects to the specific protobuf object.

Type Parameters:

T - the class to unpack as.

Parameters:

source - the raw bytes source value.

as - the class to unpack as.

Returns:

the materialized protobuf object.