Skip to content
Data > Feed Handlers

Deephaven

Requirements

  1. Docker

  2. JDK 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