francoisa
03/31/2022, 12:54 PM"ingestionConfig": {
"transformConfigs": [
{
"columnName": "type",
"transformFunction": "JSONPATHSTRING(data,'$.type')"
}
],
"complexTypeConfig": {
"fieldsToUnnest": [
"data.attributes.actualExpenses"
],
"delimiter": "."
}
},
Schema is already defined with type STRINGMark Needham
.type
from data
francoisa
03/31/2022, 3:02 PMMark Needham
francoisa
03/31/2022, 3:04 PMMark Needham
"ingestionConfig": {
"transformConfigs": [
{
"columnName": "type",
"transformFunction": "\"data.type\""
}
],
"complexTypeConfig": {
"fieldsToUnnest": [
"data.attributes.actualExpenses"
],
"delimiter": "."
}
},
francoisa
03/31/2022, 3:08 PMMark Needham
francoisa
03/31/2022, 3:10 PMSelect * from mytable
Perfect it works
Select "mycol.otherName" from my table
Throws
[
{
"message": "UnknownColumnError:\norg.apache.pinot.spi.exception.BadQueryRequestException: Unknown columnName 'actualExpenses.activityType' found in the query\n\tat org.apache.pinot.broker.requesthandler.BaseBrokerRequestHandler.getActualColumnName(BaseBrokerRequestHandler.java:1604)\n\tat org.apache.pinot.broker.requesthandler.BaseBrokerRequestHandler.fixColumnName(BaseBrokerRequestHandler.java:1538)\n\tat org.apache.pinot.broker.requesthandler.BaseBrokerRequestHandler.updateColumnNames(BaseBrokerRequestHandler.java:1421)\n\tat org.apache.pinot.broker.requesthandler.BaseBrokerRequestHandler.handleSQLRequest(BaseBrokerRequestHandler.java:254)",
"errorCode": 710
}
]
Mark Needham
francoisa
03/31/2022, 3:52 PMMark Needham
francoisa
03/31/2022, 4:00 PMMark Needham
francoisa
03/31/2022, 4:01 PMMark Needham
Mayank
francoisa
03/31/2022, 6:21 PMMayank
francoisa
03/31/2022, 7:31 PMMayank
Jackie
03/31/2022, 10:11 PMselect *
query? Want to make sure the column name matchesfrancoisa
04/01/2022, 6:57 AMMayank
Jackie
04/01/2022, 6:30 PMfrancoisa
04/01/2022, 8:09 PM