Class InlineInputSource

java.lang.Object
org.apache.druid.data.input.AbstractInputSource
org.apache.druid.data.input.impl.InlineInputSource
All Implemented Interfaces:
InputSource

public class InlineInputSource extends AbstractInputSource
  • Field Details

  • Constructor Details

    • InlineInputSource

      public InlineInputSource(String data)
  • Method Details

    • getTypes

      @Nonnull public Set<String> getTypes()
      Description copied from interface: InputSource
      The types of input sources uses. A set is returned here, as some InputSource implementation allow for combining of multiple input sources.
      Returns:
      The types of input sources uses
    • getData

      public String getData()
    • isSplittable

      public boolean isSplittable()
      Description copied from interface: InputSource
      Returns true if this inputSource can be processed in parallel using ParallelIndexSupervisorTask. It must be castable to SplittableInputSource and the various SplittableInputSource methods must work as documented.
    • needsFormat

      public boolean needsFormat()
      Description copied from interface: InputSource
      Returns true if this inputSource supports different InputFormats. Some inputSources such as LocalInputSource can store files of any format. These storage types require an InputFormat to be passed so that InputSourceReader can parse data properly. However, some storage types have a fixed format. For example, druid inputSource always reads segments. These inputSources should return false for this method.
    • formattableReader

      protected InputSourceReader formattableReader(InputRowSchema inputRowSchema, InputFormat inputFormat, @Nullable File temporaryDirectory)
      Overrides:
      formattableReader in class AbstractInputSource
    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object
    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object
    • toString

      public String toString()
      Overrides:
      toString in class Object