🗺️ Maps in Fabric — Native Geospatial Visualization¶

// Machine locations table
.create table MachineLocations (
    MachineId: string,
    FloorSection: string,
    Latitude: real,
    Longitude: real,
    MachineType: string,
    InstallDate: datetime
)

// Real-time position events
.create table PositionEvents (
    EventId: string,
    EntityId: string,
    EntityType: string,
    Latitude: real,
    Longitude: real,
    Timestamp: datetime,
    Metadata: dynamic
)

// Show all slot machines with color-coded status
MachineLocations
| join kind=leftouter (
    SlotTelemetry
    | where Timestamp > ago(5m)
    | summarize CurrentStatus = arg_max(Timestamp, Status) by MachineId
) on MachineId
| project MachineId, Latitude, Longitude, FloorSection,
          Status = coalesce(CurrentStatus, "offline")

// Transaction heat map: where is the most money flowing?
Transactions
| where Timestamp > ago(1h)
| join kind=inner MachineLocations on MachineId
| project Latitude, Longitude, Amount

// Revenue by floor section (bubble size = total revenue)
Transactions
| where Timestamp > ago(24h)
| join kind=inner MachineLocations on MachineId
| summarize TotalRevenue = sum(Amount), TransactionCount = count()
    by FloorSection, Latitude = avg(Latitude), Longitude = avg(Longitude)

// All patron check-in events (thousands of points, auto-clustered)
PositionEvents
| where Timestamp > ago(1h) and EntityType == "patron"
| project Latitude, Longitude, EntityId

// Find all machines within 50 meters of a specific location
let targetLat = 36.1147;
let targetLon = -115.1728;
MachineLocations
| extend DistanceMeters = geo_distance_2points(Longitude, Latitude, targetLon, targetLat)
| where DistanceMeters <= 50
| project MachineId, FloorSection, DistanceMeters
| order by DistanceMeters asc

// Define casino floor sections as polygons and check containment
let highLimitArea = dynamic({
    "type": "Polygon",
    "coordinates": [[
        [-115.1730, 36.1150], [-115.1720, 36.1150],
        [-115.1720, 36.1140], [-115.1730, 36.1140],
        [-115.1730, 36.1150]
    ]]
});
PositionEvents
| where Timestamp > ago(15m)
| where geo_point_in_polygon(Longitude, Latitude, highLimitArea)
| summarize PatronCount = dcount(EntityId), EventCount = count()

// Aggregate events by geohash for grid-based analysis
PositionEvents
| where Timestamp > ago(1h)
| extend GeoHash = geo_point_to_geohash(Longitude, Latitude, 6)
| summarize EventCount = count(), UniqueEntities = dcount(EntityId) by GeoHash
| extend CenterPoint = geo_geohash_to_central_point(GeoHash)
| extend Lat = toreal(CenterPoint.coordinates[1]),
         Lon = toreal(CenterPoint.coordinates[0])

// Calculate total distance traveled by a patron (movement analysis)
PositionEvents
| where EntityId == "P-12345" and Timestamp > ago(2h)
| order by Timestamp asc
| extend PrevLat = prev(Latitude), PrevLon = prev(Longitude)
| where isnotnull(PrevLat)
| extend SegmentDistance = geo_distance_2points(Longitude, Latitude, PrevLon, PrevLat)
| summarize TotalDistanceMeters = sum(SegmentDistance),
            Stops = count(),
            Duration = max(Timestamp) - min(Timestamp)

// Revenue heat map with 5-minute refresh
Transactions
| where Timestamp > ago(4h)
| join kind=inner MachineLocations on MachineId
| summarize
    Revenue = sum(Amount),
    HoldPct = round(100.0 * sum(Amount - PayoutAmount) / sum(Amount), 1)
    by MachineId, Latitude, Longitude, FloorSection
| project Latitude, Longitude, Revenue, HoldPct, FloorSection

// Patron density by floor section over time
PositionEvents
| where EntityType == "patron" and Timestamp > ago(1h)
| extend TimeSlot = bin(Timestamp, 10m)
| join kind=inner (
    MachineLocations | summarize Lat = avg(Latitude), Lon = avg(Longitude) by FloorSection
) on $left.FloorSection == $right.FloorSection
| summarize PatronCount = dcount(EntityId) by TimeSlot, FloorSection, Lat, Lon

// Real-time occupancy by zone during emergency
PositionEvents
| where Timestamp > ago(2m)
| extend Zone = case(
    geo_point_in_polygon(Longitude, Latitude, zone_main_floor), "Main Floor",
    geo_point_in_polygon(Longitude, Latitude, zone_high_limit), "High Limit",
    geo_point_in_polygon(Longitude, Latitude, zone_restaurant), "Restaurant",
    "Other")
| summarize OccupantCount = dcount(EntityId) by Zone

// Map all active weather stations with latest readings
WeatherStations
| join kind=leftouter (
    WeatherObservations
    | where Timestamp > ago(1h)
    | summarize arg_max(Timestamp, *) by StationId
) on StationId
| project StationId, Latitude, Longitude, StationName,
          Temperature, WindSpeed, Precipitation,
          Status = iff(isnull(Timestamp), "Offline", "Active")

// Map TRI facilities with bubble size = total annual release
TRIFacilities
| where ReportingYear == 2025
| summarize TotalReleaseLbs = sum(ReleaseAmountLbs),
            ChemicalCount = dcount(ChemicalName)
    by FacilityId, FacilityName, Latitude, Longitude, State
| project Latitude, Longitude, FacilityName,
          TotalReleaseLbs, ChemicalCount, State

// Map federal land parcels with wildfire risk overlay
FederalLandParcels
| extend InFireZone = geo_point_in_polygon(Longitude, Latitude, activeFirePerimeter)
| project ParcelId, Latitude, Longitude, LandType, Acreage,
          FireRisk = iff(InFireZone, "Active Fire Zone", "Normal")