ChangelogCollectResult (Flink : Table : SQL Client 1.19.3-cp3 API)

java.lang.Object
- org.apache.flink.table.client.gateway.result.CollectResultBase
- - org.apache.flink.table.client.gateway.result.ChangelogCollectResult

All Implemented Interfaces:

ChangelogResult, DynamicResult
```
public class ChangelogCollectResult
extends CollectResultBase
implements ChangelogResult
```
Collects results and returns them as a changelog.

Nested Class Summary
- Nested classes/interfaces inherited from class org.apache.flink.table.client.gateway.result.CollectResultBase
  CollectResultBase.ResultRetrievalThread

Field Summary

Fields
Modifier and Type Field Description

protected static int CHANGE_RECORD_BUFFER_SIZE
- Fields inherited from class org.apache.flink.table.client.gateway.result.CollectResultBase
  executionException, resultLock, retrievalThread

Constructor Summary

Constructors
Constructor Description

ChangelogCollectResult(StatementResult tableResult)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`protected void`	`processRecord(org.apache.flink.table.data.RowData row)`
`TypedResult<List<org.apache.flink.table.data.RowData>>`	`retrieveChanges()`	Retrieves the available result records.

Methods inherited from class org.apache.flink.table.client.gateway.result.CollectResultBase
close, handleMissingResult, isRetrieving

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.table.client.gateway.result.DynamicResult
close

- Field Detail
  - CHANGE_RECORD_BUFFER_SIZE
```
@VisibleForTesting
protected static final int CHANGE_RECORD_BUFFER_SIZE
```
    See Also:
    
    Constant Field Values
- Constructor Detail
  - ChangelogCollectResult
```
public ChangelogCollectResult(StatementResult tableResult)
```
- Method Detail
  - retrieveChanges
```
public TypedResult<List<org.apache.flink.table.data.RowData>> retrieveChanges()
```
    Description copied from interface: ChangelogResult
    
    Retrieves the available result records.
    
    Specified by:
    
    retrieveChanges in interface ChangelogResult
  - processRecord
```
protected void processRecord(org.apache.flink.table.data.RowData row)
```
    Specified by:
    
    processRecord in class CollectResultBase