refactor: remove unused arguments

Author: taewhi

traindb-core/src/main/java/traindb/engine/Session.java

@@ -33,7 +33,6 @@
 import org.apache.commons.lang3.exception.ExceptionUtils;
 import org.json.simple.JSONObject;
 import org.json.simple.parser.JSONParser;
-import traindb.catalog.CatalogContext;
 import traindb.common.TrainDBException;
 import traindb.common.TrainDBLogger;
 import traindb.engine.nio.ByteBuffers;
@@ -56,24 +55,16 @@ public final class Session implements Runnable {
 
  private final SocketChannel clientChannel;
  private final EventHandler eventHandler;
-
- private final CatalogContext catalogContext;
  private final SchemaManager schemaManager;
-
  final MessageStream messageStream;
 
- Session(SocketChannel clientChannel, EventHandler eventHandler,
- CatalogContext catalogContext, SchemaManager schemaManager) {
+ Session(SocketChannel clientChannel, EventHandler eventHandler, SchemaManager schemaManager) {
  sessionId = new Random(this.hashCode()).nextInt();
  cancelContext = new CancelContext(this);
  this.clientChannel = clientChannel;
  this.eventHandler = eventHandler;
- this.messageStream = new MessageStream(clientChannel);
-
- this.catalogContext = catalogContext;
  this.schemaManager = schemaManager;
-
- // TODO: create TrainDBQueryEngine
+ this.messageStream = new MessageStream(clientChannel);
  }
 
  public static Session currentSession() {

traindb-core/src/main/java/traindb/engine/SessionFactory.java

@@ -20,16 +20,13 @@
 import traindb.schema.SchemaManager;
 
 public class SessionFactory {
- private final CatalogStore catalogStore;
  private final SchemaManager schemaManager;
 
- public SessionFactory(CatalogStore catalogStore, SchemaManager schemaManager) {
- this.catalogStore = catalogStore;
+ public SessionFactory(SchemaManager schemaManager) {
  this.schemaManager = schemaManager;
  }
 
  public Session createSession(SocketChannel clientChannel, Session.EventHandler sessEvtHandler) {
- return new Session(
- clientChannel, sessEvtHandler, catalogStore.getCatalogContext(), schemaManager);
+ return new Session(clientChannel, sessEvtHandler, schemaManager);
  }
 }

traindb-core/src/main/java/traindb/engine/TrainDBServer.java

@@ -47,7 +47,7 @@ protected void serviceInit(Configuration conf) throws Exception {
  SchemaManager schemaManager = SchemaManager.getInstance(catalogStore);
  addService(schemaManager);
 
- SessionFactory sessFactory = new SessionFactory(catalogStore, schemaManager);
+ SessionFactory sessFactory = new SessionFactory(schemaManager);
  SessionServer sessServer = new SessionServer(sessFactory);
  addService(sessServer);