| Package | Description |
|---|---|
| co.cask.cdap.etl.spark.streaming.function |
| Constructor and Description |
|---|
DynamicAggregatorAggregate(DynamicDriverContext dynamicDriverContext) |
DynamicAggregatorGroupBy(DynamicDriverContext dynamicDriverContext) |
DynamicJoinMerge(DynamicDriverContext dynamicDriverContext) |
DynamicJoinOn(DynamicDriverContext dynamicDriverContext,
String inputStageName) |
DynamicSparkCompute(DynamicDriverContext dynamicDriverContext,
SparkCompute<T,U> compute) |
DynamicTransform(DynamicDriverContext dynamicDriverContext,
boolean isMultiOutput) |
Copyright © 2018 Cask Data, Inc. Licensed under the Apache License, Version 2.0.