mergenode proprietà

Icona Unisci nodo 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"]])
Tabella 1. proprietà mergenode
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 Ascending
Descending
Specificare se, per impostazione predefinita, i record sono ordinati in ordine crescente o decrescente in base ai valori della chiave di ordinamento.