Modifier and Type | Method and Description |
---|---|
void |
StateChangeLogger.valueElementAdded(ThrowingConsumer<DataOutputViewStreamWrapper,IOException> dataSerializer,
Namespace ns)
State element added, such as append of a single element to a list.
|
void |
StateChangeLogger.valueElementAddedOrUpdated(ThrowingConsumer<DataOutputViewStreamWrapper,IOException> dataSerializer,
Namespace ns)
State element added or updated, such as put into a map.
|
void |
StateChangeLogger.valueElementRemoved(ThrowingConsumer<DataOutputViewStreamWrapper,IOException> dataSerializer,
Namespace ns)
State element removed, such mapping removal from a map.
|
Modifier and Type | Field and Description |
---|---|
protected DataOutputViewStreamWrapper |
AbstractExternalTwoInputPythonFunctionOperator.baosWrapper |
protected DataOutputViewStreamWrapper |
AbstractExternalOneInputPythonFunctionOperator.baosWrapper
OutputStream Wrapper.
|
Modifier and Type | Field and Description |
---|---|
protected DataOutputViewStreamWrapper |
AbstractStatelessFunctionOperator.baosWrapper
OutputStream Wrapper.
|
Modifier and Type | Field and Description |
---|---|
protected DataOutputViewStreamWrapper |
AbstractPythonStreamAggregateOperator.baosWrapper
OutputStream Wrapper.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.