Schema Info

Schema Name: sfdl_dev_firehose.services_phlag_stream
  • created: 2018-08-21 13:17:01
  • disabled: False
  • format: raw
  • id: 1000
  • is_partitioned: True
  • is_schema_datatyped: False
  • name:
    {
        "database": "sfdl_dev_firehose",
        "table": "services_phlag_stream"
    }
  • type: firehose
Schema Versions: 3
    • created: 2021-01-08 11:49:34
    • ddl:
      [
          "CREATE DATABASE IF NOT EXISTS `sfdl_dev_firehose`",
          "DROP TABLE IF EXISTS `sfdl_dev_firehose.services_phlag_stream`",
          "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_dev_firehose.services_phlag_stream`\n(\n`object_name`STRING,`isoTime`STRING,`action`STRING,`_origin`STRING,`isoTimestampOriginal`STRING,`time`STRING,`isoTimestamp`STRING,`impression`struct<`label`:STRING,`variation`:STRING,`namespace`:STRING,`userToken`:STRING>,`timestamp`STRING\n)\nPARTITIONED BY (dt string)\nROW FORMAT SERDE\n'org.openx.data.jsonserde.JsonSerDe'\n \nSTORED AS INPUTFORMAT\n  'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n  'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n  's3://sfdl-firehose-services-dev/separated_dt/phlag_stream'\n",
          "MSCK REPAIR TABLE sfdl_dev_firehose.services_phlag_stream"
      ]
    • hive_path: s3://sfdl-firehose-services-dev/separated_dt/phlag_stream
    • id: 4684284
    • processed: 1
    • raw_data:
      {
          "_origin": "2021-01-08T17:49:26Z|separated_dt/phlag_stream/dt=2021-01-08/phlag_stream-dev-1-2021-01-08-17-48-21-04f1cc06-fa73-449b-9461-ec1e4669f61c.gz|firehose-dev",
          "action": "impression",
          "impression": {
              "label": "sf_9561_sfdc_covid_confirmation_page_alert",
              "namespace": "sparefoot",
              "userToken": "ca141a52b090dd5b4dcc33fc234d3a40",
              "variation": "control"
          },
          "isoTime": "2021-01-08T11:47:21-06:00",
          "object_name": "phlag_stream",
          "time": "20210108 11:47:21.9265"
      }
    • schema_attributes:
      {
          "_origin": "string",
          "action": "string",
          "impression.label": "string",
          "impression.namespace": "string",
          "impression.userToken": "string",
          "impression.variation": "string",
          "isoTime": "string",
          "isoTimestamp": "string",
          "isoTimestampOriginal": "string",
          "object_name": "string",
          "time": "string",
          "timestamp": "string"
      }
    • schema_name_id: 1000
    • schema_scan_id: 5739410
    • updated: 2021-01-08 11:50:21
    • created: 2018-08-28 13:29:16
    • ddl:
      [
          "CREATE DATABASE IF NOT EXISTS `sfdl_dev_firehose`",
          "DROP TABLE IF EXISTS `sfdl_dev_firehose.services_phlag_stream`",
          "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_dev_firehose.services_phlag_stream`\n(\n`impression`   struct< `userToken` : string , `namespace` : string , `variation` : string , `label` : string >, `timestamp`  string , `isoTimestampOriginal`  string , `isoTimestamp`  string , `object_name`  string , `_origin`  string \n)\nPARTITIONED BY (dt string)\nROW FORMAT SERDE\n'org.openx.data.jsonserde.JsonSerDe'\n \nSTORED AS INPUTFORMAT\n  'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n  'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n  's3://sfdl-firehose-services-dev/separated_dt/phlag_stream'\n",
          "MSCK REPAIR TABLE sfdl_dev_firehose.services_phlag_stream"
      ]
    • hive_path: s3://sfdl-firehose-services-dev/separated_dt/phlag_stream
    • id: 2928912
    • processed: 1
    • raw_data:
      {
          "_origin": "2018-08-28T18:28:57Z|separated_dt/phlag_stream/dt=2018-08-28/phlag_stream-dev-1-2018-08-28-18-27-53-8cd3c683-f104-4696-ad03-436cb66cde24.gz|firehose-dev",
          "impression": {
              "label": "sf_5695_ssdc_tsla_experiment",
              "namespace": "selfstorage",
              "userToken": "945b85942ea24a04319445626",
              "variation": "control"
          },
          "isoTimestamp": "2018-08-28T13:28:00-05:00",
          "isoTimestampOriginal": "2018-08-28T13:27:59-05:00",
          "object_name": "phlag_stream",
          "timestamp": "20180828 13:27:59.9764"
      }
    • schema_attributes:
      {
          "_origin": "string",
          "impression.label": "string",
          "impression.namespace": "string",
          "impression.userToken": "string",
          "impression.variation": "string",
          "isoTimestamp": "string",
          "isoTimestampOriginal": "string",
          "object_name": "string",
          "timestamp": "string"
      }
    • schema_name_id: 1000
    • schema_scan_id: 4096816
    • updated: 2018-08-28 13:29:27
    • created: 2018-08-21 13:17:01
    • ddl:
      [
          "CREATE DATABASE IF NOT EXISTS `sfdl_dev_firehose`",
          "DROP TABLE IF EXISTS `sfdl_dev_firehose.services_phlag_stream`",
          "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_dev_firehose.services_phlag_stream`\n(\n`impression`   struct< `userToken` : string , `namespace` : string , `variation` : string , `label` : string >, `object_name`  string , `isoTimestampOriginal`  string , `isoTimestamp`  string , `timestamp`  string \n)\nPARTITIONED BY (dt string)\nROW FORMAT SERDE\n'org.openx.data.jsonserde.JsonSerDe'\n \nSTORED AS INPUTFORMAT\n  'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n  'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n  's3://sfdl-firehose-services-dev/separated_dt/phlag_stream'\n",
          "MSCK REPAIR TABLE sfdl_dev_firehose.services_phlag_stream"
      ]
    • hive_path: s3://sfdl-firehose-services-dev/separated_dt/phlag_stream
    • id: 2382006
    • processed: 1
    • raw_data:
      {
          "impression": {
              "label": "smoke_test_5b78b6b70e7a5",
              "namespace": "unittest_namespace",
              "userToken": "5b78b6b71e85b",
              "variation": "control"
          },
          "isoTimestamp": "2018-08-18T19:15:52-05:00",
          "isoTimestampOriginal": "2018-08-18T19:15:51-05:00",
          "object_name": "phlag_stream",
          "timestamp": "20180818 19:15:51.139"
      }
    • schema_attributes:
      {
          "impression.label": "string",
          "impression.namespace": "string",
          "impression.userToken": "string",
          "impression.variation": "string",
          "isoTimestamp": "string",
          "isoTimestampOriginal": "string",
          "object_name": "string",
          "timestamp": "string"
      }
    • schema_name_id: 1000
    • schema_scan_id: 4079849
    • updated: 2018-08-21 13:17:12
Schema Scans: 3
Last at 2021-01-08 11:49:34
    • duration: 0:00:50.502093
    • exit_message:
      {
          "ddl_changed": true,
          "ingested_partitions": 176,
          "partitions_applied": false,
          "success": true
      }
    • id: 5739410
    • payload:
      {
          "datatype_dict": null,
          "file_format": "json",
          "is_schema_datatyped": false,
          "partition": {
              "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2021-01-08/",
              "name": "dt",
              "type": "string",
              "value": "2021-01-08"
          },
          "s3": {
              "bucket": "sfdl-firehose-services-dev",
              "hive_path": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream",
              "key": "separated_dt/phlag_stream/dt=2021-01-08/phlag_stream-dev-1-2021-01-08-17-48-21-04f1cc06-fa73-449b-9461-ec1e4669f61c.gz"
          },
          "schema": {
              "name": "sfdl_dev_firehose.services_phlag_stream",
              "type": "firehose"
          }
      }
    • running: False
    • schema_name_id: 1000
    • start_time: 2021-01-08 11:49:34
    • success: True
    • trace_id: 1256050021936813352
    • duration: 0:00:13.843372
    • exit_message:
      {
          "ddl_changed": true,
          "ingested_partitions": 2,
          "partitions_applied": false,
          "success": true
      }
    • id: 4096816
    • payload:
      {
          "datatype_dict": null,
          "file_format": "json",
          "is_schema_datatyped": false,
          "partition": {
              "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2018-08-28/",
              "name": "dt",
              "type": "string",
              "value": "2018-08-28"
          },
          "s3": {
              "bucket": "sfdl-firehose-services-dev",
              "hive_path": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream",
              "key": "separated_dt/phlag_stream/dt=2018-08-28/phlag_stream-dev-1-2018-08-28-18-27-53-8cd3c683-f104-4696-ad03-436cb66cde24.gz"
          },
          "schema": {
              "name": "sfdl_dev_firehose.services_phlag_stream",
              "type": "firehose"
          }
      }
    • running: False
    • schema_name_id: 1000
    • start_time: 2018-08-28 13:29:15
    • success: True
    • trace_id: 12757303239914217786
    • duration: 0:00:13.867974
    • exit_message:
      {
          "ddl_changed": true,
          "ingested_partitions": 1,
          "partitions_applied": false,
          "success": true
      }
    • id: 4079849
    • payload:
      {
          "datatype_dict": null,
          "file_format": "json",
          "is_schema_datatyped": false,
          "partition": {
              "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2018-08-19/",
              "name": "dt",
              "type": "string",
              "value": "2018-08-19"
          },
          "s3": {
              "bucket": "sfdl-firehose-services-dev",
              "hive_path": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream",
              "key": "separated_dt/phlag_stream/dt=2018-08-19/phlag_stream-2-2018-08-19-00-15-49-42183cc4-4ea7-4872-bbef-41d15e834058.gz"
          },
          "schema": {
              "name": "sfdl_dev_firehose.services_phlag_stream",
              "type": "firehose"
          }
      }
    • running: False
    • schema_name_id: 1000
    • start_time: 2018-08-21 13:17:01
    • success: True
    • trace_id: 12456517142252374986
Partitions:
  • count: 21
  • ddl:
    [
        "ALTER TABLE\n    `sfdl_dev_firehose.services_phlag_stream`\nADD\n\n\n PARTITION (dt='2025-11-28') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-11-28/'\n PARTITION (dt='2025-11-30') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-11-30/'\n PARTITION (dt='2025-12-01') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-01/'\n PARTITION (dt='2025-12-02') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-02/'\n PARTITION (dt='2025-12-03') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-03/'\n PARTITION (dt='2025-12-04') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-04/'\n PARTITION (dt='2025-12-05') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-05/'\n PARTITION (dt='2025-12-13') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-13/'\n PARTITION (dt='2025-12-15') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-15/'\n PARTITION (dt='2025-12-17') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-17/'\n PARTITION (dt='2025-12-18') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-18/'\n PARTITION (dt='2025-12-22') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-22/'\n PARTITION (dt='2025-12-24') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-24/'\n PARTITION (dt='2025-12-29') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-29/'\n PARTITION (dt='2025-12-30') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-30/'\n PARTITION (dt='2025-12-31') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-31/'\n PARTITION (dt='2026-01-02') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2026-01-02/'\n PARTITION (dt='2026-01-05') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2026-01-05/'\n PARTITION (dt='2026-01-06') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2026-01-06/'\n PARTITION (dt='2026-01-07') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2026-01-07/'\n PARTITION (dt='2026-03-19') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2026-03-19/'\n;"
    ]
  • name: dt
  • state:
    [
        {
            "info": {
                "id": 304132,
                "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-11-28/",
                "name": "dt",
                "value": "2025-11-28"
            },
            "state": {
                "arrival": {
                    "athena_discovery": true,
                    "first_data": "2025-12-08 03:56:23",
                    "last_data": "2025-12-08 03:56:23"
                },
                "parquet": {
                    "first_performed": null,
                    "in_progress": null,
                    "job_id": null,
                    "last_performed": null,
                    "queued": false
                }
            }
        },
        {
            "info": {
                "id": 304126,
                "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-11-30/",
                "name": "dt",
                "value": "2025-11-30"
            },
            "state": {
                "arrival": {
                    "athena_discovery": true,
                    "first_data": "2025-12-08 03:55:41",
                    "last_data": "2025-12-08 03:56:59"
                },
                "parquet": {
                    "first_performed": null,
                    "in_progress": null,
                    "job_id": null,
                    "last_performed": null,
                    "queued": false
                }
            }
        },
        {
            "info": {
                "id": 304125,
                "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-01/",
                "name": "dt",
                "value": "2025-12-01"
            },
            "state": {
                "arrival": {
                    "athena_discovery": true,
                    "first_data": "2025-12-08 03:55:26",
                    "last_data": "2025-12-08 03:57:50"
                },
                "parquet": {
                    "first_performed": null,
                    "in_progress": null,
                    "job_id": null,
                    "last_performed": null,
                    "queued": false
                }
            }
        },
        {
            "info": {
                "id": 304146,
                "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-02/",
                "name": "dt",
                "value": "2025-12-02"
            },
            "state": {
                "arrival": {
                    "athena_discovery": true,
                    "first_data": "2025-12-08 03:57:33",
                    "last_data": "2025-12-08 03:58:17"
                },
                "parquet": {
                    "first_performed": null,
                    "in_progress": null,
                    "job_id": null,
                    "last_performed": null,
                    "queued": false
                }
            }
        },
        {
            "info": {
                "id": 304148,
                "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-03/",
                "name": "dt",
                "value": "2025-12-03"
            },
            "state": {
                "arrival": {
                    "athena_discovery": true,
                    "first_data": "2025-12-08 03:57:51",
                    "last_data": "2025-12-08 04:00:31"
                },
                "parquet": {
                    "first_performed": null,
                    "in_progress": null,
                    "job_id": null,
                    "last_performed": null,
                    "queued": false
                }
            }
        },
        {
            "info": {
                "id": 304165,
                "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-04/",
                "name": "dt",
                "value": "2025-12-04"
            },
            "state": {
                "arrival": {
                    "athena_discovery": true,
                    "first_data": "2025-12-08 04:01:37",
                    "last_data": "2025-12-08 04:03:38"
                },
                "parquet": {
                    "first_performed": null,
                    "in_progress": null,
                    "job_id": null,
                    "last_performed": null,
                    "queued": false
                }
            }
        },
        {
            "info": {
                "id": 304164,
                "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-05/",
                "name": "dt",
                "value": "2025-12-05"
            },
            "state": {
                "arrival": {
                    "athena_discovery": true,
                    "first_data": "2025-12-08 04:01:29",
                    "last_data": "2025-12-08 04:04:00"
                },
                "parquet": {
                    "first_performed": null,
                    "in_progress": null,
                    "job_id": null,
                    "last_performed": null,
                    "queued": false
                }
            }
        },
        {
            "info": {
                "id": 304470,
                "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-13/",
                "name": "dt",
                "value": "2025-12-13"
            },
            "state": {
                "arrival": {
                    "athena_discovery": true,
                    "first_data": "2025-12-13 02:58:04",
                    "last_data": "2025-12-13 07:20:24"
                },
                "parquet": {
                    "first_performed": null,
                    "in_progress": null,
                    "job_id": null,
                    "last_performed": null,
                    "queued": false
                }
            }
        },
        {
            "info": {
                "id": 304597,
                "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-15/",
                "name": "dt",
                "value": "2025-12-15"
            },
            "state": {
                "arrival": {
                    "athena_discovery": true,
                    "first_data": "2025-12-15 00:17:06",
                    "last_data": "2025-12-15 09:16:28"
                },
                "parquet": {
                    "first_performed": null,
                    "in_progress": null,
                    "job_id": null,
                    "last_performed": null,
                    "queued": false
                }
            }
        },
        {
            "info": {
                "id": 304727,
                "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-17/",
                "name": "dt",
                "value": "2025-12-17"
            },
            "state": {
                "arrival": {
                    "athena_discovery": true,
                    "first_data": "2025-12-17 04:58:02",
                    "last_data": "2025-12-17 07:03:08"
                },
                "parquet": {
                    "first_performed": null,
                    "in_progress": null,
                    "job_id": null,
                    "last_performed": null,
                    "queued": false
                }
            }
        },
        {
            "info": {
                "id": 304789,
                "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-18/",
                "name": "dt",
                "value": "2025-12-18"
            },
            "state": {
                "arrival": {
                    "athena_discovery": true,
                    "first_data": "2025-12-17 23:19:59",
                    "last_data": "2025-12-18 15:35:51"
                },
                "parquet": {
                    "first_performed": null,
                    "in_progress": null,
                    "job_id": null,
                    "last_performed": null,
                    "queued": false
                }
            }
        },
        {
            "info": {
                "id": 305046,
                "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-22/",
                "name": "dt",
                "value": "2025-12-22"
            },
            "state": {
                "arrival": {
                    "athena_discovery": true,
                    "first_data": "2025-12-22 06:42:43",
                    "last_data": "2025-12-22 10:32:34"
                },
                "parquet": {
                    "first_performed": null,
                    "in_progress": null,
                    "job_id": null,
                    "last_performed": null,
                    "queued": false
                }
            }
        },
        {
            "info": {
                "id": 305178,
                "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-24/",
                "name": "dt",
                "value": "2025-12-24"
            },
            "state": {
                "arrival": {
                    "athena_discovery": true,
                    "first_data": "2025-12-24 00:42:16",
                    "last_data": "2025-12-24 00:42:16"
                },
                "parquet": {
                    "first_performed": null,
                    "in_progress": null,
                    "job_id": null,
                    "last_performed": null,
                    "queued": false
                }
            }
        },
        {
            "info": {
                "id": 305495,
                "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-29/",
                "name": "dt",
                "value": "2025-12-29"
            },
            "state": {
                "arrival": {
                    "athena_discovery": true,
                    "first_data": "2025-12-28 23:20:51",
                    "last_data": "2025-12-29 09:11:40"
                },
                "parquet": {
                    "first_performed": null,
                    "in_progress": null,
                    "job_id": null,
                    "last_performed": null,
                    "queued": false
                }
            }
        },
        {
            "info": {
                "id": 306833,
                "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-30/",
                "name": "dt",
                "value": "2025-12-30"
            },
            "state": {
                "arrival": {
                    "athena_discovery": true,
                    "first_data": "2025-12-29 20:20:41",
                    "last_data": "2025-12-30 06:44:26"
                },
                "parquet": {
                    "first_performed": null,
                    "in_progress": null,
                    "job_id": null,
                    "last_performed": null,
                    "queued": false
                }
            }
        },
        {
            "info": {
                "id": 306900,
                "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-31/",
                "name": "dt",
                "value": "2025-12-31"
            },
            "state": {
                "arrival": {
                    "athena_discovery": true,
                    "first_data": "2025-12-31 01:40:30",
                    "last_data": "2025-12-31 01:40:30"
                },
                "parquet": {
                    "first_performed": null,
                    "in_progress": null,
                    "job_id": null,
                    "last_performed": null,
                    "queued": false
                }
            }
        },
        {
            "info": {
                "id": 307028,
                "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2026-01-02/",
                "name": "dt",
                "value": "2026-01-02"
            },
            "state": {
                "arrival": {
                    "athena_discovery": true,
                    "first_data": "2026-01-01 23:02:30",
                    "last_data": "2026-01-02 01:42:55"
                },
                "parquet": {
                    "first_performed": null,
                    "in_progress": null,
                    "job_id": null,
                    "last_performed": null,
                    "queued": false
                }
            }
        },
        {
            "info": {
                "id": 307221,
                "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2026-01-05/",
                "name": "dt",
                "value": "2026-01-05"
            },
            "state": {
                "arrival": {
                    "athena_discovery": true,
                    "first_data": "2026-01-05 00:34:27",
                    "last_data": "2026-01-05 01:08:13"
                },
                "parquet": {
                    "first_performed": null,
                    "in_progress": null,
                    "job_id": null,
                    "last_performed": null,
                    "queued": false
                }
            }
        },
        {
            "info": {
                "id": 307285,
                "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2026-01-06/",
                "name": "dt",
                "value": "2026-01-06"
            },
            "state": {
                "arrival": {
                    "athena_discovery": true,
                    "first_data": "2026-01-05 21:30:09",
                    "last_data": "2026-01-06 01:14:41"
                },
                "parquet": {
                    "first_performed": null,
                    "in_progress": null,
                    "job_id": null,
                    "last_performed": null,
                    "queued": false
                }
            }
        },
        {
            "info": {
                "id": 307413,
                "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2026-01-07/",
                "name": "dt",
                "value": "2026-01-07"
            },
            "state": {
                "arrival": {
                    "athena_discovery": true,
                    "first_data": "2026-01-07 11:24:09",
                    "last_data": "2026-01-07 12:33:16"
                },
                "parquet": {
                    "first_performed": null,
                    "in_progress": null,
                    "job_id": null,
                    "last_performed": null,
                    "queued": false
                }
            }
        },
        {
            "info": {
                "id": 312204,
                "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2026-03-19/",
                "name": "dt",
                "value": "2026-03-19"
            },
            "state": {
                "arrival": {
                    "athena_discovery": true,
                    "first_data": "2026-03-19 12:10:51",
                    "last_data": "2026-03-19 14:17:12"
                },
                "parquet": {
                    "first_performed": null,
                    "in_progress": null,
                    "job_id": null,
                    "last_performed": null,
                    "queued": false
                }
            }
        }
    ]
  • type: string
Schema:
  • attributes:
    {
        "_origin": "string",
        "action": "string",
        "impression.label": "string",
        "impression.namespace": "string",
        "impression.userToken": "string",
        "impression.variation": "string",
        "isoTime": "string",
        "isoTimestamp": "string",
        "isoTimestampOriginal": "string",
        "object_name": "string",
        "time": "string",
        "timestamp": "string"
    }
  • created: 2021-01-08 11:49:34
  • ddl:
    {
        "create_database": "CREATE DATABASE IF NOT EXISTS `sfdl_dev_firehose`",
        "create_table": "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_dev_firehose.services_phlag_stream`\n(\n`object_name`STRING,`isoTime`STRING,`action`STRING,`_origin`STRING,`isoTimestampOriginal`STRING,`time`STRING,`isoTimestamp`STRING,`impression`struct<`label`:STRING,`variation`:STRING,`namespace`:STRING,`userToken`:STRING>,`timestamp`STRING\n)\nPARTITIONED BY (dt string)\nROW FORMAT SERDE\n'org.openx.data.jsonserde.JsonSerDe'\n \nSTORED AS INPUTFORMAT\n  'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n  'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n  's3://sfdl-firehose-services-dev/separated_dt/phlag_stream'\n",
        "drop_table": "DROP TABLE IF EXISTS `sfdl_dev_firehose.services_phlag_stream`",
        "repair_table": "MSCK REPAIR TABLE sfdl_dev_firehose.services_phlag_stream"
    }
Server:
  • hostname: schemamanager-5447774fc6-4w58v
  • name: schema_manager
  • process_start: 2026-04-02 21:43:44
  • sf_env: dev
  • version: 2427328685
Raw:
{
    "name": {
        "created": "2018-08-21 13:17:01",
        "disabled": false,
        "format": "raw",
        "id": 1000,
        "is_partitioned": true,
        "is_schema_datatyped": false,
        "name": {
            "database": "sfdl_dev_firehose",
            "table": "services_phlag_stream"
        },
        "type": "firehose"
    },
    "partition": {
        "count": 21,
        "ddl": [
            "ALTER TABLE\n    `sfdl_dev_firehose.services_phlag_stream`\nADD\n\n\n PARTITION (dt='2025-11-28') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-11-28/'\n PARTITION (dt='2025-11-30') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-11-30/'\n PARTITION (dt='2025-12-01') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-01/'\n PARTITION (dt='2025-12-02') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-02/'\n PARTITION (dt='2025-12-03') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-03/'\n PARTITION (dt='2025-12-04') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-04/'\n PARTITION (dt='2025-12-05') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-05/'\n PARTITION (dt='2025-12-13') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-13/'\n PARTITION (dt='2025-12-15') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-15/'\n PARTITION (dt='2025-12-17') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-17/'\n PARTITION (dt='2025-12-18') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-18/'\n PARTITION (dt='2025-12-22') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-22/'\n PARTITION (dt='2025-12-24') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-24/'\n PARTITION (dt='2025-12-29') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-29/'\n PARTITION (dt='2025-12-30') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-30/'\n PARTITION (dt='2025-12-31') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-31/'\n PARTITION (dt='2026-01-02') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2026-01-02/'\n PARTITION (dt='2026-01-05') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2026-01-05/'\n PARTITION (dt='2026-01-06') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2026-01-06/'\n PARTITION (dt='2026-01-07') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2026-01-07/'\n PARTITION (dt='2026-03-19') location 's3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2026-03-19/'\n;"
        ],
        "name": "dt",
        "state": [
            {
                "info": {
                    "id": 304132,
                    "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-11-28/",
                    "name": "dt",
                    "value": "2025-11-28"
                },
                "state": {
                    "arrival": {
                        "athena_discovery": true,
                        "first_data": "2025-12-08 03:56:23",
                        "last_data": "2025-12-08 03:56:23"
                    },
                    "parquet": {
                        "first_performed": null,
                        "in_progress": null,
                        "job_id": null,
                        "last_performed": null,
                        "queued": false
                    }
                }
            },
            {
                "info": {
                    "id": 304126,
                    "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-11-30/",
                    "name": "dt",
                    "value": "2025-11-30"
                },
                "state": {
                    "arrival": {
                        "athena_discovery": true,
                        "first_data": "2025-12-08 03:55:41",
                        "last_data": "2025-12-08 03:56:59"
                    },
                    "parquet": {
                        "first_performed": null,
                        "in_progress": null,
                        "job_id": null,
                        "last_performed": null,
                        "queued": false
                    }
                }
            },
            {
                "info": {
                    "id": 304125,
                    "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-01/",
                    "name": "dt",
                    "value": "2025-12-01"
                },
                "state": {
                    "arrival": {
                        "athena_discovery": true,
                        "first_data": "2025-12-08 03:55:26",
                        "last_data": "2025-12-08 03:57:50"
                    },
                    "parquet": {
                        "first_performed": null,
                        "in_progress": null,
                        "job_id": null,
                        "last_performed": null,
                        "queued": false
                    }
                }
            },
            {
                "info": {
                    "id": 304146,
                    "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-02/",
                    "name": "dt",
                    "value": "2025-12-02"
                },
                "state": {
                    "arrival": {
                        "athena_discovery": true,
                        "first_data": "2025-12-08 03:57:33",
                        "last_data": "2025-12-08 03:58:17"
                    },
                    "parquet": {
                        "first_performed": null,
                        "in_progress": null,
                        "job_id": null,
                        "last_performed": null,
                        "queued": false
                    }
                }
            },
            {
                "info": {
                    "id": 304148,
                    "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-03/",
                    "name": "dt",
                    "value": "2025-12-03"
                },
                "state": {
                    "arrival": {
                        "athena_discovery": true,
                        "first_data": "2025-12-08 03:57:51",
                        "last_data": "2025-12-08 04:00:31"
                    },
                    "parquet": {
                        "first_performed": null,
                        "in_progress": null,
                        "job_id": null,
                        "last_performed": null,
                        "queued": false
                    }
                }
            },
            {
                "info": {
                    "id": 304165,
                    "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-04/",
                    "name": "dt",
                    "value": "2025-12-04"
                },
                "state": {
                    "arrival": {
                        "athena_discovery": true,
                        "first_data": "2025-12-08 04:01:37",
                        "last_data": "2025-12-08 04:03:38"
                    },
                    "parquet": {
                        "first_performed": null,
                        "in_progress": null,
                        "job_id": null,
                        "last_performed": null,
                        "queued": false
                    }
                }
            },
            {
                "info": {
                    "id": 304164,
                    "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-05/",
                    "name": "dt",
                    "value": "2025-12-05"
                },
                "state": {
                    "arrival": {
                        "athena_discovery": true,
                        "first_data": "2025-12-08 04:01:29",
                        "last_data": "2025-12-08 04:04:00"
                    },
                    "parquet": {
                        "first_performed": null,
                        "in_progress": null,
                        "job_id": null,
                        "last_performed": null,
                        "queued": false
                    }
                }
            },
            {
                "info": {
                    "id": 304470,
                    "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-13/",
                    "name": "dt",
                    "value": "2025-12-13"
                },
                "state": {
                    "arrival": {
                        "athena_discovery": true,
                        "first_data": "2025-12-13 02:58:04",
                        "last_data": "2025-12-13 07:20:24"
                    },
                    "parquet": {
                        "first_performed": null,
                        "in_progress": null,
                        "job_id": null,
                        "last_performed": null,
                        "queued": false
                    }
                }
            },
            {
                "info": {
                    "id": 304597,
                    "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-15/",
                    "name": "dt",
                    "value": "2025-12-15"
                },
                "state": {
                    "arrival": {
                        "athena_discovery": true,
                        "first_data": "2025-12-15 00:17:06",
                        "last_data": "2025-12-15 09:16:28"
                    },
                    "parquet": {
                        "first_performed": null,
                        "in_progress": null,
                        "job_id": null,
                        "last_performed": null,
                        "queued": false
                    }
                }
            },
            {
                "info": {
                    "id": 304727,
                    "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-17/",
                    "name": "dt",
                    "value": "2025-12-17"
                },
                "state": {
                    "arrival": {
                        "athena_discovery": true,
                        "first_data": "2025-12-17 04:58:02",
                        "last_data": "2025-12-17 07:03:08"
                    },
                    "parquet": {
                        "first_performed": null,
                        "in_progress": null,
                        "job_id": null,
                        "last_performed": null,
                        "queued": false
                    }
                }
            },
            {
                "info": {
                    "id": 304789,
                    "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-18/",
                    "name": "dt",
                    "value": "2025-12-18"
                },
                "state": {
                    "arrival": {
                        "athena_discovery": true,
                        "first_data": "2025-12-17 23:19:59",
                        "last_data": "2025-12-18 15:35:51"
                    },
                    "parquet": {
                        "first_performed": null,
                        "in_progress": null,
                        "job_id": null,
                        "last_performed": null,
                        "queued": false
                    }
                }
            },
            {
                "info": {
                    "id": 305046,
                    "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-22/",
                    "name": "dt",
                    "value": "2025-12-22"
                },
                "state": {
                    "arrival": {
                        "athena_discovery": true,
                        "first_data": "2025-12-22 06:42:43",
                        "last_data": "2025-12-22 10:32:34"
                    },
                    "parquet": {
                        "first_performed": null,
                        "in_progress": null,
                        "job_id": null,
                        "last_performed": null,
                        "queued": false
                    }
                }
            },
            {
                "info": {
                    "id": 305178,
                    "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-24/",
                    "name": "dt",
                    "value": "2025-12-24"
                },
                "state": {
                    "arrival": {
                        "athena_discovery": true,
                        "first_data": "2025-12-24 00:42:16",
                        "last_data": "2025-12-24 00:42:16"
                    },
                    "parquet": {
                        "first_performed": null,
                        "in_progress": null,
                        "job_id": null,
                        "last_performed": null,
                        "queued": false
                    }
                }
            },
            {
                "info": {
                    "id": 305495,
                    "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-29/",
                    "name": "dt",
                    "value": "2025-12-29"
                },
                "state": {
                    "arrival": {
                        "athena_discovery": true,
                        "first_data": "2025-12-28 23:20:51",
                        "last_data": "2025-12-29 09:11:40"
                    },
                    "parquet": {
                        "first_performed": null,
                        "in_progress": null,
                        "job_id": null,
                        "last_performed": null,
                        "queued": false
                    }
                }
            },
            {
                "info": {
                    "id": 306833,
                    "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-30/",
                    "name": "dt",
                    "value": "2025-12-30"
                },
                "state": {
                    "arrival": {
                        "athena_discovery": true,
                        "first_data": "2025-12-29 20:20:41",
                        "last_data": "2025-12-30 06:44:26"
                    },
                    "parquet": {
                        "first_performed": null,
                        "in_progress": null,
                        "job_id": null,
                        "last_performed": null,
                        "queued": false
                    }
                }
            },
            {
                "info": {
                    "id": 306900,
                    "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2025-12-31/",
                    "name": "dt",
                    "value": "2025-12-31"
                },
                "state": {
                    "arrival": {
                        "athena_discovery": true,
                        "first_data": "2025-12-31 01:40:30",
                        "last_data": "2025-12-31 01:40:30"
                    },
                    "parquet": {
                        "first_performed": null,
                        "in_progress": null,
                        "job_id": null,
                        "last_performed": null,
                        "queued": false
                    }
                }
            },
            {
                "info": {
                    "id": 307028,
                    "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2026-01-02/",
                    "name": "dt",
                    "value": "2026-01-02"
                },
                "state": {
                    "arrival": {
                        "athena_discovery": true,
                        "first_data": "2026-01-01 23:02:30",
                        "last_data": "2026-01-02 01:42:55"
                    },
                    "parquet": {
                        "first_performed": null,
                        "in_progress": null,
                        "job_id": null,
                        "last_performed": null,
                        "queued": false
                    }
                }
            },
            {
                "info": {
                    "id": 307221,
                    "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2026-01-05/",
                    "name": "dt",
                    "value": "2026-01-05"
                },
                "state": {
                    "arrival": {
                        "athena_discovery": true,
                        "first_data": "2026-01-05 00:34:27",
                        "last_data": "2026-01-05 01:08:13"
                    },
                    "parquet": {
                        "first_performed": null,
                        "in_progress": null,
                        "job_id": null,
                        "last_performed": null,
                        "queued": false
                    }
                }
            },
            {
                "info": {
                    "id": 307285,
                    "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2026-01-06/",
                    "name": "dt",
                    "value": "2026-01-06"
                },
                "state": {
                    "arrival": {
                        "athena_discovery": true,
                        "first_data": "2026-01-05 21:30:09",
                        "last_data": "2026-01-06 01:14:41"
                    },
                    "parquet": {
                        "first_performed": null,
                        "in_progress": null,
                        "job_id": null,
                        "last_performed": null,
                        "queued": false
                    }
                }
            },
            {
                "info": {
                    "id": 307413,
                    "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2026-01-07/",
                    "name": "dt",
                    "value": "2026-01-07"
                },
                "state": {
                    "arrival": {
                        "athena_discovery": true,
                        "first_data": "2026-01-07 11:24:09",
                        "last_data": "2026-01-07 12:33:16"
                    },
                    "parquet": {
                        "first_performed": null,
                        "in_progress": null,
                        "job_id": null,
                        "last_performed": null,
                        "queued": false
                    }
                }
            },
            {
                "info": {
                    "id": 312204,
                    "location": "s3://sfdl-firehose-services-dev/separated_dt/phlag_stream/dt=2026-03-19/",
                    "name": "dt",
                    "value": "2026-03-19"
                },
                "state": {
                    "arrival": {
                        "athena_discovery": true,
                        "first_data": "2026-03-19 12:10:51",
                        "last_data": "2026-03-19 14:17:12"
                    },
                    "parquet": {
                        "first_performed": null,
                        "in_progress": null,
                        "job_id": null,
                        "last_performed": null,
                        "queued": false
                    }
                }
            }
        ],
        "type": "string"
    },
    "schema": {
        "attributes": {
            "_origin": "string",
            "action": "string",
            "impression.label": "string",
            "impression.namespace": "string",
            "impression.userToken": "string",
            "impression.variation": "string",
            "isoTime": "string",
            "isoTimestamp": "string",
            "isoTimestampOriginal": "string",
            "object_name": "string",
            "time": "string",
            "timestamp": "string"
        },
        "created": "2021-01-08 11:49:34",
        "ddl": {
            "create_database": "CREATE DATABASE IF NOT EXISTS `sfdl_dev_firehose`",
            "create_table": "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_dev_firehose.services_phlag_stream`\n(\n`object_name`STRING,`isoTime`STRING,`action`STRING,`_origin`STRING,`isoTimestampOriginal`STRING,`time`STRING,`isoTimestamp`STRING,`impression`struct<`label`:STRING,`variation`:STRING,`namespace`:STRING,`userToken`:STRING>,`timestamp`STRING\n)\nPARTITIONED BY (dt string)\nROW FORMAT SERDE\n'org.openx.data.jsonserde.JsonSerDe'\n \nSTORED AS INPUTFORMAT\n  'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n  'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n  's3://sfdl-firehose-services-dev/separated_dt/phlag_stream'\n",
            "drop_table": "DROP TABLE IF EXISTS `sfdl_dev_firehose.services_phlag_stream`",
            "repair_table": "MSCK REPAIR TABLE sfdl_dev_firehose.services_phlag_stream"
        }
    },
    "server": {
        "hostname": "schemamanager-5447774fc6-4w58v",
        "name": "schema_manager",
        "process_start": "2026-04-02 21:43:44",
        "sf_env": "dev",
        "version": "2427328685"
    }
}