Package io.deephaven.integrations.learn

Class Scatterer

java.lang.Object
io.deephaven.integrations.learn.Scatterer
public class Scatterer extends Object
Scatterer applies scatter functions to the result of a deferred calculation so that the results can be scattered into new table columns.

  • Constructor Details

    • Scatterer

      public Scatterer(Output[] outputs)
      Creates a new Scatterer.
      Parameters:
      outputs - array of Outputs that determine how data will be scattered back to the table.

  • Method Details

    • scatter

      public Object scatter(int idx, FutureOffset fo)
      Applies the scatter function of each output to the result of a deferred calculation to get the result into a column.
      Parameters:
      idx - index of the particular output in the list of outputs to use for scattering.
      fo - FutureOffset that contains the results of the deferred calculation as well as the index of the row. that calculation belongs to.
      Returns:
      result of the deferred calculation to be stored into a column.

    • generateQueryStrings

      public String[] generateQueryStrings(String futureOffsetColName)
      Generates query strings to create a new column for each Output.
      Parameters:
      futureOffsetColName - name of the FutureOffset column to get results from
      Returns:
      list of query strings to be used in .update() call.