Skip to main content

Deephaven Engine Python Package

Project description

Deephaven Python Integration Package

Deephaven Python Integration Package is created by Deephaven Data Labs. It allows Python developers, including data scientists, to access data, run queries, and execute Python scripts directly inside Deephaven data servers to achieve maximum performance. By taking advantage of the unique streaming table capability of Deephaven and its many data ingestion facilities (Kafka, Parquet, CSV, SQL, etc.), Python developers can quickly put together a real-time data processing pipeline that is high performing and easy to consume.

If you use a Windows operating system, WSL is not required to run Deephaven via pip.

Install

Because this package depends on the Deephaven server, it comes preinstalled with Deephaven Docker images and is made available at runtime in the Python console in the Deephaven Web UI.

Quick start

from deephaven import read_csv
from deephaven.stream.kafka.consumer import kafka_consumer, TableType
from deephaven.plot import Figure, PlotStyle
csv_table = read_csv("data1.csv")
kafka_table = kafka_consumer.consume({'bootstrap.servers': 'redpanda:29092'}, topic='realtime_feed', table_type=TableType.Append)
joined_table = kafka_table.join(csv_table, on=["key_col_1", "key_col_2"], joins=["data_col1"])
plot = Figure() \
    .axes(plot_style = PlotStyle.STACKED_BAR )\
    .plot_cat(series_name="Categories1", t=joined_table, category="Key_col_1", y = "data_col1") \
    .show()

Related documentation

API Reference

Start here

Project details


Release history Release notifications | RSS feed

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distributions

No source distribution files available for this release.See tutorial on generating distribution archives.

Built Distribution

deephaven_core-0.33.0-py3-none-any.whl (159.8 kB view details)

Uploaded Python 3

File details

Details for the file deephaven_core-0.33.0-py3-none-any.whl.

File metadata

File hashes

Hashes for deephaven_core-0.33.0-py3-none-any.whl
Algorithm Hash digest
SHA256 f3dfe7715c7725111a4e7eeb642e7ee15d52b82f46e26a16b249c15eb9370df5
MD5 551d7c447b82cda1c37808d05ae43746
BLAKE2b-256 d6fa503f8a47e51ec85f950c5de37745bd02814952271b96dd6fa934e2707d00

See more details on using hashes here.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page