private StreamEvent query(StateEvent joinStateEvent) throws SiddhiAppRuntimeException {
        Table table = ((TableWindowProcessor) findableProcessor).getTable();
        if (table.getIsConnected()) {
            try {
                return ((QueryableProcessor) findableProcessor).query(joinStateEvent, compiledCondition,
                        compiledSelection, expectedOutputAttributes);
            } catch (ConnectionUnavailableException e) {
                table.setIsConnectedToFalse();
                table.connectWithRetry();
                return query(joinStateEvent);
            }
        } else if (table.getIsTryingToConnect()) {
            log.warn("Error while performing query '" + queryName + "' within Siddhi app '" + siddhiAppName +
                    "' for event '" + joinStateEvent + "', operation busy waiting at Table '" +
                    table.getTableDefinition().getId() + "' as its trying to reconnect!");
            table.waitWhileConnect();
            log.info("Table '" + table.getTableDefinition().getId() + "' has become available for query '" +
                    queryName + "' within Siddhi app '" + siddhiAppName + "for matching event '" +
                    joinStateEvent + "'");
            return query(joinStateEvent);
        } else {
            table.connectWithRetry();
            return query(joinStateEvent);
        }
    }
Process the handed StreamEvent.

@param complexEventChunk event chunk to be processed
modules/siddhi-core/src/main/java/io/siddhi/core/query/input/stream/join/JoinProcessor.java