48 public final class ChunkParser { |
48 public final class ChunkParser { |
49 |
49 |
50 static final class ParserConfiguration { |
50 static final class ParserConfiguration { |
51 final boolean reuse; |
51 final boolean reuse; |
52 final boolean ordered; |
52 final boolean ordered; |
53 final InternalEventFilter eventFilter; |
53 final ParserFilter eventFilter; |
54 |
54 |
55 long filterStart; |
55 long filterStart; |
56 long filterEnd; |
56 long filterEnd; |
57 |
57 |
58 public ParserConfiguration(long filterStart, long filterEnd, boolean reuse, boolean ordered, InternalEventFilter filter) { |
58 public ParserConfiguration(long filterStart, long filterEnd, boolean reuse, boolean ordered, ParserFilter filter) { |
59 this.filterStart = filterStart; |
59 this.filterStart = filterStart; |
60 this.filterEnd = filterEnd; |
60 this.filterEnd = filterEnd; |
61 this.reuse = reuse; |
61 this.reuse = reuse; |
62 this.ordered = ordered; |
62 this.ordered = ordered; |
63 this.eventFilter = filter; |
63 this.eventFilter = filter; |
64 } |
64 } |
65 |
65 |
66 public ParserConfiguration() { |
66 public ParserConfiguration() { |
67 this(0, Long.MAX_VALUE, false, false, InternalEventFilter.ACCEPT_ALL); |
67 this(0, Long.MAX_VALUE, false, false, ParserFilter.ACCEPT_ALL); |
68 } |
68 } |
69 } |
69 } |
70 |
70 |
71 // Checkpoint that finishes a flush segment |
71 // Checkpoint that finishes a flush segment |
72 static final byte CHECKPOINT_FLUSH_MASK = 1; |
72 static final byte CHECKPOINT_FLUSH_MASK = 1; |