TypedAsyncJob<Row[]> |
DataFrameAsyncActor.collect() |
Executes DataFrame.collect asynchronously.
|
TypedAsyncJob<MergeResult> |
MergeBuilderAsyncActor.collect() |
Executes `MergeBuilder.collect()` asynchronously.
|
TypedAsyncJob<Void> |
CopyableDataFrameAsyncActor.copyInto(String tableName) |
Executes `CopyableDataFrame.copyInto` asynchronously.
|
TypedAsyncJob<Void> |
CopyableDataFrameAsyncActor.copyInto(String tableName,
Column[] transformations) |
Executes `CopyableDataFrame.copyInto` asynchronously.
|
TypedAsyncJob<Void> |
CopyableDataFrameAsyncActor.copyInto(String tableName,
Column[] transformations,
Map<String,?> options) |
Executes `CopyableDataFrame.copyInto` asynchronously.
|
TypedAsyncJob<Void> |
CopyableDataFrameAsyncActor.copyInto(String tableName,
String[] targetColumnNames,
Column[] transformations,
Map<String,?> options) |
Executes `CopyableDataFrame.copyInto` asynchronously.
|
TypedAsyncJob<Long> |
DataFrameAsyncActor.count() |
Executes DataFrame.count asynchronously.
|
TypedAsyncJob<WriteFileResult> |
DataFrameWriterAsyncActor.csv(String path) |
Executes `DataFrameWriter.csv()` asynchronously.
|
TypedAsyncJob<DeleteResult> |
UpdatableAsyncActor.delete() |
Executes `Updatable.delete` asynchronously.
|
TypedAsyncJob<DeleteResult> |
UpdatableAsyncActor.delete(Column condition) |
Executes `Updatable.delete` asynchronously.
|
TypedAsyncJob<DeleteResult> |
UpdatableAsyncActor.delete(Column condition,
DataFrame sourceData) |
Executes `Updatable.delete` asynchronously.
|
TypedAsyncJob<WriteFileResult> |
DataFrameWriterAsyncActor.json(String path) |
Executes `DataFrameWriter.json()` asynchronously.
|
TypedAsyncJob<WriteFileResult> |
DataFrameWriterAsyncActor.parquet(String path) |
Executes `DataFrameWriter.parquet()` asynchronously.
|
TypedAsyncJob<Void> |
DataFrameWriterAsyncActor.saveAsTable(String tableName) |
Executes `DataFrameWriter.saveAsTable` asynchronously.
|
TypedAsyncJob<Void> |
DataFrameWriterAsyncActor.saveAsTable(String[] multipartIdentifier) |
Executes `DataFrameWriter.saveAsTable` asynchronously.
|
TypedAsyncJob<Iterator<Row>> |
DataFrameAsyncActor.toLocalIterator() |
Executes DataFrame.toLocalIterator asynchronously.
|
TypedAsyncJob<UpdateResult> |
UpdatableAsyncActor.update(Map<Column,Column> assignments) |
Executes `Updatable.update` asynchronously.
|
TypedAsyncJob<UpdateResult> |
UpdatableAsyncActor.update(Map<Column,Column> assignments,
Column condition) |
Executes `Updatable.update` asynchronously.
|
TypedAsyncJob<UpdateResult> |
UpdatableAsyncActor.update(Map<Column,Column> assignments,
Column condition,
DataFrame sourceData) |
Executes `Updatable.update` asynchronously.
|
TypedAsyncJob<UpdateResult> |
UpdatableAsyncActor.updateColumn(Map<String,Column> assignments) |
Executes `Updatable.update` asynchronously.
|
TypedAsyncJob<UpdateResult> |
UpdatableAsyncActor.updateColumn(Map<String,Column> assignments,
Column condition) |
Executes `Updatable.update` asynchronously.
|
TypedAsyncJob<UpdateResult> |
UpdatableAsyncActor.updateColumn(Map<String,Column> assignments,
Column condition,
DataFrame sourceData) |
Executes `Updatable.update` asynchronously.
|