Package org.apache.druid.tasklogs

Interface TaskPayloadManager

All Known Subinterfaces:
TaskLogs
All Known Implementing Classes:
NoopTaskLogs, SwitchingTaskLogs
public interface TaskPayloadManager
Something that knows how to push a task payload before it is run to somewhere a ingestion worker will be able to stream the task payload from when trying to run the task.

  • Method Summary

    Modifier and Type
    Method
    Description
    default void
    pushTaskPayload(String taskid, File taskPayloadFile)
    Save payload so it can be retrieved later.
    default com.google.common.base.Optional<InputStream>
    streamTaskPayload(String taskid)
    Stream payload for a task.

  • Method Details

    • pushTaskPayload

      default void pushTaskPayload(String taskid, File taskPayloadFile) throws IOException
      Save payload so it can be retrieved later.
      Throws:
      IOException

    • streamTaskPayload

      default com.google.common.base.Optional<InputStream> streamTaskPayload(String taskid) throws IOException
      Stream payload for a task.
      Returns:
      inputStream for this taskPayload, if available
      Throws:
      IOException