什么是暗池交易？FINRA成交量数据

SELECT
    x.name AS venue,
    x.type AS venue_type,
    t.trade_reports AS trade_reports,
    t.pct_with_trf_stamp AS pct_with_trf_stamp
FROM
(
    SELECT
        exchange,
        count() AS trade_reports,
        round(100 * countIf(trf_timestamp > toDateTime64('1970-01-02 00:00:00', 9)) / count(), 1) AS pct_with_trf_stamp
    FROM global_markets.stocks_trades
    WHERE ticker = 'AAPL'
      AND sip_timestamp >= '2026-07-02 00:00:00' AND sip_timestamp < '2026-07-03 00:00:00'
    GROUP BY exchange
    ORDER BY trade_reports DESC
    LIMIT 6
) AS t
INNER JOIN global_markets.stocks_exchanges AS x
    ON x.id = t.exchange AND x.asset_class = 'stocks'
ORDER BY t.trade_reports DESC

WITH
    (
        SELECT countIf(window_start >= toDateTime('2026-07-02 09:30:00', 'America/New_York') AND window_start < toDateTime('2026-07-02 16:00:00', 'America/New_York'))
        FROM global_markets.delayed_stocks_minute_aggs
        WHERE ticker = 'SPY' AND window_start >= toDateTime('2026-07-02 00:00:00', 'America/New_York') AND window_start < toDateTime('2026-07-03 00:00:00', 'America/New_York')
    ) AS bars_jul02
SELECT
    bars_jul02 AS spy_session_bars_jul02,
    round(count() / 1e3) AS trade_reports_thousands,
    round(countIf(exchange = 4) / 1e3) AS venue4_reports_thousands,
    round(countIf(trf_timestamp > toDateTime64('1970-01-02 00:00:00', 9)) / 1e3) AS trf_stamped_thousands,
    countIf((exchange = 4) != (trf_timestamp > toDateTime64('1970-01-02 00:00:00', 9))) AS stamp_venue_disagreements
FROM global_markets.stocks_trades
WHERE ticker = 'AAPL'
  AND sip_timestamp >= '2026-07-02 00:00:00' AND sip_timestamp < '2026-07-03 00:00:00'

SELECT
    ticker,
    round(toFloat64(sumIf(size, exchange = 4 AND NOT hasAny(conditions, [15, 16, 38]))) / 1e6, 1) AS off_exchange_shares_m,
    round(toFloat64(sumIf(size, NOT hasAny(conditions, [15, 16, 38]))) / 1e6, 1) AS total_shares_m,
    round(100 * toFloat64(sumIf(size, exchange = 4 AND NOT hasAny(conditions, [15, 16, 38]))) / toFloat64(sumIf(size, NOT hasAny(conditions, [15, 16, 38]))), 1) AS off_exchange_pct
FROM global_markets.stocks_trades
WHERE ticker IN ('SPY', 'AAPL', 'NVDA', 'TSLA', 'KO')
  AND sip_timestamp >= '2026-07-02 00:00:00' AND sip_timestamp < '2026-07-03 00:00:00'
GROUP BY ticker
ORDER BY indexOf(['SPY', 'AAPL', 'NVDA', 'TSLA', 'KO'], ticker)

SELECT
    if(exchange = 4, 'Off-exchange (TRF)', 'On-exchange') AS where_it_printed,
    round(count() / 1e3) AS prints_thousands,
    round(toFloat64(sum(size)) / 1e6, 1) AS shares_m,
    round(quantileDeterministic(0.5)(toFloat64(size), toUInt64(sip_timestamp))) AS median_print_shares,
    countIf(size >= 10000) AS prints_10k_plus,
    round(toFloat64(max(size)) / 1e3) AS largest_print_k_shares,
    if(maxIf(size, has(conditions, 8)) = max(size), 1, 0) AS largest_is_closing_auction
FROM global_markets.stocks_trades
WHERE ticker = 'TSLA'
  AND sip_timestamp >= '2026-07-02 00:00:00' AND sip_timestamp < '2026-07-03 00:00:00'
  AND NOT hasAny(conditions, [15, 16, 38])
GROUP BY where_it_printed
ORDER BY where_it_printed

SELECT
    formatDateTime(toStartOfHour(toTimeZone(sip_timestamp, 'America/New_York')), '%H:00') AS et_hour,
    round(toFloat64(sumIf(size, exchange = 4)) / 1e6, 2) AS off_exchange_shares_m,
    round(toFloat64(sumIf(size, exchange != 4)) / 1e6, 2) AS on_exchange_shares_m,
    round(100 * toFloat64(sumIf(size, exchange = 4)) / toFloat64(sum(size)), 1) AS off_exchange_pct
FROM global_markets.stocks_trades
WHERE ticker = 'NVDA'
  AND sip_timestamp >= '2026-07-02 00:00:00' AND sip_timestamp < '2026-07-03 00:00:00'
  AND NOT hasAny(conditions, [15, 16, 38])
GROUP BY et_hour
ORDER BY et_hour