public synchronized TableInputHandler constructTableInputHandler(String tableId) {
        Table correspondingTable = tableMap.get(tableId);
        if (correspondingTable == null) {
            throw new DefinitionNotExistException("Table with table ID " + tableId + " has not been defined");
        }
        TableInputHandler tableInputHandler = new TableInputHandler(correspondingTable, siddhiAppContext);
        tableInputHandlerMap.put(tableId, tableInputHandler);
        return tableInputHandler;
    }
Manager class to handle {@link Event} insertion to Siddhi.
modules/siddhi-core/src/main/java/io/siddhi/core/stream/input/InputManager.java