@Internal public static class TableResultImpl.Builder extends Object
TableResultImpl
.Modifier and Type | Method and Description |
---|---|
TableResultInternal |
build()
Returns a
TableResult instance. |
TableResultImpl.Builder |
data(List<Row> rowList)
Specifies an row list as the execution result.
|
TableResultImpl.Builder |
jobClient(JobClient jobClient)
Specifies job client which associates the submitted Flink job.
|
TableResultImpl.Builder |
resultKind(ResultKind resultKind)
Specifies result kind of the execution result.
|
TableResultImpl.Builder |
resultProvider(ResultProvider resultProvider) |
TableResultImpl.Builder |
schema(ResolvedSchema resolvedSchema)
Specifies schema of the execution result.
|
TableResultImpl.Builder |
setCachedPlan(CachedPlan cachedPlan)
Specifies cached plan which associates the submitted Flink job.
|
TableResultImpl.Builder |
setPrintStyle(PrintStyle printStyle)
Specifies print style.
|
public TableResultImpl.Builder jobClient(JobClient jobClient)
jobClient
- a JobClient
for the submitted Flink job.public TableResultImpl.Builder schema(ResolvedSchema resolvedSchema)
resolvedSchema
- a ResolvedSchema
for the execution result.public TableResultImpl.Builder resultKind(ResultKind resultKind)
resultKind
- a ResultKind
for the execution result.public TableResultImpl.Builder resultProvider(ResultProvider resultProvider)
public TableResultImpl.Builder data(List<Row> rowList)
rowList
- a row list as the execution result.public TableResultImpl.Builder setPrintStyle(PrintStyle printStyle)
TableauStyle
with max integer column width.public TableResultImpl.Builder setCachedPlan(CachedPlan cachedPlan)
cachedPlan
- a CachedPlan
for the submitted Flink job.public TableResultInternal build()
TableResult
instance.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.