Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
dgr6878
TDengine
提交
01062e66
T
TDengine
项目概览
dgr6878
/
TDengine
与 Fork 源项目一致
Fork自
taosdata / TDengine
通知
8
Star
0
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
T
TDengine
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
体验新版 GitCode,发现更多精彩内容 >>
提交
01062e66
编写于
8月 14, 2019
作者:
F
fang
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
upload code for cassandra/tdengine test
上级
7506b1b7
变更
9
显示空白变更内容
内联
并排
Showing
9 changed file
with
532 addition
and
0 deletion
+532
-0
tests/comparisonTest/cassandra/application.conf
tests/comparisonTest/cassandra/application.conf
+5
-0
tests/comparisonTest/cassandra/cassandratest/pom.xml
tests/comparisonTest/cassandra/cassandratest/pom.xml
+131
-0
tests/comparisonTest/cassandra/cassandratest/src/main/java/com/cassandra/test/CassandraTest.java
...atest/src/main/java/com/cassandra/test/CassandraTest.java
+200
-0
tests/comparisonTest/cassandra/cassandratest/src/main/java/com/cassandra/test/WriteThread.java
...dratest/src/main/java/com/cassandra/test/WriteThread.java
+99
-0
tests/comparisonTest/cassandra/cqlstr
tests/comparisonTest/cassandra/cqlstr
+16
-0
tests/comparisonTest/cassandra/q1.txt
tests/comparisonTest/cassandra/q1.txt
+11
-0
tests/comparisonTest/cassandra/q2.txt
tests/comparisonTest/cassandra/q2.txt
+50
-0
tests/comparisonTest/cassandra/q3.txt
tests/comparisonTest/cassandra/q3.txt
+10
-0
tests/comparisonTest/cassandra/q4.txt
tests/comparisonTest/cassandra/q4.txt
+10
-0
未找到文件。
tests/comparisonTest/cassandra/application.conf
0 → 100644
浏览文件 @
01062e66
datastax
-
java
-
driver
{
basic
.
request
{
timeout
=
200000
seconds
}
}
tests/comparisonTest/cassandra/cassandratest/pom.xml
0 → 100644
浏览文件 @
01062e66
<?xml version="1.0" encoding="UTF-8"?>
<project
xmlns=
"http://maven.apache.org/POM/4.0.0"
xmlns:xsi=
"http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation=
"http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"
>
<modelVersion>
4.0.0
</modelVersion>
<groupId>
com.cassandra.test
</groupId>
<artifactId>
cassandratest
</artifactId>
<version>
1.0-SNAPSHOT
</version>
<packaging>
jar
</packaging>
<build>
<pluginManagement>
<plugins>
<plugin>
<groupId>
org.apache.maven.plugins
</groupId>
<artifactId>
maven-plugins
</artifactId>
<version>
30
</version>
</plugin>
<plugin>
<groupId>
org.apache.maven.plugins
</groupId>
<artifactId>
maven-assembly-plugin
</artifactId>
<version>
3.0.0
</version>
</plugin>
</plugins>
</pluginManagement>
<plugins>
<plugin>
<groupId>
org.apache.maven.plugins
</groupId>
<artifactId>
maven-assembly-plugin
</artifactId>
<version>
3.1.0
</version>
<configuration>
<archive>
<manifest>
<mainClass>
CassandraTest
</mainClass>
</manifest>
</archive>
<descriptorRefs>
<descriptorRef>
jar-with-dependencies
</descriptorRef>
</descriptorRefs>
</configuration>
<executions>
<execution>
<id>
make-assembly
</id>
<phase>
package
</phase>
<goals>
<goal>
single
</goal>
</goals>
</execution>
</executions>
</plugin>
<plugin>
<groupId>
org.apache.maven.plugins
</groupId>
<artifactId>
maven-compiler-plugin
</artifactId>
<version>
2.3.2
</version>
<configuration>
<source>
8
</source>
<target>
8
</target>
</configuration>
</plugin>
</plugins>
</build>
<name>
cassandratest
</name>
<!-- FIXME change it to the project's website -->
<url>
http://www.example.com
</url>
<properties>
<project.build.sourceEncoding>
UTF-8
</project.build.sourceEncoding>
<maven.compiler.source>
1.8
</maven.compiler.source>
<maven.compiler.target>
1.8
</maven.compiler.target>
</properties>
<dependencies>
<dependency>
<groupId>
junit
</groupId>
<artifactId>
junit
</artifactId>
<version>
4.11
</version>
<scope>
test
</scope>
</dependency>
<dependency>
<groupId>
com.datastax.oss
</groupId>
<artifactId>
java-driver-core
</artifactId>
<version>
4.1.0
</version>
</dependency>
<dependency>
<groupId>
com.datastax.oss
</groupId>
<artifactId>
java-driver-query-builder
</artifactId>
<version>
4.1.0
</version>
</dependency>
<dependency>
<groupId>
com.datastax.oss
</groupId>
<artifactId>
java-driver-mapper-runtime
</artifactId>
<version>
4.1.0
</version>
</dependency>
<dependency>
<groupId>
commons-io
</groupId>
<artifactId>
commons-io
</artifactId>
<version>
2.4
</version>
</dependency>
<dependency>
<groupId>
org.apache.commons
</groupId>
<artifactId>
commons-lang3
</artifactId>
<version>
3.7
</version>
</dependency>
<dependency>
<groupId>
org.slf4j
</groupId>
<artifactId>
slf4j-api
</artifactId>
<version>
1.7.5
</version>
</dependency>
<dependency>
<groupId>
org.slf4j
</groupId>
<artifactId>
slf4j-log4j12
</artifactId>
<version>
1.7.5
</version>
</dependency>
<dependency>
<groupId>
org.apache.logging.log4j
</groupId>
<artifactId>
log4j-1.2-api
</artifactId>
<version>
2.8.2
</version>
</dependency>
</dependencies>
</project>
tests/comparisonTest/cassandra/cassandratest/src/main/java/com/cassandra/test/CassandraTest.java
0 → 100644
浏览文件 @
01062e66
import
com.datastax.oss.driver.api.core.CqlSession
;
import
com.datastax.oss.driver.api.core.cql.*
;
import
com.datastax.oss.driver.api.core.session.*
;
import
com.datastax.oss.driver.api.core.config.*
;
import
com.datastax.oss.driver.api.core.cql.ResultSet
;
import
com.datastax.oss.driver.api.core.cql.Row
;
//import com.datastax.driver.core.Cluster;
//import com.datastax.driver.core.Cluster;
import
java.io.BufferedWriter
;
import
java.io.BufferedReader
;
import
java.io.File
;
import
java.io.FileNotFoundException
;
import
java.io.FileWriter
;
import
java.io.FileReader
;
import
java.io.IOException
;
import
java.text.DecimalFormat
;
import
java.util.Random
;
import
java.math.*
;
import
java.lang.reflect.Method
;
public
class
CassandraTest
{
public
static
void
main
(
String
args
[])
{
// begin to parse argument
String
datadir
=
"/home/ubuntu/testdata"
;
String
sqlfile
=
"/home/ubuntu/fang/cassandra/q1.txt"
;
String
cfgfile
=
"/home/ubuntu/fang/cassandra/application.conf"
;
boolean
q4flag
=
false
;
int
numOfRows
=
1000000
;
int
numOfFiles
=
0
;
int
numOfClients
=
0
;
int
rowsPerRequest
=
0
;
for
(
int
i
=
0
;
i
<
args
.
length
;
++
i
)
{
if
(
args
[
i
].
equalsIgnoreCase
(
"-dataDir"
))
{
if
(
i
<
args
.
length
-
1
)
{
datadir
=
args
[++
i
];
}
}
else
if
(
args
[
i
].
equalsIgnoreCase
(
"-numofFiles"
))
{
if
(
i
<
args
.
length
-
1
)
{
numOfFiles
=
Integer
.
parseInt
(
args
[++
i
]);
}
}
else
if
(
args
[
i
].
equalsIgnoreCase
(
"-rowsPerRequest"
))
{
if
(
i
<
args
.
length
-
1
)
{
rowsPerRequest
=
Integer
.
parseInt
(
args
[++
i
]);
}
}
else
if
(
args
[
i
].
equalsIgnoreCase
(
"-writeClients"
))
{
if
(
i
<
args
.
length
-
1
)
{
numOfClients
=
Integer
.
parseInt
(
args
[++
i
]);
}
}
else
if
(
args
[
i
].
equalsIgnoreCase
(
"-sql"
))
{
sqlfile
=
args
[++
i
];
}
else
if
(
args
[
i
].
equalsIgnoreCase
(
"-timetest"
))
{
q4flag
=
true
;
}
else
if
(
args
[
i
].
equalsIgnoreCase
(
"-conf"
))
{
cfgfile
=
args
[++
i
];
}
}
// file below to make sure no timeout error
File
confile
=
new
File
(
cfgfile
);
System
.
out
.
println
(
"parameters\n"
);
if
(
numOfFiles
>
0
)
{
// write data
System
.
out
.
printf
(
"----dataDir:%s\n"
,
datadir
);
System
.
out
.
printf
(
"----numOfFiles:%d\n"
,
numOfFiles
);
System
.
out
.
printf
(
"----numOfClients:%d\n"
,
numOfClients
);
System
.
out
.
printf
(
"----rowsPerRequest:%d\n"
,
rowsPerRequest
);
// connect to cassandra server
System
.
out
.
printf
(
"----connecting to cassandra server\n"
);
try
{
CqlSession
session
=
CqlSession
.
builder
()
.
withConfigLoader
(
DriverConfigLoader
.
fromFile
(
confile
))
.
build
();
session
.
execute
(
"drop keyspace if exists cassandra"
);
session
.
execute
(
"CREATE KEYSPACE if not exists cassandra WITH replication = {'class':'SimpleStrategy', 'replication_factor':1}"
);
if
(
q4flag
)
{
session
.
execute
(
"create table if not exists cassandra.test (devid int, devname text, devgroup int, ts bigint, minute bigint, temperature int, humidity float ,primary key (minute,ts,devgroup,devid,devname))"
);
}
else
{
session
.
execute
(
"create table if not exists cassandra.test (devid int, devname text, devgroup int, ts bigint, temperature int, humidity float ,primary key (devgroup,devid,devname,ts))"
);
}
session
.
close
();
System
.
out
.
printf
(
"----created keyspace cassandra and table test\n"
);
// begin to insert data
System
.
out
.
printf
(
"----begin to insert data\n"
);
long
startTime
=
System
.
currentTimeMillis
();
int
a
=
numOfFiles
/
numOfClients
;
int
b
=
numOfFiles
%
numOfClients
;
int
last
=
0
;
WriteThread
[]
writethreads
=
new
WriteThread
[
numOfClients
];
int
[]
wargs
=
new
int
[
2
];
// data file start, end
wargs
[
0
]
=
numOfRows
;
//rows to be read from each file
wargs
[
1
]
=
rowsPerRequest
;
int
fstart
=
0
;
int
fend
=
0
;
for
(
int
i
=
0
;
i
<
numOfClients
;
++
i
)
{
if
(
i
<
b
)
{
fstart
=
last
;
fend
=
last
+
a
;
last
=
last
+
a
+
1
;
writethreads
[
i
]
=
new
WriteThread
(
fstart
,
fend
,
wargs
,
datadir
,
q4flag
);
System
.
out
.
printf
(
"----Thread %d begin to write\n"
,
i
);
writethreads
[
i
].
start
();
}
else
{
fstart
=
last
;
fend
=
last
+
a
-
1
;
last
=
last
+
a
;
writethreads
[
i
]
=
new
WriteThread
(
fstart
,
fend
,
wargs
,
datadir
,
q4flag
);
System
.
out
.
printf
(
"----Thread %d begin to write\n"
,
i
);
writethreads
[
i
].
start
();
}
}
for
(
int
i
=
0
;
i
<
numOfClients
;
++
i
)
{
try
{
writethreads
[
i
].
join
();
}
catch
(
InterruptedException
e
)
{
e
.
printStackTrace
();
}
}
long
stopTime
=
System
.
currentTimeMillis
();
float
elapseTime
=
stopTime
-
startTime
;
elapseTime
=
elapseTime
/
1000
;
float
speeds
=
numOfRows
*
numOfFiles
/
elapseTime
;
System
.
out
.
printf
(
"---- insertation speed: %f Rows/Second\n"
,
speeds
);
}
catch
(
Exception
ex
)
{
ex
.
printStackTrace
();
System
.
exit
(
1
);
}
finally
{
System
.
out
.
printf
(
"---- insertion end\n"
);
}
// above:write part; below: read part;
}
else
{
// query data begin
System
.
out
.
printf
(
"----sql command file:%s\n"
,
sqlfile
);
// connect to cassandra server
try
{
CqlSession
session
=
CqlSession
.
builder
()
.
withConfigLoader
(
DriverConfigLoader
.
fromFile
(
confile
))
.
build
();
//session.execute("use cassandra;");
BufferedReader
br
=
null
;
String
line
=
""
;
try
{
br
=
new
BufferedReader
(
new
FileReader
(
sqlfile
));
while
((
line
=
br
.
readLine
())
!=
null
&&
line
.
length
()>
10
)
{
long
startTime
=
System
.
currentTimeMillis
();
// begin to query one line command //
// end querying one line command
try
{
ResultSet
results
=
session
.
execute
(
line
);
long
icounter
=
0
;
for
(
Row
row
:
results
)
{
icounter
++;
}
long
stopTime
=
System
.
currentTimeMillis
();
float
elapseTime
=
stopTime
-
startTime
;
elapseTime
=
elapseTime
/
1000
;
System
.
out
.
printf
(
"----spend %f seconds to query: %s\n"
,
elapseTime
,
line
);
}
catch
(
Exception
ex
)
{
ex
.
printStackTrace
();
System
.
out
.
printf
(
"---- query failed!\n"
);
System
.
exit
(
1
);
}
}
}
catch
(
FileNotFoundException
e
)
{
e
.
printStackTrace
();
}
catch
(
IOException
e
)
{
e
.
printStackTrace
();
}
finally
{
if
(
br
!=
null
)
{
try
{
br
.
close
();
}
catch
(
IOException
e
)
{
e
.
printStackTrace
();
}
}
session
.
close
();
}
}
catch
(
Exception
ex
)
{
ex
.
printStackTrace
();
}
finally
{
System
.
out
.
println
(
"query end:----\n"
);
}
}
// end write or query
System
.
exit
(
0
);
}
// end main
}
// end class
tests/comparisonTest/cassandra/cassandratest/src/main/java/com/cassandra/test/WriteThread.java
0 → 100644
浏览文件 @
01062e66
import
java.io.BufferedReader
;
import
java.io.FileNotFoundException
;
import
java.io.FileReader
;
import
java.io.IOException
;
import
java.math.*
;
import
com.datastax.oss.driver.api.core.CqlSession
;
import
com.datastax.oss.driver.api.core.cql.*
;
import
com.datastax.oss.driver.api.core.session.*
;
import
com.datastax.oss.driver.api.core.config.*
;
public
class
WriteThread
extends
Thread
{
private
int
[]
wargs
;
// fstart, fend, rows to be read, rows perrequest
private
String
fdir
;
private
int
fstart
;
private
int
fend
;
private
boolean
q4flag
;
public
WriteThread
(
int
fstart
,
int
fend
,
int
[]
wargs
,
String
fdir
,
boolean
q4flag
)
{
this
.
fstart
=
fstart
;
this
.
fend
=
fend
;
this
.
fdir
=
fdir
;
this
.
wargs
=
wargs
;
this
.
q4flag
=
q4flag
;
}
// begin to insert in this thread
public
void
run
()
{
/*
// this configuration file makes sure no timeout error
File confile = new File("/home/ubuntu/fang/cassandra/application.conf");
*/
// connect to server
try
{
CqlSession
session
=
CqlSession
.
builder
()
//.withConfigLoader(DriverConfigLoader.fromFile(confile))
.
build
();
//session.execute("use cassandra");
int
tominute
=
6000
;
for
(
int
i
=
fstart
;
i
<=
fend
;
i
++)
{
String
csvfile
;
csvfile
=
fdir
+
"/testdata"
+
Integer
.
toString
(
i
)+
".csv"
;
BufferedReader
br
=
null
;
String
line
=
""
;
String
cvsSplitBy
=
" "
;
try
{
br
=
new
BufferedReader
(
new
FileReader
(
csvfile
));
System
.
out
.
println
(
"---- begin to read file "
+
csvfile
+
"\n"
);
for
(
int
itotalrow
=
0
;
itotalrow
<
wargs
[
0
];
itotalrow
=
itotalrow
+
wargs
[
1
])
{
String
cqlstr
=
"BEGIN BATCH "
;
for
(
int
irow
=
0
;
irow
<
wargs
[
1
];
++
irow
)
{
line
=
br
.
readLine
();
if
(
line
!=
null
)
{
String
[]
meter
=
line
.
split
(
cvsSplitBy
);
BigInteger
tminute
=
new
BigInteger
(
meter
[
3
]);
tminute
=
tminute
.
divide
(
BigInteger
.
valueOf
(
tominute
));
if
(
q4flag
)
{
cqlstr
=
cqlstr
+
"insert into cassandra.test (devid,devname,devgroup,ts, minute,temperature,humidity) values "
;
cqlstr
=
cqlstr
+
"("
+
meter
[
0
]
+
","
+
"'"
+
meter
[
1
]
+
"'"
+
","
+
meter
[
2
]
+
","
+
meter
[
3
]
+
","
;
cqlstr
=
cqlstr
+
tminute
.
toString
()
+
","
+
meter
[
4
]
+
","
+
meter
[
5
]
+
");"
;
}
else
{
cqlstr
=
cqlstr
+
"insert into cassandra.test (devid,devname,devgroup,ts,temperature,humidity) values "
;
cqlstr
=
cqlstr
+
"("
+
meter
[
0
]
+
","
+
"'"
+
meter
[
1
]
+
"'"
+
","
+
meter
[
2
]
+
","
+
meter
[
3
]
+
","
;
cqlstr
=
cqlstr
+
meter
[
4
]
+
","
+
meter
[
5
]
+
");"
;
}
}
// if this line is not null
}
//end row iteration in one batch
cqlstr
=
cqlstr
+
" APPLY BATCH;"
;
try
{
//System.out.println(cqlstr+"----\n");
session
.
execute
(
cqlstr
);
}
catch
(
Exception
ex
)
{
ex
.
printStackTrace
();
}
}
// end one file reading
}
catch
(
FileNotFoundException
e
)
{
e
.
printStackTrace
();
}
catch
(
IOException
e
)
{
e
.
printStackTrace
();
}
finally
{
if
(
br
!=
null
)
{
try
{
br
.
close
();
}
catch
(
IOException
e
)
{
e
.
printStackTrace
();
}
}
}
}
//end file iteration
session
.
close
();
}
catch
(
Exception
ex
)
{
ex
.
printStackTrace
();
}
}
//end run
}
//end class
tests/comparisonTest/cassandra/cqlstr
0 → 100644
浏览文件 @
01062e66
drop keyspace if exists cassandra;
CREATE KEYSPACE cassandra WITH replication = {'class':'SimpleStrategy', 'replication_factor':1};
USE cassandra;
create table test (devid int, devname text, devgroup int, ts bigint, minute bigint, temperature int, humidity float,primary key (ts, devgroup, minute));
insert into test (devid,devname,devgroup,ts, minute,temperature,humidity) values (1, 'dev_1', 1,120000,1,1,1.2);
create function tominute (ts bigint) returns null on null input returns bigint language java as $$ return ts/6000; $$;
select * from test where devgroup<1 allow filtering;
##############################################################
!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
change primary key, can't be same;
tests/comparisonTest/cassandra/q1.txt
0 → 100644
浏览文件 @
01062e66
select * from cassandra.test where devgroup=0 allow filtering;
select * from cassandra.test where devgroup=10 allow filtering;
select * from cassandra.test where devgroup=20 allow filtering;
select * from cassandra.test where devgroup=30 allow filtering;
select * from cassandra.test where devgroup=40 allow filtering;
select * from cassandra.test where devgroup=50 allow filtering;
select * from cassandra.test where devgroup=60 allow filtering;
select * from cassandra.test where devgroup=70 allow filtering;
select * from cassandra.test where devgroup=80 allow filtering;
select * from cassandra.test where devgroup=90 allow filtering;
tests/comparisonTest/cassandra/q2.txt
0 → 100644
浏览文件 @
01062e66
select count(*) from cassandra.test where devgroup<10 allow filtering;
select count(*) from cassandra.test where devgroup<20 allow filtering;
select count(*) from cassandra.test where devgroup<30 allow filtering;
select count(*) from cassandra.test where devgroup<40 allow filtering;
select count(*) from cassandra.test where devgroup<50 allow filtering;
select count(*) from cassandra.test where devgroup<60 allow filtering;
select count(*) from cassandra.test where devgroup<70 allow filtering;
select count(*) from cassandra.test where devgroup<80 allow filtering;
select count(*) from cassandra.test where devgroup<90 allow filtering;
select count(*) from cassandra.test allow filtering;
select avg(temperature) from cassandra.test where devgroup<10 allow filtering;
select avg(temperature) from cassandra.test where devgroup<20 allow filtering;
select avg(temperature) from cassandra.test where devgroup<30 allow filtering;
select avg(temperature) from cassandra.test where devgroup<40 allow filtering;
select avg(temperature) from cassandra.test where devgroup<50 allow filtering;
select avg(temperature) from cassandra.test where devgroup<60 allow filtering;
select avg(temperature) from cassandra.test where devgroup<70 allow filtering;
select avg(temperature) from cassandra.test where devgroup<80 allow filtering;
select avg(temperature) from cassandra.test where devgroup<90 allow filtering;
select avg(temperature) from cassandra.test allow filtering;
select sum(temperature) from cassandra.test where devgroup<10 allow filtering;
select sum(temperature) from cassandra.test where devgroup<20 allow filtering;
select sum(temperature) from cassandra.test where devgroup<30 allow filtering;
select sum(temperature) from cassandra.test where devgroup<40 allow filtering;
select sum(temperature) from cassandra.test where devgroup<50 allow filtering;
select sum(temperature) from cassandra.test where devgroup<60 allow filtering;
select sum(temperature) from cassandra.test where devgroup<70 allow filtering;
select sum(temperature) from cassandra.test where devgroup<80 allow filtering;
select sum(temperature) from cassandra.test where devgroup<90 allow filtering;
select sum(temperature) from cassandra.test allow filtering;
select max(temperature) from cassandra.test where devgroup<10 allow filtering;
select max(temperature) from cassandra.test where devgroup<20 allow filtering;
select max(temperature) from cassandra.test where devgroup<30 allow filtering;
select max(temperature) from cassandra.test where devgroup<40 allow filtering;
select max(temperature) from cassandra.test where devgroup<50 allow filtering;
select max(temperature) from cassandra.test where devgroup<60 allow filtering;
select max(temperature) from cassandra.test where devgroup<70 allow filtering;
select max(temperature) from cassandra.test where devgroup<80 allow filtering;
select max(temperature) from cassandra.test where devgroup<90 allow filtering;
select max(temperature) from cassandra.test allow filtering;
select min(temperature) from cassandra.test where devgroup<10 allow filtering;
select min(temperature) from cassandra.test where devgroup<20 allow filtering;
select min(temperature) from cassandra.test where devgroup<30 allow filtering;
select min(temperature) from cassandra.test where devgroup<40 allow filtering;
select min(temperature) from cassandra.test where devgroup<50 allow filtering;
select min(temperature) from cassandra.test where devgroup<60 allow filtering;
select min(temperature) from cassandra.test where devgroup<70 allow filtering;
select min(temperature) from cassandra.test where devgroup<80 allow filtering;
select min(temperature) from cassandra.test where devgroup<90 allow filtering;
select min(temperature) from cassandra.test allow filtering;
tests/comparisonTest/cassandra/q3.txt
0 → 100644
浏览文件 @
01062e66
select count(temperature), sum(temperature), avg(temperature) from cassandra.test where devgroup<10 group by devgroup allow filtering;
select count(temperature), sum(temperature), avg(temperature) from cassandra.test where devgroup<20 group by devgroup allow filtering;
select count(temperature), sum(temperature), avg(temperature) from cassandra.test where devgroup<30 group by devgroup allow filtering;
select count(temperature), sum(temperature), avg(temperature) from cassandra.test where devgroup<40 group by devgroup allow filtering;
select count(temperature), sum(temperature), avg(temperature) from cassandra.test where devgroup<50 group by devgroup allow filtering;
select count(temperature), sum(temperature), avg(temperature) from cassandra.test where devgroup<60 group by devgroup allow filtering;
select count(temperature), sum(temperature), avg(temperature) from cassandra.test where devgroup<70 group by devgroup allow filtering;
select count(temperature), sum(temperature), avg(temperature) from cassandra.test where devgroup<80 group by devgroup allow filtering;
select count(temperature), sum(temperature), avg(temperature) from cassandra.test where devgroup<90 group by devgroup allow filtering;
select count(temperature), sum(temperature), avg(temperature) from cassandra.test group by devgroup allow filtering;
tests/comparisonTest/cassandra/q4.txt
0 → 100644
浏览文件 @
01062e66
select count(temperature), sum(temperature), avg(temperature) from cassandra.test where devgroup<10 group by minute allow filtering;
select count(temperature), sum(temperature), avg(temperature) from cassandra.test where devgroup<20 group by minute allow filtering;
select count(temperature), sum(temperature), avg(temperature) from cassandra.test where devgroup<30 group by minute allow filtering;
select count(temperature), sum(temperature), avg(temperature) from cassandra.test where devgroup<40 group by minute allow filtering;
select count(temperature), sum(temperature), avg(temperature) from cassandra.test where devgroup<50 group by minute allow filtering;
select count(temperature), sum(temperature), avg(temperature) from cassandra.test where devgroup<60 group by minute allow filtering;
select count(temperature), sum(temperature), avg(temperature) from cassandra.test where devgroup<70 group by minute allow filtering;
select count(temperature), sum(temperature), avg(temperature) from cassandra.test where devgroup<80 group by minute allow filtering;
select count(temperature), sum(temperature), avg(temperature) from cassandra.test where devgroup<90 group by minute allow filtering;
select count(temperature), sum(temperature), avg(temperature) from cassandra.test group by minute;
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录