Uses of Class
org.apache.arrow.vector.types.pojo.Schema
Package
Description
-
Uses of Schema in org.apache.arrow.adapter.jdbc
Modifier and TypeMethodDescriptionstatic Schema
JdbcToArrowUtils.jdbcToArrowSchema
(ParameterMetaData parameterMetaData, Calendar calendar) Create ArrowSchema
object for the given JDBCResultSetMetaData
.static Schema
JdbcToArrowUtils.jdbcToArrowSchema
(ResultSetMetaData rsmd, Calendar calendar) Create ArrowSchema
object for the given JDBCResultSetMetaData
.static Schema
JdbcToArrowUtils.jdbcToArrowSchema
(ResultSetMetaData rsmd, JdbcToArrowConfig config) Create ArrowSchema
object for the given JDBCResultSetMetaData
. -
Uses of Schema in org.apache.arrow.driver.jdbc.client
Modifier and TypeMethodDescriptionArrowFlightSqlClientHandler.PreparedStatement.getDataSetSchema()
Gets theSchema
of thisArrowFlightSqlClientHandler.PreparedStatement
.ArrowFlightSqlClientHandler.PreparedStatement.getParameterSchema()
Gets theSchema
of the parameters for thisArrowFlightSqlClientHandler.PreparedStatement
. -
Uses of Schema in org.apache.arrow.driver.jdbc.utils
-
Uses of Schema in org.apache.arrow.flight
Modifier and TypeMethodDescriptionFlightInfo.getSchema()
Deprecated.Deprecated.FlightStream.getSchema()
Get the schema for this stream.SchemaResult.getSchema()
Modifier and TypeMethodDescriptionstatic FlightInfo.Builder
FlightInfo.builder
(Schema schema, FlightDescriptor descriptor, List<FlightEndpoint> endpoints) Create a builder for FlightInfo.ModifierConstructorDescriptionFlightInfo
(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, boolean ordered, IpcOption option, byte[] appMetadata) 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. -
Uses of Schema in org.apache.arrow.flight.integration.tests
Modifier and TypeMethodDescriptionprotected void
FlightSqlScenario.validate
(Schema expectedSchema, FlightInfo flightInfo, FlightSqlClient sqlClient) protected void
FlightSqlScenario.validateSchema
(Schema expected, SchemaResult actual) -
Uses of Schema in org.apache.arrow.flight.sql
Modifier and TypeFieldDescriptionstatic final Schema
FlightSqlProducer.Schemas.GET_CATALOGS_SCHEMA
static final Schema
FlightSqlProducer.Schemas.GET_CROSS_REFERENCE_SCHEMA
static final Schema
FlightSqlProducer.Schemas.GET_EXPORTED_KEYS_SCHEMA
static final Schema
FlightSqlProducer.Schemas.GET_IMPORTED_KEYS_SCHEMA
static final Schema
FlightSqlProducer.Schemas.GET_PRIMARY_KEYS_SCHEMA
static final Schema
FlightSqlProducer.Schemas.GET_SCHEMAS_SCHEMA
static final Schema
FlightSqlProducer.Schemas.GET_SQL_INFO_SCHEMA
static final Schema
FlightSqlProducer.Schemas.GET_TABLE_TYPES_SCHEMA
static final Schema
FlightSqlProducer.Schemas.GET_TABLES_SCHEMA
static final Schema
FlightSqlProducer.Schemas.GET_TABLES_SCHEMA_NO_SCHEMA
static final Schema
FlightSqlProducer.Schemas.GET_TYPE_INFO_SCHEMA
Modifier and TypeMethodDescriptionFlightSqlClient.PreparedStatement.getParameterSchema()
Returns the Schema of the parameters.FlightSqlClient.PreparedStatement.getResultSetSchema()
Returns the Schema of the resultset.Modifier and TypeMethodDescriptionprotected abstract <T extends com.google.protobuf.Message>
List<FlightEndpoint>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>
FlightInfoBasicFlightSqlProducer.generateFlightInfo
(T request, FlightDescriptor descriptor, Schema schema) -
Uses of Schema in org.apache.arrow.vector
Modifier and TypeMethodDescriptionstatic VectorSchemaRoot
VectorSchemaRoot.create
(Schema schema, BufferAllocator allocator) Creates a new set of empty vectors corresponding to the given schema.ModifierConstructorDescriptionVectorSchemaRoot
(Schema schema, List<FieldVector> fieldVectors, int rowCount) Constructs a new instance. -
Uses of Schema in org.apache.arrow.vector.ipc
Modifier and TypeMethodDescriptionprotected Schema
ArrowFileReader.readSchema()
protected abstract Schema
ArrowReader.readSchema()
Read the Schema from the source, will be invoked at the beginning the initialization.protected Schema
ArrowStreamReader.readSchema()
Reads the schema message from the beginning of the stream.JsonFileReader.start()
Reads the beginning (schema section) of the json file and returns it.Modifier and TypeMethodDescriptionvoid
JsonFileWriter.start
(Schema schema, DictionaryProvider provider) Writes out the "header" of the file including the schema and any dictionaries required. -
Uses of Schema in org.apache.arrow.vector.ipc.message
Modifier and TypeMethodDescriptionstatic 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 aMessageMetadataResult
.static Schema
MessageSerializer.deserializeSchema
(ReadChannel in) Deserializes an Arrow Schema read from the input channel.ArrowFooter.getSchema()
Modifier and TypeMethodDescriptionstatic 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.ModifierConstructorDescriptionArrowFooter
(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. -
Uses of Schema in org.apache.arrow.vector.table
-
Uses of Schema in org.apache.arrow.vector.types.pojo
Modifier and TypeMethodDescriptionstatic 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 usingserializeAsMessage()
.static Schema
-
Uses of Schema in org.apache.arrow.vector.util
Modifier and TypeMethodDescriptionstatic Schema
SchemaUtility.deserialize
(byte[] bytes, BufferAllocator allocator) Deserialize Arrow schema from byte array.Modifier and TypeMethodDescriptionstatic void
Validator.compareSchemas
(Schema schema1, Schema schema2) Validate two arrow schemas are equal.static byte[]
Serialize Arrow schema into byte array. -
Uses of Schema in org.apache.arrow.vector.validate
Modifier and TypeMethodDescriptionstatic void
MetadataV4UnionChecker.checkRead
(Schema schema, MetadataVersion metadataVersion) Check the schema, raising an error if an unsupported feature is used (e.g.