Constructor and Description |
---|
MiniBatchGroupAggFunction(GeneratedAggsHandleFunction genAggsHandler,
GeneratedRecordEqualiser genRecordEqualiser,
LogicalType[] accTypes,
RowType inputType,
int indexOfCountStar,
boolean generateRetraction)
Creates a
MiniBatchGroupAggFunction . |
Modifier and Type | Method and Description |
---|---|
static HashJoinOperator |
HashJoinOperator.newHashJoinOperator(HashJoinType type,
GeneratedJoinCondition condFuncCode,
boolean reverseJoinFunction,
boolean[] filterNullKeys,
GeneratedProjection buildProjectionCode,
GeneratedProjection probeProjectionCode,
boolean tryDistinctBuildRow,
int buildRowSize,
long buildRowCount,
long probeRowCount,
RowType keyType) |
Modifier and Type | Field and Description |
---|---|
protected RowType |
AbstractPythonScalarFunctionOperator.inputType
The input logical type.
|
protected RowType |
AbstractPythonScalarFunctionOperator.outputType
The output logical type.
|
protected RowType |
AbstractPythonScalarFunctionOperator.udfInputType
The udf input logical type.
|
protected RowType |
AbstractPythonScalarFunctionOperator.udfOutputType
The udf output logical type.
|
Constructor and Description |
---|
BaseRowPythonScalarFunctionOperator(Configuration config,
PythonFunctionInfo[] scalarFunctions,
RowType inputType,
RowType outputType,
int[] udfInputOffsets,
int[] forwardedFields) |
PythonScalarFunctionOperator(Configuration config,
PythonFunctionInfo[] scalarFunctions,
RowType inputType,
RowType outputType,
int[] udfInputOffsets,
int[] forwardedFields) |
Modifier and Type | Method and Description |
---|---|
RowType |
AbstractPythonScalarFunctionRunner.getInputType()
Gets the logical type of the input elements of the Python user-defined functions.
|
RowType |
AbstractPythonScalarFunctionRunner.getOutputType()
Gets the logical type of the execution results of the Python user-defined functions.
|
Constructor and Description |
---|
AbstractPythonScalarFunctionRunner(String taskName,
org.apache.beam.sdk.fn.data.FnDataReceiver<OUT> resultReceiver,
PythonFunctionInfo[] scalarFunctions,
PythonEnvironmentManager environmentManager,
RowType inputType,
RowType outputType) |
BaseRowPythonScalarFunctionRunner(String taskName,
org.apache.beam.sdk.fn.data.FnDataReceiver<BaseRow> resultReceiver,
PythonFunctionInfo[] scalarFunctions,
PythonEnvironmentManager environmentManager,
RowType inputType,
RowType outputType) |
PythonScalarFunctionRunner(String taskName,
org.apache.beam.sdk.fn.data.FnDataReceiver<Row> resultReceiver,
PythonFunctionInfo[] scalarFunctions,
PythonEnvironmentManager environmentManager,
RowType inputType,
RowType outputType) |
Modifier and Type | Method and Description |
---|---|
static RowType |
PlannerTypeUtils.toRowType(LogicalType t) |
Modifier and Type | Method and Description |
---|---|
RowType |
BaseRowTypeInfo.toRowType() |
Modifier and Type | Method and Description |
---|---|
static BaseRowTypeInfo |
BaseRowTypeInfo.of(RowType rowType) |
Constructor and Description |
---|
BaseRowSerializer(ExecutionConfig config,
RowType rowType) |
Modifier and Type | Method and Description |
---|---|
static RowType |
RowType.of(LogicalType... types) |
static RowType |
RowType.of(LogicalType[] types,
String[] names) |
Modifier and Type | Method and Description |
---|---|
R |
LogicalTypeVisitor.visit(RowType rowType) |
Modifier and Type | Method and Description |
---|---|
LogicalType |
LogicalTypeDuplicator.visit(RowType rowType) |
R |
LogicalTypeDefaultVisitor.visit(RowType rowType) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.