Modifier and Type | Method and Description |
---|---|
ExtendedOperationExecutor |
TableEnvironmentImpl.getExtendedOperationExecutor() |
Modifier and Type | Method and Description |
---|---|
ExtendedOperationExecutor |
Planner.getExtendedOperationExecutor()
Retrieves a
ExtendedOperationExecutor that provides method for executing operation in
a custom way. |
Modifier and Type | Class and Description |
---|---|
static class |
DialectFactory.EmptyOperationExecutor
Default implementation for
ExtendedOperationExecutor that doesn't extend any
operation behavior but forward all operations to the Flink planner. |
Modifier and Type | Method and Description |
---|---|
default ExtendedOperationExecutor |
DialectFactory.createExtendedOperationExecutor(DialectFactory.Context context) |
Modifier and Type | Class and Description |
---|---|
class |
HiveOperationExecutor
A Hive's operation executor used to execute operation in custom way instead of Flink's
implementation.
|
Modifier and Type | Method and Description |
---|---|
ExtendedOperationExecutor |
HiveDialectFactory.createExtendedOperationExecutor(DialectFactory.Context context) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.