本文整理了Java中org.apache.flink.runtime.operators.sort.QuickSort.<init>方法的一些代码示例，展示了QuickSort.<init>的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。QuickSort.<init>方法的具体详情如下：
包路径：org.apache.flink.runtime.operators.sort.QuickSort
类名称：QuickSort
方法名：<init>

QuickSort.<init>介绍

暂无

代码示例

代码示例来源：origin: org.apache.flink/flink-runtime

/**
 * Creates a new sorting thread.
 * 
 * @param exceptionHandler The exception handler to call for all exceptions.
 * @param queues The queues used to pass buffers between the threads.
 * @param parentTask The task that started this thread. If non-null, it is used to register this thread.
 */
public SortingThread(ExceptionHandler<IOException> exceptionHandler, CircularQueues<E> queues,
    AbstractInvokable parentTask) {
  super(exceptionHandler, "SortMerger sorting thread", queues, parentTask);
  // members
  this.sorter = new QuickSort();
}

代码示例来源：origin: com.alibaba.blink/flink-table

/**
 * Creates a new sorting thread.
 *
 * @param exceptionHandler The exception handler to call for all exceptions.
 * @param queues           The circularQueues used to pass buffers between the threads.
 */
public SortingThread(ExceptionHandler<IOException> exceptionHandler,
    CircularQueues queues) {
  super(exceptionHandler, "SortMerger sorting thread", queues);
  // members
  this.sorter = new QuickSort();
}

代码示例来源：origin: org.apache.flink/flink-runtime_2.11

/**
 * Creates a new sorting thread.
 * 
 * @param exceptionHandler The exception handler to call for all exceptions.
 * @param queues The queues used to pass buffers between the threads.
 * @param parentTask The task that started this thread. If non-null, it is used to register this thread.
 */
public SortingThread(ExceptionHandler<IOException> exceptionHandler, CircularQueues<E> queues,
    AbstractInvokable parentTask) {
  super(exceptionHandler, "SortMerger sorting thread", queues, parentTask);
  // members
  this.sorter = new QuickSort();
}

代码示例来源：origin: com.alibaba.blink/flink-runtime

/**
 * Creates a new sorting thread.
 *
 * @param exceptionHandler The exception handler to call for all exceptions.
 * @param queues The queues used to pass buffers between the threads.
 * @param parentTask The task that started this thread. If non-null, it is used to register this thread.
 */
public SortingThread(ExceptionHandler<IOException> exceptionHandler, CircularQueues<E> queues,
    AbstractInvokable parentTask) {
  super(exceptionHandler, "SortMerger sorting thread", queues, parentTask);
  // members
  this.sorter = new QuickSort();
}

代码示例来源：origin: org.apache.flink/flink-runtime_2.10

/**
 * Creates a new sorting thread.
 * 
 * @param exceptionHandler The exception handler to call for all exceptions.
 * @param queues The queues used to pass buffers between the threads.
 * @param parentTask The task that started this thread. If non-null, it is used to register this thread.
 */
public SortingThread(ExceptionHandler<IOException> exceptionHandler, CircularQueues<E> queues,
    AbstractInvokable parentTask) {
  super(exceptionHandler, "SortMerger sorting thread", queues, parentTask);
  // members
  this.sorter = new QuickSort();
}

代码示例来源：origin: com.alibaba.blink/flink-table

this.comparator = comparator;
this.pageSize = pageSize;
this.sorter = new QuickSort();
this.maxNumFileHandles = conf.getInteger(TableConfigOptions.SQL_EXEC_SORT_FILE_HANDLES_MAX_NUM);
this.compressionEnable = conf.getBoolean(TableConfigOptions.SQL_EXEC_SPILL_COMPRESSION_ENABLED);