org.apache.flink.table.client.gateway.local.result

Class MaterializedCollectStreamResult

java.lang.Object

org.apache.flink.table.client.gateway.local.result.CollectResultBase

org.apache.flink.table.client.gateway.local.result.MaterializedCollectResultBase

org.apache.flink.table.client.gateway.local.result.MaterializedCollectStreamResult

All Implemented Interfaces:

DynamicResult, MaterializedResult

public class MaterializedCollectStreamResult
extends MaterializedCollectResultBase

Collects results and returns them as table snapshots.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.table.client.gateway.local.result.CollectResultBase

CollectResultBase.ResultRetrievalThread

Field Summary

Fields inherited from class org.apache.flink.table.client.gateway.local.result.MaterializedCollectResultBase

MATERIALIZED_TABLE_CAPACITY_FACTOR, MATERIALIZED_TABLE_MAX_INITIAL_CAPACITY, MATERIALIZED_TABLE_MAX_OVERCOMMIT, MATERIALIZED_TABLE_OVERCOMMIT_FACTOR, materializedTable, maxRowCount, overcommitThreshold, validRowPosition

Fields inherited from class org.apache.flink.table.client.gateway.local.result.CollectResultBase

executionException, resultLock, retrievalThread

Constructor Summary

Constructors

Constructor and Description
MaterializedCollectStreamResult(TableResultInternal tableResult, int maxRowCount)
MaterializedCollectStreamResult(TableResultInternal tableResult, int maxRowCount, int overcommitThreshold)

Method Summary

Modifier and Type	Method and Description
protected void	processRecord(RowData row)

Methods inherited from class org.apache.flink.table.client.gateway.local.result.MaterializedCollectResultBase

computeMaterializedTableCapacity, computeMaterializedTableOvercommit, getMaterializedTable, isMaterialized, retrievePage, snapshot

Methods inherited from class org.apache.flink.table.client.gateway.local.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.local.result.DynamicResult

close

Constructor Detail

MaterializedCollectStreamResult

@VisibleForTesting
public MaterializedCollectStreamResult(TableResultInternal tableResult,
                                                          int maxRowCount,
                                                          int overcommitThreshold)

MaterializedCollectStreamResult

public MaterializedCollectStreamResult(TableResultInternal tableResult,
                                       int maxRowCount)

Method Detail

processRecord

protected void processRecord(RowData row)

Specified by:

processRecord in class CollectResultBase