Modifier and Type | Method and Description |
---|---|
static Schema |
JdbcToArrowUtils.jdbcToArrowSchema(ParameterMetaData parameterMetaData,
Calendar calendar)
Create Arrow
Schema object for the given JDBC ResultSetMetaData . |
static Schema |
JdbcToArrowUtils.jdbcToArrowSchema(ResultSetMetaData rsmd,
Calendar calendar)
Create Arrow
Schema object for the given JDBC ResultSetMetaData . |
static Schema |
JdbcToArrowUtils.jdbcToArrowSchema(ResultSetMetaData rsmd,
JdbcToArrowConfig config)
Create Arrow
Schema object for the given JDBC ResultSetMetaData . |
Modifier and Type | Method and Description |
---|---|
Schema |
ArrowFlightSqlClientHandler.PreparedStatement.getDataSetSchema()
Gets the
Schema of this ArrowFlightSqlClientHandler.PreparedStatement . |
Constructor and Description |
---|
Builder(Schema schema,
BufferAllocator bufferAllocator) |
Modifier and Type | Method and Description |
---|---|
Schema |
SchemaResult.getSchema() |
Schema |
FlightStream.getSchema()
Get the schema for this stream.
|
Schema |
FlightInfo.getSchema()
Deprecated.
Deprecated. Use
FlightInfo.getSchemaOptional() instead. |
Modifier and Type | Method and Description |
---|---|
Optional<Schema> |
FlightInfo.getSchemaOptional() |
Constructor and Description |
---|
FlightInfo(Schema schema,
FlightDescriptor descriptor,
List<FlightEndpoint> endpoints,
long bytes,
long records)
Constructs a new instance.
|
FlightInfo(Schema schema,
FlightDescriptor descriptor,
List<FlightEndpoint> endpoints,
long bytes,
long records,
boolean ordered,
IpcOption option)
Constructs a new instance.
|
FlightInfo(Schema schema,
FlightDescriptor descriptor,
List<FlightEndpoint> endpoints,
long bytes,
long records,
IpcOption option)
Constructs a new instance.
|
SchemaResult(Schema schema) |
SchemaResult(Schema schema,
IpcOption option)
Create a schema result with specific IPC options for serialization.
|
Modifier and Type | Method and Description |
---|---|
protected void |
FlightSqlScenario.validate(Schema expectedSchema,
FlightInfo flightInfo,
FlightSqlClient sqlClient) |
protected void |
FlightSqlScenario.validateSchema(Schema expected,
SchemaResult actual) |
Modifier and Type | Field and Description |
---|---|
static Schema |
FlightSqlProducer.Schemas.GET_CATALOGS_SCHEMA |
static Schema |
FlightSqlProducer.Schemas.GET_CROSS_REFERENCE_SCHEMA |
static Schema |
FlightSqlProducer.Schemas.GET_EXPORTED_KEYS_SCHEMA |
static Schema |
FlightSqlProducer.Schemas.GET_IMPORTED_KEYS_SCHEMA |
static Schema |
FlightSqlProducer.Schemas.GET_PRIMARY_KEYS_SCHEMA |
static Schema |
FlightSqlProducer.Schemas.GET_SCHEMAS_SCHEMA |
static Schema |
FlightSqlProducer.Schemas.GET_SQL_INFO_SCHEMA |
static Schema |
FlightSqlProducer.Schemas.GET_TABLE_TYPES_SCHEMA |
static Schema |
FlightSqlProducer.Schemas.GET_TABLES_SCHEMA |
static Schema |
FlightSqlProducer.Schemas.GET_TABLES_SCHEMA_NO_SCHEMA |
static Schema |
FlightSqlProducer.Schemas.GET_TYPE_INFO_SCHEMA |
Modifier and Type | Method and Description |
---|---|
Schema |
FlightSqlClient.PreparedStatement.getParameterSchema()
Returns the Schema of the parameters.
|
Schema |
FlightSqlClient.PreparedStatement.getResultSetSchema()
Returns the Schema of the resultset.
|
Modifier and Type | Method and Description |
---|---|
protected abstract <T extends com.google.protobuf.Message> |
BasicFlightSqlProducer.determineEndpoints(T request,
FlightDescriptor flightDescriptor,
Schema schema)
Return a list of FlightEndpoints for the given request and FlightDescriptor.
|
protected <T extends com.google.protobuf.Message> |
BasicFlightSqlProducer.generateFlightInfo(T request,
FlightDescriptor descriptor,
Schema schema) |
Modifier and Type | Method and Description |
---|---|
Schema |
VectorSchemaRoot.getSchema() |
Modifier and Type | Method and Description |
---|---|
static VectorSchemaRoot |
VectorSchemaRoot.create(Schema schema,
BufferAllocator allocator)
Creates a new set of empty vectors corresponding to the given schema.
|
Constructor and Description |
---|
VectorSchemaRoot(Schema schema,
List<FieldVector> fieldVectors,
int rowCount)
Constructs a new instance.
|
Modifier and Type | Field and Description |
---|---|
protected Schema |
ArrowWriter.schema |
Modifier and Type | Method and Description |
---|---|
protected abstract Schema |
ArrowReader.readSchema()
Read the Schema from the source, will be invoked at the beginning the initialization.
|
protected Schema |
ArrowFileReader.readSchema() |
protected Schema |
ArrowStreamReader.readSchema()
Reads the schema message from the beginning of the stream.
|
Schema |
JsonFileReader.start()
Reads the beginning (schema section) of the json file and returns it.
|
Modifier and Type | Method and Description |
---|---|
void |
JsonFileWriter.start(Schema schema,
DictionaryProvider provider)
Writes out the "header" of the file including the schema and any dictionaries required.
|
Modifier and Type | Method and Description |
---|---|
static Schema |
MessageSerializer.deserializeSchema(Message schemaMessage)
Deserializes an Arrow Schema object from a schema message.
|
static Schema |
MessageSerializer.deserializeSchema(MessageMetadataResult message)
Deserializes an Arrow Schema object from a
MessageMetadataResult . |
static Schema |
MessageSerializer.deserializeSchema(ReadChannel in)
Deserializes an Arrow Schema read from the input channel.
|
Schema |
ArrowFooter.getSchema() |
Modifier and Type | Method and Description |
---|---|
static long |
MessageSerializer.serialize(WriteChannel out,
Schema schema)
Serialize a schema object.
|
static long |
MessageSerializer.serialize(WriteChannel out,
Schema schema,
IpcOption option)
Serialize a schema object.
|
static ByteBuffer |
MessageSerializer.serializeMetadata(Schema schema)
Deprecated.
|
static ByteBuffer |
MessageSerializer.serializeMetadata(Schema schema,
IpcOption writeOption)
Returns the serialized flatbuffer bytes of the schema wrapped in a message table.
|
Constructor and Description |
---|
ArrowFooter(Schema schema,
List<ArrowBlock> dictionaries,
List<ArrowBlock> recordBatches) |
ArrowFooter(Schema schema,
List<ArrowBlock> dictionaries,
List<ArrowBlock> recordBatches,
Map<String,String> metaData)
Constructs a new instance.
|
ArrowFooter(Schema schema,
List<ArrowBlock> dictionaries,
List<ArrowBlock> recordBatches,
Map<String,String> metaData,
MetadataVersion metadataVersion)
Constructs a new instance.
|
Modifier and Type | Field and Description |
---|---|
protected Schema |
BaseTable.schema
The schema for the table.
|
Modifier and Type | Method and Description |
---|---|
Schema |
BaseTable.getSchema()
Returns the schema for this Table.
|
Modifier and Type | Method and Description |
---|---|
static Schema |
Schema.convertSchema(Schema schema)
Converts a flatbuffer schema to its POJO representation.
|
static Schema |
Schema.deserialize(ByteBuffer buffer)
Deprecated.
|
static Schema |
Schema.deserializeMessage(ByteBuffer buffer)
Deserialize a schema that has been serialized as a message using
serializeAsMessage() . |
static Schema |
Schema.fromJSON(String json) |
Modifier and Type | Method and Description |
---|---|
static Schema |
SchemaUtility.deserialize(byte[] bytes,
BufferAllocator allocator)
Deserialize Arrow schema from byte array.
|
Modifier and Type | Method and Description |
---|---|
static void |
Validator.compareSchemas(Schema schema1,
Schema schema2)
Validate two arrow schemas are equal.
|
static byte[] |
SchemaUtility.serialize(Schema schema)
Serialize Arrow schema into byte array.
|
Modifier and Type | Method and Description |
---|---|
static void |
MetadataV4UnionChecker.checkRead(Schema schema,
MetadataVersion metadataVersion)
Check the schema, raising an error if an unsupported feature is used (e.g.
|
Copyright © 2023 The Apache Software Foundation. All rights reserved.