Mark JoinFilterFunction not thread safe
@@ -15,8 +15,11 @@ package com.facebook.presto.operator;
import com.facebook.presto.spi.Page;
+import javax.annotation.concurrent.NotThreadSafe;
+
import java.util.Optional;
+@NotThreadSafe
public interface JoinFilterFunction
{
boolean filter(int leftAddress, int rightPosition, Page rightPage);
