Add native index join perf related session properties

Author: zacw7

presto-main-base/src/main/java/com/facebook/presto/sessionpropertyproviders/NativeWorkerSessionPropertyProvider.java

@@ -28,7 +28,6 @@
 import static com.facebook.presto.spi.session.PropertyMetadata.stringProperty;
 import static java.util.Objects.requireNonNull;
 
-@Deprecated
 public class NativeWorkerSessionPropertyProvider
         implements WorkerSessionPropertyProvider
 {
@@ -81,6 +80,10 @@ public class NativeWorkerSessionPropertyProvider
     public static final String NATIVE_REQUEST_DATA_SIZES_MAX_WAIT_SEC = "native_request_data_sizes_max_wait_sec";
     public static final String NATIVE_QUERY_MEMORY_RECLAIMER_PRIORITY = "native_query_memory_reclaimer_priority";
     public static final String NATIVE_MAX_NUM_SPLITS_LISTENED_TO = "native_max_num_splits_listened_to";
+    public static final String NATIVE_INDEX_LOOKUP_JOIN_MAX_PREFETCH_BATCHES = "native_index_lookup_join_max_prefetch_batches";
+    public static final String NATIVE_INDEX_LOOKUP_JOIN_SPLIT_OUTPUT = "native_index_lookup_join_split_output";
+    public static final String NATIVE_UNNEST_SPLIT_OUTPUT = "native_unnest_split_output";
+
     private final List<PropertyMetadata<?>> sessionProperties;
 
     @Inject
@@ -152,7 +155,7 @@ public NativeWorkerSessionPropertyProvider(FeaturesConfig featuresConfig)
                 longProperty(
                         NATIVE_WRITER_FLUSH_THRESHOLD_BYTES,
                         "Native Execution only. Minimum memory footprint size required to reclaim memory from a file " +
-                        "writer by flushing its buffered data to disk.",
+                                "writer by flushing its buffered data to disk.",
                         96L << 20,
                         false),
                 booleanProperty(
@@ -266,7 +269,7 @@ public NativeWorkerSessionPropertyProvider(FeaturesConfig featuresConfig)
                         "",
                         !nativeExecution),
                 stringProperty(NATIVE_QUERY_TRACE_FRAGMENT_ID,
-                            "The fragment id of the traced task.",
+                        "The fragment id of the traced task.",
                         "",
                         !nativeExecution),
                 stringProperty(NATIVE_QUERY_TRACE_SHARD_ID,
@@ -366,13 +369,34 @@ public NativeWorkerSessionPropertyProvider(FeaturesConfig featuresConfig)
                 integerProperty(
                         NATIVE_QUERY_MEMORY_RECLAIMER_PRIORITY,
                         "Native Execution only. Priority of memory recliamer when deciding on memory pool to abort." +
-                        "Lower value has higher priority and less likely to be choosen for memory pool abort",
+                                "Lower value has higher priority and less likely to be choosen for memory pool abort",
                         2147483647,
                         !nativeExecution),
                 integerProperty(
                         NATIVE_MAX_NUM_SPLITS_LISTENED_TO,
                         "Maximum number of splits to listen to per table scan node per worker.",
                         0,
+                        !nativeExecution),
+
+                integerProperty(
+                        NATIVE_INDEX_LOOKUP_JOIN_MAX_PREFETCH_BATCHES,
+                        "Specifies the max number of input batches to prefetch to do index lookup ahead. " +
+                                "If it is zero, then process one input batch at a time.",
+                        0,
+                        !nativeExecution),
+                booleanProperty(
+                        NATIVE_INDEX_LOOKUP_JOIN_SPLIT_OUTPUT,
+                        "If this is true, then the index join operator might split output for each input " +
+                                "batch based on the output batch size control. Otherwise, it tries to produce a " +
+                                "single output for each input batch.",
+                        true,
+                        !nativeExecution),
+                booleanProperty(
+                        NATIVE_UNNEST_SPLIT_OUTPUT,
+                        "If this is true, then the unnest operator might split output for each input " +
+                                "batch based on the output batch size control. Otherwise, it produces a single " +
+                                "output for each input batch.",
+                        true,
                         !nativeExecution));
     }