Name client = emitClient(compiledSlots, key, value, grouping, ordering, outputLocation);
LOG.debug("Finish preparing output stage for Direct I/O epilogue: batch={}, flow={}, class={}", new Object[] {
environment.getBatchId(),
environment.getFlowId(),
client.toNameString(),
});
return new CompiledStage(client, Naming.getEpilogueName(moduleId));
}
private CompiledStage emitClientWithoutReducer(List<Slot> slots, Location outputLocation) throws IOException {