No one has voted on any posts yet. Votes from other community members are used to determine a member's reputation amongst their peers.
|
Hello, I have an arrayList that I want to emit and receive it in another bolt. So as suggested on another post here I used: the first bolt: collector.emit(new Values(listI)); the next bolt: public void execute(Tuple tuple) { ArrayList<Integer> i = (ArrayList<Integer>)tuple.getValue(0); .... } but instead of a size 4 … 
|
|
|
Hello, i am new to storm and stream data. I have implemented a sketch algorithm in java with maven. The algorithm has as an input a continuous stream of integers. The result is an array of integer frequencies and i want to run some queries on that array, but i … |
|
|
while(1){ new=accept(socket, (struct sockaddr*)&peer_addr,&peer_addrlen); if (new<0){ break; } else{ recv(new,mesg,sizeof(mesg),0); if (strstr(mesg, "GET") != NULL){ printf("\n%s",mesg); FILE *write = fdopen(new, "w"); fprintf(write, "HTTP/1.1 200 OK\nContent-length: 47\nContent-Type: text/html\n\n<html><body>< H1>HTTP/1.1 200 OK</H1></body></html>"); fflush(write); } else if (strstr(mesg, "POST") != NULL){ strcpy(resp,"POST\nContent-length: 47\nContent-Type: text/html\n\n<html><body><H1>POST</H1></body></html>"); c=send(new,&resp,sizeof(resp),0); printf("%c",c); } else{ strcpy(resp,"HTTP/1.1 500 Server Interval Error\nContent-length: … 
|