Produces events to an Apache Arrow Flight SQL server.

Flight Sql🔗

Produces events to an Apache Arrow Flight SQL server.

Configuration🔗

Field	Type	Required	Default	Description
`inputs`	`[string]`	yes	—	Upstream component names that feed events into this sink.
`error_policy`	`ErrorPolicy`	no	`drop_on_error`	Policy for handling errors during event processing.
`encoding`	`EncoderConfigEnum (optional)`	no	—	Optional encoder configuration for output events.
`buffer`	`BufferConfig`	no	—	Buffer configuration for event batching.
`endpoint`	`string`	yes	—	Target Flight SQL endpoint URL (e.g., "http://localhost:32010").
`table_name`	`string (optional)`	no	—	Destination table name for insertions.
`setup_commands`	`[string] (optional)`	no	—	SQL commands to execute upon connecting (e.g., SET proxy = 'my-proxy').

Telemetry🔗

This component emits the following standard telemetry metrics and events.

Metrics🔗

Name	Type	Description
`component_sent_events_total`	Counter	Total number of Kinetic events successfully sent by this sink.
`component_sent_event_bytes_total`	Counter	Total estimated byte size of events sent.
`component_sent_network_bytes_total`	Counter	Total number of raw network bytes sent.
`component_errors_total`	Counter	Total number of errors encountered during processing.

Events🔗

Name	Description
`ComponentError`	Emitted when an error occurs during component execution.
`ComponentEventsDropped`	Emitted when events are intentionally or unintentionally dropped.

Example🔗

sinks:
  my_flight_sql:
    type: flight_sql
    inputs: ["my_transform"]
    endpoint: http://localhost:32010
    table_name: events
    setup_commands: ["SET proxy = 'my-proxy'"]

Flight Sql Stable

Flight Sql🔗

Configuration🔗

Telemetry🔗

Metrics🔗

Events🔗

Example🔗