Uses of Interface
org.apache.druid.data.input.impl.prefetch.ObjectOpenFunction
Packages that use ObjectOpenFunction
Package
Description
-
Uses of ObjectOpenFunction in org.apache.druid.data.input.impl
Constructors in org.apache.druid.data.input.impl with parameters of type ObjectOpenFunctionModifierConstructorDescriptionRetryingInputStream(T object, ObjectOpenFunction<T> objectOpenFunction, com.google.common.base.Predicate<Throwable> retryCondition, Integer maxTries) -
Uses of ObjectOpenFunction in org.apache.druid.java.util.common
Methods in org.apache.druid.java.util.common with parameters of type ObjectOpenFunctionModifier and TypeMethodDescriptionstatic <T> longFileUtils.copyLarge(T object, ObjectOpenFunction<T> objectOpenFunction, File outFile, byte[] fetchBuffer, com.google.common.base.Predicate<Throwable> retryCondition, int numTries, String messageOnRetry) Copies data from the InputStream opened with objectOpenFunction to the given file. -
Uses of ObjectOpenFunction in org.apache.druid.storage.remote
Methods in org.apache.druid.storage.remote that return ObjectOpenFunctionMethods in org.apache.druid.storage.remote with parameters of type ObjectOpenFunctionModifier and TypeMethodDescriptionChunkingStorageConnectorParameters.Builder.objectOpenFunction(ObjectOpenFunction<T> objectOpenFunction) Constructors in org.apache.druid.storage.remote with parameters of type ObjectOpenFunctionModifierConstructorDescriptionChunkingStorageConnectorParameters(long start, long end, String cloudStoragePath, ChunkingStorageConnector.GetObjectFromRangeFunction<T> objectSupplier, ObjectOpenFunction<T> objectOpenFunction, com.google.common.base.Predicate<Throwable> retryCondition, int maxRetry, Supplier<File> tempDirSupplier)