Schema Info
Schema Name: sfdl_stage_segment.sms_conversation_enqueued
- created: 2018-04-17 15:03:35
- disabled: False
- format: raw
- id: 489
- is_partitioned: True
- is_schema_datatyped: False
- name:
{ "database": "sfdl_stage_segment", "table": "sms_conversation_enqueued" } - type: segment
Schema Versions: 3
-
Version 203244
- created: 2019-04-30 15:06:29
- ddl:
[ "CREATE DATABASE IF NOT EXISTS `sfdl_stage_segment`", "DROP TABLE IF EXISTS `sfdl_stage_segment.sms_conversation_enqueued`", "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_stage_segment.sms_conversation_enqueued`\n(\n`timestamp`STRING,`userId`STRING,`integrations`struct<`library`:struct<`version`:STRING,`name`:STRING>>,`receivedAt`STRING,`_origin`STRING,`event`STRING,`projectId`STRING,`properties`struct<`phone_number`:STRING,`conversation_id`:STRING,`sender_handle_id`:STRING,`message_channel`:STRING>,`_metadata`struct<`nodeVersion`:STRING>,`version`STRING,`originalTimestamp`STRING,`context`struct<`library`:struct<`version`:STRING,`name`:STRING>>,`messageId`STRING,`writeKey`STRING,`type`STRING,`channel`STRING,`sentAt`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-segment-sms-stage/separated_dt/conversation_enqueued'\n", "MSCK REPAIR TABLE sfdl_stage_segment.sms_conversation_enqueued" ] - hive_path: s3://sfdl-segment-sms-stage/separated_dt/conversation_enqueued
- id: 203244
- processed: 1
- raw_data:
{ "_metadata": { "nodeVersion": "8.6.0" }, "_origin": "2019-04-30T20:02:48Z|s3://sfdl-segment-sms-stage/segment-logs/V2tM95dEVw/1556582400000/1556654205058.f38b02cc5633.9f83b95.91047290-20c6-49f4-bb20-9ac850a1df16.gz|segment_separator:37", "channel": "server", "context": { "library": { "name": "unknown", "version": "unknown" } }, "event": "conversation_enqueued", "integrations": { "library": { "name": "analytics-node", "version": "3.2.0" } }, "messageId": "node-onyXhAyONtM49FTihy6cfX6I5OGrQ72S", "originalTimestamp": "2019-04-30T19:36:43.340Z", "projectId": "V2tM95dEVw", "properties": { "conversation_id": "cid.1556653002419.24c978670027891b37", "message_channel": "sms", "phone_number": "4697167190", "sender_handle_id": "selfstorage-com-reservation-reminders" }, "receivedAt": "2019-04-30T19:36:53.365Z", "sentAt": "2019-04-30T19:36:53.090Z", "timestamp": "2019-04-30T19:36:43.615Z", "type": "track", "userId": "4697167190", "version": 2, "writeKey": "iCEzOyc2a3YKXWOsBpNjF2ZlYvfnVCyv" } - schema_attributes:
{ "_origin": "string", "channel": "string", "context.library.name": "string", "context.library.version": "string", "event": "string", "integrations.library.name": "string", "integrations.library.version": "string", "messageId": "string", "originalTimestamp": "string", "projectId": "string", "properties.conversation_id": "string", "properties.message_channel": "string", "properties.phone_number": "string", "properties.sender_handle_id": "string", "receivedAt": "string", "sentAt": "string", "timestamp": "string", "type": "string", "userId": "string", "version": "string", "writeKey": "string" } - schema_name_id: 489
- schema_scan_id: 2085083
- updated: 2019-04-30 15:07:23
-
Version 3712
- created: 2018-04-24 09:24:26
- ddl:
[ "CREATE DATABASE IF NOT EXISTS `sfdl_stage_segment`", "DROP TABLE IF EXISTS `sfdl_stage_segment.sms_conversation_enqueued`", "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_stage_segment.sms_conversation_enqueued`\n(\n `writeKey` string , `timestamp` string , `messageId` string , `userId` string ,`properties` struct< `phone_number` : string , `conversation_id` : string , `sender_handle_id` : string , `message_channel` : string >, `receivedAt` string ,`_metadata` struct< `nodeVersion` : string >, `version` string , `originalTimestamp` string ,`context` struct<`library` : struct< `version` : string , `name` : string >>, `projectId` string , `_origin` string , `type` string , `event` string , `channel` string , `sentAt` 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-segment-sms-stage/separated_dt/conversation_enqueued'\n", "MSCK REPAIR TABLE sfdl_stage_segment.sms_conversation_enqueued" ] - hive_path: s3://sfdl-segment-sms-stage/separated_dt/conversation_enqueued
- id: 3712
- processed: 1
- raw_data:
{ "_metadata": { "nodeVersion": "8.6.0" }, "_origin": "2018-04-24T14:24:22Z|s3://sfdl-segment-sms-stage/segment-logs/V2tM95dEVw/1524528000000/1524579742182.b969765643b4.1.11.1.a15ac936-de2b-4205-91c4-ce2ba3be4309.gz|segment_separator:37", "channel": "server", "context": { "library": { "name": "analytics-node", "version": "3.2.0" } }, "event": "conversation_enqueued", "integrations": {}, "messageId": "node-5grU8oaBZ4n6OzABWvYsi3NyeckfSxIN", "originalTimestamp": "2018-04-24T14:00:09.557Z", "projectId": "V2tM95dEVw", "properties": { "conversation_id": "cid.1524578409061.b108a3f9c745e96f5f", "message_channel": "sms", "phone_number": "6103509476", "sender_handle_id": "default" }, "receivedAt": "2018-04-24T14:00:19.824Z", "sentAt": "2018-04-24T14:00:19.458Z", "timestamp": "2018-04-24T14:00:09.923Z", "type": "track", "userId": "6103509476", "version": 2, "writeKey": "iCEzOyc2a3YKXWOsBpNjF2ZlYvfnVCyv" } - schema_attributes:
{ "_origin": "string", "channel": "string", "context.library.name": "string", "context.library.version": "string", "event": "string", "messageId": "string", "originalTimestamp": "string", "projectId": "string", "properties.conversation_id": "string", "properties.message_channel": "string", "properties.phone_number": "string", "properties.sender_handle_id": "string", "receivedAt": "string", "sentAt": "string", "timestamp": "string", "type": "string", "userId": "string", "version": "string", "writeKey": "string" } - schema_name_id: 489
- schema_scan_id: 254826
- updated: 2018-05-25 15:15:27
-
Version 3646
- created: 2018-04-17 15:03:35
- ddl:
[ "CREATE DATABASE IF NOT EXISTS `sfdl_stage_segment`", "DROP TABLE IF EXISTS `sfdl_stage_segment.sms_conversation_enqueued`", "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_stage_segment.sms_conversation_enqueued`\n(\n `type` string , `timestamp` string , `projectId` string , `userId` string , `event` string , `receivedAt` string ,`_metadata` struct< `nodeVersion` : string >, `version` string , `originalTimestamp` string ,`context` struct<`library` : struct< `version` : string , `name` : string >>, `messageId` string , `writeKey` string , `_origin` string ,`properties` struct< `phone_number` : string , `sender_handle_id` : string , `message_channel` : string >, `channel` string , `sentAt` 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-segment-sms-stage/separated_dt/conversation_enqueued'\n", "MSCK REPAIR TABLE sfdl_stage_segment.sms_conversation_enqueued" ] - hive_path: s3://sfdl-segment-sms-stage/separated_dt/conversation_enqueued
- id: 3646
- processed: 1
- raw_data:
{ "_metadata": { "nodeVersion": "8.6.0" }, "_origin": "2018-04-17T20:03:26Z|s3://sfdl-segment-sms-stage/segment-logs/V2tM95dEVw/1523923200000/1523995272550.6397a3828d1f.1.11.1.4694d3e4-b481-4187-ad83-56854cb47a2a.gz|segment_separator:37", "channel": "server", "context": { "library": { "name": "analytics-node", "version": "3.2.0" } }, "event": "conversation_enqueued", "integrations": {}, "messageId": "node-ijTkODHF4RIfE9Sbxkt52gO23IUMtvDC", "originalTimestamp": "2018-04-17T19:12:12.131Z", "projectId": "V2tM95dEVw", "properties": { "message_channel": "sms", "phone_number": "2817973883", "sender_handle_id": "default" }, "receivedAt": "2018-04-17T19:12:13.351Z", "sentAt": "2018-04-17T19:12:12.132Z", "timestamp": "2018-04-17T19:12:13.350Z", "type": "track", "userId": "2817973883", "version": 2, "writeKey": "iCEzOyc2a3YKXWOsBpNjF2ZlYvfnVCyv" } - schema_attributes:
{ "_origin": "string", "channel": "string", "context.library.name": "string", "context.library.version": "string", "event": "string", "messageId": "string", "originalTimestamp": "string", "projectId": "string", "properties.message_channel": "string", "properties.phone_number": "string", "properties.sender_handle_id": "string", "receivedAt": "string", "sentAt": "string", "timestamp": "string", "type": "string", "userId": "string", "version": "string", "writeKey": "string" } - schema_name_id: 489
- schema_scan_id: 247152
- updated: 2018-04-17 15:03:45
Schema Scans: 3
Last at 2019-04-30 15:06:29
-
Scan 2085083
- duration: 0:00:59.490129
- exit_message:
{ "ddl_changed": true, "ingested_partitions": 336, "partitions_applied": false, "success": true } - id: 2085083
- payload:
{ "datatype_dict": null, "file_format": "json", "partition": { "location": "s3://sfdl-segment-sms-stage/separated_dt/conversation_enqueued/dt=2019-04-30/", "name": "dt", "type": "string", "value": "2019-04-30" }, "s3": { "bucket": "sfdl-segment-sms-stage", "hive_path": "s3://sfdl-segment-sms-stage/separated_dt/conversation_enqueued", "key": "separated_dt/conversation_enqueued/dt=2019-04-30/1556654205058.f38b02cc5633.9f83b95.91047290-20c6-49f4-bb20-9ac850a1df16.json.gz" }, "schema": { "name": "sfdl_stage_segment.sms_conversation_enqueued", "type": "segment" } } - running: False
- schema_name_id: 489
- start_time: 2019-04-30 15:06:29
- success: True
- trace_id: 11510488071673689812
-
Scan 254826
- duration: 0:00:13.760816
- exit_message:
{ "ddl_changed": true, "ingested_partitions": 2, "partitions_applied": false, "success": true } - id: 254826
- payload:
{ "datatype_dict": null, "file_format": "json", "partition": { "location": "s3://sfdl-segment-sms-stage/separated_dt/conversation_enqueued/dt=2018-04-24/", "name": "dt", "type": "string", "value": "2018-04-24" }, "s3": { "bucket": "sfdl-segment-sms-stage", "hive_path": "s3://sfdl-segment-sms-stage/separated_dt/conversation_enqueued", "key": "separated_dt/conversation_enqueued/dt=2018-04-24/1524579742182.b969765643b4.1.11.1.a15ac936-de2b-4205-91c4-ce2ba3be4309.json.gz" }, "schema": { "name": "sfdl_stage_segment.sms_conversation_enqueued", "type": "segment" } } - running: False
- schema_name_id: 489
- start_time: 2018-04-24 09:24:26
- success: True
-
Scan 247152
- duration: 0:00:13.751939
- exit_message:
{ "ddl_changed": true, "ingested_partitions": 1, "partitions_applied": false, "success": true } - id: 247152
- payload:
{ "datatype_dict": null, "file_format": "json", "partition": { "location": "s3://sfdl-segment-sms-stage/separated_dt/conversation_enqueued/dt=2018-04-17/", "name": "dt", "type": "string", "value": "2018-04-17" }, "s3": { "bucket": "sfdl-segment-sms-stage", "hive_path": "s3://sfdl-segment-sms-stage/separated_dt/conversation_enqueued", "key": "separated_dt/conversation_enqueued/dt=2018-04-17/1523995272550.6397a3828d1f.1.11.1.4694d3e4-b481-4187-ad83-56854cb47a2a.json.gz" }, "schema": { "name": "sfdl_stage_segment.sms_conversation_enqueued", "type": "segment" } } - running: False
- schema_name_id: 489
- start_time: 2018-04-17 15:03:35
- success: True
- count: 4
- ddl:
[ "ALTER TABLE\n `sfdl_stage_segment.sms_conversation_enqueued`\nADD\n\n\n PARTITION (dt='2024-12-30') location 's3://sfdl-segment-sms-stage/separated_dt/conversation_enqueued/dt=2024-12-30/'\n PARTITION (dt='2024-12-31') location 's3://sfdl-segment-sms-stage/separated_dt/conversation_enqueued/dt=2024-12-31/'\n PARTITION (dt='2025-01-01') location 's3://sfdl-segment-sms-stage/separated_dt/conversation_enqueued/dt=2025-01-01/'\n PARTITION (dt='2025-01-02') location 's3://sfdl-segment-sms-stage/separated_dt/conversation_enqueued/dt=2025-01-02/'\n;" ] - name: dt
- state:
[ { "info": { "id": 589643, "location": "s3://sfdl-segment-sms-stage/separated_dt/conversation_enqueued/dt=2024-12-30/", "name": "dt", "value": "2024-12-30" }, "state": { "arrival": { "athena_discovery": true, "first_data": "2024-12-29 20:47:55", "last_data": "2024-12-30 12:32:48" }, "parquet": { "first_performed": null, "in_progress": null, "job_id": null, "last_performed": null, "queued": true } } }, { "info": { "id": 589823, "location": "s3://sfdl-segment-sms-stage/separated_dt/conversation_enqueued/dt=2024-12-31/", "name": "dt", "value": "2024-12-31" }, "state": { "arrival": { "athena_discovery": true, "first_data": "2024-12-31 02:33:32", "last_data": "2024-12-31 17:49:26" }, "parquet": { "first_performed": null, "in_progress": null, "job_id": null, "last_performed": null, "queued": true } } }, { "info": { "id": 589977, "location": "s3://sfdl-segment-sms-stage/separated_dt/conversation_enqueued/dt=2025-01-01/", "name": "dt", "value": "2025-01-01" }, "state": { "arrival": { "athena_discovery": true, "first_data": "2024-12-31 19:06:09", "last_data": "2025-01-01 15:18:57" }, "parquet": { "first_performed": null, "in_progress": null, "job_id": null, "last_performed": null, "queued": true } } }, { "info": { "id": 590161, "location": "s3://sfdl-segment-sms-stage/separated_dt/conversation_enqueued/dt=2025-01-02/", "name": "dt", "value": "2025-01-02" }, "state": { "arrival": { "athena_discovery": true, "first_data": "2025-01-02 01:28:31", "last_data": "2025-01-02 13:23:20" }, "parquet": { "first_performed": null, "in_progress": null, "job_id": null, "last_performed": null, "queued": true } } } ] - type: string
- attributes:
{ "_origin": "string", "channel": "string", "context.library.name": "string", "context.library.version": "string", "event": "string", "integrations.library.name": "string", "integrations.library.version": "string", "messageId": "string", "originalTimestamp": "string", "projectId": "string", "properties.conversation_id": "string", "properties.message_channel": "string", "properties.phone_number": "string", "properties.sender_handle_id": "string", "receivedAt": "string", "sentAt": "string", "timestamp": "string", "type": "string", "userId": "string", "version": "string", "writeKey": "string" } - created: 2019-04-30 15:06:29
- ddl:
{ "create_database": "CREATE DATABASE IF NOT EXISTS `sfdl_stage_segment`", "create_table": "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_stage_segment.sms_conversation_enqueued`\n(\n`timestamp`STRING,`userId`STRING,`integrations`struct<`library`:struct<`version`:STRING,`name`:STRING>>,`receivedAt`STRING,`_origin`STRING,`event`STRING,`projectId`STRING,`properties`struct<`phone_number`:STRING,`conversation_id`:STRING,`sender_handle_id`:STRING,`message_channel`:STRING>,`_metadata`struct<`nodeVersion`:STRING>,`version`STRING,`originalTimestamp`STRING,`context`struct<`library`:struct<`version`:STRING,`name`:STRING>>,`messageId`STRING,`writeKey`STRING,`type`STRING,`channel`STRING,`sentAt`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-segment-sms-stage/separated_dt/conversation_enqueued'\n", "drop_table": "DROP TABLE IF EXISTS `sfdl_stage_segment.sms_conversation_enqueued`", "repair_table": "MSCK REPAIR TABLE sfdl_stage_segment.sms_conversation_enqueued" }
- hostname: schemamanager-5c55c886bf-h2ts4
- name: schema_manager
- process_start: 2025-10-21 13:03:27
- sf_env: stage
- version: 2112174301
{
"name": {
"created": "2018-04-17 15:03:35",
"disabled": false,
"format": "raw",
"id": 489,
"is_partitioned": true,
"is_schema_datatyped": false,
"name": {
"database": "sfdl_stage_segment",
"table": "sms_conversation_enqueued"
},
"type": "segment"
},
"partition": {
"count": 4,
"ddl": [
"ALTER TABLE\n `sfdl_stage_segment.sms_conversation_enqueued`\nADD\n\n\n PARTITION (dt='2024-12-30') location 's3://sfdl-segment-sms-stage/separated_dt/conversation_enqueued/dt=2024-12-30/'\n PARTITION (dt='2024-12-31') location 's3://sfdl-segment-sms-stage/separated_dt/conversation_enqueued/dt=2024-12-31/'\n PARTITION (dt='2025-01-01') location 's3://sfdl-segment-sms-stage/separated_dt/conversation_enqueued/dt=2025-01-01/'\n PARTITION (dt='2025-01-02') location 's3://sfdl-segment-sms-stage/separated_dt/conversation_enqueued/dt=2025-01-02/'\n;"
],
"name": "dt",
"state": [
{
"info": {
"id": 589643,
"location": "s3://sfdl-segment-sms-stage/separated_dt/conversation_enqueued/dt=2024-12-30/",
"name": "dt",
"value": "2024-12-30"
},
"state": {
"arrival": {
"athena_discovery": true,
"first_data": "2024-12-29 20:47:55",
"last_data": "2024-12-30 12:32:48"
},
"parquet": {
"first_performed": null,
"in_progress": null,
"job_id": null,
"last_performed": null,
"queued": true
}
}
},
{
"info": {
"id": 589823,
"location": "s3://sfdl-segment-sms-stage/separated_dt/conversation_enqueued/dt=2024-12-31/",
"name": "dt",
"value": "2024-12-31"
},
"state": {
"arrival": {
"athena_discovery": true,
"first_data": "2024-12-31 02:33:32",
"last_data": "2024-12-31 17:49:26"
},
"parquet": {
"first_performed": null,
"in_progress": null,
"job_id": null,
"last_performed": null,
"queued": true
}
}
},
{
"info": {
"id": 589977,
"location": "s3://sfdl-segment-sms-stage/separated_dt/conversation_enqueued/dt=2025-01-01/",
"name": "dt",
"value": "2025-01-01"
},
"state": {
"arrival": {
"athena_discovery": true,
"first_data": "2024-12-31 19:06:09",
"last_data": "2025-01-01 15:18:57"
},
"parquet": {
"first_performed": null,
"in_progress": null,
"job_id": null,
"last_performed": null,
"queued": true
}
}
},
{
"info": {
"id": 590161,
"location": "s3://sfdl-segment-sms-stage/separated_dt/conversation_enqueued/dt=2025-01-02/",
"name": "dt",
"value": "2025-01-02"
},
"state": {
"arrival": {
"athena_discovery": true,
"first_data": "2025-01-02 01:28:31",
"last_data": "2025-01-02 13:23:20"
},
"parquet": {
"first_performed": null,
"in_progress": null,
"job_id": null,
"last_performed": null,
"queued": true
}
}
}
],
"type": "string"
},
"schema": {
"attributes": {
"_origin": "string",
"channel": "string",
"context.library.name": "string",
"context.library.version": "string",
"event": "string",
"integrations.library.name": "string",
"integrations.library.version": "string",
"messageId": "string",
"originalTimestamp": "string",
"projectId": "string",
"properties.conversation_id": "string",
"properties.message_channel": "string",
"properties.phone_number": "string",
"properties.sender_handle_id": "string",
"receivedAt": "string",
"sentAt": "string",
"timestamp": "string",
"type": "string",
"userId": "string",
"version": "string",
"writeKey": "string"
},
"created": "2019-04-30 15:06:29",
"ddl": {
"create_database": "CREATE DATABASE IF NOT EXISTS `sfdl_stage_segment`",
"create_table": "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_stage_segment.sms_conversation_enqueued`\n(\n`timestamp`STRING,`userId`STRING,`integrations`struct<`library`:struct<`version`:STRING,`name`:STRING>>,`receivedAt`STRING,`_origin`STRING,`event`STRING,`projectId`STRING,`properties`struct<`phone_number`:STRING,`conversation_id`:STRING,`sender_handle_id`:STRING,`message_channel`:STRING>,`_metadata`struct<`nodeVersion`:STRING>,`version`STRING,`originalTimestamp`STRING,`context`struct<`library`:struct<`version`:STRING,`name`:STRING>>,`messageId`STRING,`writeKey`STRING,`type`STRING,`channel`STRING,`sentAt`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-segment-sms-stage/separated_dt/conversation_enqueued'\n",
"drop_table": "DROP TABLE IF EXISTS `sfdl_stage_segment.sms_conversation_enqueued`",
"repair_table": "MSCK REPAIR TABLE sfdl_stage_segment.sms_conversation_enqueued"
}
},
"server": {
"hostname": "schemamanager-5c55c886bf-h2ts4",
"name": "schema_manager",
"process_start": "2025-10-21 13:03:27",
"sf_env": "stage",
"version": "2112174301"
}
}