Skip to main content

MarketDataLake

The lake read model. Each field is computed only when selected.

type MarketDataLake {
  totals(
    exchange: String
  ): MarketDataLakeTotals!
  rollup: [MarketDataLakeGroup!]!
  datasets(
    filter: MarketDataLakeDatasetFilter
    first: Int = 50
    after: String
  ): MarketDataLakeDatasetConnection!
  queueHealth: MarketDataLakeQueueHealth!
}

Fields​

MarketDataLake.totals ● MarketDataLakeTotals! non-null object​

Whole-lake file counts, sizes and coverage, optionally for one exchange.

MarketDataLake.totals.exchange ● String scalar​

MarketDataLake.rollup ● [MarketDataLakeGroup!]! non-null object​

One row per (exchange, trading mode, timeframe), ordered by those.

MarketDataLake.datasets ● MarketDataLakeDatasetConnection! non-null object​

Datasets, keyset-paginated. With a status filter they come in (exchange, trading mode, pair, timeframe, kind) order; without one, datasets with a file come first in that order, then datasets with no file yet. Cursors are opaque.

MarketDataLake.datasets.filter ● MarketDataLakeDatasetFilter input​
MarketDataLake.datasets.first ● Int scalar​
MarketDataLake.datasets.after ● String scalar​

MarketDataLake.queueHealth ● MarketDataLakeQueueHealth! non-null object​

The backfill queue.

Returned By​

marketDataLake query