我在AWSS3中建立了一个数据湖,并使用athena在其中创建了一个表。这是你的答案 CREATE TABLE
我使用的语句:
CREATE EXTERNAL TABLE `controllers`(
`commandkey` varchar(40),
`commandvalue` varchar(5),
`container` varchar(15),
`containername` varchar(15),
`controllerid` varchar(5),
`cpupercent` float,
`deviceid` varchar(5),
`diskpercent` float,
`epoch` timestamp,
`error` map<varchar(20),array<varchar(10)>>,
`errorvalue` map<varchar(15),varchar(20)>,
`exceptioninfo` varchar(50),
`exceptionname` varchar(8),
`funcname` varchar(20),
`jouleboxcontrollerid` varchar(5),
`key` varchar(40),
`level` varchar(8),
`linenumber` varchar(5),
`linkquality` float,
`logtype` varchar(20),
`memorypercent` float,
`mode` varchar(10),
`module` varchar(20),
`networkstrength` float,
`param` varchar(15),
`rc` int,
`requesttopic` varchar(50),
`response` varchar(5),
`responsetopic` varchar(50),
`restarttime` timestamp,
`rid` varchar(15),
`shifttype` char(1),
`siteid` varchar(8),
`source` varchar(15),
`startedat` timestamp,
`status` varchar(5),
`topic` varchar(50),
`ts` timestamp,
`type` varchar(15),
`val` varchar(20),
`value` varchar(5))
ROW FORMAT SERDE
'org.apache.hadoop.hive.ql.io.parquet.serde.ParquetHiveSerDe'
STORED AS INPUTFORMAT
'org.apache.hadoop.hive.ql.io.parquet.MapredParquetInputFormat'
OUTPUTFORMAT
'org.apache.hadoop.hive.ql.io.parquet.MapredParquetOutputFormat'
LOCATION
's3://controller-logs.smartjoules.org/raw'
TBLPROPERTIES (
'classification'='PARQUET'
)
每当我尝试使用where子句运行简单的select查询时,例如:
SELECT AVG(networkstrength)
FROM controllers
WHERE deviceid="123"
它无法抛出错误: SYNTAX_ERROR: line 2:21: Column '123' cannot be resolved
我不确定这是不是因为 CREATE TABLE
语句或数据输入/存储或完全不同的东西。
2条答案
按热度按时间6qfn3psc1#
在字符串周围加上“使它认为您引用的是列名而不是文本值。用'作为你的字符串
xtfmy6hx2#
查询语法有问题。引用字符串值时使用单引号,因为双引号引用表中的列名