RemoveFieldRecordReader¶
Beschreibung¶
Ein Wrapper für eine RecordReaderFactory, die das Herausfiltern bestimmter Felder aus NiFi-Datensätzen unterstützt. Ermöglicht Benutzern, eine Liste von Feldnamen anzugeben, die beim Lesen von Datensätzen aus dem Record Reader ignoriert werden sollen, der von der eingeschlossenen RecordReaderFactory zurückgegeben wird. Die ignorierten Datensatzfelder werden als dynamische Eigenschaften angegeben. Es muss mindestens eine dynamische Eigenschaft festgelegt sein. Der Name der dynamischen Eigenschaft wird als Beschreibung des zu entfernenden Feldes verwendet, und der Wert der dynamischen Eigenschaft ist ein RecordPath, der das zu entfernende Feld identifiziert. Verschachtelte Pfade werden unterstützt. Datensatzpfade, die auf den Stammpfad („/“) zielen, sind nicht zulässig und führen zu einem Validierungsfehler. Dieser Service sollte verwendet werden, wenn alle der folgenden Kriterien erfüllt sind: - Ihre delegierte RecordReaderFactory ist so konfiguriert, dass das Schema aus den Daten abgeleitet wird - Sie haben kein statisches Schema für die Daten, die Sie lesen, oder möchten kein statisches Schema definieren - Die Felder, die Sie als ignoriert einstellen, sollen aus Sicherheits- oder Leistungsgründen nicht in das NiFi Inhalts-Repository serialisiert werden. Wenn eines der oben genannten Kriterien nicht erfüllt ist, sollten Sie stattdessen den RecordFieldRemover verwenden. NOTE: Der von dieser Implementierung zurückgegebene RecordReader ist hartcodiert, um unbekannte Felder zu löschen, anstatt sie zu ignorieren. Auch wenn die Methode nextRecord(coerceTypes, dropUnknownFields) des RecordReader mit dropUnknownFields auf „false“ gesetzt aufgerufen wird, löscht RecordReader weiterhin unbekannte Felder.
Eigenschaften¶
In der folgenden Liste sind die erforderlichen Eigenschaften mit einem Sternchen (*) gekennzeichnet. Andere Eigenschaften werden als optional betrachtet. Die Tabelle zeigt auch alle Standardwerte und ob eine Eigenschaft die NiFi Expression Language unterstützt.
Display Name (Anzeigename) |
API-Name |
Standardwert |
Zugelassene Werte |
Beschreibung |
|---|---|---|---|---|
Record Reader * |
Record Reader |
Der zugrunde liegende RecordReaderFactory-Service, der verwendet wird, um Datensätze zu lesen, bevor die Filterung angewendet wird. |
Statusmanagement¶
Diese Komponente speichert keinen Status.
Eingeschränkt¶
Diese Komponente ist nicht eingeschränkt.
Hinweise zu Systemressourcen¶
Diese Komponente enthält keine Angaben zu den Systemressourcen.