Neeraj Bhadani NeerajBhadani

## win_rowsBetween_agg.scala
val rows_between_df = empsalary.withColumn("max_salary", max("salary").over(winSpec))

rows_between_df.show()

## win_rowsBetween_spec.scala
val winSpec = Window.partitionBy("depName")
            .orderBy("salary").rowsBetween(-1, 1)

## win_rangeBetween_agg_boundary.scala
val winSpec = Window.partitionBy("depName").orderBy("salary")
             .rangeBetween(300L, Window.unboundedFollowing)

val range_unbounded_df = empsalary.withColumn("max_salary", max("salary").over(winSpec))

range_unbounded_df.show()

## win_rangeBetween_agg.scala
val range_between_df = empsalary.withColumn("max_salary", max("salary").over(winSpec))

range_between_df.show()

## win_rangeBetween.scala
val winSpec = Window.partitionBy("depName")
          .orderBy("salary")
          .rangeBetween(100L, 300L)

## win_lead.scala
val winSpec = Window.partitionBy("depName").orderBy("salary")

val lead_df =
          empsalary.withColumn("lead", lead("salary", 2).over(winSpec))

lead_df.show()

## win_lag.scala
val winSpec = Window.partitionBy("depName").orderBy("salary")

val lag_df =
          empsalary.withColumn("lag", lag("salary", 2).over(winSpec))

lag_df.show()

## win_cume_dist.scala
val winSpec = Window.partitionBy("depName").orderBy("salary")

val cume_dist_df =
              empsalary.withColumn("cume_dist",cume_dist().over(winSpec))

cume_dist_df.show()

## win_ntile.scala
val ntile_df = empsalary.withColumn("ntile", ntile(3).over(winSpec))

ntile_df.show()

## win_percent_rank.scala
val percent_rank_df = empsalary.withColumn("percent_rank", percent_rank().over(winSpec))

percent_rank_df.show()
	val rows_between_df = empsalary.withColumn("max_salary", max("salary").over(winSpec))

	rows_between_df.show()
	val winSpec = Window.partitionBy("depName")
	.orderBy("salary").rowsBetween(-1, 1)
	val winSpec = Window.partitionBy("depName").orderBy("salary")
	.rangeBetween(300L, Window.unboundedFollowing)

	val range_unbounded_df = empsalary.withColumn("max_salary", max("salary").over(winSpec))

	range_unbounded_df.show()
	val range_between_df = empsalary.withColumn("max_salary", max("salary").over(winSpec))

	range_between_df.show()
	val winSpec = Window.partitionBy("depName")
	.orderBy("salary")
	.rangeBetween(100L, 300L)
	val winSpec = Window.partitionBy("depName").orderBy("salary")

	val lead_df =
	empsalary.withColumn("lead", lead("salary", 2).over(winSpec))

	lead_df.show()
	val winSpec = Window.partitionBy("depName").orderBy("salary")

	val lag_df =
	empsalary.withColumn("lag", lag("salary", 2).over(winSpec))

	lag_df.show()
	val winSpec = Window.partitionBy("depName").orderBy("salary")

	val cume_dist_df =
	empsalary.withColumn("cume_dist",cume_dist().over(winSpec))

	cume_dist_df.show()
	val ntile_df = empsalary.withColumn("ntile", ntile(3).over(winSpec))

	ntile_df.show()
	val percent_rank_df = empsalary.withColumn("percent_rank", percent_rank().over(winSpec))

	percent_rank_df.show()