JOIN_KEY- type of the join key
INPUT_RECORD- type of input records to be joined
OUT- type of output object
@Beta public interface Joiner<JOIN_KEY,INPUT_RECORD,OUT>
|Modifier and Type||Method and Description|
Creates join configuration which holds information about required inputs which are needed to decide type of the join and produce join result.
Return value for the join key on which join will be performed
Merges records present in joinResult and returns merged output.
JOIN_KEY joinOn(String stageName, INPUT_RECORD inputRecord) throws Exception
stageName- name of the stage to which records belongs to
inputRecord- input record to be joined
Exception- if there is some error getting the join key
JoinConfig getJoinConfig() throws Exception
OUT merge(JOIN_KEY joinKey, Iterable<JoinElement<INPUT_RECORD>> joinResult) throws Exception
joinKey- join key on which join needs to be performed
joinResult- list of
JoinElementwhich will be used to create merged output. It will have all the records after performing join operation
Exception- if there is some error while creating merged output
Copyright © 2017 Cask Data, Inc. Licensed under the Apache License, Version 2.0.