Skip to content
Data > Feed Handlers

Deephaven

The following are required to use Deephaven with 3forge:

  1. Docker

  2. JDK version >=17

Getting Started with Deephaven

  1. Install sample python-example containers from Deephaven from Quick start Install Deephaven.

    1
2
3
    curl https://raw.githubusercontent.com/deephaven/deephaven-core/main/containers/python-examples/base/docker-compose.yml -O
docker-compose* pull
docker-compose* up

  2. If you run into errors with the grpc container, downgrade the containers in the "docker-compose.yml" file to 0.16.1.

  3. Go to http://localhost:10000/ide/ on the browser.

  4. Execute the following commands in the Deephaven IDE:

    1
2
    from deephaven import time_table
sample = time_table('00:00:02')

This will create a ticking table that will insert a new timestamp record every 2 seconds.

Installing the feedhandler plugin to AMI

  1. Place DeephavenFH.jar and all other jar files in the dependencies directory under /amione/lib/.

  2. Copy the properties from the local.properties file to your own local.properties.

  3. For JDK17 compatibility, use the attached start.sh file or add the following parameters to the java launch command:

    1
    --add-opens java.base/java.lang=ALL-UNNAMED --add-opens java.base/java.util=ALL-UNNAMED --add-opens java.base/java.text=ALL-UNNAMED --add-opens java.base/sun.net=ALL-UNNAMED --add-opens java.management/sun.management=ALL-UNNAMED --add-opens java.base/sun.security.action=ALL-UNNAMED

  4. Add the following to the java launch parameters to the start.sh file as well:

    1
    -DConfiguration.rootFile=dh-defaults.prop

  5. Launch AMI.

Configuring the feedhandler

There are 3 properties that can be configured from the local.properties file:

  1. ami.relay.fh.deephaven.props.url: Subscription source url.

  2. ami.relay.fh.deephaven.props.topics: Tables to be subscribed to (delimited by commas).

  3. ami.relay.fh.deephaven.props.messagesize: (Optional) maximum size of messages from the source. Default is 1000000.

For example, to subscribe to a localhost deephaven server with tables Sample1 & Sample2 with a maximum message size of 2000000:

1
2
3
ami.relay.fh.deephaven.props.url=localhost
ami.relay.fh.deephaven.props.topics=Sample1,Sample2
ami.relay.fh.deephaven.props.messagesize=2000000