amazon-redshift

0热度

1回答

我试图根据两个标准将MIN/MAX应用于我的SELECT子句。（见下文）。当我尝试在另一个查询中引用我的列submitted_at时，它说列引用不明确。 MIN(CASE WHEN (document != 'dphoto' AND document_type != 'dlicenses' AND status = 'upload') THEN occurred_at END) AS subm

0热度

1回答

并不在红移出于某种原因

假设下面的SQL工作表中的查询： CREATE TABLE test_data ( field1 varchar(50), field2 varchar(50), counter int NOT NULL DEFAULT 0 ) 和下面的数据： INSERT INTO test_data (field1, field2, counter) VALUES ('10','zyx',10);

0热度

2回答

需要创建一个在日期前填写值的表格

使用红移。我有一个具有以下字段的表： Column: Type: department | varchar employee_ID | varchar event | varchar date | date 和只是有一个字段，并列出所有日期的日期表。每个部门都有几个部门有员工。 “事件”字段有两个可能的值：JOIN或LEAVE。加入记录是他们加入公司/部门的日

2热度

1回答

Amazon Redshift可以自动进入Kinesis Firehose吗？

我希望Amazon Redshift将任何插入到Amazon Kinesis Firehose中的新行插入到将用Lambda函数转换数据的Amazon Kinesis Firehose中。可以这样做吗？如果是这样，你能指点我一个例子和文档吗？

0热度

2回答

在Redshift中按类别选择n最大计数

我想选择表格中每个组的X个最常见的配对。让我们在下表中考虑： +-------------+-----------+ | identifier | city | +-------------+-----------+ | AB | Seattle | | AC | Seattle | | AC | Seattle | | AB | Seattle | | AD

2热度

2回答

我可以从数据库中的另一列中读取间隔值吗？

我有一个表格，其中的天数为(custid,purchase_timestamp (dd-mm-yyyy), warranty_period)。我需要purchase_time和warranty_period的总和。我可以如何为此编写SQL。我试图 SELECT DATE_SUB(purchase_timestamp, INTERVAL warranty_period DAY); ，但它不工作

0热度

2回答

是否有可能在DataFrame写入时检索文件列表，或者是否有火花将其存储在某个地方？

随着像 df.write.csv("s3a://mybucket/mytable")df.write.csv("s3a://mybucket/mytable") 我很明白知道哪里写文件/对象，但由于S3的最终一致性保证，我不能100％确定从该位置获取列表将返回所有（甚至是任何）刚刚写入的文件。如果我能得到刚才写的文件/对象列表，那么我可以为Redshift COPY命令准备一个清单文件，而不用担心

0热度

3回答

SQL：如何根据条件使用先前行值填充空单元格？

SQL：根据条件填充具有上一行值的空单元格？请将此作为高优先级Request..help需要请求它（http://i.imgur.com/P4UOiMz.jpg）我需要使用SQL生成列“OXY_ID_NEW”下表中的高代表用户链接。这是可能的SQL 2008R2或SQL 2012或亚马逊REDSHIFT？ SQL表图像（http://i.imgur.com/P4UOiMz.jpg）基本上，

1热度

2回答

如何从定制REST API将数据加载到Redshift中

我是AWS的新手，如果以前提出过这个问题，请原谅我。我有一个REST API，它返回2个参数（名称，电子邮件）。我想将这些数据加载到Redshift中。我想制作一个每2分钟启动一次Lambda函数并调用REST API。该API可能会在此2分钟内返回最多3-4条记录。因此，在这种情况下可以只做一个插入操作，或者我仍然需要使用COPY（使用S3）？我只关心性能和无差错（健壮）的数据插入。此外

1热度

2回答

Redshift能够优化重复聚合表达式吗？

比方说，我有以下查询： SELECT sum(a), sum(b), sum(a) - sum(b) FROM salelines 希望它应该只需要做sum(a)和sum(b)曾经因为第三栏可以重用这些聚集。这里是EXPLAIN： XN HashAggregate (cost=35.21..41.90 rows=535 width=22) -> XN Seq Scan on sal