// Path: reference/src/main/java/me/doubledutch/stroom/client/StreamConnection.java
// public interface StreamConnection{
// 	public final static int LINEAR=0;
// 	public final static int SYNC=1;
// 	public final static int FLUSH=2;
// 	public final static int NONE=3;
// 
// 	public List<String> get(long index,long endIndex) throws IOException;
// 	public String get(long index) throws IOException;
// 	public String getLast() throws IOException;
// 	public long getCount() throws IOException;
// 	
// 	public long append(JSONObject data) throws IOException,JSONException;
// 	public long append(String data) throws IOException,JSONException;
// 	public List<Long> append(List<String> data) throws IOException,JSONException;
// 	
// 	public long append(JSONObject data,int hint) throws IOException,JSONException;
// 	public long append(String data,int hint) throws IOException,JSONException;
// 	public List<Long> append(List<String> data,int hint) throws IOException,JSONException;
// 
// 	public void truncate(long index) throws IOException;
// }


import me.doubledutch.stroom.client.*;
import me.doubledutch.stroom.streams.*;
import me.doubledutch.stroom.query.sql.*;
import me.doubledutch.stroom.*;
import me.doubledutch.stroom.client.StreamConnection;
import me.doubledutch.lazyjson.*;
import org.json.*;
import java.io.*;
import java.net.*;
import java.util.*;
import java.util.concurrent.*;
			}else{
				result=new HashMap<String,TempTable>();
				if(query.isPartitioned()){
					raw.reset();
					while(raw.hasNext()){
						LazyObject next=raw.next();
						String key=query.getPartitionKey(next);
						TempTable partition=getPartition(key);
						partition.append(next);
					}
				}else{
					result.put("",raw);
				}
			}
			// Partition data
			/*if(query.isPartitioned()){
				raw.reset();
				while(raw.hasNext()){
					LazyObject next=raw.next();
					String key=query.getPartitionKey(next);
					System.out.println("key:"+key);
					TempTable partition=getPartition(key);
					partition.append(next);
				}
			}else{
				result=new HashMap<String,TempTable>();
				result.put("",raw);
			}*/
			long post=System.nanoTime();
			time=post-pre;
// Path: reference/src/main/java/me/doubledutch/stroom/client/StreamConnection.java
// public interface StreamConnection{
// 	public final static int LINEAR=0;
// 	public final static int SYNC=1;
// 	public final static int FLUSH=2;
// 	public final static int NONE=3;
// 
// 	public List<String> get(long index,long endIndex) throws IOException;
// 	public String get(long index) throws IOException;
// 	public String getLast() throws IOException;
// 	public long getCount() throws IOException;
// 	
// 	public long append(JSONObject data) throws IOException,JSONException;
// 	public long append(String data) throws IOException,JSONException;
// 	public List<Long> append(List<String> data) throws IOException,JSONException;
// 	
// 	public long append(JSONObject data,int hint) throws IOException,JSONException;
// 	public long append(String data,int hint) throws IOException,JSONException;
// 	public List<Long> append(List<String> data,int hint) throws IOException,JSONException;
// 
// 	public void truncate(long index) throws IOException;
// }


// Path: reference/src/main/java/me/doubledutch/stroom/query/QueryRunner.java
import me.doubledutch.stroom.client.*;
import me.doubledutch.stroom.streams.*;
import me.doubledutch.stroom.query.sql.*;
import me.doubledutch.stroom.*;
import me.doubledutch.stroom.client.StreamConnection;
import me.doubledutch.lazyjson.*;
import org.json.*;
import java.io.*;
import java.net.*;
import java.util.*;
import java.util.concurrent.*;

			}else{
				result=new HashMap<String,TempTable>();
				if(query.isPartitioned()){
					raw.reset();
					while(raw.hasNext()){
						LazyObject next=raw.next();
						String key=query.getPartitionKey(next);
						TempTable partition=getPartition(key);
						partition.append(next);
					}
				}else{
					result.put("",raw);
				}
			}
			// Partition data
			/*if(query.isPartitioned()){
				raw.reset();
				while(raw.hasNext()){
					LazyObject next=raw.next();
					String key=query.getPartitionKey(next);
					System.out.println("key:"+key);
					TempTable partition=getPartition(key);
					partition.append(next);
				}
			}else{
				result=new HashMap<String,TempTable>();
				result.put("",raw);
			}*/
			long post=System.nanoTime();
			time=post-pre;
			time=time/1000000;