c
net.sansa_stack.query.flink.sparqlify
QueryExecutionSparqlifyFlink
Companion object QueryExecutionSparqlifyFlink
class QueryExecutionSparqlifyFlink extends QueryExecutionBaseSelect
Created by Simon Bin on 12/06/17.
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- QueryExecutionSparqlifyFlink
- QueryExecutionBaseSelect
- QueryExecutionDecorator
- QueryExecutionDecoratorBase
- QueryExecution
- AutoCloseable
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Instance Constructors
- new QueryExecutionSparqlifyFlink(query: Query, subFactory: QueryExecutionFactory, sparqlSqlRewriter: SparqlSqlStringRewriter, flinkEnv: ExecutionEnvironment, flinkTable: BatchTableEnvironment)
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
abort(): Unit
- Definition Classes
- QueryExecutionDecoratorBase → QueryExecution
-
def
afterExec(): Unit
- Attributes
- protected[core]
- Definition Classes
- QueryExecutionDecoratorBase
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
beforeExec(): Unit
- Attributes
- protected[core]
- Definition Classes
- QueryExecutionDecoratorBase
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
def
close(): Unit
- Definition Classes
- QueryExecutionDecoratorBase → QueryExecution → AutoCloseable
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
execAsk(): Boolean
- Definition Classes
- QueryExecutionBaseSelect → QueryExecutionDecoratorBase → QueryExecution
-
def
execConstruct(): Model
- Definition Classes
- QueryExecutionBaseSelect → QueryExecutionDecoratorBase → QueryExecution
-
def
execConstruct(arg0: Model): Model
- Definition Classes
- QueryExecutionBaseSelect → QueryExecutionDecoratorBase → QueryExecution
-
def
execConstructDataset(arg0: Dataset): Dataset
- Definition Classes
- QueryExecutionDecoratorBase → QueryExecution
-
def
execConstructDataset(): Dataset
- Definition Classes
- QueryExecutionDecoratorBase → QueryExecution
-
def
execConstructQuads(): Iterator[Quad]
- Definition Classes
- QueryExecutionDecoratorBase → QueryExecution
-
def
execConstructTriples(): Iterator[Triple]
- Definition Classes
- QueryExecutionBaseSelect → QueryExecutionDecoratorBase → QueryExecution
-
def
execDescribe(arg0: Model): Model
- Definition Classes
- QueryExecutionBaseSelect → QueryExecutionDecoratorBase → QueryExecution
-
def
execDescribe(): Model
- Definition Classes
- QueryExecutionBaseSelect → QueryExecutionDecoratorBase → QueryExecution
-
def
execDescribeTriples(): Iterator[Triple]
- Definition Classes
- QueryExecutionBaseSelect → QueryExecutionDecoratorBase → QueryExecution
-
def
execJson(): JsonArray
- Definition Classes
- QueryExecutionSparqlifyFlink → QueryExecutionBaseSelect → QueryExecutionDecoratorBase → QueryExecution
-
def
execJsonItems(): Iterator[JsonObject]
- Definition Classes
- QueryExecutionSparqlifyFlink → QueryExecutionBaseSelect → QueryExecutionDecoratorBase → QueryExecution
-
def
execSelect(): ResultSet
- Definition Classes
- QueryExecutionBaseSelect → QueryExecutionDecoratorBase → QueryExecution
-
def
executeCoreSelect(query: Query): ResultSetCloseable
- Definition Classes
- QueryExecutionSparqlifyFlink → QueryExecutionBaseSelect
-
def
executeCoreSelectX(query: Query): QueryExecution
- Definition Classes
- QueryExecutionSparqlifyFlink → QueryExecutionBaseSelect
-
def
executeUpdate(arg0: UpdateRequest): Unit
- Definition Classes
- QueryExecutionBaseSelect
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
- val flinkEnv: ExecutionEnvironment
- val flinkTable: BatchTableEnvironment
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
getContext(): Context
- Definition Classes
- QueryExecutionDecoratorBase → QueryExecution
-
def
getDataset(): Dataset
- Definition Classes
- QueryExecutionDecoratorBase → QueryExecution
-
def
getDecoratee(): QueryExecution
- Definition Classes
- QueryExecutionDecoratorBase
-
def
getQuery(): Query
- Definition Classes
- QueryExecutionBaseSelect → QueryExecutionDecoratorBase → QueryExecution
-
def
getTimeout1(): Long
- Definition Classes
- QueryExecutionSparqlifyFlink → QueryExecutionDecoratorBase → QueryExecution
-
def
getTimeout2(): Long
- Definition Classes
- QueryExecutionDecoratorBase → QueryExecution
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
isClosed(): Boolean
- Definition Classes
- QueryExecutionDecoratorBase → QueryExecution
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
def
onException(arg0: Exception): Unit
- Attributes
- protected[core]
- Definition Classes
- QueryExecutionDecoratorBase
-
def
setInitialBinding(arg0: Binding): Unit
- Definition Classes
- QueryExecutionDecoratorBase → QueryExecution
-
def
setInitialBinding(arg0: QuerySolution): Unit
- Definition Classes
- QueryExecutionDecoratorBase → QueryExecution
-
def
setTimeout(arg0: Long, arg1: Long): Unit
- Definition Classes
- QueryExecutionDecoratorBase → QueryExecution
-
def
setTimeout(arg0: Long, arg1: TimeUnit, arg2: Long, arg3: TimeUnit): Unit
- Definition Classes
- QueryExecutionDecoratorBase → QueryExecution
-
def
setTimeout(arg0: Long): Unit
- Definition Classes
- QueryExecutionDecoratorBase → QueryExecution
-
def
setTimeout(arg0: Long, arg1: TimeUnit): Unit
- Definition Classes
- QueryExecutionDecoratorBase → QueryExecution
- val sparqlSqlRewriter: SparqlSqlStringRewriter
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
def
unwrap[X](arg0: Class[X]): X
- Definition Classes
- QueryExecutionDecoratorBase
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()