| Package | Description |
|---|---|
| com.snowflake.snowpark_java |
Provides most of the classes for the Snowpark Java API.
|
| com.snowflake.snowpark_java.udtf |
| Modifier and Type | Method and Description |
|---|---|
Row |
Row.clone()
Creates a clone of this
Row object. |
Row[] |
DataFrame.collect()
Executes the query representing this DataFrame and returns the result as an array of Row
objects.
|
static Row |
Row.create(Object... values)
Creates a
Row based on the given values. |
Row[] |
DataFrame.first(int n)
Executes the query representing this DataFrame and returns the first
n rows of the
results. |
Row[] |
AsyncJob.getRows()
Returns an Array of Row objects that represent the results of the underlying query.
|
Row[] |
AsyncJob.getRows(int maxWaitTimeInSeconds)
Returns an Array of Row objects that represent the results of the underlying query.
|
| Modifier and Type | Method and Description |
|---|---|
Optional<Row> |
DataFrame.first()
Executes the query representing this DataFrame and returns the first row of results.
|
Iterator<Row> |
AsyncJob.getIterator()
Returns an iterator of Row objects that you can use to retrieve the results for the underlying
query.
|
Iterator<Row> |
AsyncJob.getIterator(int maxWaitTimeInSeconds)
Returns an iterator of Row objects that you can use to retrieve the results for the underlying
query.
|
TypedAsyncJob<Iterator<Row>> |
DataFrameAsyncActor.toLocalIterator()
Executes
DataFrame.toLocalIterator asynchronously. |
Iterator<Row> |
DataFrame.toLocalIterator()
Executes the query representing this DataFrame and returns an iterator of Row objects that you
can use to retrieve the results.
|
| Modifier and Type | Method and Description |
|---|---|
DataFrame |
Session.createDataFrame(Row[] data,
StructType schema)
Creates a new DataFrame that uses the specified schema and contains the specified Row objects.
|
| Modifier and Type | Method and Description |
|---|---|
Stream<Row> |
JavaUDTF.endPartition() |
Stream<Row> |
JavaUDTF0.process() |
Stream<Row> |
JavaUDTF1.process(A0 arg0) |
Stream<Row> |
JavaUDTF2.process(A0 arg0,
A1 arg1) |
Stream<Row> |
JavaUDTF3.process(A0 arg0,
A1 arg1,
A2 arg2) |
Stream<Row> |
JavaUDTF4.process(A0 arg0,
A1 arg1,
A2 arg2,
A3 arg3) |
Stream<Row> |
JavaUDTF5.process(A0 arg0,
A1 arg1,
A2 arg2,
A3 arg3,
A4 arg4) |
Stream<Row> |
JavaUDTF6.process(A0 arg0,
A1 arg1,
A2 arg2,
A3 arg3,
A4 arg4,
A5 arg5) |
Stream<Row> |
JavaUDTF7.process(A0 arg0,
A1 arg1,
A2 arg2,
A3 arg3,
A4 arg4,
A5 arg5,
A6 arg6) |
Stream<Row> |
JavaUDTF8.process(A0 arg0,
A1 arg1,
A2 arg2,
A3 arg3,
A4 arg4,
A5 arg5,
A6 arg6,
A7 arg7) |
Stream<Row> |
JavaUDTF9.process(A0 arg0,
A1 arg1,
A2 arg2,
A3 arg3,
A4 arg4,
A5 arg5,
A6 arg6,
A7 arg7,
A8 arg8) |
Stream<Row> |
JavaUDTF10.process(A0 arg0,
A1 arg1,
A2 arg2,
A3 arg3,
A4 arg4,
A5 arg5,
A6 arg6,
A7 arg7,
A8 arg8,
A9 arg9) |
Stream<Row> |
JavaUDTF11.process(A0 arg0,
A1 arg1,
A2 arg2,
A3 arg3,
A4 arg4,
A5 arg5,
A6 arg6,
A7 arg7,
A8 arg8,
A9 arg9,
A10 arg10) |
Stream<Row> |
JavaUDTF12.process(A0 arg0,
A1 arg1,
A2 arg2,
A3 arg3,
A4 arg4,
A5 arg5,
A6 arg6,
A7 arg7,
A8 arg8,
A9 arg9,
A10 arg10,
A11 arg11) |
Stream<Row> |
JavaUDTF13.process(A0 arg0,
A1 arg1,
A2 arg2,
A3 arg3,
A4 arg4,
A5 arg5,
A6 arg6,
A7 arg7,
A8 arg8,
A9 arg9,
A10 arg10,
A11 arg11,
A12 arg12) |
Stream<Row> |
JavaUDTF14.process(A0 arg0,
A1 arg1,
A2 arg2,
A3 arg3,
A4 arg4,
A5 arg5,
A6 arg6,
A7 arg7,
A8 arg8,
A9 arg9,
A10 arg10,
A11 arg11,
A12 arg12,
A13 arg13) |
Stream<Row> |
JavaUDTF15.process(A0 arg0,
A1 arg1,
A2 arg2,
A3 arg3,
A4 arg4,
A5 arg5,
A6 arg6,
A7 arg7,
A8 arg8,
A9 arg9,
A10 arg10,
A11 arg11,
A12 arg12,
A13 arg13,
A14 arg14) |
Stream<Row> |
JavaUDTF16.process(A0 arg0,
A1 arg1,
A2 arg2,
A3 arg3,
A4 arg4,
A5 arg5,
A6 arg6,
A7 arg7,
A8 arg8,
A9 arg9,
A10 arg10,
A11 arg11,
A12 arg12,
A13 arg13,
A14 arg14,
A15 arg15) |
Stream<Row> |
JavaUDTF17.process(A0 arg0,
A1 arg1,
A2 arg2,
A3 arg3,
A4 arg4,
A5 arg5,
A6 arg6,
A7 arg7,
A8 arg8,
A9 arg9,
A10 arg10,
A11 arg11,
A12 arg12,
A13 arg13,
A14 arg14,
A15 arg15,
A16 arg16) |
Stream<Row> |
JavaUDTF18.process(A0 arg0,
A1 arg1,
A2 arg2,
A3 arg3,
A4 arg4,
A5 arg5,
A6 arg6,
A7 arg7,
A8 arg8,
A9 arg9,
A10 arg10,
A11 arg11,
A12 arg12,
A13 arg13,
A14 arg14,
A15 arg15,
A16 arg16,
A17 arg17) |
Stream<Row> |
JavaUDTF19.process(A0 arg0,
A1 arg1,
A2 arg2,
A3 arg3,
A4 arg4,
A5 arg5,
A6 arg6,
A7 arg7,
A8 arg8,
A9 arg9,
A10 arg10,
A11 arg11,
A12 arg12,
A13 arg13,
A14 arg14,
A15 arg15,
A16 arg16,
A17 arg17,
A18 arg18) |
Stream<Row> |
JavaUDTF20.process(A0 arg0,
A1 arg1,
A2 arg2,
A3 arg3,
A4 arg4,
A5 arg5,
A6 arg6,
A7 arg7,
A8 arg8,
A9 arg9,
A10 arg10,
A11 arg11,
A12 arg12,
A13 arg13,
A14 arg14,
A15 arg15,
A16 arg16,
A17 arg17,
A18 arg18,
A19 arg19) |
Stream<Row> |
JavaUDTF21.process(A0 arg0,
A1 arg1,
A2 arg2,
A3 arg3,
A4 arg4,
A5 arg5,
A6 arg6,
A7 arg7,
A8 arg8,
A9 arg9,
A10 arg10,
A11 arg11,
A12 arg12,
A13 arg13,
A14 arg14,
A15 arg15,
A16 arg16,
A17 arg17,
A18 arg18,
A19 arg19,
A20 arg20) |
Stream<Row> |
JavaUDTF22.process(A0 arg0,
A1 arg1,
A2 arg2,
A3 arg3,
A4 arg4,
A5 arg5,
A6 arg6,
A7 arg7,
A8 arg8,
A9 arg9,
A10 arg10,
A11 arg11,
A12 arg12,
A13 arg13,
A14 arg14,
A15 arg15,
A16 arg16,
A17 arg17,
A18 arg18,
A19 arg19,
A20 arg20,
A21 arg21) |
© 2022 Snowflake Inc. All Rights Reserved