Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.
Filterklasse
Erstellt einen neuen DynamicFrame
, der Datensätzen aus der Eingabe DynamicFrame
enthält, die eine angegebene Prädikat-Funktion erfüllen.
Beispiel
Wir empfehlen Ihnen, die DynamicFrame.filter()-Methode zum Filtern von Datensätzen aus einem DynamicFrame
zu verwenden. Code-Beispiele finden Sie unter Beispiel: Verwenden Sie Filter, um eine gefilterte Auswahl von Feldern zu erhalten.
Methoden
__call__(frame, f, transformation_ctx="", info="", stageThreshold=0, totalThreshold=0))
Gibt einen neuen DynamicFrame
zurück, der durch Auswahl von Datensätzen aus dem Eingabe-DynamicFrame
erstellt wurde, der eine angegebene Prädikat-Funktion erfüllt.
frame
– Der Quell-DynamicFrame
, auf den die angegebene Filterfunktion angewendet werden soll (erforderlich).-
f
– Die Prädikatfunktion, die auf jedenDynamicRecord
imDynamicFrame
angewendet werden soll. Die Funktion muss einenDynamicRecord
als Argument enthalten und "True" zurückgeben, wenn derDynamicRecord
die Filteranforderungen erfüllt, oder andernfalls "False" (erforderlich).Ein
DynamicRecord
stellt einen logischen Datensatz in einemDynamicFrame
dar. Er ist mit einer Zeile in einem SparkDataFrame
vergleichbar, mit der Ausnahme, dass er selbstbeschreibend ist und für Daten verwendet werden kann, die keinem festen Schema entsprechen. transformation_ctx
– Eine eindeutige Zeichenfolge zur Identifikation von Statusinformationen (optional).info
– Eine Zeichenfolge, die mit Fehlern in der Transformation im Zusammenhang steht (optional).stageThreshold
– Die maximale Anzahl von Fehlern, die in der Transformation auftreten dürfen, bevor der Vorgang abgebrochen wird (optional). Der Standardwert ist „Null“.totalThreshold
– Die maximale Anzahl von Fehlern, die insgesamt auftreten dürfen, bevor die Verarbeitung abgebrochen wird (optional). Der Standardwert ist „Null“.
apply(cls, *args, **kwargs)
Geerbt von GlueTransform
apply.
name(cls)
Geerbt von GlueTransform
Name.
describeArgs(cls)
Geerbt von GlueTransform
describeArgs.
describeReturn(cls)
Geerbt von GlueTransform
describeReturn.
describeTransform(cls)
Geerbt von GlueTransform
describeTransform.
describeErrors(cls)
Geerbt von GlueTransform
describeErrors.
describe(cls)
Geerbt von GlueTransform
Beschreiben.