Source code for deephaven.stream

#
# Copyright (c) 2016-2024 Deephaven Data Labs and Patent Pending
#

""" Utility module for the stream subpackage. """
from warnings import warn

import jpy

from deephaven import DHError
from deephaven.table import Table

_JBlinkTableTools = jpy.get_type("io.deephaven.engine.table.impl.BlinkTableTools")




# TODO (https://github.com/deephaven/deephaven-core/issues/3853): Delete this method
[docs] def stream_to_append_only(table: Table) -> Table: """Deprecated synonym for blink_to_append_only""" warn('This function is deprecated, prefer blink_to_append_only', DeprecationWarning, stacklevel=2) return blink_to_append_only(table)