Package | Description |
---|---|
org.apache.flink.runtime.operators.sort |
Modifier and Type | Method and Description |
---|---|
ExternalSorterBuilder<T> |
ExternalSorterBuilder.enableSpilling(IOManager ioManager) |
ExternalSorterBuilder<T> |
ExternalSorterBuilder.enableSpilling(IOManager ioManager,
double startSpillingFraction) |
ExternalSorterBuilder<T> |
ExternalSorterBuilder.largeRecords(boolean enabled) |
ExternalSorterBuilder<T> |
ExternalSorterBuilder.maxNumFileHandles(int maxNumFileHandles) |
ExternalSorterBuilder<T> |
ExternalSorterBuilder.memory(List<MemorySegment> memorySegments) |
ExternalSorterBuilder<T> |
ExternalSorterBuilder.memoryFraction(double fraction) |
static <E> ExternalSorterBuilder<E> |
ExternalSorter.newBuilder(MemoryManager memoryManager,
AbstractInvokable parentTask,
TypeSerializer<E> serializer,
TypeComparator<E> comparator)
Creates a builder for the
ExternalSorter . |
ExternalSorterBuilder<T> |
ExternalSorterBuilder.objectReuse(boolean enabled) |
ExternalSorterBuilder<T> |
ExternalSorterBuilder.sortBuffers(int numSortBuffers) |
ExternalSorterBuilder<T> |
ExternalSorterBuilder.sorterFactory(InMemorySorterFactory<T> sorterFactory) |
ExternalSorterBuilder<T> |
ExternalSorterBuilder.withCombiner(GroupCombineFunction<T,T> combineFunction) |
ExternalSorterBuilder<T> |
ExternalSorterBuilder.withCombiner(GroupCombineFunction<T,T> combineFunction,
Configuration udfConfig) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.