java.lang.Object namespace_
java.lang.Object type_
java.lang.Object id_
byte memoizedIsInitialized
java.lang.Object id_
int invokeCount_
byte memoizedIsInitialized
java.lang.Object invokeTargetId_
java.lang.Object key_
byte memoizedIsInitialized
byte memoizedIsInitialized
int count_
byte memoizedIsInitialized
java.lang.Object id_
int invokeCount_
byte memoizedIsInitialized
int kindCase_
java.lang.Object kind_
VerificationMessages.FnAddress target_
byte memoizedIsInitialized
int type_
java.lang.Object id_
byte memoizedIsInitialized
int delta_
byte memoizedIsInitialized
byte memoizedIsInitialized
java.util.List<E> commandToSend_
byte memoizedIsInitialized
VerificationMessages.FnAddress from_
int state_
byte memoizedIsInitialized
java.lang.Object who_
byte memoizedIsInitialized
java.lang.Object who_
java.lang.Object greeting_
byte memoizedIsInitialized
java.lang.Object driverId_
byte memoizedIsInitialized
java.lang.Object driverId_
java.lang.Object passengerId_
int driverLocation_
byte memoizedIsInitialized
java.lang.Object driverId_
java.lang.Object rideId_
byte memoizedIsInitialized
com.google.protobuf.LazyStringList driverId_
byte memoizedIsInitialized
byte memoizedIsInitialized
int messageCase_
java.lang.Object message_
java.lang.Object driverId_
byte memoizedIsInitialized
int currentGeoCell_
byte memoizedIsInitialized
java.lang.Object rideId_
byte memoizedIsInitialized
byte memoizedIsInitialized
int messageCase_
java.lang.Object message_
java.lang.Object passengerId_
byte memoizedIsInitialized
int startGeoCell_
int endGeoCell_
byte memoizedIsInitialized
byte memoizedIsInitialized
byte memoizedIsInitialized
int messageCase_
java.lang.Object message_
java.lang.Object driverId_
byte memoizedIsInitialized
java.lang.Object rideId_
int startGeoLocation_
int endGeoLocation_
byte memoizedIsInitialized
int messageCase_
java.lang.Object message_
java.lang.Object passengerId_
byte memoizedIsInitialized
java.lang.Object driverId_
int driverGeoCell_
byte memoizedIsInitialized
byte memoizedIsInitialized
java.lang.Object rideId_
byte memoizedIsInitialized
java.lang.Object driverId_
byte memoizedIsInitialized
java.lang.Object passengerId_
int startGeoCell_
int endGeoCell_
byte memoizedIsInitialized
java.lang.Object driverId_
java.lang.Object passengerId_
int passengerStartCell_
int passengerEndCell_
byte memoizedIsInitialized
byte memoizedIsInitialized
java.lang.Object rideId_
byte memoizedIsInitialized
java.lang.Object driverId_
int driverGeoCell_
byte memoizedIsInitialized
java.lang.Object userId_
java.lang.Object itemId_
int quantity_
byte memoizedIsInitialized
java.lang.Object userId_
byte memoizedIsInitialized
java.lang.Object userId_
byte memoizedIsInitialized
int status_
int quantity_
byte memoizedIsInitialized
java.lang.Object userId_
java.lang.Object details_
byte memoizedIsInitialized
int quantity_
byte memoizedIsInitialized
java.lang.Object itemId_
int quantity_
byte memoizedIsInitialized
java.lang.Object generatedJavaName_
java.lang.Object messageName_
com.google.protobuf.DescriptorProtos.FileDescriptorSet descriptorSet_
byte memoizedIsInitialized
java.lang.Class<T> messageTypeClass
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, java.lang.ClassNotFoundException
java.io.IOException
java.lang.ClassNotFoundException
java.lang.Class<T> typeClass
com.google.protobuf.Any imported_
byte memoizedIsInitialized
int letter_
byte memoizedIsInitialized
TestProtos.NestedMessage.Foo foo_
byte memoizedIsInitialized
java.lang.Object name_
byte memoizedIsInitialized
int payloadCase_
java.lang.Object payload_
byte memoizedIsInitialized
java.util.List<E> simpleMessage_
byte memoizedIsInitialized
java.lang.Object name_
byte memoizedIsInitialized
MessageFactoryType factoryType
java.lang.String flinkJobName
byte[] universeInitializerClassBytes
org.apache.flink.configuration.MemorySize feedbackBufferSize
int maxAsyncOperationsPerTask
java.util.Map<K,V> globalConfigurations
java.lang.String pipelineName
long invocationId
FeedbackKey<V> key
java.util.function.LongFunction<R> barrierSentinelSupplier
FeedbackKey<V> feedbackKey
SerializableFunction<T,R> isBarrierMessage
SerializableFunction<T,R> keySelector
long totalMemoryUsedForFeedbackCheckpointing
org.apache.flink.api.common.typeutils.TypeSerializer<T> elementSerializer
StatefulFunctionsConfig configuration
FeedbackKey<V> feedbackKey
SerializableFunction<T,R> isBarrierMessage
SerializableFunction<T,R> keySelector
java.lang.String pipelineName
int subtaskIndex
long invocationId
StatefulFunctionsConfig configuration
java.util.Map<K,V> sideOutputs
java.util.Map<K,V> sideOutputs
StatefulFunctionsConfig configuration
long checkpointId_
byte memoizedIsInitialized
int bodyCase_
java.lang.Object body_
EnvelopeAddress source_
EnvelopeAddress target_
byte memoizedIsInitialized
java.lang.Object namespace_
java.lang.Object type_
java.lang.Object id_
byte memoizedIsInitialized
java.lang.Object className_
com.google.protobuf.ByteString payloadBytes_
byte memoizedIsInitialized
MessageFactoryType messageFactoryType
MessageFactoryType messageFactoryType
java.lang.Object namespace_
java.lang.Object type_
java.lang.Object id_
byte memoizedIsInitialized
int responseCase_
java.lang.Object response_
byte memoizedIsInitialized
long delayInMs_
Address target_
com.google.protobuf.Any argument_
byte memoizedIsInitialized
java.lang.Object egressNamespace_
java.lang.Object egressType_
com.google.protobuf.Any argument_
byte memoizedIsInitialized
Address target_
com.google.protobuf.Any argument_
byte memoizedIsInitialized
java.util.List<E> stateMutations_
java.util.List<E> outgoingMessages_
java.util.List<E> delayedInvocations_
java.util.List<E> outgoingEgresses_
byte memoizedIsInitialized
int mutationType_
java.lang.Object stateName_
com.google.protobuf.ByteString stateValue_
byte memoizedIsInitialized
int requestCase_
java.lang.Object request_
byte memoizedIsInitialized
Address caller_
com.google.protobuf.Any argument_
byte memoizedIsInitialized
int bitField0_
Address target_
java.util.List<E> state_
java.util.List<E> invocations_
byte memoizedIsInitialized
java.lang.Object stateName_
com.google.protobuf.ByteString stateValue_
byte memoizedIsInitialized
com.google.protobuf.Any imported_
byte memoizedIsInitialized
int letter_
byte memoizedIsInitialized
TestProtos.NestedMessage.Foo foo_
byte memoizedIsInitialized
java.lang.Object name_
byte memoizedIsInitialized
int payloadCase_
java.lang.Object payload_
byte memoizedIsInitialized
java.util.List<E> simpleMessage_
byte memoizedIsInitialized
java.lang.Object name_
byte memoizedIsInitialized
java.util.List<E> specs
java.util.List<E> artifactUrls
StatefulFunctionsConfig configuration
IngressIdentifier<T> id
EgressIdentifier<T> id
SerializableConsumer<T> consumer
IngressIdentifier<T> id
SerializableSupplier<T> supplier
long delayInMilliseconds
EgressIdentifier<T> id
org.apache.flink.streaming.api.functions.sink.SinkFunction<IN> delegate
IngressIdentifier<T> id
org.apache.flink.streaming.api.functions.source.SourceFunction<T> delegate
RoutingConfig config_
java.lang.Object id_
com.google.protobuf.ByteString payloadBytes_
byte memoizedIsInitialized
java.lang.Object key_
com.google.protobuf.ByteString valueBytes_
java.lang.Object topic_
byte memoizedIsInitialized
java.lang.Object partitionKey_
com.google.protobuf.ByteString valueBytes_
java.lang.Object stream_
java.lang.Object explicitHashKey_
byte memoizedIsInitialized
int bitField0_
java.lang.Object typeUrl_
java.util.List<E> targetFunctionTypes_
byte memoizedIsInitialized
java.lang.Object namespace_
java.lang.Object type_
byte memoizedIsInitialized
java.util.Map<K,V> routingConfigs
java.util.Map<K,V> routingConfigs
StateBootstrapFunctionRegistry stateBootstrapFunctionRegistry
long snapshotTimestamp
org.apache.flink.core.fs.Path snapshotPath
java.util.Map<K,V> stateBootstrapFunctionProviders
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, java.lang.ClassNotFoundException
java.io.IOException
java.lang.ClassNotFoundException
org.apache.flink.api.common.typeutils.TypeSerializer<T>[] payloadSerializers
java.util.List<E> payloadTypeInfos
java.lang.String namespace
java.lang.String name
java.lang.Class<T> consumedType
java.lang.String namespace
java.lang.String name
java.lang.Class<T> producedType
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.