@Test public void testAbortJob() throws IOException { committer.abortJob(mockTaskAttemptContext, State.KILLED); verify(mockCommitter).abortJob(eq(mockTaskAttemptContext), eq(State.KILLED)); }
@Override public void abortJob(JobContext context, State state) throws IOException { delegate.abortJob(context, state); }
ForwardingBigQueryFileOutputCommitter extends OutputCommitter { @Override public void abortJob(JobContext context, State state) throws IOException { delegate.abortJob(context, state); } }
ForwardingBigQueryFileOutputCommitter extends OutputCommitter { @Override public void abortJob(JobContext context, State state) throws IOException { delegate.abortJob(context, state); } ForwardingBigQueryFileOutputCommitter(TaskAttemptContext context, OutputCommitter delegate); }
ForwardingBigQueryFileOutputCommitter extends OutputCommitter { @Override public void abortJob(JobContext context, State state) throws IOException { delegate.abortJob(context, state); } ForwardingBigQueryFileOutputCommitter(TaskAttemptContext context, OutputCommitter delegate); @Override void commitJob(JobContext context); @Override void abortJob(JobContext context, State state); @Override void abortTask(TaskAttemptContext context); @Override void commitTask(TaskAttemptContext context); @Override boolean needsTaskCommit(TaskAttemptContext context); @Override void setupJob(JobContext context); @Override void setupTask(TaskAttemptContext context); }
ForwardingBigQueryFileOutputCommitter extends OutputCommitter { @Override public void abortJob(JobContext context, State state) throws IOException { delegate.abortJob(context, state); } ForwardingBigQueryFileOutputCommitter(TaskAttemptContext context, OutputCommitter delegate); @Override void commitJob(JobContext context); @Override void abortJob(JobContext context, State state); @Override void abortTask(TaskAttemptContext context); @Override void commitTask(TaskAttemptContext context); @Override boolean needsTaskCommit(TaskAttemptContext context); @Override void setupJob(JobContext context); @Override void setupTask(TaskAttemptContext context);  }