Compare commits
No commits in common. '181abacc55f42c32150d04da171b9ff73166efff' and '529c5cb6a8f5b5aa89e74b96d6764acfa0ddbc0a' have entirely different histories.
181abacc55
...
529c5cb6a8
@ -1,72 +0,0 @@
|
||||
#include "./server/libaquery.h"
|
||||
|
||||
#ifndef __AQ_USE_THREADEDGC__
|
||||
|
||||
#include "./server/gc.h"
|
||||
__AQEXPORT__(void) __AQ_Init_GC__(Context* cxt) {
|
||||
GC::gc_handle = static_cast<GC*>(cxt->gc);
|
||||
}
|
||||
|
||||
#else // __AQ_USE_THREADEDGC__
|
||||
#define __AQ_Init_GC__(x)
|
||||
#endif // __AQ_USE_THREADEDGC__
|
||||
#include "./server/hasher.h"
|
||||
#include "./server/monetdb_conn.h"
|
||||
#include "./server/aggregations.h"
|
||||
|
||||
__AQEXPORT__(int) dll_2Cxoox(Context* cxt) {
|
||||
using namespace std;
|
||||
using namespace types;
|
||||
auto server = static_cast<Server*>(cxt->alt_server);
|
||||
auto len_4ycjiV = server->cnt;
|
||||
auto mont_8AE = ColRef<const char*>(len_4ycjiV, server->getCol(0));
|
||||
auto sales_2RB = ColRef<int>(len_4ycjiV, server->getCol(1));
|
||||
const char* names_6pIt[] = {"mont", "minw2ysales"};
|
||||
auto out_2LuaMH = new TableInfo<const char*,vector_type<double>>("out_2LuaMH", names_6pIt);
|
||||
decltype(auto) col_EeW23s = out_2LuaMH->get_col<0>();
|
||||
decltype(auto) col_5gY1Dm = out_2LuaMH->get_col<1>();
|
||||
typedef record<decays<decltype(mont_8AE)::value_t>> record_typegj3e8Xf;
|
||||
ankerl::unordered_dense::map<record_typegj3e8Xf, uint32_t, transTypes<record_typegj3e8Xf, hasher>> gMzMTEvd;
|
||||
gMzMTEvd.reserve(mont_8AE.size);
|
||||
uint32_t* reversemap = new uint32_t[mont_8AE.size<<1],
|
||||
*mapbase = reversemap + mont_8AE.size;
|
||||
for (uint32_t i2E = 0; i2E < mont_8AE.size; ++i2E){
|
||||
reversemap[i2E] = gMzMTEvd.hashtable_push(forward_as_tuple(mont_8AE[i2E]));
|
||||
}
|
||||
auto arr_values = gMzMTEvd.values().data();
|
||||
auto arr_len = gMzMTEvd.size();
|
||||
uint32_t* seconds = new uint32_t[gMzMTEvd.size()];
|
||||
|
||||
auto vecs = static_cast<vector_type<uint32_t>*>(malloc(sizeof(vector_type<uint32_t>) * arr_len));
|
||||
vecs[0].init_from(arr_values[0].second, mapbase);
|
||||
for (uint32_t i = 1; i < arr_len; ++i) {
|
||||
vecs[i].init_from(arr_values[i].second, mapbase + arr_values[i - 1].second);
|
||||
arr_values[i].second += arr_values[i - 1].second;
|
||||
}
|
||||
for (uint32_t i = 0; i < mont_8AE.size; ++i) {
|
||||
auto id = reversemap[i];
|
||||
mapbase[--arr_values[id].second] = i;
|
||||
}
|
||||
|
||||
col_EeW23s.reserve(gMzMTEvd.size());
|
||||
col_5gY1Dm.reserve(gMzMTEvd.size());
|
||||
auto buf_col_5gY1Dm = new double[mont_8AE.size];
|
||||
for (uint32_t i = 0; i < arr_len; ++i) {
|
||||
col_5gY1Dm[i].init_from(vecs[i].size, buf_col_5gY1Dm + arr_values[i].second);
|
||||
}
|
||||
for (uint32_t i = 0; i < arr_len; ++i) {
|
||||
|
||||
auto &key_3iNX3qG = arr_values[i].first;
|
||||
auto &val_7jjv8Mo = arr_values[i].second;
|
||||
col_EeW23s.emplace_back(get<0>(key_3iNX3qG));
|
||||
|
||||
avgw(10, sales_2RB[vecs[i]], col_5gY1Dm[i]);
|
||||
|
||||
}
|
||||
//print(*out_2LuaMH);
|
||||
//FILE* fp_5LQeym = fopen("flatten.csv", "wb");
|
||||
out_2LuaMH->printall(",", "\n", nullptr, nullptr, 10);
|
||||
//fclose(fp_5LQeym);
|
||||
puts("done.");
|
||||
return 0;
|
||||
}
|
||||
@ -1,51 +0,0 @@
|
||||
import struct
|
||||
import readline
|
||||
from typing import List
|
||||
|
||||
name : str = input()
|
||||
|
||||
def write():
|
||||
s : str = input()
|
||||
qs : List[str] = []
|
||||
|
||||
while(len(s) and not s.startswith('S')):
|
||||
qs.append(s)
|
||||
s = input()
|
||||
|
||||
ms : int = int(input())
|
||||
|
||||
with open(f'./procedures/{name}.aqp', 'wb') as fp:
|
||||
fp.write(struct.pack("I", len(qs) + (ms > 0)))
|
||||
fp.write(struct.pack("I", ms))
|
||||
if (ms > 0):
|
||||
fp.write(b'N\x00')
|
||||
|
||||
for q in qs:
|
||||
fp.write(q.encode('utf-8'))
|
||||
if q.startswith('Q'):
|
||||
fp.write(b'\n ')
|
||||
fp.write(b'\x00')
|
||||
|
||||
|
||||
def read():
|
||||
with open(f'./procedures/{name}.aqp', 'rb') as fp:
|
||||
nq = struct.unpack("I", fp.read(4))[0]
|
||||
ms = struct.unpack("I", fp.read(4))[0]
|
||||
qs = fp.read().split(b'\x00')
|
||||
print(f'Procedure {name}, {nq} queries, {ms} modules:')
|
||||
for q in qs:
|
||||
print(' ' + q.decode('utf-8'))
|
||||
|
||||
|
||||
if __name__ == '__main__':
|
||||
while True:
|
||||
cmd = input("r for read, w for write: ")
|
||||
if cmd.lower().startswith('r'):
|
||||
read()
|
||||
break
|
||||
elif cmd.lower().startswith('w'):
|
||||
write()
|
||||
break
|
||||
elif cmd.lower().startswith('q'):
|
||||
break
|
||||
|
||||
Loading…
Reference in new issue