/
BytesRefVectorBlock.java
105 lines (86 loc) · 2.71 KB
/
BytesRefVectorBlock.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
/*
* Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
* or more contributor license agreements. Licensed under the Elastic License
* 2.0; you may not use this file except in compliance with the Elastic License
* 2.0.
*/
package org.elasticsearch.compute.data;
import org.apache.lucene.util.BytesRef;
import org.elasticsearch.common.unit.ByteSizeValue;
import org.elasticsearch.core.ReleasableIterator;
import org.elasticsearch.core.Releasables;
/**
* Block view of a {@link BytesRefVector}. Cannot represent multi-values or nulls.
* This class is generated. Do not edit it.
*/
public final class BytesRefVectorBlock extends AbstractVectorBlock implements BytesRefBlock {
private final BytesRefVector vector;
/**
* @param vector considered owned by the current block; must not be used in any other {@code Block}
*/
BytesRefVectorBlock(BytesRefVector vector) {
this.vector = vector;
}
@Override
public BytesRefVector asVector() {
return vector;
}
@Override
public BytesRef getBytesRef(int valueIndex, BytesRef dest) {
return vector.getBytesRef(valueIndex, dest);
}
@Override
public int getPositionCount() {
return vector.getPositionCount();
}
@Override
public ElementType elementType() {
return vector.elementType();
}
@Override
public BytesRefBlock filter(int... positions) {
return vector.filter(positions).asBlock();
}
@Override
public ReleasableIterator<BytesRefBlock> lookup(IntBlock positions, ByteSizeValue targetBlockSize) {
// TODO optimizations
return new BytesRefLookup(this, positions, targetBlockSize);
}
@Override
public BytesRefBlock expand() {
incRef();
return this;
}
@Override
public long ramBytesUsed() {
return vector.ramBytesUsed();
}
@Override
public boolean equals(Object obj) {
if (obj instanceof BytesRefBlock that) {
return BytesRefBlock.equals(this, that);
}
return false;
}
@Override
public int hashCode() {
return BytesRefBlock.hash(this);
}
@Override
public String toString() {
return getClass().getSimpleName() + "[vector=" + vector + "]";
}
@Override
public void closeInternal() {
assert (vector.isReleased() == false) : "can't release block [" + this + "] containing already released vector";
Releasables.closeExpectNoException(vector);
}
@Override
public void allowPassingToDifferentDriver() {
vector.allowPassingToDifferentDriver();
}
@Override
public BlockFactory blockFactory() {
return vector.blockFactory();
}
}