func (l *Linearizer) SetStartLWM(time Timestamp) {
	l.startAtLWM = time
}
SetStartLWM sets the LWM at which we start processing
package dagger
import (
	log "github.com/Sirupsen/logrus"
)
type Linearizer struct {
	compID     StreamID
	store      StreamBuffer
	lwmTracker LWMTracker
	LWM        Timestamp
	lwmCh      chan Timestamp
	startAtLWM Timestamp
	ltp        LinearizedRecordProcessor
	stopCh     chan struct{}
	tmpT       chan *Record
}
func NewLinearizer(compID StreamID, store StreamBuffer, lwmTracker LWMTracker) *Linearizer {
	return &Linearizer{
		compID:     compID,
		store:      store,
		lwmTracker: lwmTracker,
		lwmCh:      make(chan Timestamp),
		tmpT:       make(chan *Record),
		stopCh:     make(chan struct{}),
	}
}
func (l *Linearizer) SetProcessor(ltp LinearizedRecordProcessor) {
	l.ltp = ltp
}