<commit_before>package org.inaetics.ails.impl.server.streaming_profile.miner;

import org.inaetics.ails.api.common.model.Location;
import org.inaetics.ails.api.common.model.RawLocationProfile;
import org.inaetics.ails.api.common.model.User;
import org.inaetics.ails.api.common.model.UserWiFiProfile;
import org.inaetics.ails.api.server.buffer.BufferService;

/**
 * The Streaming Profile Miner will process {@link UserWiFiProfile UserWiFiProfiles} from the
 * {@link BufferService}.
 * 
 * New UserWiFiProfiles arriving from the buffer will be stored. Stored UserWiFiProfiles will be
 * combined with {@link RawLocationProfile RawLocationProfiles} to gather new information about the
 * {@link Location} of a {@link User}.
 * 
 * @author <NAME>, <NAME>, <NAME>
 * @version 0.1.0
 * @since 10-11-2015
 */
public class StreamingProfileMiner {

    // Injected by Dependency Manager
    private volatile BufferService<UserWiFiProfile> buffer;

    public StreamingProfileMiner() {
        new StreamingProfileMinerThread().start();
    }

    private final class StreamingProfileMinerThread extends Thread {

        @Override
        public void run() {
            while (buffer == null) {
                System.out.println("StreamingProfileMiner not yet received BufferService<UserWiFiProfile>");
                try {
                    Thread.sleep(10);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
            System.out.println("StreamingProfileMiner has received BufferService<UserWiFiProfile>");
        }

    }

}<commit_msg>SteramingProfileMiner now started by Felix DM in proper start method<commit_after>package org.inaetics.ails.impl.server.streaming_profile.miner;

import org.inaetics.ails.api.common.model.Location;
import org.inaetics.ails.api.common.model.RawLocationProfile;
import org.inaetics.ails.api.common.model.User;
import org.inaetics.ails.api.common.model.UserWiFiProfile;
import org.inaetics.ails.api.server.buffer.BufferService;

/**
 * The Streaming Profile Miner will process {@link UserWiFiProfile UserWiFiProfiles} from the
 * {@link BufferService}.
 * 
 * New UserWiFiProfiles arriving from the buffer will be stored. Stored UserWiFiProfiles will be
 * combined with {@link RawLocationProfile RawLocationProfiles} to gather new information about the
 * {@link Location} of a {@link User}.
 * 
 * @author <NAME>, <NAME>, <NAME>
 * @version 0.1.1
 * @since 10-11-2015
 */
public class StreamingProfileMiner {

    // Injected by Dependency Manager
    private volatile BufferService<UserWiFiProfile> incomingUserWiFiProfileBuffer;

    /**
     * Called by Felix DM when starting this component.
     */
    public void start() {
        new StreamingProfileMinerThread().start();
    }

    private final class StreamingProfileMinerThread extends Thread {

        @Override
        public void run() {
            while (incomingUserWiFiProfileBuffer == null) {
                System.out.println("StreamingProfileMiner not yet "
                        + "received BufferService<UserWiFiProfile>");
                try {
                    Thread.sleep(10);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
            System.out.println("StreamingProfileMiner has received BufferService<UserWiFiProfile>");
        }

    }

}
{'fraction_non_alphanumeric': 0.09359461830944721, 'fraction_numerical': 0.0076045627376425855, 'mean_word_length': 2.917525773195876, 'pattern_counts': {'":': 0, '<': 15, '<?xml version=': 0, '>': 15, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '424456', 'n_tokens_mistral': 977, 'n_tokens_neox': 928, 'n_words': 230}