public class FlightSqlScenario extends Object
Modifier and Type | Field and Description |
---|---|
static byte[] |
SAVEPOINT_ID |
static String |
SAVEPOINT_NAME |
static FlightSqlClient.SubstraitPlan |
SUBSTRAIT_PLAN |
static byte[] |
SUBSTRAIT_PLAN_TEXT |
static String |
SUBSTRAIT_VERSION |
static byte[] |
TRANSACTION_ID |
static long |
UPDATE_PREPARED_STATEMENT_EXPECTED_ROWS |
static long |
UPDATE_PREPARED_STATEMENT_WITH_TRANSACTION_EXPECTED_ROWS |
static long |
UPDATE_STATEMENT_EXPECTED_ROWS |
static long |
UPDATE_STATEMENT_WITH_TRANSACTION_EXPECTED_ROWS |
Constructor and Description |
---|
FlightSqlScenario() |
Modifier and Type | Method and Description |
---|---|
void |
buildServer(FlightServer.Builder builder)
Set any other server options.
|
void |
client(BufferAllocator allocator,
Location location,
FlightClient client)
Run as the client in the scenario.
|
FlightProducer |
producer(BufferAllocator allocator,
Location location)
Construct the FlightProducer for a server in this scenario.
|
protected void |
validate(Schema expectedSchema,
FlightInfo flightInfo,
FlightSqlClient sqlClient) |
protected void |
validateSchema(Schema expected,
SchemaResult actual) |
public static final long UPDATE_STATEMENT_EXPECTED_ROWS
public static final long UPDATE_STATEMENT_WITH_TRANSACTION_EXPECTED_ROWS
public static final long UPDATE_PREPARED_STATEMENT_EXPECTED_ROWS
public static final long UPDATE_PREPARED_STATEMENT_WITH_TRANSACTION_EXPECTED_ROWS
public static final byte[] SAVEPOINT_ID
public static final String SAVEPOINT_NAME
public static final byte[] SUBSTRAIT_PLAN_TEXT
public static final String SUBSTRAIT_VERSION
public static final FlightSqlClient.SubstraitPlan SUBSTRAIT_PLAN
public static final byte[] TRANSACTION_ID
public FlightProducer producer(BufferAllocator allocator, Location location) throws Exception
Exception
public void buildServer(FlightServer.Builder builder) throws Exception
Exception
public void client(BufferAllocator allocator, Location location, FlightClient client) throws Exception
Exception
protected void validate(Schema expectedSchema, FlightInfo flightInfo, FlightSqlClient sqlClient) throws Exception
Exception
protected void validateSchema(Schema expected, SchemaResult actual)
Copyright © 2023 The Apache Software Foundation. All rights reserved.