@qualithm/arrow-flight-sql-js - v0.4.3
    Preparing search index...

    @qualithm/arrow-flight-sql-js - v0.4.3

    @qualithm/arrow-flight-sql-js

    Arrow Flight SQL client for JavaScript and TypeScript runtimes.

    import { FlightSqlClient } from "@qualithm/arrow-flight-sql-js"

    const client = new FlightSqlClient({
    host: "localhost",
    port: 50051,
    tls: false,
    auth: { type: "bearer", token: "my-token" }
    })

    await client.connect()

    const result = await client.query("SELECT * FROM users")
    for await (const batch of result.stream()) {
    console.log(batch.numRows)
    }

    await client.close()

    Classes

    AuthenticationError
    CancelledError
    ConnectionError
    ConsoleMetricsHandler
    FlightSqlClient
    FlightSqlError
    FlightSqlPool
    GrpcJsTransport
    GrpcWebTransport
    InMemoryMetricsHandler
    MetricsTimer
    NoopMetricsHandler
    NotFoundError
    PreparedStatement
    ProtocolError
    QueryBuilder
    QueryError
    QueryResult
    RetryPolicy
    Subscription
    TimeoutError

    Type Aliases

    Action
    ActionResult
    ActionType
    AuthConfig
    BuiltQuery
    CatalogInfo
    ColumnSpec
    ComparisonOperator
    CounterEvent
    DescriptorType
    DuplexStream
    ExchangeStream
    ExecuteOptions
    FlightData
    FlightDescriptor
    FlightEndpoint
    FlightInfo
    FlightSqlClientOptions
    FlightTransport
    ForeignKeyInfo
    GaugeEvent
    HandshakeResult
    JoinSpec
    JoinType
    Location
    LogicalOperator
    MetricEvent
    MetricsHandler
    OperationStatus
    OperationType
    OrderSpec
    PoolOptions
    PoolStats
    PreparedStatementOptions
    PreparedStatementResult
    PrimaryKeyInfo
    PutResult
    RawAction
    RawActionResult
    RawActionType
    RawExpression
    RawFlightData
    RawFlightInfo
    RawHandshakeMessage
    RawPutResult
    RawTicket
    ReadableStream
    RecordBatchStream
    RetryOptions
    RetryResult
    RuntimeInfo
    RuntimeType
    SchemaInfo
    SchemaResult
    SortDirection
    SqlInfo
    SqlInfoValue
    SqlValue
    SubscribeOptions
    SubscriptionHandle
    SubscriptionMessageType
    SubscriptionMetadata
    SubscriptionMode
    TableInfo
    TableType
    Ticket
    TransportError
    TransportFactory
    TransportMetadata
    TransportOptions
    UpdateResult
    WhereCondition
    WritableStream
    XdbcTypeInfo

    Variables

    DescriptorType
    MetricNames
    retryPolicies
    Runtime
    SubscriptionMessageType
    SubscriptionMode
    TypeUrls

    Functions

    assertRuntime
    calculateBackoffDelay
    clearRuntimeCache
    collectToTable
    createGrpcJsTransport
    createGrpcWebTransport
    defaultIsRetryable
    deleteFrom
    detectRuntime
    encodeCommandGetCatalogs
    encodeCommandGetCrossReference
    encodeCommandGetDbSchemas
    encodeCommandGetExportedKeys
    encodeCommandGetImportedKeys
    encodeCommandGetPrimaryKeys
    encodeCommandGetSqlInfo
    encodeCommandGetTables
    encodeCommandGetTableTypes
    encodeCommandGetXdbcTypeInfo
    encodeCommandStatementQuery
    encodeCommandStatementUpdate
    escapeIdentifier
    escapeString
    formatValue
    fromGrpcStatus
    getColumnNames
    getRegisteredRuntimes
    getRowCount
    getTransportFactory
    getTransportForRuntime
    getWebTransport
    insertInto
    isRetryableGrpcError
    parseFlightData
    parseFlightDataStream
    parseSchema
    raw
    registerTransport
    requiresGrpcWeb
    select
    startTimer
    supportsGrpcJs
    tableToObjects
    tryParseSchema
    update
    withMetrics
    withRetry