lake.insider_owner_events dataset schema

Scroll sideways to compare all columns. Select a heading to sort.

No matching rows. Clear the filter to see all records.

Current logical schema for lake.insider_owner_events

Query lake.insider_owner_events using the column names and types below. The query validator and engine use this logical catalog; a field absent from an older shard returns typed NULL.

Save this page's SQL as query.sql and the runner below as query.py. Use a registered key with lake scope from Developers. The runner submits the displayed insider_owner_events query once, saves its operation, waits on that same ID, saves the returned manifest and downloads its Parquet parts.

This submission has not been executed for the reference page. Inspect the SQL, dates and resource limits before running it. Reuse the request key only for this identical SQL and limits; use a new key when changing them.

python3 -m pip install nexustrade==1.42.0
export NEXUSTRADE_API_KEY="YOUR_LAKE_SCOPED_KEY"
python3 query.py

import json
from pathlib import Path
from nexustrade import NexusTradeClient

# Save the SQL displayed on this page as query.sql.
sql = Path("query.sql").read_text()
client = NexusTradeClient.from_environment()
operation = client.create_lake_query(
    {"query": sql, "limits": {"timeoutSeconds": 30, "maxRows": 50,
                              "maxResultBytes": 1048576}},
    idempotency_key="reference-insider_owner_events-20261012-v1",
)
Path("query-operation.json").write_text(json.dumps(operation, indent=2))
finished = client.wait_for_lake_query(operation["id"])
if finished["status"] != "completed":
    raise RuntimeError(finished)
manifest = client.get_lake_query_manifest(operation["id"])["result"]
Path("query-manifest.json").write_text(json.dumps(manifest, indent=2))
print(json.dumps(manifest, indent=2))
for part in manifest["parts"]:
    Path(f"query-{part['part']}.parquet").write_bytes(
        client.download_lake_query_part(operation["id"], part["part"], max_bytes=1048576)
    )

The logical view is backed by canonical manifest-resolved data. Query this name rather than guessing a physical database collection or object-storage path.

One relation per exact owner CIK and transaction version. Select ownerCik exactly, and optionally issuerCik for a company such as Oscar Health; names/tickers resolve through the owner/company directory. Roles constrain that same owner row.

As of T: firstAvailableAt <= T AND availableAt <= T AND (supersededAt IS NULL OR T < supersededAt) AND (coverageUnverifiedAt IS NULL OR T < coverageUnverifiedAt). The trailing window uses firstAvailableAt, never transactionDate or a correction's availableAt. Purchases require transactionCode P, acquiredDisposed A, shares > 0; sales S/D. Unknown corrections are unverified, never appended as fresh buys.

For aggregate company totals, deduplicate by eventId before SUM/COUNT: joint filings have several owners. For distinct buyer counts, COUNT(DISTINCT ownerCik) is correct. Missing totalValue is unknown, not zero.

Public followers enter at the next tradable session/price after publication, not pricePerShare. These are signals, not actual personal returns; best-strategy requests require the verified strategy leaderboard, not raw transaction dollars.