public class SparkHadoopMapRedUtil
extends Object
Constructor and Description |
---|
SparkHadoopMapRedUtil() |
Modifier and Type | Method and Description |
---|---|
static void |
commitTask(org.apache.hadoop.mapreduce.OutputCommitter committer,
org.apache.hadoop.mapreduce.TaskAttemptContext mrTaskContext,
int jobId,
int splitId)
Commits a task output.
|
static void |
initializeForcefully(boolean isInterpreter,
boolean silent) |
static void |
org$apache$spark$internal$Logging$$log__$eq(org.slf4j.Logger x$1) |
static org.slf4j.Logger |
org$apache$spark$internal$Logging$$log_() |
public static void commitTask(org.apache.hadoop.mapreduce.OutputCommitter committer, org.apache.hadoop.mapreduce.TaskAttemptContext mrTaskContext, int jobId, int splitId)
Output commit coordinator is only used when spark.hadoop.outputCommitCoordination.enabled
is set to true (which is the default).
committer
- (undocumented)mrTaskContext
- (undocumented)jobId
- (undocumented)splitId
- (undocumented)public static org.slf4j.Logger org$apache$spark$internal$Logging$$log_()
public static void org$apache$spark$internal$Logging$$log__$eq(org.slf4j.Logger x$1)
public static void initializeForcefully(boolean isInterpreter, boolean silent)