SharpMan

package koh.concurrency;

import java.util.Comparator;
import java.util.Iterator;
import java.util.Optional;
import java.util.Spliterator;
import java.util.concurrent.Callable;
import java.util.concurrent.ForkJoinPool;
import java.util.function.*;
import java.util.stream.*;

SharpMan

package koh.protocol.client.codec;

import java.util.Date;
import koh.protocol.MessageQueue;
import koh.protocol.client.Message;
import koh.protocol.messages.handshake.ProtocolRequired;
import org.apache.mina.core.buffer.CachedBufferAllocator;
import org.apache.mina.core.buffer.IoBuffer;
import org.apache.mina.core.buffer.IoBufferAllocator;
import org.apache.mina.core.session.IoSession;

SharpMan

//1-Count high speeds: Find the number of speeds > 100 in the data set.


db.agg_w_loopdata.find( { speed: { $gt: 100 } } ).count()

//2-Volume: Find the total volume for the station Foster NB for Sept 21, 2011.


db.agg_w_loopdata.aggregate([
    { $match: