@ Override protected final QueryResult executeWorkFlow ( LogicalWorkflow workflow ) throws ConnectorException { checkIsSupported ( workflow ) ; ClusterName clusterName = ( ( Project ) workflow . getInitialSteps ( ) . get ( 0 ) ) . getClusterName ( ) ; return execute ( ( Project ) workflow . getInitialSteps ( ) . get ( 0 ) , connectionHandler . getConnection ( clusterName . getName ( ) ) ) ; }
This method execute a query with only a project .