var newRequest = new Entity( sourceRequest.LogicalName, Guid.Empty) { Attributes = new AttributeCollection(sourceRequest.Attributes) }; foreach (string field in ExcludedFields) { newRequest.Attributes.Remove(field); }
fff
import pyspark.sql.functions as F
spark = ... # initialization
df = spark.table("a").where(F.col("country") == "abc")
df_unique = df.distinct()
users_without_kids = df_unique.where(F.col("kid_count") == 0)
obser = Observation()
observed_df = users_without_kids.observe(observation, F.count(F.lit(1)).alias("row_count"))
observed_df.writeTo("b")
print(observation.get["row_count"])Lorem ipsum dolor sit amet, consectetur adipiscing elit. Ut elit tellus, luctus nec ullamcorper mattis, pulvinar dapibus leo.