T - query stage configuration classpublic abstract class QueryStageBase<T extends QueryStageConfig> extends java.lang.Object implements QueryStage<T>
@Stage(type = "myStage", configClass = MyStageConfig.class)
public class MyStage extends QueryStageBase<MyStageConfig> {
@Override
public QueryRequestAndResponse process(QueryRequestAndResponse query, Context context) {
// get configuration
String myBlobId = config.myBlobdId();
// call Fusion API methods
fusion.blobs().getBlobContent(myBlobId);
// further query processing logic
}
}
| Modifier and Type | Field and Description |
|---|---|
protected T |
config |
protected Fusion |
fusion |
| Constructor and Description |
|---|
QueryStageBase() |
| Modifier and Type | Method and Description |
|---|---|
void |
init(T config,
Fusion fusion)
Stage initialization callback.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitprocess, processprotected Fusion fusion
protected T extends QueryStageConfig config
public void init(T config, Fusion fusion)
QueryStageQueryStageConfig instance. Additionally Fusion
interface instance will be passed to allow calling Fusion API from the query stage.init in interface QueryStage<T extends QueryStageConfig>config - query pipeline stage configurationfusion - Fusion API instance