Skip to content

Commit bf20e58

Browse files
authored
Merge pull request #2 from lriggs/19_upgrade
Synchronize filter methods to match synconization on projector.
2 parents 41b721b + b308c5d commit bf20e58

File tree

1 file changed

+2
-2
lines changed
  • gandiva/src/main/java/org/apache/arrow/gandiva/evaluator

1 file changed

+2
-2
lines changed

gandiva/src/main/java/org/apache/arrow/gandiva/evaluator/Filter.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -111,7 +111,7 @@ public static Filter make(Schema schema, Condition condition, boolean optimize)
111111
* @param configurationId Custom configuration created through config builder.
112112
* @return A native evaluator object that can be used to invoke these projections on a RecordBatch
113113
*/
114-
public static Filter make(Schema schema, Condition condition, long configurationId)
114+
public static synchronized Filter make(Schema schema, Condition condition, long configurationId)
115115
throws GandivaException {
116116
// Invoke the JNI layer to create the LLVM module representing the filter.
117117
GandivaTypes.Condition conditionBuf = condition.toProtobuf();
@@ -158,7 +158,7 @@ public void evaluate(int numRows, List<ArrowBuf> buffers, SelectionVector select
158158
evaluate(numRows, buffers, buffersLayout, selectionVector);
159159
}
160160

161-
private void evaluate(
161+
private synchronized void evaluate(
162162
int numRows,
163163
List<ArrowBuf> buffers,
164164
List<ArrowBuffer> buffersLayout,

0 commit comments

Comments
 (0)