| /lucene-3.6.0/solr/solrj/src/java/org/apache/solr/common/util/ |
| H A D | FastWriter.java | 30 protected final Writer sink; field in class:FastWriter
38 public FastWriter(Writer sink, char[] tempBuffer, int start) { argument
39 this.sink = sink;
44 public static FastWriter wrap(Writer sink) { argument
45 return (sink instanceof FastWriter) ? (FastWriter)sink : new FastWriter(sink);
55 sink.write(buf,0,pos);
64 sink
[all...] |
| H A D | FastOutputStream.java | 37 public FastOutputStream(OutputStream sink, byte[] tempBuffer, int start) { argument
38 this.out = sink;
44 public static FastOutputStream wrap(OutputStream sink) { argument
45 return (sink instanceof FastOutputStream) ? (FastOutputStream)sink : new FastOutputStream(sink);
86 // don't buffer, just write to sink
|
| /lucene-3.6.0/lucene/core/src/java/org/apache/lucene/analysis/ |
| H A D | TeeSinkTokenFilter.java | 60 * less the sink's field names). If you are not sure, which stream is consumed first, you can simply
61 * add another sink and then pass all tokens to the sinks at once using {@link #consumeAllTokens}.
98 SinkTokenStream sink = new SinkTokenStream(this.cloneAttributes(), filter);
99 this.sinks.add(new WeakReference<SinkTokenStream>(sink));
100 return sink;
106 * This method can be used to pass tokens from two different tees to one sink.
108 public void addSinkTokenStream(final SinkTokenStream sink) { argument
109 // check that sink has correct factory
110 if (!this.getAttributeFactory().equals(sink.getAttributeFactory())) {
111 throw new IllegalArgumentException("The supplied sink i
[all...] |
| H A D | ReusableAnalyzerBase.java | 46 * {@link TokenStreamComponents} sink as a reader
56 * instance of {@link TokenStreamComponents}. It returns the sink of the
81 * instance of {@link TokenStreamComponents} and returns the sink of the
104 * access to the source ({@link Tokenizer}) and the outer end (sink), an
112 protected final TokenStream sink; field in class:ReusableAnalyzerBase.TokenStreamComponents
125 this.sink = result;
136 this.sink = source;
159 * Returns the sink {@link TokenStream}
161 * @return the sink {@link TokenStream}
164 return sink;
[all...] |
| /lucene-3.6.0/lucene/contrib/analyzers/common/src/test/org/apache/lucene/analysis/sinks/ |
| H A D | DateRecognizerSinkTokenizerTest.java | 35 SinkTokenStream sink = tee.newSinkTokenStream(sinkFilter);
45 sink.reset();
46 while (sink.incrementToken()) {
49 assertTrue("sink Size: " + sinkCount + " is not: " + 2, sinkCount == 2);
|
| H A D | TokenTypeSinkTokenizerTest.java | 38 SinkTokenStream sink = ttf.newSinkTokenStream(sinkFilter);
56 sink.reset();
57 while (sink.incrementToken()) {
61 assertTrue("sink Size: " + sinkCount + " is not: " + 1, sinkCount == 1);
|
| /lucene-3.6.0/lucene/core/src/test/org/apache/lucene/analysis/ |
| H A D | TestTeeSinkTokenFilter.java | 130 TokenStream sink = teeStream.newSinkTokenStream(new ModuloSinkFilter(100));
134 CharTermAttribute sinkTok = sink.addAttribute(CharTermAttribute.class);
136 assertTrue(sink.incrementToken());
159 //simulate one field with one sink
163 sink = teeStream.newSinkTokenStream(new ModuloSinkFilter(modCounts[j]));
169 posIncrAtt = sink.getAttribute(PositionIncrementAttribute.class);
170 while (sink.incrementToken()) {
|
| /lucene-3.6.0/lucene/backwards/src/test/org/apache/lucene/analysis/ |
| H A D | TestTeeSinkTokenFilter.java | 130 TokenStream sink = teeStream.newSinkTokenStream(new ModuloSinkFilter(100));
134 CharTermAttribute sinkTok = sink.addAttribute(CharTermAttribute.class);
136 assertTrue(sink.incrementToken());
159 //simulate one field with one sink
163 sink = teeStream.newSinkTokenStream(new ModuloSinkFilter(modCounts[j]));
169 posIncrAtt = sink.getAttribute(PositionIncrementAttribute.class);
170 while (sink.incrementToken()) {
|
| /lucene-3.6.0/solr/solrj/src/java/org/apache/noggit/ |
| H A D | CharArr.java | 292 protected Writer sink; field in class:CharArrWriter
297 sink.write(buf, start, end-start);
324 sink.write(b, off, len);
345 // don't buffer, just write to sink
347 sink.write(s, stringOffset, len);
|
| /lucene-3.6.0/lucene/core/src/test/org/apache/lucene/index/ |
| H A D | TestTermVectorsWriter.java | 153 TokenStream sink = tee.newSinkTokenStream();
155 Field f2 = new Field("field", sink, Field.TermVector.WITH_POSITIONS_OFFSETS);
|
| /lucene-3.6.0/lucene/backwards/src/test/org/apache/lucene/index/ |
| H A D | TestTermVectorsWriter.java | 152 TokenStream sink = tee.newSinkTokenStream();
154 Field f2 = new Field("field", sink, Field.TermVector.WITH_POSITIONS_OFFSETS);
|
| /lucene-3.6.0/solr/core/src/java/org/apache/solr/response/ |
| H A D | CSVResponseWriter.java | 118 cw = (OpenCharArrayWriter)sink;
|