KOSASIH / Galactic-Chain

Re-defined variable from outer scope PYL-W0621
Anti-pattern
Major
4 months ago4 months old
Redefining name 'data' from outer scope (line 19)
 5    def __init__(self, spark):
 6        self.spark = spark
 7
 8    def process_data(self, data): 9        # Process the data using Spark Structured Streaming
10        # For example, calculate the average value of the data
11        df = self.spark.createDataFrame(data, ["value"])
Redefining name 'spark' from outer scope (line 17)
 2from pyspark.sql.functions import col, avg
 3
 4class SparkStructuredStreamingProcessor:
 5    def __init__(self, spark): 6        self.spark = spark
 7
 8    def process_data(self, data):
Redefining name 'data' from outer scope (line 17)
 4    def __init__(self, sc):
 5        self.sc = sc
 6
 7    def process_data(self, data): 8        # Process the data using Spark Streaming
 9        # For example, calculate the average value of the data
10        stream = self.sc.parallelize(data)
Redefining name 'sc' from outer scope (line 15)
 1from pyspark.streaming import StreamingContext
 2
 3class SparkStreamingProcessor:
 4    def __init__(self, sc): 5        self.sc = sc
 6
 7    def process_data(self, data):
Redefining name 'data' from outer scope (line 20)
 5    def __init__(self, buffer_size=1000):
 6        self.buffer = deque(maxlen=buffer_size)
 7
 8    def process_data(self, data): 9        # Process the data in real-time
10        # For example, calculate the average value of the data
11        self.buffer.append(data)