mergenode proprietà
Il nodo Merge prende più record di input e crea un unico record di output contenente alcuni o tutti i campi di input. È utile per unire i dati da diverse fonti, come i dati dei clienti interni e i dati demografici acquistati.
Esempio
node = stream.create("merge", "My node")
# assume customerdata and salesdata are configured database import nodes
stream.link(customerdata, node)
stream.link(salesdata, node)
node.setPropertyValue("method", "Keys")
node.setPropertyValue("key_fields", ["id"])
node.setPropertyValue("common_keys", True)
node.setPropertyValue("join", "PartialOuter")
node.setKeyedPropertyValue("outer_join_tag", "2", True)
node.setKeyedPropertyValue("outer_join_tag", "4", True)
node.setPropertyValue("single_large_input", True)
node.setPropertyValue("single_large_input_tag", "2")
node.setPropertyValue("use_existing_sort_keys", True)
node.setPropertyValue("existing_sort_keys", [["id", "Ascending"]])
mergenode Proprietà |
Tipo di dati | Descrizione proprietà |
|---|---|---|
method |
Order Keys Condition Rankedcondition |
Specificare se i record vengono uniti nell'ordine in cui sono elencati nei file di dati, se uno o più campi chiave verranno utilizzati per unire i record con lo stesso valore nei campi chiave, se i record verranno uniti se viene soddisfatta una condizione specifica, o se ogni coppia di righe nel set di dati primario e in tutti i set di dati secondari deve essere unita; utilizzando l'espressione di classificazione per ordinare eventuali corrispondenze multiple in ordine da basso ad alto. |
condition |
stringa | Se method è impostato su Condition, specifica la condizione per includere o scartare i record. |
key_fields |
elenco | |
common_keys |
indicatore | |
join |
Inner FullOuter PartialOuter Anti |
|
outer_join_tag.n |
indicatore | In questa proprietà, n è il nome tag come visualizzato nelle proprietà del nodo. Si noti che è possibile specificare più nomi di tag, poiché un numero qualsiasi di set di dati potrebbe contribuire a record incompleti. |
single_large_input |
indicatore | Specifica se verrà utilizzata l'ottimizzazione per avere un ingresso relativamente grande rispetto agli altri ingressi. |
single_large_input_tag |
stringa | Specifica il nome tag come visualizzato nelle proprietà della nota. Si noti che l'uso di questa proprietà differisce leggermente dalla proprietà " outer_join_tag " (flag rispetto a stringa) perché è possibile specificare un solo set di dati di input. |
use_existing_sort_keys |
indicatore | Specifica se gli input sono già ordinati in base a uno o più campi chiave. |
existing_sort_keys |
[['string ', 'Ascending'] \ ['string' ', 'Descending']] |
Specifica i campi già ordinati e la direzione in cui sono ordinati. |
primary_dataset |
stringa | Se method è Rankedcondition, selezionare il set di dati primario nella fusione. Questo può essere considerato come il lato sinistro di un'unione di giunzione esterna. |
rename_duplicate_fields |
booleano | Se method è Rankedcondition e questo è impostato su Y, se il set di dati risultante contiene più campi con lo stesso nome provenienti da fonti di dati diverse, i rispettivi tag delle fonti di dati vengono aggiunti all'inizio delle intestazioni delle colonne dei campi. |
merge_condition |
stringa | |
ranking_expression |
stringa | |
Num_matches |
intero | Il numero di partite da restituire, in base all' merge_condition e ranking_expression. Minimo 1, massimo 100. |
default_sort_order |
AscendingDescending |
Specificare se, per impostazione predefinita, i record sono ordinati in ordine crescente o decrescente in base ai valori della chiave di ordinamento. |