SelectFromCollection 클래스
DynamicFrameCollection에서 DynamicFrame 하나를 선택합니다.
예
이 예제에서는 SelectFromCollection을 사용하여 DynamicFrameCollection에서 DynamicFrame를 선택합니다.
예제 데이터 세트
예제에서는 split_rows_collection을 호출한 DynamicFrameCollection에서 두 개의 DynamicFrames을 선택합니다. 다음은 split_rows_collection에서의 키 목록입니다.
dict_keys(['high', 'low'])
예제 코드
# Example: Use SelectFromCollection to select # DynamicFrames from a DynamicFrameCollection from pyspark.context import SparkContext from awsglue.context import GlueContext from awsglue.transforms import SelectFromCollection # Create GlueContext sc = SparkContext.getOrCreate() glueContext = GlueContext(sc) # Select frames and inspect entries frame_low = SelectFromCollection.apply(dfc=split_rows_collection, key="low") frame_low.toDF().show() frame_high = SelectFromCollection.apply(dfc=split_rows_collection, key="high") frame_high.toDF().show()
+---+-----+------------------------+-------------------------+ | id|index|contact_details.val.type|contact_details.val.value| +---+-----+------------------------+-------------------------+ | 1| 0| fax| 202-225-3307| | 1| 1| phone| 202-225-5731| | 2| 0| fax| 202-225-3307| | 2| 1| phone| 202-225-5731| | 3| 0| fax| 202-225-3307| | 3| 1| phone| 202-225-5731| | 4| 0| fax| 202-225-3307| | 4| 1| phone| 202-225-5731| | 5| 0| fax| 202-225-3307| | 5| 1| phone| 202-225-5731| | 6| 0| fax| 202-225-3307| | 6| 1| phone| 202-225-5731| | 7| 0| fax| 202-225-3307| | 7| 1| phone| 202-225-5731| | 8| 0| fax| 202-225-3307| | 8| 1| phone| 202-225-5731| | 9| 0| fax| 202-225-3307| | 9| 1| phone| 202-225-5731| | 10| 0| fax| 202-225-6328| | 10| 1| phone| 202-225-4576| +---+-----+------------------------+-------------------------+ only showing top 20 rows +---+-----+------------------------+-------------------------+ | id|index|contact_details.val.type|contact_details.val.value| +---+-----+------------------------+-------------------------+ | 11| 0| fax| 202-225-6328| | 11| 1| phone| 202-225-4576| | 11| 2| twitter| RepTrentFranks| | 12| 0| fax| 202-225-6328| | 12| 1| phone| 202-225-4576| | 12| 2| twitter| RepTrentFranks| | 13| 0| fax| 202-225-6328| | 13| 1| phone| 202-225-4576| | 13| 2| twitter| RepTrentFranks| | 14| 0| fax| 202-225-6328| | 14| 1| phone| 202-225-4576| | 14| 2| twitter| RepTrentFranks| | 15| 0| fax| 202-225-6328| | 15| 1| phone| 202-225-4576| | 15| 2| twitter| RepTrentFranks| | 16| 0| fax| 202-225-6328| | 16| 1| phone| 202-225-4576| | 16| 2| twitter| RepTrentFranks| | 17| 0| fax| 202-225-6328| | 17| 1| phone| 202-225-4576| +---+-----+------------------------+-------------------------+ only showing top 20 rows
메서드
__call__(dfc, key, transformation_ctx = "")
DynamicFrameCollection에서 DynamicFrame 하나를 가져옵니다.
-
dfc–DynamicFrame을 선택해야 하는DynamicFrameCollection입니다(필수). -
key- 선택할DynamicFrame의 키입니다(필수). -
transformation_ctx- 고유 문자열을 통해 상태 정보를 확인합니다(선택 사항).
apply(cls, *args, **kwargs)
GlueTransform apply에서 상속됩니다.
name(cls)
GlueTransform name에서 상속됩니다.
describeArgs(cls)
GlueTransform describeArgs에서 상속됩니다.
describeReturn(cls)
GlueTransform describeReturn에서 상속됩니다.
describeTransform(cls)
GlueTransform describeTransform에서 상속됩니다.
describeErrors(cls)
GlueTransform describeErrors에서 상속됩니다.
describe(cls)
GlueTransform describe에서 상속됩니다.
