|
6 | 6 | import numpy.typing as npt |
7 | 7 | from numpy import array # noqa: F401 |
8 | 8 |
|
9 | | -NDArray = npt.NDArray |
10 | | - |
11 | | -StringArray = StrArray = npt.NDArray[np.str_] |
12 | | -BytesArray = npt.NDArray[np.bytes_] |
13 | | -Float16Array = HalfArray = npt.NDArray[np.float16] |
14 | | -Float32Array = FloatArray = npt.NDArray[np.float32] |
15 | | -Float64Array = DoubleArray = npt.NDArray[np.float64] |
16 | | -IntArray = npt.NDArray[np.int_] |
17 | | -Int8Array = npt.NDArray[np.int8] |
18 | | -Int16Array = npt.NDArray[np.int16] |
19 | | -Int32Array = npt.NDArray[np.int32] |
20 | | -Int64Array = npt.NDArray[np.int64] |
21 | | -UInt8Array = npt.NDArray[np.uint8] |
22 | | -UInt16Array = npt.NDArray[np.uint16] |
23 | | -UInt32Array = npt.NDArray[np.uint32] |
24 | | -UInt64Array = npt.NDArray[np.uint64] |
25 | | -DateTimeArray = npt.NDArray[np.datetime64] |
26 | | -TimeDeltaArray = npt.NDArray[np.timedelta64] |
27 | | -JSONArray = npt.NDArray[np.object_] |
28 | | -======= |
29 | 9 | try: |
30 | 10 | from typing import TypeAlias # type: ignore |
31 | 11 | except ImportError: |
|
48 | 28 | npt.NDArray[np.bytes_], UDFAttrs(sql_type=sql_types.BLOB(nullable=False)), |
49 | 29 | ] |
50 | 30 |
|
| 31 | +Float16Array: TypeAlias = Annotated[ |
| 32 | + npt.NDArray[np.float16], UDFAttrs(sql_type=sql_types.FLOAT16(nullable=False)), |
| 33 | +] |
| 34 | +HalfArray: TypeAlias = Float16Array |
| 35 | + |
51 | 36 | Float32Array: TypeAlias = Annotated[ |
52 | 37 | npt.NDArray[np.float32], UDFAttrs(sql_type=sql_types.FLOAT(nullable=False)), |
53 | 38 | ] |
@@ -128,4 +113,3 @@ def default(self, obj: Any) -> Any: |
128 | 113 |
|
129 | 114 |
|
130 | 115 | __all__ = ['array'] + [x for x in globals().keys() if x.endswith('Array')] |
131 | | ->>>>>>> fd486846 (Implement transformers for UDF inputs and outputs) |
0 commit comments