Package io.deephaven.engine.table.impl.locations.util

Interface TableDataRefreshService

All Known Implementing Classes:
ExecutorTableDataRefreshService, TableDataRefreshService.Null
public interface TableDataRefreshService
For TableDataService and related components, this allows a simple implementation for subscription support.

  • Method Details

    • submitOneTimeAsyncTask

      void submitOneTimeAsyncTask(@NotNull @NotNull Runnable task)
      Submit a one-time task to be run asynchronously.
      Parameters:
      task - The task to run

    • scheduleTableLocationProviderRefresh

      TableDataRefreshService.CancellableSubscriptionToken scheduleTableLocationProviderRefresh(@NotNull @NotNull AbstractTableLocationProvider tableLocationProvider)
      Schedule run for an AbstractTableLocationProvider using an implementation-defined default refresh interval
      Parameters:
      tableLocationProvider - The table location provider
      Returns:
      A subscription token to be used for matching, which also supports cancellation

    • scheduleTableLocationProviderRefresh

      TableDataRefreshService.CancellableSubscriptionToken scheduleTableLocationProviderRefresh(@NotNull @NotNull AbstractTableLocationProvider tableLocationProvider, long refreshIntervalMs)
      Schedule run for an AbstractTableLocationProvider.
      Parameters:
      tableLocationProvider - The table location provider
      refreshIntervalMs - The interval in milliseconds between refreshes
      Returns:
      A subscription token to be used for matching, which also supports cancellation

    • scheduleTableLocationRefresh

      TableDataRefreshService.CancellableSubscriptionToken scheduleTableLocationRefresh(@NotNull @NotNull AbstractTableLocation tableLocation)
      Schedule run for an AbstractTableLocation using an implementation-defined default refresh interval
      Parameters:
      tableLocation - The table location
      Returns:
      A subscription token to be used for matching, which also supports cancellation

    • scheduleTableLocationRefresh

      TableDataRefreshService.CancellableSubscriptionToken scheduleTableLocationRefresh(@NotNull @NotNull AbstractTableLocation tableLocation, long refreshIntervalMs)
      Schedule run for an AbstractTableLocation.
      Parameters:
      tableLocation - The table location
      refreshIntervalMs - The interval in milliseconds between refreshes
      Returns:
      A subscription token to be used for matching, which also supports cancellation

    • getSharedRefreshService

      static TableDataRefreshService getSharedRefreshService()
      Get (and possibly construct) a shared instance.
      Returns:
      The shared instance