Class BatchedImportRowBufferProcessor.DoubleComputedSetter
java.lang.Object
java.util.concurrent.ForkJoinTask<Void>
java.util.concurrent.RecursiveAction
com.illumon.iris.db.tables.dataimport.BatchedImportRowBufferProcessor.DoubleComputedSetter
- All Implemented Interfaces:
Serializable
,Future<Void>
- Enclosing class:
- BatchedImportRowBufferProcessor
protected final class BatchedImportRowBufferProcessor.DoubleComputedSetter extends RecursiveAction
- See Also:
- Serialized Form
-
Constructor Summary
Constructors Constructor Description DoubleComputedSetter(BatchedImportRowBufferProcessor.IndexToDoubleFunction function, LocalAppendableColumn<?> destination)
-
Method Summary
Methods inherited from class java.util.concurrent.ForkJoinTask
adapt, adapt, adapt, cancel, compareAndSetForkJoinTaskTag, complete, completeExceptionally, fork, get, get, getException, getForkJoinTaskTag, getPool, getQueuedTaskCount, getSurplusQueuedTaskCount, helpQuiesce, inForkJoinPool, invoke, invokeAll, invokeAll, invokeAll, isCancelled, isCompletedAbnormally, isCompletedNormally, isDone, join, peekNextLocalTask, pollNextLocalTask, pollSubmission, pollTask, quietlyComplete, quietlyInvoke, quietlyJoin, reinitialize, setForkJoinTaskTag, tryUnfork
-
Constructor Details
-
DoubleComputedSetter
public DoubleComputedSetter(@NotNull BatchedImportRowBufferProcessor.IndexToDoubleFunction function, @NotNull LocalAppendableColumn<?> destination)
-
-
Method Details
-
write
- Throws:
IOException
-
compute
protected final void compute()- Specified by:
compute
in classRecursiveAction
-