Module org.apache.arrow.flight.sql

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.