@Override
    public void build() {
        sourceReceiver.receive(log);
        addAutocompleteTags();
    }
RecordSinkListener forwards the log data to the persistence layer with the query required conditions.
oap-server/analyzer/log-analyzer/src/main/java/org/apache/skywalking/oap/log/analyzer/provider/log/listener/RecordSinkListener.java