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