Class BSampler

src/com/winvector/variables/BTable.java:35–55

	public Iterable<BurstMap> sample = null;
	
	private static final class BSampler implements SerialObserver<BurstMap> {
		public final VariableEncodings oldAdapter;
		public final ResevoirSampler<BurstMap> sampler;

		public BSampler(final VariableEncodings oldAdapter, final long randSeed) {
			this.oldAdapter = oldAdapter;
			sampler = new ResevoirSampler<BurstMap>(100000,randSeed);
		}
		
		@Override
		public void observe(final BurstMap row) {
			final double weight = oldAdapter.weight(row);
			if(weight>0.0) {
				final String resStr = row.getAsString(oldAdapter.def().resultColumn);
				final int category = oldAdapter.category(resStr);
				if(category>=0) {
					sampler.observe(row);
				}
			}
		}
	}