Package 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	Description
static final List<ActionType>	FLIGHT_SQL_ACTIONS
static final ActionType	FLIGHT_SQL_BEGIN_SAVEPOINT
static final ActionType	FLIGHT_SQL_BEGIN_TRANSACTION
static final ActionType	FLIGHT_SQL_CANCEL_QUERY
static final ActionType	FLIGHT_SQL_CLOSE_PREPARED_STATEMENT
static final ActionType	FLIGHT_SQL_CREATE_PREPARED_STATEMENT
static final ActionType	FLIGHT_SQL_CREATE_PREPARED_SUBSTRAIT_PLAN
static final ActionType	FLIGHT_SQL_END_SAVEPOINT
static final ActionType	FLIGHT_SQL_END_TRANSACTION

Constructor Summary

Constructors

Constructor	Description
FlightSqlUtils()

Method Summary

Modifier and Type	Method	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 Details

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 Details

FlightSqlUtils

public FlightSqlUtils()

Method Details

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.