Modifier and Type | Method and Description |
---|---|
FlinkFnApi.CoderInfoDescriptor |
FlinkFnApi.CoderInfoDescriptor.Builder.build() |
FlinkFnApi.CoderInfoDescriptor |
FlinkFnApi.CoderInfoDescriptor.Builder.buildPartial() |
static FlinkFnApi.CoderInfoDescriptor |
FlinkFnApi.CoderInfoDescriptor.getDefaultInstance() |
FlinkFnApi.CoderInfoDescriptor |
FlinkFnApi.CoderInfoDescriptor.getDefaultInstanceForType() |
FlinkFnApi.CoderInfoDescriptor |
FlinkFnApi.CoderInfoDescriptor.Builder.getDefaultInstanceForType() |
static FlinkFnApi.CoderInfoDescriptor |
FlinkFnApi.CoderInfoDescriptor.parseDelimitedFrom(InputStream input) |
static FlinkFnApi.CoderInfoDescriptor |
FlinkFnApi.CoderInfoDescriptor.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkFnApi.CoderInfoDescriptor |
FlinkFnApi.CoderInfoDescriptor.parseFrom(byte[] data) |
static FlinkFnApi.CoderInfoDescriptor |
FlinkFnApi.CoderInfoDescriptor.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkFnApi.CoderInfoDescriptor |
FlinkFnApi.CoderInfoDescriptor.parseFrom(ByteBuffer data) |
static FlinkFnApi.CoderInfoDescriptor |
FlinkFnApi.CoderInfoDescriptor.parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkFnApi.CoderInfoDescriptor |
FlinkFnApi.CoderInfoDescriptor.parseFrom(com.google.protobuf.ByteString data) |
static FlinkFnApi.CoderInfoDescriptor |
FlinkFnApi.CoderInfoDescriptor.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkFnApi.CoderInfoDescriptor |
FlinkFnApi.CoderInfoDescriptor.parseFrom(com.google.protobuf.CodedInputStream input) |
static FlinkFnApi.CoderInfoDescriptor |
FlinkFnApi.CoderInfoDescriptor.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkFnApi.CoderInfoDescriptor |
FlinkFnApi.CoderInfoDescriptor.parseFrom(InputStream input) |
static FlinkFnApi.CoderInfoDescriptor |
FlinkFnApi.CoderInfoDescriptor.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
com.google.protobuf.Parser<FlinkFnApi.CoderInfoDescriptor> |
FlinkFnApi.CoderInfoDescriptor.getParserForType() |
static com.google.protobuf.Parser<FlinkFnApi.CoderInfoDescriptor> |
FlinkFnApi.CoderInfoDescriptor.parser() |
Modifier and Type | Method and Description |
---|---|
FlinkFnApi.CoderInfoDescriptor.Builder |
FlinkFnApi.CoderInfoDescriptor.Builder.mergeFrom(FlinkFnApi.CoderInfoDescriptor other) |
static FlinkFnApi.CoderInfoDescriptor.Builder |
FlinkFnApi.CoderInfoDescriptor.newBuilder(FlinkFnApi.CoderInfoDescriptor prototype) |
Modifier and Type | Method and Description |
---|---|
FlinkFnApi.CoderInfoDescriptor |
AbstractOneInputPythonFunctionOperator.createInputCoderInfoDescriptor() |
FlinkFnApi.CoderInfoDescriptor |
AbstractTwoInputPythonFunctionOperator.createInputCoderInfoDescriptor() |
FlinkFnApi.CoderInfoDescriptor |
AbstractOneInputPythonFunctionOperator.createOutputCoderInfoDescriptor() |
FlinkFnApi.CoderInfoDescriptor |
AbstractTwoInputPythonFunctionOperator.createOutputCoderInfoDescriptor() |
Modifier and Type | Method and Description |
---|---|
static FlinkFnApi.CoderInfoDescriptor |
TimerUtils.createTimerDataCoderInfoDescriptorProto(TypeInformation<Row> timerDataType) |
Modifier and Type | Field and Description |
---|---|
protected FlinkFnApi.CoderInfoDescriptor |
BeamPythonFunctionRunner.inputCoderDescriptor |
protected FlinkFnApi.CoderInfoDescriptor |
BeamPythonFunctionRunner.outputCoderDescriptor |
Constructor and Description |
---|
BeamDataStreamPythonFunctionRunner(String taskName,
ProcessPythonEnvironmentManager environmentManager,
String headOperatorFunctionUrn,
List<FlinkFnApi.UserDefinedDataStreamFunction> userDefinedDataStreamFunctions,
FlinkMetricContainer flinkMetricContainer,
KeyedStateBackend<?> stateBackend,
TypeSerializer<?> keySerializer,
TypeSerializer<?> namespaceSerializer,
TimerRegistration timerRegistration,
MemoryManager memoryManager,
double managedMemoryFraction,
FlinkFnApi.CoderInfoDescriptor inputCoderDescriptor,
FlinkFnApi.CoderInfoDescriptor outputCoderDescriptor,
FlinkFnApi.CoderInfoDescriptor timerCoderDescriptor) |
BeamPythonFunctionRunner(String taskName,
ProcessPythonEnvironmentManager environmentManager,
FlinkMetricContainer flinkMetricContainer,
KeyedStateBackend<?> keyedStateBackend,
TypeSerializer<?> keySerializer,
TypeSerializer<?> namespaceSerializer,
TimerRegistration timerRegistration,
MemoryManager memoryManager,
double managedMemoryFraction,
FlinkFnApi.CoderInfoDescriptor inputCoderDescriptor,
FlinkFnApi.CoderInfoDescriptor outputCoderDescriptor) |
Modifier and Type | Method and Description |
---|---|
static org.apache.beam.model.pipeline.v1.RunnerApi.Coder |
ProtoUtils.createCoderProto(FlinkFnApi.CoderInfoDescriptor coderInfoDescriptor) |
Modifier and Type | Method and Description |
---|---|
abstract FlinkFnApi.CoderInfoDescriptor |
AbstractStatelessFunctionOperator.createInputCoderInfoDescriptor(RowType runnerInputType) |
abstract FlinkFnApi.CoderInfoDescriptor |
AbstractStatelessFunctionOperator.createOutputCoderInfoDescriptor(RowType runnerOutType) |
Modifier and Type | Method and Description |
---|---|
FlinkFnApi.CoderInfoDescriptor |
PythonStreamGroupWindowAggregateOperator.createInputCoderInfoDescriptor(RowType runnerInputType) |
FlinkFnApi.CoderInfoDescriptor |
AbstractPythonStreamAggregateOperator.createInputCoderInfoDescriptor(RowType runnerInputType) |
FlinkFnApi.CoderInfoDescriptor |
PythonStreamGroupWindowAggregateOperator.createOutputCoderInfoDescriptor(RowType runnerOutType) |
FlinkFnApi.CoderInfoDescriptor |
AbstractPythonStreamAggregateOperator.createOutputCoderInfoDescriptor(RowType runnerOutType) |
Modifier and Type | Method and Description |
---|---|
FlinkFnApi.CoderInfoDescriptor |
AbstractArrowPythonAggregateFunctionOperator.createInputCoderInfoDescriptor(RowType runnerInputType) |
FlinkFnApi.CoderInfoDescriptor |
AbstractArrowPythonAggregateFunctionOperator.createOutputCoderInfoDescriptor(RowType runnerOutType) |
Modifier and Type | Method and Description |
---|---|
FlinkFnApi.CoderInfoDescriptor |
BatchArrowPythonOverWindowAggregateFunctionOperator.createInputCoderInfoDescriptor(RowType runnerInputType) |
Modifier and Type | Method and Description |
---|---|
FlinkFnApi.CoderInfoDescriptor |
PythonScalarFunctionOperator.createInputCoderInfoDescriptor(RowType runnerInputType) |
FlinkFnApi.CoderInfoDescriptor |
PythonScalarFunctionOperator.createOutputCoderInfoDescriptor(RowType runnerOutType) |
Modifier and Type | Method and Description |
---|---|
FlinkFnApi.CoderInfoDescriptor |
ArrowPythonScalarFunctionOperator.createInputCoderInfoDescriptor(RowType runnerInputType) |
FlinkFnApi.CoderInfoDescriptor |
ArrowPythonScalarFunctionOperator.createOutputCoderInfoDescriptor(RowType runnerOutputType) |
Modifier and Type | Method and Description |
---|---|
FlinkFnApi.CoderInfoDescriptor |
PythonTableFunctionOperator.createInputCoderInfoDescriptor(RowType runnerInputType) |
FlinkFnApi.CoderInfoDescriptor |
PythonTableFunctionOperator.createOutputCoderInfoDescriptor(RowType runnerOutType) |
Modifier and Type | Method and Description |
---|---|
static BeamTablePythonFunctionRunner |
BeamTablePythonFunctionRunner.stateful(String taskName,
ProcessPythonEnvironmentManager environmentManager,
String functionUrn,
com.google.protobuf.GeneratedMessageV3 userDefinedFunctionProto,
FlinkMetricContainer flinkMetricContainer,
KeyedStateBackend<?> keyedStateBackend,
TypeSerializer<?> keySerializer,
TypeSerializer<?> namespaceSerializer,
MemoryManager memoryManager,
double managedMemoryFraction,
FlinkFnApi.CoderInfoDescriptor inputCoderDescriptor,
FlinkFnApi.CoderInfoDescriptor outputCoderDescriptor) |
static BeamTablePythonFunctionRunner |
BeamTablePythonFunctionRunner.stateless(String taskName,
ProcessPythonEnvironmentManager environmentManager,
String functionUrn,
com.google.protobuf.GeneratedMessageV3 userDefinedFunctionProto,
FlinkMetricContainer flinkMetricContainer,
MemoryManager memoryManager,
double managedMemoryFraction,
FlinkFnApi.CoderInfoDescriptor inputCoderDescriptor,
FlinkFnApi.CoderInfoDescriptor outputCoderDescriptor) |
Constructor and Description |
---|
BeamTablePythonFunctionRunner(String taskName,
ProcessPythonEnvironmentManager environmentManager,
String functionUrn,
com.google.protobuf.GeneratedMessageV3 userDefinedFunctionProto,
FlinkMetricContainer flinkMetricContainer,
KeyedStateBackend<?> keyedStateBackend,
TypeSerializer<?> keySerializer,
TypeSerializer<?> namespaceSerializer,
MemoryManager memoryManager,
double managedMemoryFraction,
FlinkFnApi.CoderInfoDescriptor inputCoderDescriptor,
FlinkFnApi.CoderInfoDescriptor outputCoderDescriptor) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.