Package org.apache.druid.data.input
package org.apache.druid.data.input
-
ClassDescriptionAbstract class for
InputSource.Wrapper around anInputEntitythat counts the number of bytes read.Used by someInputSourceReaderimplementations in order to know what columns will need to be read out of theInputRowobjects they create.Committer includes a Runnable and a Jackson-serialized metadata object containing the offsetAssigns each input file to its own split.DecoratedCloseableIterator<InputRow>that can process rows withHandlingInputRowIterator.InputRowHandlers.InputEntity abstracts an input entity and knows how to read bytes from the given entity.CleanableFile is the result type ofInputEntity.fetch(java.io.File, byte[]).InputEntityReader knows how to parse data intoInputRow.A class storing some attributes of an input file.InputFormat abstracts the file format of input data.An InputRow is the interface definition of an event being input into the data ingestion layer.Schema ofInputRow.InputSource abstracts the storage system where input data is stored.An interface to generate aSplittableInputSourceobjects on the fly.InputSplit<T>Input unit for distributed batch ingestion.Tracks bytes read from an input source.InputEntityReaderthat parses bytes into some intermediate rows first, and then intoInputRows.Input row backed by aList.Adapter for readingListBasedInputRow.A SplitHintSpec that can create splits of multiple files.A Row of data.SplitHintSpecfor DruidInputSource.In native parallel indexing, the supervisor task partitions input data into splits and assigns each of them to a single sub task.Represents a tuple of String values, typically used to represent (single-valued) dimension values for an InputRow.TextReader<T>AbstractInputEntityReaderfor text format readers such as CSV or JSON.