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, wait
process, process
protected Fusion fusion
protected T extends QueryStageConfig config
public void init(T config, Fusion fusion)
QueryStage
QueryStageConfig
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