Re: I want to apply external function on streaming data

I have external function scaler1 = MinMaxScaler(feature_range=(-1, 1)) def difference(dataset, interval=1): diff = list() for i in range(interval, len(dataset)): value = dataset[i] - dataset[i - interval] diff.append(value) return Series(diff)

Re: I want to apply external function on streaming data

Can any one help me please -- Sent from: http://apache-spark-developers-list.1001551.n3.nabble.com/ - To unsubscribe e-mail: dev-unsubscr...@spark.apache.org