JoinedInjectionExecutor.java

                    context
                            .getEntryJoiner()
                            .join(
                                    entriesFromFlow(
                                            request.getFlowDefinitionA(),
                                            request.getInjectionFlowA(),
                                            request.getFlowDefinition().getInjectionConfiguration().getFlowAMatching(),
                                            context
                                    ),
                                    entriesFromFlow(
                                            request.getFlowDefinitionB(),
                                            request.getInjectionFlowB(),
                                            request.getFlowDefinition().getInjectionConfiguration().getFlowBMatching(),
                                            context
                                    )
                            )
                            .mapToPair(
                                    context.getEntryMerger()
                            )
                            .filter(Objects::nonNull)
                            .leftOuterJoin(
                                    existingEntries(context)
                            )
                            .map(
                                    context.getCollisionResolver()
                            )
                            .filter(Objects::nonNull)
                            .flatMapToPair(
                                    context.getFlowEntryToHBaseRowConverter()
                            )
                            .saveAsNewAPIHadoopFile(
                                    FlowExecutorUtils.TABLE,
                                    ImmutableBytesWritable.class,
                                    Result.class,
                                    TableOutputFormat.class,
                                    context.getConfiguration()
                            );