Skip to content

Commit

Permalink
rename example file
Browse files Browse the repository at this point in the history
  • Loading branch information
emgeee committed Sep 23, 2024
1 parent 3dcf5e5 commit ae29426
Showing 1 changed file with 2 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -25,18 +25,14 @@ def signal_handler(sig, frame):
"reading": 0.0,
}


def gt(array: pa.Scalar, v: pa.Array) -> pa.Array:
return pc.greater(array, v)

def gt(lhs: pa.Array, rhs: pa.Scalar) -> pa.Array:
return pc.greater(lhs, rhs)

greater_than_udf = udf(gt, [pa.float64(), pa.float64()], pa.bool_(), "stable")


def sample_sink_func(rb: pa.RecordBatch):
if not len(rb):
return
print("==")
print(rb)


Expand Down

0 comments on commit ae29426

Please sign in to comment.