Packages

c

org.apache.spark.sql.delta.files.DeltaFileFormatWriter

PartitionedTaskAttemptContextImpl

class PartitionedTaskAttemptContextImpl extends TaskAttemptContextImpl

Linear Supertypes
TaskAttemptContextImpl, TaskAttemptContext, Progressable, JobContextImpl, JobContext, MRJobConfig, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. PartitionedTaskAttemptContextImpl
  2. TaskAttemptContextImpl
  3. TaskAttemptContext
  4. Progressable
  5. JobContextImpl
  6. JobContext
  7. MRJobConfig
  8. AnyRef
  9. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new PartitionedTaskAttemptContextImpl(conf: Configuration, taskId: TaskAttemptID, partitionColumnToDataType: Map[String, DataType])

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native() @IntrinsicCandidate()
  6. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  8. def getArchiveClassPaths(): Array[Path]
    Definition Classes
    JobContextImpl → JobContext
  9. def getArchiveTimestamps(): Array[String]
    Definition Classes
    JobContextImpl → JobContext
  10. def getCacheArchives(): Array[URI]
    Definition Classes
    JobContextImpl → JobContext
    Annotations
    @throws( classOf[java.io.IOException] )
  11. def getCacheFiles(): Array[URI]
    Definition Classes
    JobContextImpl → JobContext
    Annotations
    @throws( classOf[java.io.IOException] )
  12. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  13. def getCombinerClass(): Class[_ <: Reducer[_, _, _, _]]
    Definition Classes
    JobContextImpl → JobContext
    Annotations
    @throws( ... )
  14. def getCombinerKeyGroupingComparator(): RawComparator[_]
    Definition Classes
    JobContextImpl → JobContext
  15. def getConfiguration(): Configuration
    Definition Classes
    JobContextImpl → JobContext
  16. def getCounter(arg0: String, arg1: String): Counter
    Definition Classes
    TaskAttemptContextImpl → TaskAttemptContext
  17. def getCounter(arg0: Enum[_]): Counter
    Definition Classes
    TaskAttemptContextImpl → TaskAttemptContext
  18. def getCredentials(): Credentials
    Definition Classes
    JobContextImpl → JobContext
  19. def getFileClassPaths(): Array[Path]
    Definition Classes
    JobContextImpl → JobContext
  20. def getFileTimestamps(): Array[String]
    Definition Classes
    JobContextImpl → JobContext
  21. def getGroupingComparator(): RawComparator[_]
    Definition Classes
    JobContextImpl → JobContext
  22. def getInputFormatClass(): Class[_ <: InputFormat[_, _]]
    Definition Classes
    JobContextImpl → JobContext
    Annotations
    @throws( ... )
  23. def getJar(): String
    Definition Classes
    JobContextImpl → JobContext
  24. def getJobID(): JobID
    Definition Classes
    JobContextImpl → JobContext
  25. def getJobName(): String
    Definition Classes
    JobContextImpl → JobContext
  26. def getJobSetupCleanupNeeded(): Boolean
    Definition Classes
    JobContextImpl → JobContext
  27. def getLocalCacheArchives(): Array[Path]
    Definition Classes
    JobContextImpl → JobContext
    Annotations
    @throws( classOf[java.io.IOException] )
  28. def getLocalCacheFiles(): Array[Path]
    Definition Classes
    JobContextImpl → JobContext
    Annotations
    @throws( classOf[java.io.IOException] )
  29. def getMapOutputKeyClass(): Class[_]
    Definition Classes
    JobContextImpl → JobContext
  30. def getMapOutputValueClass(): Class[_]
    Definition Classes
    JobContextImpl → JobContext
  31. def getMapperClass(): Class[_ <: Mapper[_, _, _, _]]
    Definition Classes
    JobContextImpl → JobContext
    Annotations
    @throws( ... )
  32. def getMaxMapAttempts(): Int
    Definition Classes
    JobContextImpl → JobContext
  33. def getMaxReduceAttempts(): Int
    Definition Classes
    JobContextImpl → JobContext
  34. def getNumReduceTasks(): Int
    Definition Classes
    JobContextImpl → JobContext
  35. def getOutputFormatClass(): Class[_ <: OutputFormat[_, _]]
    Definition Classes
    JobContextImpl → JobContext
    Annotations
    @throws( ... )
  36. def getOutputKeyClass(): Class[_]
    Definition Classes
    JobContextImpl → JobContext
  37. def getOutputValueClass(): Class[_]
    Definition Classes
    JobContextImpl → JobContext
  38. def getPartitionerClass(): Class[_ <: hadoop.mapreduce.Partitioner[_, _]]
    Definition Classes
    JobContextImpl → JobContext
    Annotations
    @throws( ... )
  39. def getProfileEnabled(): Boolean
    Definition Classes
    JobContextImpl → JobContext
  40. def getProfileParams(): String
    Definition Classes
    JobContextImpl → JobContext
  41. def getProfileTaskRange(arg0: Boolean): IntegerRanges
    Definition Classes
    JobContextImpl → JobContext
  42. def getProgress(): Float
    Definition Classes
    TaskAttemptContextImpl → TaskAttemptContext
  43. def getReducerClass(): Class[_ <: Reducer[_, _, _, _]]
    Definition Classes
    JobContextImpl → JobContext
    Annotations
    @throws( ... )
  44. def getSortComparator(): RawComparator[_]
    Definition Classes
    JobContextImpl → JobContext
  45. def getStatus(): String
    Definition Classes
    TaskAttemptContextImpl → TaskAttemptContext
  46. def getSymlink(): Boolean
    Definition Classes
    JobContextImpl → JobContext
  47. def getTaskAttemptID(): TaskAttemptID
    Definition Classes
    TaskAttemptContextImpl → TaskAttemptContext
  48. def getTaskCleanupNeeded(): Boolean
    Definition Classes
    JobContextImpl → JobContext
  49. def getUser(): String
    Definition Classes
    JobContextImpl → JobContext
  50. def getWorkingDirectory(): Path
    Definition Classes
    JobContextImpl → JobContext
    Annotations
    @throws( classOf[java.io.IOException] )
  51. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  52. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  53. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  54. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  55. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  56. val partitionColToDataType: Map[String, DataType]
  57. def progress(): Unit
    Definition Classes
    TaskAttemptContextImpl → Progressable
  58. def setJobID(arg0: JobID): Unit
    Definition Classes
    JobContextImpl
  59. def setStatus(arg0: String): Unit
    Definition Classes
    TaskAttemptContextImpl → TaskAttemptContext
  60. def setStatusString(arg0: String): Unit
    Attributes
    protected[task]
    Definition Classes
    TaskAttemptContextImpl
  61. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  62. def toString(): String
    Definition Classes
    TaskAttemptContextImpl → JobContextImpl → AnyRef → Any
  63. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  64. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  65. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] ) @Deprecated
    Deprecated

Inherited from TaskAttemptContextImpl

Inherited from TaskAttemptContext

Inherited from Progressable

Inherited from JobContextImpl

Inherited from JobContext

Inherited from MRJobConfig

Inherited from AnyRef

Inherited from Any

Ungrouped