package com.cloudera.flume.handlers.rolling;
import java.util.Date;
import com.cloudera.flume.conf.FlumeConfiguration;
import com.cloudera.flume.core.Event;
import com.cloudera.util.Clock;
Tagger tagger;
long maxAge;
FlumeConfiguration conf = FlumeConfiguration.get();
this.maxAge = conf.getAgentLogMaxAge();
this.tagger = new ProcessTagger();
}
public TimeTrigger(FlumeConfiguration conf, Tagger t) {
this.maxAge = conf.getAgentLogMaxAge();
this.tagger = t;
}
this.maxAge = maxAge;
this.tagger = new ProcessTagger();
}
this.maxAge = maxAge;
this.tagger = t;
}
@Override
Date d = tagger.getDate();
long time = Clock.unixTime();
long delta = time - d.getTime();
return (delta >= maxAge);
}
@Override
}
@Override
return tagger;
}
@Override
tagger.newTag();
}
@Override
return "TimeTrigger: maxAge=" + maxAge + " tagger=" + tagger;
}
}