Uses of Class
org.apache.druid.java.util.common.io.Closer

Packages that use Closer

Package	Description
org.apache.druid.java.util.common.io
org.apache.druid.query.aggregation
org.apache.druid.segment
org.apache.druid.segment.data
org.apache.druid.segment.join
org.apache.druid.segment.join.lookup
org.apache.druid.segment.join.table
org.apache.druid.segment.nested
org.apache.druid.segment.serde.cell
org.apache.druid.segment.writeout
org.apache.druid.utils

Uses of Closer in org.apache.druid.java.util.common.io

Methods in org.apache.druid.java.util.common.io that return Closer

Modifier and Type	Method	Description
static Closer	Closer.create()	Creates a new Closer.

Uses of Closer in org.apache.druid.query.aggregation

Constructors in org.apache.druid.query.aggregation with parameters of type Closer

Modifier	Constructor	Description
	SerializablePairLongDoubleComplexColumn(CellReader cellReader, AbstractSerializablePairLongObjectDeltaEncodedStagedSerde<?> serde, Closer closer, int serializedSize)
	SerializablePairLongFloatComplexColumn(CellReader cellReader, AbstractSerializablePairLongObjectDeltaEncodedStagedSerde<?> serde, Closer closer, int serializedSize)
	SerializablePairLongLongComplexColumn(CellReader cellReader, AbstractSerializablePairLongObjectDeltaEncodedStagedSerde<?> serde, Closer closer, int serializedSize)
	SerializablePairLongStringComplexColumn(CellReader cellReader, SerializablePairLongStringDeltaEncodedStagedSerde serde, Closer closer, int serializedSize)

Uses of Closer in org.apache.druid.segment

Fields in org.apache.druid.segment declared as Closer

Modifier and Type	Field	Description
protected final Closer	DictionaryEncodedColumnMerger.closer

Methods in org.apache.druid.segment with parameters of type Closer

Modifier and Type	Method	Description
default DimensionMergerV9	DimensionHandler.makeMerger(String outputName, IndexSpec indexSpec, SegmentWriteOutMedium segmentWriteOutMedium, ColumnCapabilities capabilities, ProgressIndicator progress, File segmentBaseDir, Closer closer)	Creates a new DimensionMergerV9, a per-dimension object responsible for merging indexes/row data across segments and building the on-disk representation of a dimension.
default DimensionMergerV9	DimensionHandler.makeMerger(String outputName, IndexSpec indexSpec, SegmentWriteOutMedium segmentWriteOutMedium, ColumnCapabilities capabilities, ProgressIndicator progress, Closer closer)	Deprecated. use DimensionHandler.makeMerger(String, IndexSpec, SegmentWriteOutMedium, ColumnCapabilities, ProgressIndicator, File, Closer) This method exists for backwards compatiblity with older versions of Druid since this is an unofficial extension point that must be implemented to create custom dimension types, and will be removed in a future release.
DimensionMergerV9	DoubleDimensionHandler.makeMerger(String outputName, IndexSpec indexSpec, SegmentWriteOutMedium segmentWriteOutMedium, ColumnCapabilities capabilities, ProgressIndicator progress, File segmentBaseDir, Closer closer)
DimensionMergerV9	FloatDimensionHandler.makeMerger(String outputName, IndexSpec indexSpec, SegmentWriteOutMedium segmentWriteOutMedium, ColumnCapabilities capabilities, ProgressIndicator progress, File segmentBaseDir, Closer closer)
DimensionMergerV9	LongDimensionHandler.makeMerger(String outputName, IndexSpec indexSpec, SegmentWriteOutMedium segmentWriteOutMedium, ColumnCapabilities capabilities, ProgressIndicator progress, File segmentBaseDir, Closer closer)
DimensionMergerV9	NestedCommonFormatColumnHandler.makeMerger(String outputName, IndexSpec indexSpec, SegmentWriteOutMedium segmentWriteOutMedium, ColumnCapabilities capabilities, ProgressIndicator progress, File segmentBaseDir, Closer closer)
DimensionMergerV9	StringDimensionHandler.makeMerger(String outputName, IndexSpec indexSpec, SegmentWriteOutMedium segmentWriteOutMedium, ColumnCapabilities capabilities, ProgressIndicator progress, File segmentBaseDir, Closer closer)
protected Metadata	IndexMergerBase.makeProjections(SegmentFileBuilder segmentFileBuilder, List<AggregateProjectionMetadata> projections, List<IndexableAdapter> adapters, IndexSpec indexSpec, SegmentWriteOutMedium segmentWriteOutMedium, ProgressIndicator progress, File segmentBaseDir, Closer closer, Map<String,DimensionMergerV9> parentMergers, Metadata segmentMetadata)

Constructors in org.apache.druid.segment with parameters of type Closer

Modifier	Constructor	Description
	AutoTypeColumnMerger(String name, String outputName, ColumnType castToType, NestedCommonFormatColumnFormatSpec columnFormatSpec, SegmentWriteOutMedium segmentWriteOutMedium, File segmentBaseDir, Closer closer)
	ColumnCache(QueryableIndex index, VirtualColumns virtualColumns, Closer closer)
	DictionaryEncodedColumnMerger(String dimensionName, String outputName, IndexSpec indexSpec, SegmentWriteOutMedium segmentWriteOutMedium, ColumnCapabilities capabilities, ProgressIndicator progress, File segmentBaseDir, Closer closer)
	StringDimensionMergerV9(String dimensionName, String outputName, IndexSpec indexSpec, SegmentWriteOutMedium segmentWriteOutMedium, ColumnCapabilities capabilities, ProgressIndicator progress, File segmentBaseDir, Closer closer)

Uses of Closer in org.apache.druid.segment.data

Methods in org.apache.druid.segment.data with parameters of type Closer

Modifier and Type	Method	Description
ByteBuffer	CompressionStrategy.Compressor.allocateInBuffer(int inputSize, Closer closer)	Allocates a buffer that should be passed to CompressionStrategy.Compressor.compress(java.nio.ByteBuffer, java.nio.ByteBuffer) method as input buffer.
ByteBuffer	CompressionStrategy.LZ4Compressor.allocateInBuffer(int inputSize, Closer closer)
ByteBuffer	CompressionStrategy.ZstdCompressor.allocateInBuffer(int inputSize, Closer closer)
abstract ByteBuffer	CompressionStrategy.Compressor.allocateOutBuffer(int inputSize, Closer closer)	Allocates a buffer that should be passed to CompressionStrategy.Compressor.compress(java.nio.ByteBuffer, java.nio.ByteBuffer) method as output buffer.
ByteBuffer	CompressionStrategy.LZ4Compressor.allocateOutBuffer(int inputSize, Closer closer)
ByteBuffer	CompressionStrategy.LZFCompressor.allocateOutBuffer(int inputSize, Closer closer)
ByteBuffer	CompressionStrategy.UncompressedCompressor.allocateOutBuffer(int inputSize, Closer closer)
ByteBuffer	CompressionStrategy.ZstdCompressor.allocateOutBuffer(int inputSize, Closer closer)
static ObjectStrategy<ByteBuffer>	GenericIndexedWriter.compressedByteBuffersWriteObjectStrategy(CompressionStrategy compressionStrategy, int bufferSize, Closer closer)
static CompressedVSizeColumnarIntsSerializer	CompressedVSizeColumnarIntsSerializer.create(String columnName, SegmentWriteOutMedium segmentWriteOutMedium, String filenameBase, int maxValue, CompressionStrategy compression, Closer closer)
static CompressedVSizeColumnarMultiIntsSupplier	CompressedVSizeColumnarMultiIntsSupplier.fromIterable(Iterable<IndexedInts> objectsIterable, int maxValue, ByteOrder byteOrder, CompressionStrategy compression, Closer closer)
static V3CompressedVSizeColumnarMultiIntsSupplier	V3CompressedVSizeColumnarMultiIntsSupplier.fromIterable(Iterable<IndexedInts> objectsIterable, int offsetChunkFactor, int maxValue, ByteOrder byteOrder, CompressionStrategy compression, Closer closer)
static CompressedColumnarIntsSupplier	CompressedColumnarIntsSupplier.fromList(it.unimi.dsi.fastutil.ints.IntArrayList list, int chunkFactor, ByteOrder byteOrder, CompressionStrategy compression, Closer closer)
static CompressedVSizeColumnarIntsSupplier	CompressedVSizeColumnarIntsSupplier.fromList(it.unimi.dsi.fastutil.ints.IntList list, int maxValue, int chunkFactor, ByteOrder byteOrder, CompressionStrategy compression, Closer closer)
static ColumnarDoublesSerializer	CompressionFactory.getDoubleSerializer(String columnName, SegmentWriteOutMedium segmentWriteOutMedium, String filenameBase, ByteOrder byteOrder, CompressionStrategy compression, Closer closer)
static ColumnarFloatsSerializer	CompressionFactory.getFloatSerializer(String columnName, SegmentWriteOutMedium segmentWriteOutMedium, String filenameBase, ByteOrder order, CompressionStrategy compressionStrategy, Closer closer)
static ColumnarLongsSerializer	CompressionFactory.getLongSerializer(String columnName, SegmentWriteOutMedium segmentWriteOutMedium, String filenameBase, ByteOrder order, CompressionFactory.LongEncodingStrategy encodingStrategy, CompressionStrategy compressionStrategy, Closer closer)
static GenericIndexed<ResourceHolder<ByteBuffer>>	GenericIndexed.ofCompressedByteBuffers(Iterable<ByteBuffer> buffers, CompressionStrategy compression, int bufferSize, ByteOrder order, Closer closer)
static GenericIndexedWriter<ByteBuffer>	GenericIndexedWriter.ofCompressedByteBuffers(SegmentWriteOutMedium segmentWriteOutMedium, String filenameBase, CompressionStrategy compressionStrategy, int bufferSize, int fileSizeLimit, Closer closer)	Creates a new writer that accepts byte buffers and compresses them.

Constructors in org.apache.druid.segment.data with parameters of type Closer

Modifier	Constructor	Description
	CompressedBlockSerializer(SegmentWriteOutMedium segmentWriteOutMedium, CompressionStrategy compression, int blockSize, Closer closer)
	CompressedLongsSerializer(SegmentWriteOutMedium segmentWriteOutMedium, CompressionStrategy compression, Closer closer)

Uses of Closer in org.apache.druid.segment.join

Methods in org.apache.druid.segment.join with parameters of type Closer

Modifier and Type	Method	Description
static Cursor	HashJoinEngine.makeJoinCursor(Cursor leftCursor, JoinableClause joinableClause, Closer closer)	Creates a cursor that represents the join of with .
JoinMatcher	Joinable.makeJoinMatcher(ColumnSelectorFactory leftColumnSelectorFactory, JoinConditionAnalysis condition, boolean remainderNeeded, Closer closer)	Creates a JoinMatcher that can be used to implement a join onto this Joinable.

Uses of Closer in org.apache.druid.segment.join.lookup

Methods in org.apache.druid.segment.join.lookup with parameters of type Closer

Modifier and Type	Method	Description
JoinMatcher	LookupJoinable.makeJoinMatcher(ColumnSelectorFactory leftSelectorFactory, JoinConditionAnalysis condition, boolean remainderNeeded, Closer closer)

Uses of Closer in org.apache.druid.segment.join.table

Methods in org.apache.druid.segment.join.table with parameters of type Closer

Modifier and Type	Method	Description
ColumnSelectorFactory	BroadcastSegmentIndexedTable.makeColumnSelectorFactory(ReadableOffset offset, Closer closer)
default ColumnSelectorFactory	IndexedTable.makeColumnSelectorFactory(ReadableOffset offset, Closer closer)	This method allows a table to directly provide an optimized ColumnSelectorFactory for IndexedTableJoinMatcher to create selectors.
JoinMatcher	IndexedTableJoinable.makeJoinMatcher(ColumnSelectorFactory leftColumnSelectorFactory, JoinConditionAnalysis condition, boolean remainderNeeded, Closer closer)

Uses of Closer in org.apache.druid.segment.nested

Fields in org.apache.druid.segment.nested declared as Closer

Modifier and Type	Field	Description
protected final Closer	ScalarNestedCommonFormatColumnSerializer.closer
protected final Closer	GlobalDictionaryEncodedFieldColumnWriter.fieldResourceCloser

Constructors in org.apache.druid.segment.nested with parameters of type Closer

Modifier	Constructor	Description
	NestedDataColumnSerializer(String name, NestedCommonFormatColumnFormatSpec columnFormatSpec, SegmentWriteOutMedium segmentWriteOutMedium, Closer closer)
	ScalarDoubleColumnSerializer(String name, NestedCommonFormatColumnFormatSpec columnFormatSpec, SegmentWriteOutMedium segmentWriteOutMedium, Closer closer)
	ScalarLongColumnSerializer(String name, NestedCommonFormatColumnFormatSpec columnFormatSpec, SegmentWriteOutMedium segmentWriteOutMedium, Closer closer)
	ScalarNestedCommonFormatColumnSerializer(String name, NestedCommonFormatColumnFormatSpec columnFormatSpec, SegmentWriteOutMedium segmentWriteOutMedium, Closer closer)
	ScalarStringColumnSerializer(String name, NestedCommonFormatColumnFormatSpec columnFormatSpec, SegmentWriteOutMedium segmentWriteOutMedium, Closer closer)
	VariantColumnSerializer(String name, ColumnType logicalType, Byte variantTypeSetByte, NestedCommonFormatColumnFormatSpec columnFormatSpec, SegmentWriteOutMedium segmentWriteOutMedium, Closer closer)

Uses of Closer in org.apache.druid.segment.serde.cell

Constructors in org.apache.druid.segment.serde.cell with parameters of type Closer

Modifier	Constructor	Description
	BlockCompressedPayloadBuffer(ByteBuffer currentBlock, ByteBuffer compressedByteBuffer, BlockIndexWriter blockIndexWriter, WriteOutBytes dataOutBytes, Closer closer, CompressionStrategy.Compressor compressor)

Uses of Closer in org.apache.druid.segment.writeout

Methods in org.apache.druid.segment.writeout that return Closer

Modifier and Type	Method	Description
Closer	LegacyTmpFileSegmentWriteOutMedium.getCloser()
Closer	OffHeapMemorySegmentWriteOutMedium.getCloser()
Closer	OnHeapMemorySegmentWriteOutMedium.getCloser()
Closer	SegmentWriteOutMedium.getCloser()	Returns a closer of this SegmentWriteOutMedium, which is closed in this SegmentWriteOutMedium's close() method.
Closer	TmpFileSegmentWriteOutMedium.getCloser()

Constructors in org.apache.druid.segment.writeout with parameters of type Closer

Modifier	Constructor	Description
	LazilyAllocatingHeapWriteOutBytes(Supplier<WriteOutBytes> delegateSupplier, Closer closer)

Uses of Closer in org.apache.druid.utils

Methods in org.apache.druid.utils that return Closer

Modifier and Type	Method	Description
static Closer	CloseableUtils.forIterable(Iterable<? extends Closeable> closeables)